summaryrefslogtreecommitdiff
path: root/src/timesync/timesyncd.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/timesync/timesyncd.c')
-rw-r--r--src/timesync/timesyncd.c58
1 files changed, 34 insertions, 24 deletions
diff --git a/src/timesync/timesyncd.c b/src/timesync/timesyncd.c
index 19b58bb70a..72dcf0b058 100644
--- a/src/timesync/timesyncd.c
+++ b/src/timesync/timesyncd.c
@@ -37,6 +37,7 @@
#include "util.h"
#include "sparse-endian.h"
#include "log.h"
+#include "socket-util.h"
#include "sd-event.h"
#include "sd-daemon.h"
@@ -111,7 +112,7 @@ struct Manager {
/* peer */
sd_event_source *event_receive;
char *server;
- struct sockaddr_in server_addr;
+ union sockaddr_union server_addr;
int server_socket;
uint64_t packet_count;
@@ -168,19 +169,24 @@ static double square(double d) {
}
static int sntp_send_request(Manager *m) {
- struct ntp_msg ntpmsg = {};
- struct sockaddr_in addr = {};
+ struct ntp_msg ntpmsg = {
+ /*
+ * "The client initializes the NTP message header, sends the request
+ * to the server, and strips the time of day from the Transmit
+ * Timestamp field of the reply. For this purpose, all the NTP
+ * header fields are set to 0, except the Mode, VN, and optional
+ * Transmit Timestamp fields."
+ */
+ .field = NTP_FIELD(0, 4, NTP_MODE_CLIENT),
+ };
+
+ union sockaddr_union addr = {
+ .in.sin_family = AF_INET,
+ .in.sin_port = htobe16(123),
+ };
ssize_t len;
int r;
- /*
- * "The client initializes the NTP message header, sends the request
- * to the server, and strips the time of day from the Transmit
- * Timestamp field of the reply. For this purpose, all the NTP
- * header fields are set to 0, except the Mode, VN, and optional
- * Transmit Timestamp fields."
- */
- ntpmsg.field = NTP_FIELD(0, 4, NTP_MODE_CLIENT);
/*
* Set transmit timestamp, remember it; the server will send that back
@@ -195,10 +201,8 @@ static int sntp_send_request(Manager *m) {
ntpmsg.trans_time.sec = htobe32(m->trans_time.tv_sec + OFFSET_1900_1970);
ntpmsg.trans_time.frac = htobe32(m->trans_time.tv_nsec);
- addr.sin_family = AF_INET;
- addr.sin_port = htobe16(123);
- addr.sin_addr.s_addr = inet_addr(m->server);
- len = sendto(m->server_socket, &ntpmsg, sizeof(ntpmsg), MSG_DONTWAIT, &addr, sizeof(addr));
+ addr.in.sin_addr.s_addr = inet_addr(m->server);
+ len = sendto(m->server_socket, &ntpmsg, sizeof(ntpmsg), MSG_DONTWAIT, &addr.sa, sizeof(addr.in));
if (len == sizeof(ntpmsg)) {
m->pending = true;
log_debug("Sent NTP request to: %s", m->server);
@@ -283,7 +287,11 @@ static int sntp_clock_watch(sd_event_source *source, int fd, uint32_t revents, v
/* wake up when the system time changes underneath us */
static int sntp_clock_watch_setup(Manager *m) {
- struct itimerspec its = { .it_value.tv_sec = TIME_T_MAX };
+
+ struct itimerspec its = {
+ .it_value.tv_sec = TIME_T_MAX
+ };
+
_cleanup_close_ int fd = -1;
sd_event_source *source;
int r;
@@ -472,7 +480,7 @@ static int sntp_receive_response(sd_event_source *source, int fd, uint32_t reven
struct cmsghdr cmsghdr;
uint8_t buf[CMSG_SPACE(sizeof(struct timeval))];
} control;
- struct sockaddr_in server_addr;
+ union sockaddr_union server_addr;
struct msghdr msghdr = {
.msg_iov = &iov,
.msg_iovlen = 1,
@@ -509,7 +517,7 @@ static int sntp_receive_response(sd_event_source *source, int fd, uint32_t reven
return -EINVAL;
}
- if (m->server_addr.sin_addr.s_addr != server_addr.sin_addr.s_addr) {
+ if (m->server_addr.in.sin_addr.s_addr != server_addr.in.sin_addr.s_addr) {
log_debug("Response from unknown server. Disconnecting.");
return -EINVAL;
}
@@ -657,8 +665,8 @@ static int sntp_server_connect(Manager *m, const char *server) {
s = NULL;
zero(m->server_addr);
- m->server_addr.sin_family = AF_INET;
- m->server_addr.sin_addr.s_addr = inet_addr(server);
+ m->server_addr.in.sin_family = AF_INET;
+ m->server_addr.in.sin_addr.s_addr = inet_addr(server);
m->poll_interval_usec = NTP_POLL_INTERVAL_MIN_SEC * USEC_PER_SEC;
@@ -687,8 +695,12 @@ static void sntp_server_disconnect(Manager *m) {
}
static int sntp_listen_setup(Manager *m) {
+
+ union sockaddr_union addr = {
+ .in.sin_family = AF_INET,
+ };
+
_cleanup_close_ int fd = -1;
- struct sockaddr_in addr;
const int on = 1;
const int tos = IPTOS_LOWDELAY;
int r;
@@ -697,9 +709,7 @@ static int sntp_listen_setup(Manager *m) {
if (fd < 0)
return -errno;
- zero(addr);
- addr.sin_family = AF_INET;
- r = bind(fd, (struct sockaddr *)&addr, sizeof(addr));
+ r = bind(fd, &addr.sa, sizeof(addr.in));
if (r < 0)
return -errno;