Home | History | Annotate | Line # | Download | only in libparse
clk_sel240x.c revision 1.1.1.3 
      1 //////////////////////////////////////////////////////////////////////////////
      2 // Copyright (c) 2009,2012 -
      3 //        Schweitzer Engineering Laboratories, Inc. <opensource (at) selinc.com>
      4 //////////////////////////////////////////////////////////////////////////////
      5 
      6 // Need to have _XOPEN_SOURCE defined for time.h to give the
      7 // correct strptime signature.  As per feature_test_macros(7),
      8 // define this before including any header files.
      9 
     10 // #ifndef _XOPEN_SOURCE
     11 // #define _XOPEN_SOURCE
     12 // #endif
     13 
     14 #ifdef HAVE_CONFIG_H
     15 # include <config.h>
     16 #endif
     17 
     18 #if defined(REFCLOCK) && defined(CLOCK_PARSE) && defined(CLOCK_SEL240X)
     19 
     20 #include "ntp_syslog.h"
     21 #include "ntp_types.h"
     22 #include "ntp_fp.h"
     23 #include "ntp_unixtime.h"
     24 #include "ntp_calendar.h"
     25 #include "ntp_machine.h"
     26 #include "ntp_stdlib.h"
     27 
     28 #include "parse.h"
     29 
     30 #ifndef PARSESTREAM
     31 # include <stdio.h>
     32 #else
     33 # include "sys/parsestreams.h"
     34 #endif
     35 
     36 #include <time.h>
     37 
     38 //////////////////////////////////////////////////////////////////////////////
     39 // The B8 output has the following format B8 = '\x01YYYY:ddd:hh:mm:ssq\r\n'
     40 //    where q = ' ' locked
     41 //              '.' <1 us
     42 //              '*' <10 us
     43 //              '#' <100 us
     44 //              '?' >100 us
     45 //
     46 // Based on this we need to recored the stime when we receive the <SOH>
     47 // character and end it when we see the \n.
     48 //
     49 // The q or quality character indicates satellite lock and sync.   For the
     50 // purposes of NTP we are going to call it valid when we receive anything but
     51 // a '?'.  But we are only going to call it synced when we receive a ' '
     52 //////////////////////////////////////////////////////////////////////////////
     53 
     54 static parse_inp_fnc_t inp_sel240x;
     55 static parse_cvt_fnc_t cvt_sel240x;
     56 
     57 // Parse clock format structure describing the message above
     58 static struct format sel240x_fmt =
     59 { { {  6, 3 },
     60     {  0, 0 },
     61     {  1, 4 },
     62     { 10, 2 },
     63     { 13, 2 },
     64     { 16, 2 },
     65     {  0, 0 },
     66     {  0, 0 },
     67     {  0, 0 },
     68     {  0, 0 },
     69     {  0, 0 },
     70     {  0, 0 }
     71   },
     72   (const unsigned char *)"\x01    :   :  :  :   \x0d\x0a",
     73   0
     74 };
     75 
     76 // Structure desctibing the parser
     77 clockformat_t clock_sel240x =
     78 {
     79 	inp_sel240x,
     80 	cvt_sel240x,
     81 	pps_one,
     82 	(void*)&sel240x_fmt,
     83 	"SEL B8",
     84 	25,
     85 	0
     86 };
     87 
     88 //////////////////////////////////////////////////////////////////////////////
     89 static unsigned long
     90 inp_sel240x( parse_t      *parseio,
     91 	     char         ch,
     92 	     timestamp_t  *tstamp
     93 	   )
     94 {
     95 	unsigned long rc;
     96 
     97 	parseprintf( DD_PARSE,
     98 	             ("inp_sel240x(0x%lx, 0x%x, ...)\n",(long)parseio, ch));
     99 
    100 	switch( ch )
    101 	{
    102 	case '\x01':
    103 		parseio->parse_index = 1;
    104 		parseio->parse_data[0] = ch;
    105 		parseio->parse_dtime.parse_stime = *tstamp;
    106 		rc = PARSE_INP_SKIP;
    107 		break;
    108 	case '\n':
    109 		if( (rc = parse_addchar(parseio, ch)) == PARSE_INP_SKIP )
    110 		{
    111 			rc = parse_end( parseio );
    112 		}
    113 		break;
    114 	default:
    115 		rc = parse_addchar( parseio, ch );
    116 	}
    117 
    118 	return rc;
    119 }
    120 
    121 //////////////////////////////////////////////////////////////////////////////
    122 static unsigned long
    123 cvt_sel240x( unsigned char *buffer,
    124 	     int            size,
    125 	     struct format *format,
    126 	     clocktime_t   *clock_time,
    127 	     void          *local
    128 	   )
    129 {
    130 	unsigned long rc = CVT_NONE;
    131 
    132 	if( Strok(buffer, format->fixed_string) )
    133 	{
    134 		struct tm ptime;
    135 		buffer++;
    136 		buffer = (unsigned char *) strptime(
    137 			(const char *)buffer, "%Y:%j:%H:%M:%S", &ptime );
    138 		if( *(buffer+1) != '\x0d' )
    139 		{
    140 			rc = CVT_FAIL | CVT_BADFMT;
    141 		}
    142 		else
    143 		{
    144 			clock_time->day = ptime.tm_mday;
    145 			clock_time->month = ptime.tm_mon + 1;
    146 			clock_time->year = ptime.tm_year + 1900;
    147 			clock_time->hour = ptime.tm_hour;
    148 			clock_time->minute = ptime.tm_min;
    149 			clock_time->second = ptime.tm_sec;
    150 			clock_time->usecond = 0;
    151 			clock_time->utcoffset = 0;
    152 			clock_time->flags = PARSEB_UTC;
    153 
    154 			if( *buffer == '?' )
    155 			{
    156 				clock_time->flags |= PARSEB_POWERUP;
    157 			}
    158 			else if( *buffer != ' ' )
    159 			{
    160 				clock_time->flags |= PARSEB_NOSYNC;
    161 			}
    162 
    163 			rc = CVT_OK;
    164 		}
    165 	}
    166 
    167 	return rc;
    168 }
    169 
    170 #else  /* not (REFCLOCK && CLOCK_PARSE && CLOCK_SEL240X) */
    171 int clk_sel240x_bs;
    172 #endif /* not (REFCLOCK && CLOCK_PARSE && CLOCK_SEL240X) */
    173