-
Notifications
You must be signed in to change notification settings - Fork 0
/
NTP.h
240 lines (199 loc) · 7.68 KB
/
NTP.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
// NTP Time Handler //
// //
// Jim 01/01/2018 //
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
// //
// //
// //
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
/*
* TimeNTP_ESP8266WiFi.ino
* Example showing time sync to NTP time source
*
*/
#include <TimeLib.h>
#include <WiFiUdp.h>
#define countof(a) (sizeof(a) / sizeof(a[0]))
#ifndef RESYNCMINS
#define RESYNCMINS 30 //default if not overloaded
#endif
bool updatePermitted=true;
String NTPfulltime=""; //With Seconds
String NTPfulltimeNS=""; //No Seconds
String NTPm_d_yr="";
String NTPmiltime="";
int timeSinceSync=0;
long NTPlastMinute = -1; // timestamp last minute
// NTP Servers:
static const char ntpServerName[] = "us.pool.ntp.org";
//static const char ntpServerName[] = "time.nist.gov";
//static const char ntpServerName[] = "time-a.timefreq.bldrdoc.gov";
//static const char ntpServerName[] = "time-b.timefreq.bldrdoc.gov";
//static const char ntpServerName[] = "time-c.timefreq.bldrdoc.gov";
//const int timeZone = 1; // Central European Time
//const int timeZone = -5; // Eastern Standard Time (USA)
const int timeZone = -4; // Eastern Daylight Time (USA)
//const int timeZone = -8; // Pacific Standard Time (USA)
//const int timeZone = -7; // Pacific Daylight Time (USA)
String str="";
WiFiUDP Udp;
unsigned int localPort = 8888; // local port to listen for UDP packets
time_t getNtpTime();
void digitalClockDisplay();
void printDigits(int digits);
void sendNTPpacket(IPAddress &address);
void digitalClockDisplay()
{
// digital clock display of the time
Serial.print(hour());
printDigits(minute());
printDigits(second());
Serial.print(" ");
Serial.print(day());
Serial.print(".");
Serial.print(month());
Serial.print(".");
Serial.print(year());
Serial.println();
}
void printDigits(int digits)
{
// utility for digital clock display: prints preceding colon and leading 0
Serial.print(":");
if (digits < 10)
Serial.print('0');
Serial.print(digits);
}
/*-------- NTP code ----------*/
const int NTP_PACKET_SIZE = 48; // NTP time is in the first 48 bytes of message
byte packetBuffer[NTP_PACKET_SIZE]; //buffer to hold incoming & outgoing packets
time_t getNtpTime()
{
if (updatePermitted){
IPAddress ntpServerIP; // NTP server's ip address
while (Udp.parsePacket() > 0) ; // discard any previously received packets
Serial.println("Transmit NTP Request");
// get a random server from the pool
WiFi.hostByName(ntpServerName, ntpServerIP);
Serial.print(ntpServerName);
Serial.print(": ");
Serial.println(ntpServerIP);
sendNTPpacket(ntpServerIP);
uint32_t beginWait = millis();
while (millis() - beginWait < 1500) {
int size = Udp.parsePacket();
if (size >= NTP_PACKET_SIZE) {
Serial.println("Receive NTP Response");
Udp.read(packetBuffer, NTP_PACKET_SIZE); // read packet into the buffer
unsigned long secsSince1900;
// convert four bytes starting at location 40 to a long integer
secsSince1900 = (unsigned long)packetBuffer[40] << 24;
secsSince1900 |= (unsigned long)packetBuffer[41] << 16;
secsSince1900 |= (unsigned long)packetBuffer[42] << 8;
secsSince1900 |= (unsigned long)packetBuffer[43];
return secsSince1900 - 2208988800UL + timeZone * SECS_PER_HOUR;
}
}
Serial.println("No NTP Response :-(");
return 0; // return 0 if unable to get the time
}
}
// send an NTP request to the time server at the given address
void sendNTPpacket(IPAddress &address)
{
if (updatePermitted){
// set all bytes in the buffer to 0
memset(packetBuffer, 0, NTP_PACKET_SIZE);
// Initialize values needed to form NTP request
// (see URL above for details on the packets)
packetBuffer[0] = 0b11100011; // LI, Version, Mode
packetBuffer[1] = 0; // Stratum, or type of clock
packetBuffer[2] = 6; // Polling Interval
packetBuffer[3] = 0xEC; // Peer Clock Precision
// 8 bytes of zero for Root Delay & Root Dispersion
packetBuffer[12] = 49;
packetBuffer[13] = 0x4E;
packetBuffer[14] = 49;
packetBuffer[15] = 52;
// all NTP fields have been given values, now
// you can send a packet requesting a timestamp:
Udp.beginPacket(address, 123); //NTP requests are to port 123
Udp.write(packetBuffer, NTP_PACKET_SIZE);
Udp.endPacket();
}
}
void printDateTime()
{
// char datestring[20];
//
// snprintf_P(datestring,
// countof(datestring),
// PSTR("%02u/%02u/%04u %02u:%02u:%02u"),
// dt.Month(),
// dt.Day(),
// dt.Year(),
// dt.Hour(),
// dt.Minute(),
// dt.Second() );
// Serial.print(datestring);
}
void getNetTime(){
Serial.print("Getting Net Time...");
if (WiFi.status() != WL_CONNECTED) {
Serial.print("...connection FAIL.");
return;
}
Serial.println("Connection OK. ");
Serial.print("IP number assigned by DHCP is ");
Serial.println(WiFi.localIP());
Serial.println("Starting UDP");
Udp.begin(localPort);
Serial.print("Local port: ");
Serial.println(Udp.localPort());
Serial.println("waiting for sync");
setSyncProvider(getNtpTime); // Set the time using NTP
//setSyncInterval(300);
if(timeStatus() != timeNotSet){
digitalClockDisplay();
Serial.println("here is another way to display");
time_t t = now();
char d_mon_yr[12];
snprintf_P(d_mon_yr, countof(d_mon_yr), PSTR("%s %02u %04u"), monthShortStr(month(t)), day(t), year(t)); // get month, day and year
Serial.println(d_mon_yr);
char tim_set[9];
snprintf_P(tim_set, countof(tim_set), PSTR("%02u:%02u:%02u"), hour(t), minute(t), second(t)); // get time
Serial.println(tim_set);
Serial.println("Done.");
}
}
//////////////////////////////////////////////
void setTimeStrings(){
time_t t = now();
char buff1[14];
sprintf(buff1,"%02u:%02u", hour(t), minute(t)); // get time
//sprintf(NTPfulltimeNS,buff1[10]);
NTPfulltimeNS=String((char*)buff1);
snprintf_P(buff1, countof(buff1), PSTR("%02u:%02u:%02u"), hour(t), minute(t), second(t)); // get time
NTPfulltime=String((char*)buff1);
snprintf_P(buff1, countof(buff1), PSTR("%s %02u %04u"), monthShortStr(month(t)), day(t), year(t)); // get month, day and year
NTPm_d_yr=String((char*)buff1);
}
void handleTime(int resyncMins){
if (NTPlastMinute != (millis()/60000)) { // another minute passed ?
NTPlastMinute = millis()/60000;
timeSinceSync++;
if ((timeSinceSync>=(resyncMins*1000)) || (needTsync) ){
getNetTime();
timeSinceSync=0;
needTsync=false;
}else{
//////Do the updating here
//no need to do anything with this new code.
}
}
setTimeStrings();
}
void handleTime(){
handleTime(RESYNCMINS);
}