DWS/chrony
1
0
Fork 0
mirror of https://gitlab.com/chrony/chrony.git synced 2025-12-04 08:05:06 -05:00
Code Issues Packages Projects Releases Wiki Activity

ntp: create new socket for each client request

Browse Source 
Create a new connected client socket before each request and close it
when a valid reply is received.

This is useful when the network configuration is changed and the client
socket should be reconnected, but the old bound address remains valid
and sendmsg() doesn't return with an error.
This commit is contained in:
Miroslav Lichvar
2014-08-13 18:11:34 +02:00
parent ead9394a31
commit a9b9e7befe
1 changed files with 23 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
ntp_core.c
View File

@@ -279,12 +279,17 @@ start_initial_timeout(NCR_Instance inst)
/* Mark source active */ /* Mark source active */
SRC_SetActive(inst->source); SRC_SetActive(inst->source);
}
}
/* Open client socket */ /* ================================================== */
if (inst->mode == MODE_CLIENT) {
assert(inst->local_addr.sock_fd == INVALID_SOCK_FD); static void
inst->local_addr.sock_fd = NIO_GetClientSocket(&inst->remote_addr); close_client_socket(NCR_Instance inst)
} {
if (inst->mode == MODE_CLIENT && inst->local_addr.sock_fd != INVALID_SOCK_FD) {
NIO_CloseClientSocket(inst->local_addr.sock_fd);
inst->local_addr.sock_fd = INVALID_SOCK_FD;
} }
} }
@@ -305,11 +310,7 @@ take_offline(NCR_Instance inst)
/* And inactive */ /* And inactive */
SRC_UnsetActive(inst->source); SRC_UnsetActive(inst->source);
/* Close client socket */ close_client_socket(inst);
if (inst->mode == MODE_CLIENT && inst->local_addr.sock_fd != INVALID_SOCK_FD) {
NIO_CloseClientSocket(inst->local_addr.sock_fd);
inst->local_addr.sock_fd = INVALID_SOCK_FD;
}
NCR_ResetInstance(inst); NCR_ResetInstance(inst);
} }
@@ -328,7 +329,7 @@ NCR_GetInstance(NTP_Remote_Address *remote_addr, NTP_Source_Type type, SourcePar
switch (type) { switch (type) {
case NTP_SERVER: case NTP_SERVER:
/* Client socket will be obtained when timer is started */ /* Client socket will be obtained when sending request */
result->local_addr.sock_fd = INVALID_SOCK_FD; result->local_addr.sock_fd = INVALID_SOCK_FD;
result->mode = MODE_CLIENT; result->mode = MODE_CLIENT;
break; break;
@@ -758,6 +759,13 @@ transmit_timeout(void *arg)
DEBUG_LOG(LOGF_NtpCore, "Transmit timeout for [%s:%d]", DEBUG_LOG(LOGF_NtpCore, "Transmit timeout for [%s:%d]",
UTI_IPToString(&inst->remote_addr.ip_addr), inst->remote_addr.port); UTI_IPToString(&inst->remote_addr.ip_addr), inst->remote_addr.port);
/* Open new client socket */
if (inst->mode == MODE_CLIENT) {
close_client_socket(inst);
assert(inst->local_addr.sock_fd == INVALID_SOCK_FD);
inst->local_addr.sock_fd = NIO_GetClientSocket(&inst->remote_addr);
}
/* Check whether we need to 'warm up' the link to the other end by /* Check whether we need to 'warm up' the link to the other end by
sending an echo exchange to ensure both ends' ARP caches are sending an echo exchange to ensure both ends' ARP caches are
primed. On loaded systems this might also help ensure that bits primed. On loaded systems this might also help ensure that bits
@@ -1257,6 +1265,10 @@ receive_packet(NTP_Packet *message, struct timeval *now, double now_err, NCR_Ins
adjust_poll(inst, 0.1); adjust_poll(inst, 0.1);
} }
/* If in client mode, no more packets are expected to be coming from the
server and the socket can be closed */
close_client_socket(inst);
requeue_transmit = 1; requeue_transmit = 1;
} }