LRSD stephane / Mbed 2 deprecated WEBserverv2

serveur WEB sur carte SD pour TestBed , lit des tensions les met dans un fichier htm et l\'envoie . on peut agir sur les ES .

Dependencies:   mbed

lwip/SNTPClient/SNTPClient.cpp@0:83cf97c10b63, 2011-09-05 (annotated)

Committer:
geiineuville
Date:
Mon Sep 05 14:36:10 2011 +0000
Revision:
0:83cf97c10b63
webserver v 0 v 1

Who changed what in which revision?

UserRevisionLine numberNew contents of line
geiineuville 0:83cf97c10b63 1 /*
geiineuville 0:83cf97c10b63 2 * SNTPClient.cpp
geiineuville 0:83cf97c10b63 3 * SNTP (Simple NTP) client
geiineuville 0:83cf97c10b63 4 * Written by iva2k
geiineuville 0:83cf97c10b63 5 *
geiineuville 0:83cf97c10b63 6 * Wrapper around LWIP/sntp for MBED, with DST rules.
geiineuville 0:83cf97c10b63 7 * This implementation relies on:
geiineuville 0:83cf97c10b63 8 * 1. LWIP (http://www.sics.se/~adam/lwip/) adopted for MBED
geiineuville 0:83cf97c10b63 9 * http://mbed.org/projects/cookbook/svn/EMAC/lwip/trunk
geiineuville 0:83cf97c10b63 10 * 2. LWIP's contributed SNTP client (sntp.c and sntp.h) from
geiineuville 0:83cf97c10b63 11 * http://cvs.savannah.gnu.org/viewvc/contrib/apps/sntp/?root=lwip
geiineuville 0:83cf97c10b63 12 * (used version 1.8)
geiineuville 0:83cf97c10b63 13 *
geiineuville 0:83cf97c10b63 14 * Changes needed in LWIP/sntp:
geiineuville 0:83cf97c10b63 15 * - pointer typecast (line 594) - fixes mbed compiler problem
geiineuville 0:83cf97c10b63 16 * - #include "sntp.h" moved after lwip/opt.h et.al - for re-defines.
geiineuville 0:83cf97c10b63 17 * - pbuf_free(p) in sntp_send_request() (line 602) - fixes memory leak BUG.
geiineuville 0:83cf97c10b63 18 * - changing sntp_dns_found() to delayed sntp_try_next_server() - to unblock if network is disconnected.
geiineuville 0:83cf97c10b63 19 *
geiineuville 0:83cf97c10b63 20 * Changes in MBED's LWIP:
geiineuville 0:83cf97c10b63 21 * - modified lwipopts.h (this file is automatically included into sntp.c)
geiineuville 0:83cf97c10b63 22 *
geiineuville 0:83cf97c10b63 23 * Requirements:
geiineuville 0:83cf97c10b63 24 * + direct RTC update from receiving the NTP time packet
geiineuville 0:83cf97c10b63 25 * + optionally support more than one NTP server
geiineuville 0:83cf97c10b63 26 * + the IP address of the NTP server(s) stored in a local file
geiineuville 0:83cf97c10b63 27 * + timeout error recovery should the NTP server(s) not be available. No RTC update should the NTP access fail
geiineuville 0:83cf97c10b63 28 * + allow for a UTC offset, also stored in the local file
geiineuville 0:83cf97c10b63 29 * + DST correction
geiineuville 0:83cf97c10b63 30 * + use DNS for NTP servers IP address resolution
geiineuville 0:83cf97c10b63 31 * + periodic updates at specified time intervals
geiineuville 0:83cf97c10b63 32 *
geiineuville 0:83cf97c10b63 33 * TODO:
geiineuville 0:83cf97c10b63 34 * . DST correction
geiineuville 0:83cf97c10b63 35 * - record metrics (count of updates, failed tries?, correction more than epsilon, etc.?)
geiineuville 0:83cf97c10b63 36 */
geiineuville 0:83cf97c10b63 37
geiineuville 0:83cf97c10b63 38 #include "mbed.h"
geiineuville 0:83cf97c10b63 39 #include "lwip/opt.h"
geiineuville 0:83cf97c10b63 40 #include "SNTPClient.h"
geiineuville 0:83cf97c10b63 41
geiineuville 0:83cf97c10b63 42 #define SNTP_EPSILON 10 // time difference noticed as big update (in seconds).
geiineuville 0:83cf97c10b63 43
geiineuville 0:83cf97c10b63 44 //#define SNTP_DST_TESTS // Define this to run DST algorithms tests
geiineuville 0:83cf97c10b63 45
geiineuville 0:83cf97c10b63 46 typedef struct DST_ZONE_DESCR {
geiineuville 0:83cf97c10b63 47 tDST_ZONE zone;
geiineuville 0:83cf97c10b63 48 const char *name;
geiineuville 0:83cf97c10b63 49 int gmt;
geiineuville 0:83cf97c10b63 50 int dst;
geiineuville 0:83cf97c10b63 51 int hr1;
geiineuville 0:83cf97c10b63 52 int wk1;
geiineuville 0:83cf97c10b63 53 int wday1;
geiineuville 0:83cf97c10b63 54 int mon1;
geiineuville 0:83cf97c10b63 55 int hr2;
geiineuville 0:83cf97c10b63 56 int wk2;
geiineuville 0:83cf97c10b63 57 int wday2;
geiineuville 0:83cf97c10b63 58 int mon2;
geiineuville 0:83cf97c10b63 59 pFncDstCalc fnc;
geiineuville 0:83cf97c10b63 60 } tDST_ZONE_DESR;
geiineuville 0:83cf97c10b63 61
geiineuville 0:83cf97c10b63 62 static tDST_ZONE_DESR gSntpDstZones[] = {
geiineuville 0:83cf97c10b63 63 #define _(z, fnc, gmt, dst, hr1,wk1,wday1,mon1, hr2,wk2,wday2,mon2) \
geiineuville 0:83cf97c10b63 64 { z, #z, gmt, dst, hr1,wk1,wday1,mon1, hr2,wk2,wday2,mon2, fnc },
geiineuville 0:83cf97c10b63 65 #include "DstZones.h"
geiineuville 0:83cf97c10b63 66 };
geiineuville 0:83cf97c10b63 67 #define DST_ZONE_DESCR_CNT (sizeof(gSntpDstZones)/sizeof(gSntpDstZones[0]))
geiineuville 0:83cf97c10b63 68
geiineuville 0:83cf97c10b63 69 const char *SNTPDstZoneName(tDST_ZONE zone) {
geiineuville 0:83cf97c10b63 70 if (zone >= DST_ZONE_DESCR_CNT)
geiineuville 0:83cf97c10b63 71 return "";
geiineuville 0:83cf97c10b63 72 return gSntpDstZones[zone].name;
geiineuville 0:83cf97c10b63 73 }
geiineuville 0:83cf97c10b63 74
geiineuville 0:83cf97c10b63 75 #ifdef __cplusplus
geiineuville 0:83cf97c10b63 76 extern "C" {
geiineuville 0:83cf97c10b63 77 #endif
geiineuville 0:83cf97c10b63 78 tDST_ZONE gSntpDstZone = DST_NONE; // DST zone - rule selector
geiineuville 0:83cf97c10b63 79 unsigned int gSntpRecvTimeout_s = 3; // 3 sec; SNTP_RECV_TIMEOUT
geiineuville 0:83cf97c10b63 80 unsigned int gSntpUpdateDelay_s = 3600; // 1 hour; SNTP_UPDATE_DELAY
geiineuville 0:83cf97c10b63 81 signed int gSntpTimezone = 0*3600; // seconds from UTC to local time
geiineuville 0:83cf97c10b63 82 signed int gSntpDST = 0*3600; // seconds from UTC to local time
geiineuville 0:83cf97c10b63 83 bool gSntpRtcUtc = false; // true to keep RTC in UTC, false to keep in local time
geiineuville 0:83cf97c10b63 84 unsigned int gSntpUpdates = 0; // Track number of all clock NTP updates
geiineuville 0:83cf97c10b63 85 unsigned int gSntpUpdatesBig = 0; // Track number of significant clock NTP updates
geiineuville 0:83cf97c10b63 86 bool gSntpRunning = false; // true if SNTP service is running
geiineuville 0:83cf97c10b63 87 Timeout gSntpDelay; // For async calls.
geiineuville 0:83cf97c10b63 88 Ticker gSntpTicker; // There is no RTC interrupt on MBED (yet). Use (more wastefull) timer.
geiineuville 0:83cf97c10b63 89 time_t gSntpRtcTCR = 0; // Timer Capture Register equivalent (in RTC time - either local or UTC depending on gSntpRtcUtc)
geiineuville 0:83cf97c10b63 90 signed int gSntpRtcTCRDST = 0; // New DST value for when RTC crosses gSntpRtcTCR
geiineuville 0:83cf97c10b63 91
geiineuville 0:83cf97c10b63 92 static void SNTPSetDSTEx(unsigned int dst, bool adjust_clock) {
geiineuville 0:83cf97c10b63 93 if (adjust_clock && !gSntpRtcUtc && gSntpDST != dst) {
geiineuville 0:83cf97c10b63 94 time_t seconds = time(NULL);
geiineuville 0:83cf97c10b63 95 seconds -= gSntpDST; // Convert from old local time
geiineuville 0:83cf97c10b63 96 seconds += dst; // Convert to new local time
geiineuville 0:83cf97c10b63 97 set_time(seconds);
geiineuville 0:83cf97c10b63 98 if (gSntpRtcTCR) {
geiineuville 0:83cf97c10b63 99 // Adjust our alarm clock
geiineuville 0:83cf97c10b63 100 gSntpRtcTCR -= gSntpDST;
geiineuville 0:83cf97c10b63 101 gSntpRtcTCR += dst;
geiineuville 0:83cf97c10b63 102 }
geiineuville 0:83cf97c10b63 103 }
geiineuville 0:83cf97c10b63 104 gSntpDST = dst;
geiineuville 0:83cf97c10b63 105 }
geiineuville 0:83cf97c10b63 106
geiineuville 0:83cf97c10b63 107 #if 0
geiineuville 0:83cf97c10b63 108 // Custom DST zone function example
geiineuville 0:83cf97c10b63 109 // USA (since 2007)
geiineuville 0:83cf97c10b63 110 // Calculate start or stop DST point for given year based on rules
geiineuville 0:83cf97c10b63 111 // tz - Timezone
geiineuville 0:83cf97c10b63 112 // year - current year. DST changes well away from year end, so does not matter what timezone.
geiineuville 0:83cf97c10b63 113 // start - DST_START for start, DST_STOP for stop
geiineuville 0:83cf97c10b63 114 // Returns DST point (in local time). DST_STOP time is in DST
geiineuville 0:83cf97c10b63 115 static tDstPoint _sntp_dst_calc_custom(int tz, int year, tDST_START start) {
geiineuville 0:83cf97c10b63 116 tDstPoint ret;
geiineuville 0:83cf97c10b63 117 struct tm t;
geiineuville 0:83cf97c10b63 118
geiineuville 0:83cf97c10b63 119 // USA: 3600; 2, Second SUN, March; 2, First SUN, November
geiineuville 0:83cf97c10b63 120 int dst = 3600; // DST shift (seconds)
geiineuville 0:83cf97c10b63 121 int hour; // Hour of the change
geiineuville 0:83cf97c10b63 122 int N; // Week in the month
geiineuville 0:83cf97c10b63 123 int wday; // Day of the week
geiineuville 0:83cf97c10b63 124 int month;
geiineuville 0:83cf97c10b63 125 if (start == DST_START) {
geiineuville 0:83cf97c10b63 126 hour = 2; // (0-23) Hour of the change
geiineuville 0:83cf97c10b63 127 N = 2-1; // 2nd in the month
geiineuville 0:83cf97c10b63 128 wday = 0; // Sunday
geiineuville 0:83cf97c10b63 129 month = 2; // March
geiineuville 0:83cf97c10b63 130 } else { // DST_STOP
geiineuville 0:83cf97c10b63 131 hour = 2; // (0-23) Hour of the change
geiineuville 0:83cf97c10b63 132 N = 1-1; // 1st in the month
geiineuville 0:83cf97c10b63 133 wday = 0; // Sunday
geiineuville 0:83cf97c10b63 134 month = 10; // November
geiineuville 0:83cf97c10b63 135 }
geiineuville 0:83cf97c10b63 136
geiineuville 0:83cf97c10b63 137 t.tm_sec = 0; // 0-59
geiineuville 0:83cf97c10b63 138 t.tm_min = 0; // 0-59
geiineuville 0:83cf97c10b63 139 t.tm_hour = hour; // 0-23
geiineuville 0:83cf97c10b63 140 t.tm_year = year - 1900; //
geiineuville 0:83cf97c10b63 141 t.tm_mon = month; // 0-11
geiineuville 0:83cf97c10b63 142 t.tm_mday = 1+N*7; // 1-31, first possible date for Nth given weekday
geiineuville 0:83cf97c10b63 143 mktime(&t); // Calculate tm_wday
geiineuville 0:83cf97c10b63 144 t.tm_mday += (wday-t.tm_wday+14)%7; // Shift to wday
geiineuville 0:83cf97c10b63 145 ret.t = mktime(&t);
geiineuville 0:83cf97c10b63 146 ret.dst = (start == DST_START) ? dst : 0;
geiineuville 0:83cf97c10b63 147 ret.dstshift = dst;
geiineuville 0:83cf97c10b63 148 return ret;
geiineuville 0:83cf97c10b63 149 }
geiineuville 0:83cf97c10b63 150 #endif
geiineuville 0:83cf97c10b63 151
geiineuville 0:83cf97c10b63 152 // Calculate start or stop DST point for given year based on rules for the DST zone
geiineuville 0:83cf97c10b63 153 // tz - Timezone
geiineuville 0:83cf97c10b63 154 // zone - DST zone
geiineuville 0:83cf97c10b63 155 // year - current year. DST changes well away from year end, so does not matter timezone.
geiineuville 0:83cf97c10b63 156 // start - DST_START for start, DST_STOP for stop
geiineuville 0:83cf97c10b63 157 // Returns DST point (in standard local time). DST_STOP time is in NOT IN DST
geiineuville 0:83cf97c10b63 158 static tDstPoint _sntp_dst_calc(int tz, tDST_ZONE zone, int year, tDST_START start) {
geiineuville 0:83cf97c10b63 159 tDstPoint ret;
geiineuville 0:83cf97c10b63 160
geiineuville 0:83cf97c10b63 161 ret.t = 0;
geiineuville 0:83cf97c10b63 162 ret.dst = 0;
geiineuville 0:83cf97c10b63 163 ret.dstshift = 0;
geiineuville 0:83cf97c10b63 164 if (zone == DST_NONE || zone >= DST_ZONE_DESCR_CNT)
geiineuville 0:83cf97c10b63 165 return ret;
geiineuville 0:83cf97c10b63 166
geiineuville 0:83cf97c10b63 167 tDST_ZONE_DESR *descr = &gSntpDstZones[zone];
geiineuville 0:83cf97c10b63 168 if (descr->fnc) {
geiineuville 0:83cf97c10b63 169 // Use custom function
geiineuville 0:83cf97c10b63 170 ret = descr->fnc(tz, year, start);
geiineuville 0:83cf97c10b63 171 } else {
geiineuville 0:83cf97c10b63 172 // Use rules
geiineuville 0:83cf97c10b63 173 struct tm t;
geiineuville 0:83cf97c10b63 174 t.tm_sec = 0; // 0-59
geiineuville 0:83cf97c10b63 175 t.tm_min = 0; // 0-59
geiineuville 0:83cf97c10b63 176 t.tm_hour = (start == DST_START) ? descr->hr1 : descr->hr2;
geiineuville 0:83cf97c10b63 177 t.tm_year = year - 1900; //
geiineuville 0:83cf97c10b63 178 t.tm_mon = (start == DST_START) ? descr->mon1 : descr->mon2; // 0-11
geiineuville 0:83cf97c10b63 179 int wk =((start == DST_START) ? descr->wk1 : descr->wk2) -1;
geiineuville 0:83cf97c10b63 180 int wday = (start == DST_START) ? descr->wday1: descr->wday2;
geiineuville 0:83cf97c10b63 181 if (wk < 0) {
geiineuville 0:83cf97c10b63 182 // For "Last in the month" - we go to next month, then move back by one week
geiineuville 0:83cf97c10b63 183 t.tm_mon += 1; // 0-11
geiineuville 0:83cf97c10b63 184 if (t.tm_mon > 11) {
geiineuville 0:83cf97c10b63 185 t.tm_mon -= 12;
geiineuville 0:83cf97c10b63 186 t.tm_year += 1;
geiineuville 0:83cf97c10b63 187 }
geiineuville 0:83cf97c10b63 188 t.tm_mday = 1+0*7; // 1-31, first possible date for Nth given weekday
geiineuville 0:83cf97c10b63 189 } else {
geiineuville 0:83cf97c10b63 190 t.tm_mday = 1+wk*7; // 1-31, first possible date for Nth given weekday
geiineuville 0:83cf97c10b63 191 }
geiineuville 0:83cf97c10b63 192 mktime(&t); // Calculate tm_wday
geiineuville 0:83cf97c10b63 193 t.tm_mday += (wday-t.tm_wday+14)%7; // Shift to wday
geiineuville 0:83cf97c10b63 194 ret.t = mktime(&t);
geiineuville 0:83cf97c10b63 195 if (wk < 0) {
geiineuville 0:83cf97c10b63 196 ret.t -= 7 * 24 * 3600;
geiineuville 0:83cf97c10b63 197 }
geiineuville 0:83cf97c10b63 198 if (descr->gmt) {
geiineuville 0:83cf97c10b63 199 ret.t += tz;
geiineuville 0:83cf97c10b63 200 }
geiineuville 0:83cf97c10b63 201 ret.dst = (start == DST_START) ? descr->dst : 0;
geiineuville 0:83cf97c10b63 202 ret.dstshift = descr->dst;
geiineuville 0:83cf97c10b63 203 }
geiineuville 0:83cf97c10b63 204 if (start == DST_STOP) {
geiineuville 0:83cf97c10b63 205 ret.t -= ret.dstshift;
geiineuville 0:83cf97c10b63 206 // this correction is due to the fact that rules are given in local time with DST,
geiineuville 0:83cf97c10b63 207 // but calculations are made in standard local time (without DST adjustment)
geiineuville 0:83cf97c10b63 208 }
geiineuville 0:83cf97c10b63 209 return ret;
geiineuville 0:83cf97c10b63 210 }
geiineuville 0:83cf97c10b63 211
geiineuville 0:83cf97c10b63 212 // Calculate desired DST point relative to now based on rules for the DST zone
geiineuville 0:83cf97c10b63 213 // tz - timezone
geiineuville 0:83cf97c10b63 214 // zone - DST zone
geiineuville 0:83cf97c10b63 215 // now - current time (standard local time = excluding DST).
geiineuville 0:83cf97c10b63 216 // index - 0 for immediate next, +1 for second next, -1 for immediate previous
geiineuville 0:83cf97c10b63 217 // Returns DST point (in standard local time)
geiineuville 0:83cf97c10b63 218 static tDstPoint _sntp_dst_point(int tz, tDST_ZONE zone, time_t now, int index) {
geiineuville 0:83cf97c10b63 219 tDstPoint ret;
geiineuville 0:83cf97c10b63 220 int year;
geiineuville 0:83cf97c10b63 221 tDST_START type;
geiineuville 0:83cf97c10b63 222 struct tm *pt = localtime(&now);
geiineuville 0:83cf97c10b63 223
geiineuville 0:83cf97c10b63 224 ret.t = 0;
geiineuville 0:83cf97c10b63 225 ret.dst = 0;
geiineuville 0:83cf97c10b63 226 ret.dstshift = 0;
geiineuville 0:83cf97c10b63 227 if (zone == DST_NONE || zone >= DST_ZONE_DESCR_CNT)
geiineuville 0:83cf97c10b63 228 return ret;
geiineuville 0:83cf97c10b63 229
geiineuville 0:83cf97c10b63 230 // Algorithm
geiineuville 0:83cf97c10b63 231 // 1. Determine where now is in respect to current year DST points (find for index=0)
geiineuville 0:83cf97c10b63 232 // 2. Use index to shift year and type
geiineuville 0:83cf97c10b63 233 // 3. return the point
geiineuville 0:83cf97c10b63 234 // This algorithm relies on DST start date being before DST stop date in the year.
geiineuville 0:83cf97c10b63 235
geiineuville 0:83cf97c10b63 236 year = pt->tm_year + 1900;
geiineuville 0:83cf97c10b63 237 type = DST_START;
geiineuville 0:83cf97c10b63 238 ret = _sntp_dst_calc(tz, zone, year, type);
geiineuville 0:83cf97c10b63 239 if (now > ret.t) {
geiineuville 0:83cf97c10b63 240 type = DST_STOP;
geiineuville 0:83cf97c10b63 241 ret = _sntp_dst_calc(tz, zone, year, type);
geiineuville 0:83cf97c10b63 242 if (now > ret.t) {
geiineuville 0:83cf97c10b63 243 // It is next year's start point
geiineuville 0:83cf97c10b63 244 type = DST_START;
geiineuville 0:83cf97c10b63 245 year += 1;
geiineuville 0:83cf97c10b63 246 }
geiineuville 0:83cf97c10b63 247 }
geiineuville 0:83cf97c10b63 248 // Now year and type are right for index=0
geiineuville 0:83cf97c10b63 249
geiineuville 0:83cf97c10b63 250 // Calculate where index points to - shift year and type
geiineuville 0:83cf97c10b63 251 int norm = (index > 0) ? (int)(index/2) : (int)((index-1)/2);
geiineuville 0:83cf97c10b63 252 year += norm;
geiineuville 0:83cf97c10b63 253 index -= norm*2; // Now index is (0,1)
geiineuville 0:83cf97c10b63 254 if (index) {
geiineuville 0:83cf97c10b63 255 // Flip the type
geiineuville 0:83cf97c10b63 256 type = (type == DST_START) ? DST_STOP : DST_START;
geiineuville 0:83cf97c10b63 257 }
geiineuville 0:83cf97c10b63 258
geiineuville 0:83cf97c10b63 259 ret = _sntp_dst_calc(tz, zone, year, type);
geiineuville 0:83cf97c10b63 260 return ret;
geiineuville 0:83cf97c10b63 261
geiineuville 0:83cf97c10b63 262 // struct tm t;
geiineuville 0:83cf97c10b63 263 // t.tm_sec = 0; // 0-59
geiineuville 0:83cf97c10b63 264 // t.tm_min = 0; // 0-59
geiineuville 0:83cf97c10b63 265 // t.tm_hour = 0; // 0-23
geiineuville 0:83cf97c10b63 266 // t.tm_mday = 0; // 1-31
geiineuville 0:83cf97c10b63 267 // t.tm_mon = 0; // 0-11
geiineuville 0:83cf97c10b63 268 // t.tm_year = 2005-1900; // year since 1900
geiineuville 0:83cf97c10b63 269 // t.tm_wday = 0; // 0-6 Day of week (Sunday = 0)
geiineuville 0:83cf97c10b63 270 // t.tm_yday = 0; // Day of year (0 - 365)
geiineuville 0:83cf97c10b63 271 // t.tm_isdst = -1; // Nonzero = Daylight saving time
geiineuville 0:83cf97c10b63 272 }
geiineuville 0:83cf97c10b63 273
geiineuville 0:83cf97c10b63 274 #if defined(LWIP_DEBUG)
geiineuville 0:83cf97c10b63 275 // Print DST dates report
geiineuville 0:83cf97c10b63 276 static void _sntp_dst_dates(int tz, tDST_ZONE zone, int year) {
geiineuville 0:83cf97c10b63 277 char _buffer[64];
geiineuville 0:83cf97c10b63 278 tDstPoint r;
geiineuville 0:83cf97c10b63 279 printf("\r\nDST DATES for zone %d/%s:\r\n", (int)zone, SNTPDstZoneName(zone));
geiineuville 0:83cf97c10b63 280
geiineuville 0:83cf97c10b63 281 r = _sntp_dst_calc(tz, zone, year, DST_START);
geiineuville 0:83cf97c10b63 282 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 283 printf(" %d DST BEGINS (+%04d sec) %s\r\n", year, r.dst, _buffer);
geiineuville 0:83cf97c10b63 284
geiineuville 0:83cf97c10b63 285 r = _sntp_dst_calc(tz, zone, year, DST_STOP);
geiineuville 0:83cf97c10b63 286 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 287 printf(" %d DST ENDS (+%04d sec) %s\r\n", year, r.dst, _buffer);
geiineuville 0:83cf97c10b63 288 }
geiineuville 0:83cf97c10b63 289 #endif
geiineuville 0:83cf97c10b63 290
geiineuville 0:83cf97c10b63 291 #ifdef SNTP_DST_TESTS
geiineuville 0:83cf97c10b63 292 static void test_sntp_dst_calc(int tz, tDST_ZONE zone) {
geiineuville 0:83cf97c10b63 293 char _buffer[64];
geiineuville 0:83cf97c10b63 294 tDstPoint r;
geiineuville 0:83cf97c10b63 295 int year;
geiineuville 0:83cf97c10b63 296
geiineuville 0:83cf97c10b63 297 printf("\r\nTEST: _sntp_dst_calc(tz=%d, zone=%d/%s)\r\n", tz, (int)zone, SNTPDstZoneName(zone));
geiineuville 0:83cf97c10b63 298
geiineuville 0:83cf97c10b63 299 for (year = 1999; year < 2016; year++) {
geiineuville 0:83cf97c10b63 300 r = _sntp_dst_calc(tz, zone, year, DST_START);
geiineuville 0:83cf97c10b63 301 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 302 printf(" (0,%d,start) %s %d\r\n", year, _buffer, r.dst);
geiineuville 0:83cf97c10b63 303
geiineuville 0:83cf97c10b63 304 r = _sntp_dst_calc(tz, zone, year, DST_STOP);
geiineuville 0:83cf97c10b63 305 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 306 printf(" (0,%d,stop ) %s %d\r\n", year, _buffer, r.dst);
geiineuville 0:83cf97c10b63 307 }
geiineuville 0:83cf97c10b63 308 }
geiineuville 0:83cf97c10b63 309
geiineuville 0:83cf97c10b63 310 static void test_sntp_dst_point(int index) {
geiineuville 0:83cf97c10b63 311 char _buffer[64];
geiineuville 0:83cf97c10b63 312 struct tm t;
geiineuville 0:83cf97c10b63 313 tDstPoint r;
geiineuville 0:83cf97c10b63 314 int tz=gSntpTimezone;
geiineuville 0:83cf97c10b63 315 tDST_ZONE zone=gSntpDstZone;
geiineuville 0:83cf97c10b63 316 int year = 2009, day, month;
geiineuville 0:83cf97c10b63 317
geiineuville 0:83cf97c10b63 318 int norm = (index > 0) ? (int)(index/2) : (int)((index-1)/2);
geiineuville 0:83cf97c10b63 319 printf("\r\nTEST: _sntp_dst_point(%d) norm=%d\r\n", index, norm);
geiineuville 0:83cf97c10b63 320
geiineuville 0:83cf97c10b63 321 t.tm_sec = 0; // 0-59
geiineuville 0:83cf97c10b63 322 t.tm_min = 0; // 0-59
geiineuville 0:83cf97c10b63 323 t.tm_hour = 9; // 0-23
geiineuville 0:83cf97c10b63 324 t.tm_year = year-1900;
geiineuville 0:83cf97c10b63 325
geiineuville 0:83cf97c10b63 326 day = 1;
geiineuville 0:83cf97c10b63 327 for (month = 0; month < 2; month++) {
geiineuville 0:83cf97c10b63 328 t.tm_mon = month;
geiineuville 0:83cf97c10b63 329 t.tm_mday = day;
geiineuville 0:83cf97c10b63 330 t.tm_year = year-1900;
geiineuville 0:83cf97c10b63 331 r = _sntp_dst_point(tz, zone, mktime(&t), index);
geiineuville 0:83cf97c10b63 332 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 333 printf(" (0,%02d/%02d/%d,%d) %s %d\r\n", month+1, day, year, index, _buffer, r.dst);
geiineuville 0:83cf97c10b63 334 }
geiineuville 0:83cf97c10b63 335
geiineuville 0:83cf97c10b63 336 for (day = 1; day < 32; day++) {
geiineuville 0:83cf97c10b63 337 t.tm_mon = month;
geiineuville 0:83cf97c10b63 338 t.tm_mday = day;
geiineuville 0:83cf97c10b63 339 t.tm_year = year-1900;
geiineuville 0:83cf97c10b63 340 r = _sntp_dst_point(tz, zone, mktime(&t), index);
geiineuville 0:83cf97c10b63 341 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 342 printf(" (0,%02d/%02d/%d,%d) %s %d\r\n", month+1, day, year, index, _buffer, r.dst);
geiineuville 0:83cf97c10b63 343 }
geiineuville 0:83cf97c10b63 344
geiineuville 0:83cf97c10b63 345 day = 30;
geiineuville 0:83cf97c10b63 346 for (; month < 10; month++) {
geiineuville 0:83cf97c10b63 347 t.tm_mon = month;
geiineuville 0:83cf97c10b63 348 t.tm_mday = day;
geiineuville 0:83cf97c10b63 349 t.tm_year = year-1900;
geiineuville 0:83cf97c10b63 350 r = _sntp_dst_point(tz, zone, mktime(&t), index);
geiineuville 0:83cf97c10b63 351 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 352 printf(" (0,%02d/%02d/%d,%d) %s %d\r\n", month+1, day, year, index, _buffer, r.dst);
geiineuville 0:83cf97c10b63 353 }
geiineuville 0:83cf97c10b63 354
geiineuville 0:83cf97c10b63 355 for (day = 1; day < 32; day++) {
geiineuville 0:83cf97c10b63 356 t.tm_mon = month;
geiineuville 0:83cf97c10b63 357 t.tm_mday = day;
geiineuville 0:83cf97c10b63 358 t.tm_year = year-1900;
geiineuville 0:83cf97c10b63 359 r = _sntp_dst_point(tz, zone, mktime(&t), index);
geiineuville 0:83cf97c10b63 360 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&r.t));
geiineuville 0:83cf97c10b63 361 printf(" (0,%02d/%02d/%d,%d) %s %d\r\n", month+1, day, year, index, _buffer, r.dst);
geiineuville 0:83cf97c10b63 362 }
geiineuville 0:83cf97c10b63 363
geiineuville 0:83cf97c10b63 364 }
geiineuville 0:83cf97c10b63 365 #endif // SNTP_DST_TESTS
geiineuville 0:83cf97c10b63 366
geiineuville 0:83cf97c10b63 367 // Set current DST
geiineuville 0:83cf97c10b63 368 static void _sntp_dst_now(void) {
geiineuville 0:83cf97c10b63 369 time_t now = time(NULL);
geiineuville 0:83cf97c10b63 370 // Convert to standart local time (no DST)
geiineuville 0:83cf97c10b63 371 now = gSntpRtcUtc ? (now + gSntpTimezone) : (now - gSntpDST);
geiineuville 0:83cf97c10b63 372
geiineuville 0:83cf97c10b63 373 // Check DST setting for now
geiineuville 0:83cf97c10b63 374 tDstPoint dst = _sntp_dst_point(gSntpTimezone, gSntpDstZone, now, -1);
geiineuville 0:83cf97c10b63 375
geiineuville 0:83cf97c10b63 376 #ifdef LWIP_DEBUG
geiineuville 0:83cf97c10b63 377 char _buffer[64];
geiineuville 0:83cf97c10b63 378 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&dst.t));
geiineuville 0:83cf97c10b63 379 LWIP_DEBUGF(SNTP_DEBUG_STATE, (
geiineuville 0:83cf97c10b63 380 "DEBUG: _sntp_dst_now(%d) based on last DST change on (%d) %s to (+%04d sec)\r\n",
geiineuville 0:83cf97c10b63 381 now, dst.t, _buffer, dst.dst));
geiineuville 0:83cf97c10b63 382 #endif
geiineuville 0:83cf97c10b63 383
geiineuville 0:83cf97c10b63 384 // Change RTC
geiineuville 0:83cf97c10b63 385 SNTPSetDSTEx(dst.dst, true);
geiineuville 0:83cf97c10b63 386 }
geiineuville 0:83cf97c10b63 387
geiineuville 0:83cf97c10b63 388 // Plan for next DST change
geiineuville 0:83cf97c10b63 389 static void _sntp_dst_schedule(void) {
geiineuville 0:83cf97c10b63 390 time_t now = time(NULL);
geiineuville 0:83cf97c10b63 391 // Convert to standart local time (no DST)
geiineuville 0:83cf97c10b63 392 now = gSntpRtcUtc ? (now + gSntpTimezone) : (now - gSntpDST);
geiineuville 0:83cf97c10b63 393
geiineuville 0:83cf97c10b63 394 // Check next DST change point
geiineuville 0:83cf97c10b63 395 tDstPoint dst = _sntp_dst_point(gSntpTimezone, gSntpDstZone, now, 0);
geiineuville 0:83cf97c10b63 396
geiineuville 0:83cf97c10b63 397 if (dst.t) {
geiineuville 0:83cf97c10b63 398
geiineuville 0:83cf97c10b63 399 #ifdef LWIP_DEBUG
geiineuville 0:83cf97c10b63 400 char _buffer[64];
geiineuville 0:83cf97c10b63 401 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&dst.t));
geiineuville 0:83cf97c10b63 402 #endif
geiineuville 0:83cf97c10b63 403
geiineuville 0:83cf97c10b63 404 // Set our alarm clock
geiineuville 0:83cf97c10b63 405 // Convert from standard local to UTC time or local time
geiineuville 0:83cf97c10b63 406 dst.t = gSntpRtcUtc ? (dst.t - gSntpTimezone) : (dst.t + gSntpDST);
geiineuville 0:83cf97c10b63 407
geiineuville 0:83cf97c10b63 408 #ifdef LWIP_DEBUG
geiineuville 0:83cf97c10b63 409 if (time(NULL) > dst.t) {
geiineuville 0:83cf97c10b63 410 LWIP_DEBUGF(SNTP_DEBUG_STATE, (
geiineuville 0:83cf97c10b63 411 "DEBUG: _sntp_dst_schedule() ASSERTION FAILED !(%d<%d) trying to schedule for the past: %s (+%04d sec)\r\n",
geiineuville 0:83cf97c10b63 412 time(NULL), dst.t, _buffer, dst.dst));
geiineuville 0:83cf97c10b63 413 } else {
geiineuville 0:83cf97c10b63 414 LWIP_DEBUGF(SNTP_DEBUG_STATE, (
geiineuville 0:83cf97c10b63 415 "DEBUG: _sntp_dst_schedule() scheduled in %d seconds, set for %s (+%04d sec)\r\n",
geiineuville 0:83cf97c10b63 416 dst.t-time(NULL), _buffer, dst.dst));
geiineuville 0:83cf97c10b63 417 }
geiineuville 0:83cf97c10b63 418 #endif
geiineuville 0:83cf97c10b63 419 }
geiineuville 0:83cf97c10b63 420 gSntpRtcTCR = dst.t;
geiineuville 0:83cf97c10b63 421 gSntpRtcTCRDST = dst.dst;
geiineuville 0:83cf97c10b63 422 }
geiineuville 0:83cf97c10b63 423
geiineuville 0:83cf97c10b63 424 // RTC ISR - called upon each RTC tick
geiineuville 0:83cf97c10b63 425 static void _sntp_isr(void) {
geiineuville 0:83cf97c10b63 426 time_t seconds = time(NULL);
geiineuville 0:83cf97c10b63 427 if (gSntpRtcTCR && seconds > gSntpRtcTCR ) {
geiineuville 0:83cf97c10b63 428 // DST change has arrived
geiineuville 0:83cf97c10b63 429 gSntpRtcTCR = 0;
geiineuville 0:83cf97c10b63 430 // Disable ISR and avoid extra calcs in SNTPSetDSTEx()
geiineuville 0:83cf97c10b63 431
geiineuville 0:83cf97c10b63 432 //if (gSntpRtcTCRDST != gSntpDST) {
geiineuville 0:83cf97c10b63 433 // Change to/from DST
geiineuville 0:83cf97c10b63 434 SNTPSetDSTEx(gSntpRtcTCRDST, true);
geiineuville 0:83cf97c10b63 435 gSntpRtcTCRDST = 0;
geiineuville 0:83cf97c10b63 436
geiineuville 0:83cf97c10b63 437 // Schedule callback to plan for next DST change (take it out of ISR context)
geiineuville 0:83cf97c10b63 438 gSntpDelay.attach(_sntp_dst_schedule, 1.0);
geiineuville 0:83cf97c10b63 439
geiineuville 0:83cf97c10b63 440 #ifdef LWIP_DEBUG
geiineuville 0:83cf97c10b63 441 char _buffer[64];
geiineuville 0:83cf97c10b63 442 if (gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 443 seconds += gSntpTimezone + gSntpDST; // Convert to local time
geiineuville 0:83cf97c10b63 444 }
geiineuville 0:83cf97c10b63 445 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&seconds));
geiineuville 0:83cf97c10b63 446 LWIP_DEBUGF(SNTP_DEBUG_STATE, (
geiineuville 0:83cf97c10b63 447 "DEBUG: _sntp_isr() changed DST. datetime=%s\r\n", _buffer));
geiineuville 0:83cf97c10b63 448 #endif
geiineuville 0:83cf97c10b63 449
geiineuville 0:83cf97c10b63 450 //}
geiineuville 0:83cf97c10b63 451
geiineuville 0:83cf97c10b63 452 }
geiineuville 0:83cf97c10b63 453 }
geiineuville 0:83cf97c10b63 454
geiineuville 0:83cf97c10b63 455 // NTP Callback - timestamp from NTP server arrives here
geiineuville 0:83cf97c10b63 456 void SntpClientSet(time_t seconds) {
geiineuville 0:83cf97c10b63 457 time_t old_seconds = time(NULL);
geiineuville 0:83cf97c10b63 458 if (!gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 459 seconds += gSntpTimezone + gSntpDST; // Convert to local time
geiineuville 0:83cf97c10b63 460 }
geiineuville 0:83cf97c10b63 461 set_time(seconds);
geiineuville 0:83cf97c10b63 462
geiineuville 0:83cf97c10b63 463 // Special tasks for the very first NTP updates
geiineuville 0:83cf97c10b63 464 if (!gSntpUpdates) {
geiineuville 0:83cf97c10b63 465
geiineuville 0:83cf97c10b63 466 #if defined(LWIP_DEBUG)
geiineuville 0:83cf97c10b63 467 // Report DST dates for the zone
geiineuville 0:83cf97c10b63 468 struct tm *pt = localtime(&seconds);
geiineuville 0:83cf97c10b63 469 _sntp_dst_dates(gSntpTimezone, gSntpDstZone, pt->tm_year+1900);
geiineuville 0:83cf97c10b63 470 #endif
geiineuville 0:83cf97c10b63 471
geiineuville 0:83cf97c10b63 472 // DST scheduler
geiineuville 0:83cf97c10b63 473 _sntp_dst_now();
geiineuville 0:83cf97c10b63 474 _sntp_dst_schedule();
geiineuville 0:83cf97c10b63 475
geiineuville 0:83cf97c10b63 476 // Enable RTC ISR
geiineuville 0:83cf97c10b63 477 gSntpTicker.attach(_sntp_isr, 1.0);
geiineuville 0:83cf97c10b63 478 }
geiineuville 0:83cf97c10b63 479
geiineuville 0:83cf97c10b63 480 if (gSntpUpdates && abs((int)(old_seconds - seconds)) > SNTP_EPSILON) {
geiineuville 0:83cf97c10b63 481 printf("SNTP settime() corrected big difference: (%d) seconds, more than %d. Big updates count=%d.\r\n",
geiineuville 0:83cf97c10b63 482 old_seconds-seconds, SNTP_EPSILON, gSntpUpdatesBig);
geiineuville 0:83cf97c10b63 483 gSntpUpdatesBig ++;
geiineuville 0:83cf97c10b63 484 }
geiineuville 0:83cf97c10b63 485
geiineuville 0:83cf97c10b63 486 gSntpUpdates++;
geiineuville 0:83cf97c10b63 487
geiineuville 0:83cf97c10b63 488 if (1) {
geiineuville 0:83cf97c10b63 489 char _buffer[64];
geiineuville 0:83cf97c10b63 490 if (gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 491 seconds += gSntpTimezone + gSntpDST; // Convert to local time
geiineuville 0:83cf97c10b63 492 }
geiineuville 0:83cf97c10b63 493 strftime(_buffer, sizeof(_buffer), "%A %m/%d/%Y %H:%M:%S", localtime(&seconds));
geiineuville 0:83cf97c10b63 494 printf("SNTP settime() #%d seconds=%d TZ=%0.1f datetime=%s\r\n",
geiineuville 0:83cf97c10b63 495 gSntpUpdates, seconds, gSntpTimezone/3600.0, _buffer);
geiineuville 0:83cf97c10b63 496 }
geiineuville 0:83cf97c10b63 497 }
geiineuville 0:83cf97c10b63 498 #ifdef __cplusplus
geiineuville 0:83cf97c10b63 499 };
geiineuville 0:83cf97c10b63 500 #endif
geiineuville 0:83cf97c10b63 501
geiineuville 0:83cf97c10b63 502 #ifdef __cplusplus
geiineuville 0:83cf97c10b63 503 extern "C" {
geiineuville 0:83cf97c10b63 504 #endif
geiineuville 0:83cf97c10b63 505
geiineuville 0:83cf97c10b63 506 #include "lwip/def.h"
geiineuville 0:83cf97c10b63 507 #include "lwip/pbuf.h"
geiineuville 0:83cf97c10b63 508 #include "lwip/sys.h"
geiineuville 0:83cf97c10b63 509 #include "lwip/stats.h"
geiineuville 0:83cf97c10b63 510 #include "netif/etharp.h"
geiineuville 0:83cf97c10b63 511 #include "string.h"
geiineuville 0:83cf97c10b63 512
geiineuville 0:83cf97c10b63 513 #ifdef __cplusplus
geiineuville 0:83cf97c10b63 514 };
geiineuville 0:83cf97c10b63 515 #endif
geiineuville 0:83cf97c10b63 516
geiineuville 0:83cf97c10b63 517 // Accomodating sntp timeout functions
geiineuville 0:83cf97c10b63 518 #if NO_SYS
geiineuville 0:83cf97c10b63 519 #include "sntp.h"
geiineuville 0:83cf97c10b63 520 extern void sntp_request(void *arg); // this is dirty hack around "static" function. Some linkers may revolt!
geiineuville 0:83cf97c10b63 521 extern void sntp_try_next_server(void *arg);
geiineuville 0:83cf97c10b63 522 extern char* sntp_server_addresses[];
geiineuville 0:83cf97c10b63 523 extern u8_t sntp_current_server;
geiineuville 0:83cf97c10b63 524 extern u8_t sntp_num_servers;
geiineuville 0:83cf97c10b63 525 static void (*sntp_addresses_free)(void*) = NULL;
geiineuville 0:83cf97c10b63 526 static Timeout _sntp_timer1;
geiineuville 0:83cf97c10b63 527 static Timeout _sntp_timer2;
geiineuville 0:83cf97c10b63 528 void sntp_sys_timeout(u32_t timeout_s, void (*func)(void *arg), void *arg) {
geiineuville 0:83cf97c10b63 529 // all we really need to track is only 2 functions: sntp_request, sntp_try_next_server
geiineuville 0:83cf97c10b63 530 Timeout *t = NULL;
geiineuville 0:83cf97c10b63 531 if (func == &sntp_request) {
geiineuville 0:83cf97c10b63 532 t = &_sntp_timer1;
geiineuville 0:83cf97c10b63 533 LWIP_DEBUGF(SNTP_DEBUG_STATE, ("DEBUG: IN sntp_sys_timeout(), func=sntp_request\r\n"));
geiineuville 0:83cf97c10b63 534 } else if (func == &sntp_try_next_server) {
geiineuville 0:83cf97c10b63 535 t = &_sntp_timer2;
geiineuville 0:83cf97c10b63 536 LWIP_DEBUGF(SNTP_DEBUG_STATE, ("DEBUG: IN sntp_sys_timeout(), func=sntp_try_next_server\r\n"));
geiineuville 0:83cf97c10b63 537 }
geiineuville 0:83cf97c10b63 538 if (t) {
geiineuville 0:83cf97c10b63 539 t->detach();
geiineuville 0:83cf97c10b63 540 t->attach((void(*)(void))func, 1.0*timeout_s);
geiineuville 0:83cf97c10b63 541 // Another shortcut - we have no arg to pass, so just typecast the func.
geiineuville 0:83cf97c10b63 542 }
geiineuville 0:83cf97c10b63 543 }
geiineuville 0:83cf97c10b63 544
geiineuville 0:83cf97c10b63 545 void sntp_sys_untimeout(void (*func)(void *arg), void *arg) {
geiineuville 0:83cf97c10b63 546 Timeout *t = NULL;
geiineuville 0:83cf97c10b63 547 if (func == &sntp_request) {
geiineuville 0:83cf97c10b63 548 t = &_sntp_timer1;
geiineuville 0:83cf97c10b63 549 LWIP_DEBUGF(SNTP_DEBUG_STATE, ("DEBUG: IN sntp_sys_untimeout(), func=sntp_request\r\n"));
geiineuville 0:83cf97c10b63 550 } else if (func == &sntp_try_next_server) {
geiineuville 0:83cf97c10b63 551 t = &_sntp_timer2;
geiineuville 0:83cf97c10b63 552 LWIP_DEBUGF(SNTP_DEBUG_STATE, ("DEBUG: IN sntp_sys_untimeout(), func=sntp_try_next_server\r\n"));
geiineuville 0:83cf97c10b63 553 }
geiineuville 0:83cf97c10b63 554 if (t) {
geiineuville 0:83cf97c10b63 555 t->detach();
geiineuville 0:83cf97c10b63 556 }
geiineuville 0:83cf97c10b63 557 }
geiineuville 0:83cf97c10b63 558
geiineuville 0:83cf97c10b63 559 #else // NO_SYS
geiineuville 0:83cf97c10b63 560 #error "I don't know how to compile LWIP/SNTP with NO_SYS=0"
geiineuville 0:83cf97c10b63 561 #endif // NO_SYS
geiineuville 0:83cf97c10b63 562
geiineuville 0:83cf97c10b63 563 // Can be called when already running
geiineuville 0:83cf97c10b63 564 void SNTPSetDstZone(tDST_ZONE zone) {
geiineuville 0:83cf97c10b63 565 if (zone >= DST_ZONE_DESCR_CNT)
geiineuville 0:83cf97c10b63 566 return; // ERR_INVALID_ARG
geiineuville 0:83cf97c10b63 567
geiineuville 0:83cf97c10b63 568 gSntpDstZone = zone;
geiineuville 0:83cf97c10b63 569
geiineuville 0:83cf97c10b63 570 if (gSntpRunning) {
geiineuville 0:83cf97c10b63 571 // DST scheduler
geiineuville 0:83cf97c10b63 572 _sntp_dst_now();
geiineuville 0:83cf97c10b63 573 _sntp_dst_schedule();
geiineuville 0:83cf97c10b63 574 }
geiineuville 0:83cf97c10b63 575 }
geiineuville 0:83cf97c10b63 576
geiineuville 0:83cf97c10b63 577 void SNTPSetRecvTimeout(unsigned int val_s) { gSntpRecvTimeout_s = val_s; }
geiineuville 0:83cf97c10b63 578 void SNTPSetUpdateDelay(unsigned int val_s) { gSntpUpdateDelay_s = val_s; }
geiineuville 0:83cf97c10b63 579 void SNTPSetTimezone(float hours_from_utc, bool adjust_clock) {
geiineuville 0:83cf97c10b63 580 if (adjust_clock && !gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 581 time_t seconds = time(NULL);
geiineuville 0:83cf97c10b63 582 seconds -= gSntpTimezone; // Convert from old local time
geiineuville 0:83cf97c10b63 583 seconds += hours_from_utc * 3600; // Convert to new local time
geiineuville 0:83cf97c10b63 584 set_time(seconds);
geiineuville 0:83cf97c10b63 585 if (gSntpRtcTCR) {
geiineuville 0:83cf97c10b63 586 // Adjust our alarm clock
geiineuville 0:83cf97c10b63 587 gSntpRtcTCR -= gSntpTimezone;
geiineuville 0:83cf97c10b63 588 gSntpRtcTCR += hours_from_utc * 3600;
geiineuville 0:83cf97c10b63 589 }
geiineuville 0:83cf97c10b63 590 }
geiineuville 0:83cf97c10b63 591 gSntpTimezone = hours_from_utc * 3600;
geiineuville 0:83cf97c10b63 592 }
geiineuville 0:83cf97c10b63 593 void SNTPSetDST(float hours_from_utc, bool adjust_clock) {
geiineuville 0:83cf97c10b63 594 SNTPSetDSTEx(hours_from_utc * 3600, adjust_clock);
geiineuville 0:83cf97c10b63 595 }
geiineuville 0:83cf97c10b63 596
geiineuville 0:83cf97c10b63 597 static int sntp_num_servers_alloc = 0;
geiineuville 0:83cf97c10b63 598 static void _SNTPClrAddresses(void) {
geiineuville 0:83cf97c10b63 599 if (!sntp_num_servers_alloc) sntp_num_servers_alloc = sntp_num_servers;
geiineuville 0:83cf97c10b63 600 // Here we save the original size of the sntp_server_addresses[] array.
geiineuville 0:83cf97c10b63 601
geiineuville 0:83cf97c10b63 602 if (sntp_addresses_free) {
geiineuville 0:83cf97c10b63 603 for (int i=0; i<sntp_num_servers; i++) {
geiineuville 0:83cf97c10b63 604 sntp_addresses_free(sntp_server_addresses[i]);
geiineuville 0:83cf97c10b63 605 }
geiineuville 0:83cf97c10b63 606 }
geiineuville 0:83cf97c10b63 607 sntp_current_server = 0;
geiineuville 0:83cf97c10b63 608 sntp_num_servers = 0;
geiineuville 0:83cf97c10b63 609 sntp_addresses_free = NULL;
geiineuville 0:83cf97c10b63 610 }
geiineuville 0:83cf97c10b63 611 static int _SNTPAddAddress(const char* server_address) {
geiineuville 0:83cf97c10b63 612 if (sntp_num_servers+1 > sntp_num_servers_alloc)
geiineuville 0:83cf97c10b63 613 return -1;
geiineuville 0:83cf97c10b63 614 sntp_server_addresses[sntp_num_servers] = (char*)malloc(strlen(server_address)+1);
geiineuville 0:83cf97c10b63 615 if (sntp_server_addresses[sntp_num_servers] == NULL) return -1; // Out of memory
geiineuville 0:83cf97c10b63 616 strcpy(sntp_server_addresses[sntp_num_servers], server_address);
geiineuville 0:83cf97c10b63 617 sntp_num_servers++;
geiineuville 0:83cf97c10b63 618 return 0;
geiineuville 0:83cf97c10b63 619 }
geiineuville 0:83cf97c10b63 620
geiineuville 0:83cf97c10b63 621 // Override default servers list.
geiineuville 0:83cf97c10b63 622 // For no-copy, pass pointer to free() in p_free.
geiineuville 0:83cf97c10b63 623 // Returns: actual number of servers set (limited by allocated buffer size)
geiineuville 0:83cf97c10b63 624 // WARNING! There is no interlock to ensure that SNTP service does not read its data while we are updating it.
geiineuville 0:83cf97c10b63 625 // This function is intended to be called only before SNTPClientInit().
geiineuville 0:83cf97c10b63 626 int SNTPSetAddresses(const char* server_addresses[], int count, void (*p_free)(void*)) {
geiineuville 0:83cf97c10b63 627 // In order to use sntp.c as-is, we hack into its static variables.
geiineuville 0:83cf97c10b63 628 // Not all compilers/linkers will support that.
geiineuville 0:83cf97c10b63 629
geiineuville 0:83cf97c10b63 630 _SNTPClrAddresses();
geiineuville 0:83cf97c10b63 631 if (count > sntp_num_servers_alloc)
geiineuville 0:83cf97c10b63 632 count = sntp_num_servers_alloc;
geiineuville 0:83cf97c10b63 633 for (int i=0; i<count; i++) {
geiineuville 0:83cf97c10b63 634 if (p_free) {
geiineuville 0:83cf97c10b63 635 sntp_server_addresses[i] = (char *)server_addresses[i];
geiineuville 0:83cf97c10b63 636 } else {
geiineuville 0:83cf97c10b63 637 _SNTPAddAddress(server_addresses[i]);
geiineuville 0:83cf97c10b63 638 }
geiineuville 0:83cf97c10b63 639 }
geiineuville 0:83cf97c10b63 640 sntp_num_servers = count;
geiineuville 0:83cf97c10b63 641 sntp_current_server = 0;
geiineuville 0:83cf97c10b63 642 sntp_addresses_free = p_free ? p_free : &free;
geiineuville 0:83cf97c10b63 643 return count;
geiineuville 0:83cf97c10b63 644 }
geiineuville 0:83cf97c10b63 645
geiineuville 0:83cf97c10b63 646 // Trim whitespace/CRLFs from both ends of a given string
geiineuville 0:83cf97c10b63 647 char * str_cleanup(char *in) {
geiineuville 0:83cf97c10b63 648 char * out = in;
geiineuville 0:83cf97c10b63 649 // Trim leading spaces and CR/LF
geiineuville 0:83cf97c10b63 650 while (*out == ' ' || *out == '\t' || *out == '\r' || *out == '\n')
geiineuville 0:83cf97c10b63 651 out ++;
geiineuville 0:83cf97c10b63 652 // Trim trailing spaces and CR/LF
geiineuville 0:83cf97c10b63 653 int len = strlen(out)-1;
geiineuville 0:83cf97c10b63 654 while (out[len] == ' ' || out[len] == '\t' || out[len] == '\r' || out[len] == '\n') {
geiineuville 0:83cf97c10b63 655 out[len] = '\0';
geiineuville 0:83cf97c10b63 656 len--;
geiineuville 0:83cf97c10b63 657 }
geiineuville 0:83cf97c10b63 658 return out;
geiineuville 0:83cf97c10b63 659 }
geiineuville 0:83cf97c10b63 660
geiineuville 0:83cf97c10b63 661 #ifndef CRLF
geiineuville 0:83cf97c10b63 662 #define CRLF "\r\n"
geiineuville 0:83cf97c10b63 663 #endif
geiineuville 0:83cf97c10b63 664 void SNTPWriteIniFile(FILE * f) {
geiineuville 0:83cf97c10b63 665 fprintf(f, "# SNTP Configuration file" CRLF);
geiineuville 0:83cf97c10b63 666 fprintf(f, CRLF "[Servers]" CRLF);
geiineuville 0:83cf97c10b63 667 for (int i=0; i<sntp_num_servers; i++) {
geiineuville 0:83cf97c10b63 668 fprintf(f, "%s" CRLF, sntp_server_addresses[i]);
geiineuville 0:83cf97c10b63 669 }
geiineuville 0:83cf97c10b63 670 fprintf(f, CRLF "[Global]" CRLF);
geiineuville 0:83cf97c10b63 671 fprintf(f, "RtcUtc=%d" CRLF, (int)gSntpRtcUtc);
geiineuville 0:83cf97c10b63 672 fprintf(f, "Timezone=%0.1f" CRLF, gSntpTimezone / 3600.0);
geiineuville 0:83cf97c10b63 673 fprintf(f, "DstZone=%d" CRLF, gSntpDstZone);
geiineuville 0:83cf97c10b63 674 fprintf(f, "# %s" CRLF, SNTPDstZoneName(gSntpDstZone));
geiineuville 0:83cf97c10b63 675 fprintf(f, "UpdateDelay=%d" CRLF, gSntpUpdateDelay_s);
geiineuville 0:83cf97c10b63 676 fprintf(f, "RecvTimeout=%d" CRLF, gSntpRecvTimeout_s);
geiineuville 0:83cf97c10b63 677 fprintf(f, CRLF "##END" CRLF);
geiineuville 0:83cf97c10b63 678 }
geiineuville 0:83cf97c10b63 679
geiineuville 0:83cf97c10b63 680 // Simple ini file parser for SNTP configuration (Case-sensitive!)
geiineuville 0:83cf97c10b63 681 // This function is intended to be called only before SNTPClientInit().
geiineuville 0:83cf97c10b63 682 // Returns: 0 if OK, errno otherwise
geiineuville 0:83cf97c10b63 683 enum {
geiineuville 0:83cf97c10b63 684 SECT_NONE,
geiineuville 0:83cf97c10b63 685 SECT_SERVERS,
geiineuville 0:83cf97c10b63 686 SECT_GLOBAL,
geiineuville 0:83cf97c10b63 687 };
geiineuville 0:83cf97c10b63 688 int SNTPReadIniFile(const char* filename) {
geiineuville 0:83cf97c10b63 689 FILE *f;
geiineuville 0:83cf97c10b63 690 char buf[512];
geiineuville 0:83cf97c10b63 691 bool addresses_cleared = false;
geiineuville 0:83cf97c10b63 692
geiineuville 0:83cf97c10b63 693 f = fopen(filename, "r");
geiineuville 0:83cf97c10b63 694 if (!f)
geiineuville 0:83cf97c10b63 695 return -1; // errno not used?
geiineuville 0:83cf97c10b63 696
geiineuville 0:83cf97c10b63 697 char *buf1, *buf2;
geiineuville 0:83cf97c10b63 698 int section=SECT_NONE;
geiineuville 0:83cf97c10b63 699 int line = 0;
geiineuville 0:83cf97c10b63 700 while (fgets(buf, sizeof(buf)/sizeof(buf[0]), f)) {
geiineuville 0:83cf97c10b63 701 line++;
geiineuville 0:83cf97c10b63 702 buf1 = str_cleanup(buf);
geiineuville 0:83cf97c10b63 703 if (*buf1 == '#' || *buf1 == '\0')
geiineuville 0:83cf97c10b63 704 continue; // Comment line or empty line - skip
geiineuville 0:83cf97c10b63 705 if (*buf1 == '[') {
geiineuville 0:83cf97c10b63 706 // New section
geiineuville 0:83cf97c10b63 707 if (0 == strncmp(buf1,"[Servers]", sizeof("[Servers]")-1)) {
geiineuville 0:83cf97c10b63 708 section=SECT_SERVERS;
geiineuville 0:83cf97c10b63 709 if (!addresses_cleared) {
geiineuville 0:83cf97c10b63 710 // Clear addresses only once.
geiineuville 0:83cf97c10b63 711 _SNTPClrAddresses();
geiineuville 0:83cf97c10b63 712 addresses_cleared = true;
geiineuville 0:83cf97c10b63 713 }
geiineuville 0:83cf97c10b63 714 } else if (0 == strncmp(buf1,"[Global]", sizeof("[Global]")-1)) {
geiineuville 0:83cf97c10b63 715 section=SECT_GLOBAL;
geiineuville 0:83cf97c10b63 716 } else {
geiineuville 0:83cf97c10b63 717 section=SECT_NONE;
geiineuville 0:83cf97c10b63 718 fprintf(stderr, "File \"%s\", line %d - section \"%s\" is not understood.\r\n", filename, line, buf1);
geiineuville 0:83cf97c10b63 719 }
geiineuville 0:83cf97c10b63 720 } else {
geiineuville 0:83cf97c10b63 721 // Section values
geiineuville 0:83cf97c10b63 722 switch (section) {
geiineuville 0:83cf97c10b63 723 case SECT_SERVERS:
geiineuville 0:83cf97c10b63 724 if (_SNTPAddAddress(buf1)) {
geiineuville 0:83cf97c10b63 725 fprintf(stderr, "File \"%s\", line %d - cannot add server \"%s\" - exceeded allocated slots.\r\n", filename, line, buf1);
geiineuville 0:83cf97c10b63 726 }
geiineuville 0:83cf97c10b63 727 break;
geiineuville 0:83cf97c10b63 728 case SECT_GLOBAL:
geiineuville 0:83cf97c10b63 729 buf2 = strchr(buf1, '=');
geiineuville 0:83cf97c10b63 730 if (buf2) {
geiineuville 0:83cf97c10b63 731 *buf2++ = '\0'; // Now buf1 has variable name, buf2 has value
geiineuville 0:83cf97c10b63 732 buf2 = str_cleanup(buf2);
geiineuville 0:83cf97c10b63 733 if (0 == strncmp(buf1, "Timezone", sizeof("Timezone")-1)) {
geiineuville 0:83cf97c10b63 734 gSntpTimezone = strtod(buf2, &buf2) * 3600;
geiineuville 0:83cf97c10b63 735 } else if (0 == strncmp(buf1, "UpdateDelay", sizeof("UpdateDelay")-1)) {
geiineuville 0:83cf97c10b63 736 gSntpUpdateDelay_s = strtoul(buf2, &buf2, 10);
geiineuville 0:83cf97c10b63 737 } else if (0 == strncmp(buf1, "RecvTimeout", sizeof("RecvTimeout")-1)) {
geiineuville 0:83cf97c10b63 738 gSntpRecvTimeout_s = strtoul(buf2, &buf2, 10);
geiineuville 0:83cf97c10b63 739 } else if (0 == strncmp(buf1, "RtcUtc", sizeof("RtcUtc")-1)) {
geiineuville 0:83cf97c10b63 740 gSntpRtcUtc = (bool)strtol(buf2, &buf2, 10);
geiineuville 0:83cf97c10b63 741 } else if (0 == strncmp(buf1, "DstZone", sizeof("DstZone")-1)) {
geiineuville 0:83cf97c10b63 742 // FIXME: It would be nice to allow human-readable string here.
geiineuville 0:83cf97c10b63 743 gSntpDstZone = (tDST_ZONE)strtol(buf2, &buf2, 10);
geiineuville 0:83cf97c10b63 744 } else {
geiineuville 0:83cf97c10b63 745 fprintf(stderr, "File \"%s\", line %d - unrecognized variable \"%s\" in section [Global]\r\n", filename, line, buf1);
geiineuville 0:83cf97c10b63 746 }
geiineuville 0:83cf97c10b63 747 } else {
geiineuville 0:83cf97c10b63 748 fprintf(stderr, "File \"%s\", line %d - unrecognized statement in section [Global]: %s\r\n", filename, line, buf1);
geiineuville 0:83cf97c10b63 749 }
geiineuville 0:83cf97c10b63 750 break;
geiineuville 0:83cf97c10b63 751 default:
geiineuville 0:83cf97c10b63 752 fprintf(stderr, "File \"%s\", line %d - unrecognized statement / no section: %s\r\n", filename, line, buf1);
geiineuville 0:83cf97c10b63 753 }
geiineuville 0:83cf97c10b63 754 }
geiineuville 0:83cf97c10b63 755 }
geiineuville 0:83cf97c10b63 756 fclose(f);
geiineuville 0:83cf97c10b63 757 printf("SNTP configuration read from file \"%s\", %d lines.\r\n", filename, line);
geiineuville 0:83cf97c10b63 758 return 0;
geiineuville 0:83cf97c10b63 759 }
geiineuville 0:83cf97c10b63 760
geiineuville 0:83cf97c10b63 761 // Start the SNTP client
geiineuville 0:83cf97c10b63 762 void SNTPClientInit(void) {
geiineuville 0:83cf97c10b63 763
geiineuville 0:83cf97c10b63 764 #ifdef SNTP_DST_TESTS
geiineuville 0:83cf97c10b63 765 // Test our DST algorithms
geiineuville 0:83cf97c10b63 766 test_sntp_dst_calc(gSntpTimezone, gSntpDstZone);
geiineuville 0:83cf97c10b63 767 test_sntp_dst_point(-2);
geiineuville 0:83cf97c10b63 768 test_sntp_dst_point(-1);
geiineuville 0:83cf97c10b63 769 test_sntp_dst_point(0);
geiineuville 0:83cf97c10b63 770 test_sntp_dst_point(1);
geiineuville 0:83cf97c10b63 771 test_sntp_dst_point(2);
geiineuville 0:83cf97c10b63 772 #endif
geiineuville 0:83cf97c10b63 773
geiineuville 0:83cf97c10b63 774 // SNTPv4 RFC 4330 enforces a minimum update time of 15 seconds
geiineuville 0:83cf97c10b63 775 if (gSntpUpdateDelay_s < 15) {
geiineuville 0:83cf97c10b63 776 gSntpUpdateDelay_s = 15;
geiineuville 0:83cf97c10b63 777 }
geiineuville 0:83cf97c10b63 778
geiineuville 0:83cf97c10b63 779 gSntpRunning = true;
geiineuville 0:83cf97c10b63 780
geiineuville 0:83cf97c10b63 781 // Just call this to start SNTP client:
geiineuville 0:83cf97c10b63 782 sntp_init();
geiineuville 0:83cf97c10b63 783
geiineuville 0:83cf97c10b63 784 // // Enable RTC ISR
geiineuville 0:83cf97c10b63 785 // gSntpTicker.attach(_sntp_isr, 1);
geiineuville 0:83cf97c10b63 786 // We do it from first NTP response
geiineuville 0:83cf97c10b63 787 }
geiineuville 0:83cf97c10b63 788
geiineuville 0:83cf97c10b63 789 // Use instead of system time()
geiineuville 0:83cf97c10b63 790 // Returns local time
geiineuville 0:83cf97c10b63 791 time_t SNTPTime(void) {
geiineuville 0:83cf97c10b63 792 time_t seconds = time(NULL);
geiineuville 0:83cf97c10b63 793 if (gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 794 seconds += gSntpTimezone + gSntpDST; // Convert to local time
geiineuville 0:83cf97c10b63 795 }
geiineuville 0:83cf97c10b63 796 return seconds;
geiineuville 0:83cf97c10b63 797 }
geiineuville 0:83cf97c10b63 798
geiineuville 0:83cf97c10b63 799 // Use instead of system set_time()
geiineuville 0:83cf97c10b63 800 // seconds - local time
geiineuville 0:83cf97c10b63 801 void SNTPSetTime(time_t seconds) {
geiineuville 0:83cf97c10b63 802 if (gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 803 seconds -= gSntpTimezone + gSntpDST; // Convert from local time
geiineuville 0:83cf97c10b63 804 }
geiineuville 0:83cf97c10b63 805 set_time(seconds);
geiineuville 0:83cf97c10b63 806 }
geiineuville 0:83cf97c10b63 807
geiineuville 0:83cf97c10b63 808 // Use instead of system time()
geiineuville 0:83cf97c10b63 809 // Returns UTC time
geiineuville 0:83cf97c10b63 810 time_t SNTPTimeUTC(void) {
geiineuville 0:83cf97c10b63 811 time_t seconds = time(NULL);
geiineuville 0:83cf97c10b63 812 if (!gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 813 seconds -= gSntpTimezone + gSntpDST; // Convert from local time
geiineuville 0:83cf97c10b63 814 }
geiineuville 0:83cf97c10b63 815 return seconds;
geiineuville 0:83cf97c10b63 816 }
geiineuville 0:83cf97c10b63 817
geiineuville 0:83cf97c10b63 818 // Use instead of system set_time()
geiineuville 0:83cf97c10b63 819 // seconds - UTC time
geiineuville 0:83cf97c10b63 820 void SNTPSetTimeUTC(time_t seconds) {
geiineuville 0:83cf97c10b63 821 if (!gSntpRtcUtc) {
geiineuville 0:83cf97c10b63 822 seconds += gSntpTimezone + gSntpDST; // Convert to local time
geiineuville 0:83cf97c10b63 823 }
geiineuville 0:83cf97c10b63 824 set_time(seconds);
geiineuville 0:83cf97c10b63 825 }
geiineuville 0:83cf97c10b63 826
geiineuville 0:83cf97c10b63 827 //END