|
@@ -429,6 +429,7 @@ double offset_request(const char *host, int *status){
|
|
|
if(verbose) printf("sending request to peer %d\n", i);
|
|
if(verbose) printf("sending request to peer %d\n", i);
|
|
|
setup_request(&req[i]);
|
|
setup_request(&req[i]);
|
|
|
write(socklist[i], &req[i], sizeof(ntp_message));
|
|
write(socklist[i], &req[i], sizeof(ntp_message));
|
|
|
|
|
+ if(servers[i].waiting == 0) now_time++;
|
|
|
servers[i].waiting=now_time;
|
|
servers[i].waiting=now_time;
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -459,7 +460,6 @@ double offset_request(const char *host, int *status){
|
|
|
servers[i].stratum=req[i].stratum;
|
|
servers[i].stratum=req[i].stratum;
|
|
|
servers[i].rtdisp=NTP32asDOUBLE(req[i].rtdisp);
|
|
servers[i].rtdisp=NTP32asDOUBLE(req[i].rtdisp);
|
|
|
servers[i].rtdelay=NTP32asDOUBLE(req[i].rtdelay);
|
|
servers[i].rtdelay=NTP32asDOUBLE(req[i].rtdelay);
|
|
|
- servers[i].waiting=0;
|
|
|
|
|
servers[i].flags=req[i].flags;
|
|
servers[i].flags=req[i].flags;
|
|
|
servers_readable--;
|
|
servers_readable--;
|
|
|
one_read = 1;
|
|
one_read = 1;
|