StrippedDownNetServices - This library is stripped down version of NetServi…

Users » idinor » Code » StrippedDownNetServices

idinor Launcher / StrippedDownNetServices

This library is stripped down version of NetServices library. HTTP server and client function is NOT supported.

services/ntp/NTPClient.cpp@0:dcf3c92487ca, 2011-07-20 (annotated)

Committer:: idinor
Date:: Wed Jul 20 11:45:39 2011 +0000
Revision:: 0:dcf3c92487ca

Who changed what in which revision?

User	Revision	Line number	New contents of line
idinor	0:dcf3c92487ca	1	#pragma diag_remark 1293
idinor	0:dcf3c92487ca	2	/*
idinor	0:dcf3c92487ca	3	Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
idinor	0:dcf3c92487ca	4
idinor	0:dcf3c92487ca	5	Permission is hereby granted, free of charge, to any person obtaining a copy
idinor	0:dcf3c92487ca	6	of this software and associated documentation files (the "Software"), to deal
idinor	0:dcf3c92487ca	7	in the Software without restriction, including without limitation the rights
idinor	0:dcf3c92487ca	8	to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
idinor	0:dcf3c92487ca	9	copies of the Software, and to permit persons to whom the Software is
idinor	0:dcf3c92487ca	10	furnished to do so, subject to the following conditions:
idinor	0:dcf3c92487ca	11
idinor	0:dcf3c92487ca	12	The above copyright notice and this permission notice shall be included in
idinor	0:dcf3c92487ca	13	all copies or substantial portions of the Software.
idinor	0:dcf3c92487ca	14
idinor	0:dcf3c92487ca	15	THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
idinor	0:dcf3c92487ca	16	IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
idinor	0:dcf3c92487ca	17	FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
idinor	0:dcf3c92487ca	18	AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
idinor	0:dcf3c92487ca	19	LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
idinor	0:dcf3c92487ca	20	OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
idinor	0:dcf3c92487ca	21	THE SOFTWARE.
idinor	0:dcf3c92487ca	22	*/
idinor	0:dcf3c92487ca	23
idinor	0:dcf3c92487ca	24	#include "NTPClient.h"
idinor	0:dcf3c92487ca	25
idinor	0:dcf3c92487ca	26	#include <stdio.h>
idinor	0:dcf3c92487ca	27
idinor	0:dcf3c92487ca	28	//#define __DEBUG
idinor	0:dcf3c92487ca	29	#include "dbg/dbg.h"
idinor	0:dcf3c92487ca	30
idinor	0:dcf3c92487ca	31	#define NTP_PORT 123
idinor	0:dcf3c92487ca	32	#define NTP_CLIENT_PORT 0//50420 //Random port
idinor	0:dcf3c92487ca	33	#define NTP_REQUEST_TIMEOUT 15000
idinor	0:dcf3c92487ca	34	#define NTP_TIMESTAMP_DELTA 2208988800ull //Diff btw a UNIX timestamp (Starting Jan, 1st 1970) and a NTP timestamp (Starting Jan, 1st 1900)
idinor	0:dcf3c92487ca	35
idinor	0:dcf3c92487ca	36	#define htons( x ) ( (( x << 8 ) & 0xFF00) \| (( x >> 8 ) & 0x00FF) )
idinor	0:dcf3c92487ca	37	#define ntohs( x ) (htons(x))
idinor	0:dcf3c92487ca	38
idinor	0:dcf3c92487ca	39	#define htonl( x ) ( (( x << 24 ) & 0xFF000000) \
idinor	0:dcf3c92487ca	40	\| (( x << 8 ) & 0x00FF0000) \
idinor	0:dcf3c92487ca	41	\| (( x >> 8 ) & 0x0000FF00) \
idinor	0:dcf3c92487ca	42	\| (( x >> 24 ) & 0x000000FF) )
idinor	0:dcf3c92487ca	43	#define ntohl( x ) (htonl(x))
idinor	0:dcf3c92487ca	44
idinor	0:dcf3c92487ca	45	NTPClient::NTPClient() : NetService(false), m_state(NTP_PING), m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL),
idinor	0:dcf3c92487ca	46	m_watchdog(), m_timeout(0), m_closed(true), m_host(), m_pDnsReq(NULL), m_blockingResult(NTP_PROCESSING)
idinor	0:dcf3c92487ca	47	{
idinor	0:dcf3c92487ca	48	setTimeout(NTP_REQUEST_TIMEOUT);
idinor	0:dcf3c92487ca	49	DBG("\r\nNew NTPClient %p\r\n",this);
idinor	0:dcf3c92487ca	50	}
idinor	0:dcf3c92487ca	51
idinor	0:dcf3c92487ca	52	NTPClient::~NTPClient()
idinor	0:dcf3c92487ca	53	{
idinor	0:dcf3c92487ca	54	close();
idinor	0:dcf3c92487ca	55	}
idinor	0:dcf3c92487ca	56
idinor	0:dcf3c92487ca	57	//High level setup functions
idinor	0:dcf3c92487ca	58	NTPResult NTPClient::setTime(const Host& host) //Blocking
idinor	0:dcf3c92487ca	59	{
idinor	0:dcf3c92487ca	60	doSetTime(host);
idinor	0:dcf3c92487ca	61	return blockingProcess();
idinor	0:dcf3c92487ca	62	}
idinor	0:dcf3c92487ca	63
idinor	0:dcf3c92487ca	64	NTPResult NTPClient::setTime(const Host& host, void (*pMethod)(NTPResult)) //Non blocking
idinor	0:dcf3c92487ca	65	{
idinor	0:dcf3c92487ca	66	setOnResult(pMethod);
idinor	0:dcf3c92487ca	67	doSetTime(host);
idinor	0:dcf3c92487ca	68	return NTP_PROCESSING;
idinor	0:dcf3c92487ca	69	}
idinor	0:dcf3c92487ca	70
idinor	0:dcf3c92487ca	71	#if 0 //For doc only
idinor	0:dcf3c92487ca	72	template<class T>
idinor	0:dcf3c92487ca	73	NTPResult NTPClient::setTime(const Host& host, T* pItem, void (T::*pMethod)(NTPResult)) //Non blocking
idinor	0:dcf3c92487ca	74	{
idinor	0:dcf3c92487ca	75	setOnResult(pItem, pMethod);
idinor	0:dcf3c92487ca	76	doSetTime(host);
idinor	0:dcf3c92487ca	77	return NTP_PROCESSING;
idinor	0:dcf3c92487ca	78	}
idinor	0:dcf3c92487ca	79	#endif
idinor	0:dcf3c92487ca	80
idinor	0:dcf3c92487ca	81	void NTPClient::doSetTime(const Host& host)
idinor	0:dcf3c92487ca	82	{
idinor	0:dcf3c92487ca	83	init();
idinor	0:dcf3c92487ca	84	resetTimeout();
idinor	0:dcf3c92487ca	85	m_host = host;
idinor	0:dcf3c92487ca	86	if(!m_host.getPort())
idinor	0:dcf3c92487ca	87	{
idinor	0:dcf3c92487ca	88	m_host.setPort(NTP_PORT);
idinor	0:dcf3c92487ca	89	}
idinor	0:dcf3c92487ca	90	if(m_host.getIp().isNull())
idinor	0:dcf3c92487ca	91	{
idinor	0:dcf3c92487ca	92	//DNS query required
idinor	0:dcf3c92487ca	93	m_pDnsReq = new DNSRequest();
idinor	0:dcf3c92487ca	94	DBG("\r\nNTPClient : DNSRequest %p\r\n", m_pDnsReq);
idinor	0:dcf3c92487ca	95	m_pDnsReq->setOnReply(this, &NTPClient::onDNSReply);
idinor	0:dcf3c92487ca	96	m_pDnsReq->resolve(&m_host);
idinor	0:dcf3c92487ca	97	return;
idinor	0:dcf3c92487ca	98	}
idinor	0:dcf3c92487ca	99	open();
idinor	0:dcf3c92487ca	100	}
idinor	0:dcf3c92487ca	101
idinor	0:dcf3c92487ca	102	void NTPClient::setOnResult( void (*pMethod)(NTPResult) )
idinor	0:dcf3c92487ca	103	{
idinor	0:dcf3c92487ca	104	m_pCb = pMethod;
idinor	0:dcf3c92487ca	105	}
idinor	0:dcf3c92487ca	106
idinor	0:dcf3c92487ca	107	void NTPClient::close()
idinor	0:dcf3c92487ca	108	{
idinor	0:dcf3c92487ca	109	if(m_closed)
idinor	0:dcf3c92487ca	110	return;
idinor	0:dcf3c92487ca	111	m_closed = true; //Prevent recursive calling or calling on an object being destructed by someone else
idinor	0:dcf3c92487ca	112	m_watchdog.stop();
idinor	0:dcf3c92487ca	113	m_pUDPSocket->resetOnEvent();
idinor	0:dcf3c92487ca	114	m_pUDPSocket->close();
idinor	0:dcf3c92487ca	115	delete m_pUDPSocket;
idinor	0:dcf3c92487ca	116	if( m_pDnsReq )
idinor	0:dcf3c92487ca	117	{
idinor	0:dcf3c92487ca	118	m_pDnsReq->close();
idinor	0:dcf3c92487ca	119	delete m_pDnsReq;
idinor	0:dcf3c92487ca	120	m_pDnsReq = NULL;
idinor	0:dcf3c92487ca	121	}
idinor	0:dcf3c92487ca	122	}
idinor	0:dcf3c92487ca	123
idinor	0:dcf3c92487ca	124	void NTPClient::poll() //Called by NetServices
idinor	0:dcf3c92487ca	125	{
idinor	0:dcf3c92487ca	126	if( (!m_closed) && (m_watchdog.read_ms() >= m_timeout) )
idinor	0:dcf3c92487ca	127	{
idinor	0:dcf3c92487ca	128	onTimeout();
idinor	0:dcf3c92487ca	129	}
idinor	0:dcf3c92487ca	130	}
idinor	0:dcf3c92487ca	131
idinor	0:dcf3c92487ca	132	void NTPClient::init() //Create and setup socket if needed
idinor	0:dcf3c92487ca	133	{
idinor	0:dcf3c92487ca	134	if(!m_closed) //Already opened
idinor	0:dcf3c92487ca	135	return;
idinor	0:dcf3c92487ca	136	m_state = NTP_PING;
idinor	0:dcf3c92487ca	137	m_pUDPSocket = new UDPSocket;
idinor	0:dcf3c92487ca	138	m_pUDPSocket->setOnEvent(this, &NTPClient::onUDPSocketEvent);
idinor	0:dcf3c92487ca	139	m_closed = false;
idinor	0:dcf3c92487ca	140	DBG("NTPClient: Init OK\n");
idinor	0:dcf3c92487ca	141	}
idinor	0:dcf3c92487ca	142
idinor	0:dcf3c92487ca	143	void NTPClient::open()
idinor	0:dcf3c92487ca	144	{
idinor	0:dcf3c92487ca	145	resetTimeout();
idinor	0:dcf3c92487ca	146	DBG("Opening connection\n");
idinor	0:dcf3c92487ca	147	m_state = NTP_PING;
idinor	0:dcf3c92487ca	148	Host localhost(IpAddr(), NTP_CLIENT_PORT, "localhost"); //Any local address
idinor	0:dcf3c92487ca	149	m_pUDPSocket->bind(localhost);
idinor	0:dcf3c92487ca	150	if ((int)time(NULL) < 1280000000) set_time( 1280000000 ); //End of July 2010... just there to limit offset range
idinor	0:dcf3c92487ca	151	process();
idinor	0:dcf3c92487ca	152	}
idinor	0:dcf3c92487ca	153
idinor	0:dcf3c92487ca	154	#define MIN(a,b) ((a)<(b))?(a):(b)
idinor	0:dcf3c92487ca	155	void NTPClient::process() //Main state-machine
idinor	0:dcf3c92487ca	156	{
idinor	0:dcf3c92487ca	157	int len;
idinor	0:dcf3c92487ca	158	Host host;
idinor	0:dcf3c92487ca	159
idinor	0:dcf3c92487ca	160	switch(m_state)
idinor	0:dcf3c92487ca	161	{
idinor	0:dcf3c92487ca	162	case NTP_PING:
idinor	0:dcf3c92487ca	163	DBG("\r\nPing\r\n");
idinor	0:dcf3c92487ca	164	//Prepare NTP Packet:
idinor	0:dcf3c92487ca	165	m_pkt.li = 0; //Leap Indicator : No warning
idinor	0:dcf3c92487ca	166	m_pkt.vn = 4; //Version Number : 4
idinor	0:dcf3c92487ca	167	m_pkt.mode = 3; //Client mode
idinor	0:dcf3c92487ca	168	m_pkt.stratum = 0; //Not relevant here
idinor	0:dcf3c92487ca	169	m_pkt.poll = 0; //Not significant as well
idinor	0:dcf3c92487ca	170	m_pkt.precision = 0; //Neither this one is
idinor	0:dcf3c92487ca	171
idinor	0:dcf3c92487ca	172	m_pkt.rootDelay = 0; //Or this one
idinor	0:dcf3c92487ca	173	m_pkt.rootDispersion = 0; //Or that one
idinor	0:dcf3c92487ca	174	m_pkt.refId = 0; //...
idinor	0:dcf3c92487ca	175
idinor	0:dcf3c92487ca	176	m_pkt.refTm_s = 0;
idinor	0:dcf3c92487ca	177	m_pkt.origTm_s = 0;
idinor	0:dcf3c92487ca	178	m_pkt.rxTm_s = 0;
idinor	0:dcf3c92487ca	179	m_pkt.txTm_s = htonl( NTP_TIMESTAMP_DELTA + time(NULL) ); //WARN: We are in LE format, network byte order is BE
idinor	0:dcf3c92487ca	180
idinor	0:dcf3c92487ca	181	m_pkt.refTm_f = m_pkt.origTm_f = m_pkt.rxTm_f = m_pkt.txTm_f = 0;
idinor	0:dcf3c92487ca	182
idinor	0:dcf3c92487ca	183	#ifdef __DEBUG
idinor	0:dcf3c92487ca	184	//Hex Dump:
idinor	0:dcf3c92487ca	185	DBG("\r\nDump Tx:\r\n");
idinor	0:dcf3c92487ca	186	for(int i = 0; i< sizeof(NTPPacket); i++)
idinor	0:dcf3c92487ca	187	{
idinor	0:dcf3c92487ca	188	DBG("%02x ", ((char)&m_pkt + i));
idinor	0:dcf3c92487ca	189	}
idinor	0:dcf3c92487ca	190	DBG("\r\n\r\n");
idinor	0:dcf3c92487ca	191	#endif
idinor	0:dcf3c92487ca	192
idinor	0:dcf3c92487ca	193	len = m_pUDPSocket->sendto( (char*)&m_pkt, sizeof(NTPPacket), &m_host );
idinor	0:dcf3c92487ca	194	if(len < sizeof(NTPPacket))
idinor	0:dcf3c92487ca	195	{ onResult(NTP_PRTCL); close(); return; }
idinor	0:dcf3c92487ca	196
idinor	0:dcf3c92487ca	197	m_state = NTP_PONG;
idinor	0:dcf3c92487ca	198
idinor	0:dcf3c92487ca	199	break;
idinor	0:dcf3c92487ca	200
idinor	0:dcf3c92487ca	201	case NTP_PONG:
idinor	0:dcf3c92487ca	202	DBG("\r\nPong\r\n");
idinor	0:dcf3c92487ca	203	while( len = m_pUDPSocket->recvfrom( (char*)&m_pkt, sizeof(NTPPacket), &host ) )
idinor	0:dcf3c92487ca	204	{
idinor	0:dcf3c92487ca	205	if( len <= 0 )
idinor	0:dcf3c92487ca	206	break;
idinor	0:dcf3c92487ca	207	if( !host.getIp().isEq(m_host.getIp()) )
idinor	0:dcf3c92487ca	208	continue; //Not our packet
idinor	0:dcf3c92487ca	209	if( len > 0 )
idinor	0:dcf3c92487ca	210	break;
idinor	0:dcf3c92487ca	211	}
idinor	0:dcf3c92487ca	212
idinor	0:dcf3c92487ca	213	if(len == 0)
idinor	0:dcf3c92487ca	214	return; //Wait for the next packet
idinor	0:dcf3c92487ca	215
idinor	0:dcf3c92487ca	216	if(len < 0)
idinor	0:dcf3c92487ca	217	{ onResult(NTP_PRTCL); close(); return; }
idinor	0:dcf3c92487ca	218
idinor	0:dcf3c92487ca	219	if(len < sizeof(NTPPacket)) //TODO: Accept chunks
idinor	0:dcf3c92487ca	220	{ onResult(NTP_PRTCL); close(); return; }
idinor	0:dcf3c92487ca	221
idinor	0:dcf3c92487ca	222	#ifdef __DEBUG
idinor	0:dcf3c92487ca	223	//Hex Dump:
idinor	0:dcf3c92487ca	224	DBG("\r\nDump Rx:\r\n");
idinor	0:dcf3c92487ca	225	for(int i = 0; i< sizeof(NTPPacket); i++)
idinor	0:dcf3c92487ca	226	{
idinor	0:dcf3c92487ca	227	DBG("%02x ", ((char)&m_pkt + i));
idinor	0:dcf3c92487ca	228	}
idinor	0:dcf3c92487ca	229	DBG("\r\n\r\n");
idinor	0:dcf3c92487ca	230	#endif
idinor	0:dcf3c92487ca	231
idinor	0:dcf3c92487ca	232	if( m_pkt.stratum == 0) //Kiss of death message : Not good !
idinor	0:dcf3c92487ca	233	{
idinor	0:dcf3c92487ca	234	onResult(NTP_PRTCL); close(); return;
idinor	0:dcf3c92487ca	235	}
idinor	0:dcf3c92487ca	236
idinor	0:dcf3c92487ca	237	//Correct Endianness
idinor	0:dcf3c92487ca	238	m_pkt.refTm_s = ntohl( m_pkt.refTm_s );
idinor	0:dcf3c92487ca	239	m_pkt.refTm_f = ntohl( m_pkt.refTm_f );
idinor	0:dcf3c92487ca	240	m_pkt.origTm_s = ntohl( m_pkt.origTm_s );
idinor	0:dcf3c92487ca	241	m_pkt.origTm_f = ntohl( m_pkt.origTm_f );
idinor	0:dcf3c92487ca	242	m_pkt.rxTm_s = ntohl( m_pkt.rxTm_s );
idinor	0:dcf3c92487ca	243	m_pkt.rxTm_f = ntohl( m_pkt.rxTm_f );
idinor	0:dcf3c92487ca	244	m_pkt.txTm_s = ntohl( m_pkt.txTm_s );
idinor	0:dcf3c92487ca	245	m_pkt.txTm_f = ntohl( m_pkt.txTm_f );
idinor	0:dcf3c92487ca	246
idinor	0:dcf3c92487ca	247	//Compute offset, see RFC 4330 p.13
idinor	0:dcf3c92487ca	248	uint32_t destTm_s = (NTP_TIMESTAMP_DELTA + time(NULL));
idinor	0:dcf3c92487ca	249	//int32_t origTm = (int32_t) ((uint64_t) m_pkt.origTm - NTP_TIMESTAMP_DELTA); //Convert in local 32 bits timestamps
idinor	0:dcf3c92487ca	250	//int32_t rxTm = (int32_t) ((uint64_t) m_pkt.rxTm - NTP_TIMESTAMP_DELTA); //Convert in local 32 bits timestamps
idinor	0:dcf3c92487ca	251	//int32_t txTm = (int32_t) ((uint64_t) m_pkt.txTm - NTP_TIMESTAMP_DELTA); //Convert in local 32 bits timestamps
idinor	0:dcf3c92487ca	252	// int64_t offset = ( ( ( m_pkt.rxTm_s - m_pkt.origTm_s ) + ( m_pkt.txTm_s - destTm_s ) ) << 32 + ( ( m_pkt.rxTm_f - m_pkt.origTm_f ) + ( m_pkt.txTm_f - 0 ) ) ) / 2;
idinor	0:dcf3c92487ca	253	int64_t offset = ( (int64_t)( m_pkt.rxTm_s - m_pkt.origTm_s ) + (int64_t) ( m_pkt.txTm_s - destTm_s ) ) / 2; //Avoid overflow
idinor	0:dcf3c92487ca	254	DBG("\r\nSent @%d\r\n", m_pkt.txTm_s);
idinor	0:dcf3c92487ca	255	DBG("\r\nOffset: %d\r\n", offset);
idinor	0:dcf3c92487ca	256	//Set time accordingly
idinor	0:dcf3c92487ca	257	set_time( time(NULL) + (offset />> 32/) );
idinor	0:dcf3c92487ca	258
idinor	0:dcf3c92487ca	259	onResult(NTP_OK);
idinor	0:dcf3c92487ca	260	close();
idinor	0:dcf3c92487ca	261
idinor	0:dcf3c92487ca	262	break;
idinor	0:dcf3c92487ca	263	}
idinor	0:dcf3c92487ca	264	}
idinor	0:dcf3c92487ca	265
idinor	0:dcf3c92487ca	266	void NTPClient::setTimeout(int ms)
idinor	0:dcf3c92487ca	267	{
idinor	0:dcf3c92487ca	268	m_timeout = ms;
idinor	0:dcf3c92487ca	269	}
idinor	0:dcf3c92487ca	270
idinor	0:dcf3c92487ca	271	void NTPClient::resetTimeout()
idinor	0:dcf3c92487ca	272	{
idinor	0:dcf3c92487ca	273	m_watchdog.reset();
idinor	0:dcf3c92487ca	274	m_watchdog.start();
idinor	0:dcf3c92487ca	275	}
idinor	0:dcf3c92487ca	276
idinor	0:dcf3c92487ca	277	void NTPClient::onTimeout() //Connection has timed out
idinor	0:dcf3c92487ca	278	{
idinor	0:dcf3c92487ca	279	close();
idinor	0:dcf3c92487ca	280	onResult(NTP_TIMEOUT);
idinor	0:dcf3c92487ca	281	}
idinor	0:dcf3c92487ca	282
idinor	0:dcf3c92487ca	283	void NTPClient::onDNSReply(DNSReply r)
idinor	0:dcf3c92487ca	284	{
idinor	0:dcf3c92487ca	285	if(m_closed)
idinor	0:dcf3c92487ca	286	{
idinor	0:dcf3c92487ca	287	DBG("\r\nWARN: Discarded\r\n");
idinor	0:dcf3c92487ca	288	return;
idinor	0:dcf3c92487ca	289	}
idinor	0:dcf3c92487ca	290
idinor	0:dcf3c92487ca	291	if( r != DNS_FOUND )
idinor	0:dcf3c92487ca	292	{
idinor	0:dcf3c92487ca	293	DBG("\r\nCould not resolve hostname.\r\n");
idinor	0:dcf3c92487ca	294	onResult(NTP_DNS);
idinor	0:dcf3c92487ca	295	close();
idinor	0:dcf3c92487ca	296	return;
idinor	0:dcf3c92487ca	297	}
idinor	0:dcf3c92487ca	298	DBG("\r\nDNS resolved.\r\n");
idinor	0:dcf3c92487ca	299	m_pDnsReq->close();
idinor	0:dcf3c92487ca	300	delete m_pDnsReq;
idinor	0:dcf3c92487ca	301	m_pDnsReq=NULL;
idinor	0:dcf3c92487ca	302	open();
idinor	0:dcf3c92487ca	303	}
idinor	0:dcf3c92487ca	304
idinor	0:dcf3c92487ca	305	void NTPClient::onUDPSocketEvent(UDPSocketEvent e)
idinor	0:dcf3c92487ca	306	{
idinor	0:dcf3c92487ca	307	resetTimeout();
idinor	0:dcf3c92487ca	308	switch(e)
idinor	0:dcf3c92487ca	309	{
idinor	0:dcf3c92487ca	310	case UDPSOCKET_READABLE: //The only event for now
idinor	0:dcf3c92487ca	311	resetTimeout();
idinor	0:dcf3c92487ca	312	process();
idinor	0:dcf3c92487ca	313	break;
idinor	0:dcf3c92487ca	314	}
idinor	0:dcf3c92487ca	315	}
idinor	0:dcf3c92487ca	316
idinor	0:dcf3c92487ca	317	void NTPClient::onResult(NTPResult r) //Must be called by impl when the request completes
idinor	0:dcf3c92487ca	318	{
idinor	0:dcf3c92487ca	319	if(m_pCbItem && m_pCbMeth)
idinor	0:dcf3c92487ca	320	(m_pCbItem->*m_pCbMeth)(r);
idinor	0:dcf3c92487ca	321	else if(m_pCb)
idinor	0:dcf3c92487ca	322	m_pCb(r);
idinor	0:dcf3c92487ca	323	m_blockingResult = r; //Blocking mode
idinor	0:dcf3c92487ca	324	}
idinor	0:dcf3c92487ca	325
idinor	0:dcf3c92487ca	326	NTPResult NTPClient::blockingProcess() //Called in blocking mode, calls Net::poll() until return code is available
idinor	0:dcf3c92487ca	327	{
idinor	0:dcf3c92487ca	328	m_blockingResult = NTP_PROCESSING;
idinor	0:dcf3c92487ca	329	do
idinor	0:dcf3c92487ca	330	{
idinor	0:dcf3c92487ca	331	Net::poll();
idinor	0:dcf3c92487ca	332	} while(m_blockingResult == NTP_PROCESSING);
idinor	0:dcf3c92487ca	333	Net::poll(); //Necessary for cleanup
idinor	0:dcf3c92487ca	334	return m_blockingResult;
idinor	0:dcf3c92487ca	335	}

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	20 Jul 2011
Imports:	35
Forks:	0
Commits:	1
Dependents:	1
Dependencies:	0
Followers:	1

services/ntp/NTPClient.cpp@0:dcf3c92487ca, 2011-07-20 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning