mirror of
https://gitlab.com/chrony/chrony.git
synced 2025-12-04 04:35:06 -05:00
Compare commits
31 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5331e1a146 | ||
|
|
eeac7b7ca0 | ||
|
|
efcf3f7c6b | ||
|
|
eb4c9d908c | ||
|
|
b6e40dbde7 | ||
|
|
4ba843f8f4 | ||
|
|
75a7af9edc | ||
|
|
8022874a47 | ||
|
|
ca1195a0e6 | ||
|
|
ce4e0a3c2f | ||
|
|
215d988286 | ||
|
|
084efe606f | ||
|
|
38efaf10a8 | ||
|
|
93f6664378 | ||
|
|
8a94298b7e | ||
|
|
242c520912 | ||
|
|
1a4fa3330a | ||
|
|
fd35174928 | ||
|
|
2a30c56f03 | ||
|
|
0b8979a41e | ||
|
|
4771cbe8b0 | ||
|
|
1e7e7d3231 | ||
|
|
3e7781fdaf | ||
|
|
acd99f25ef | ||
|
|
91a91d1642 | ||
|
|
29223ea476 | ||
|
|
bcae93d321 | ||
|
|
383a36371f | ||
|
|
fa83311903 | ||
|
|
f5c3a01aee | ||
|
|
d2a7dc2347 |
6
.gitignore
vendored
Normal file
6
.gitignore
vendored
Normal file
@@ -0,0 +1,6 @@
|
||||
*.swp
|
||||
*.o
|
||||
Makefile
|
||||
chronyc
|
||||
chronyd
|
||||
version.h
|
||||
22
NEWS
22
NEWS
@@ -1,3 +1,25 @@
|
||||
New in version 1.23
|
||||
===================
|
||||
|
||||
* Support for MIPS, x86_64, sparc, alpha, arm, FreeBSD
|
||||
* Fix serious sign-extension error in handling IP addresses
|
||||
* RTC support can be excluded at compile time
|
||||
* Make sources gcc-4 compatible
|
||||
* Fix various compiler warnings
|
||||
* Handle fluctuations in peer distance better.
|
||||
* Fixed handling of stratum zero.
|
||||
* Fix various problems for 64-bit systems
|
||||
* Flush chronyc output streams after each command, to allow it to be driven
|
||||
through pipes
|
||||
* Manpage improvements
|
||||
|
||||
Version 1.22
|
||||
============
|
||||
|
||||
This release number was claimed by a release that Mandriva made to patch
|
||||
important bugs in 1.21. The official numbering has jumped to 1.23 as a
|
||||
consequence.
|
||||
|
||||
New in version 1.21
|
||||
===================
|
||||
|
||||
|
||||
@@ -358,7 +358,7 @@ read_from_socket(void *anything)
|
||||
int status;
|
||||
ReceiveBuffer msg;
|
||||
struct sockaddr_in his_addr;
|
||||
int his_addr_len;
|
||||
socklen_t his_addr_len;
|
||||
int flags;
|
||||
int message_length;
|
||||
unsigned long remote_ip;
|
||||
|
||||
22
addrfilt.c
22
addrfilt.c
@@ -6,7 +6,7 @@
|
||||
chronyd/chronyc - Programs for keeping computer clocks accurate.
|
||||
|
||||
**********************************************************************
|
||||
* Copyright (C) Richard P. Curnow 1997-2002
|
||||
* Copyright (C) Richard P. Curnow 1997,1998,1999,2000,2001,2002,2005
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or modify
|
||||
* it under the terms of version 2 of the GNU General Public License as
|
||||
@@ -43,15 +43,11 @@
|
||||
/* Define the table size */
|
||||
#define TABLE_SIZE (1UL<<NBITS)
|
||||
|
||||
struct _TableNode;
|
||||
|
||||
typedef struct _TableNode ExtendedTable[TABLE_SIZE];
|
||||
|
||||
typedef enum {DENY, ALLOW, AS_PARENT} State;
|
||||
|
||||
typedef struct _TableNode {
|
||||
State state;
|
||||
ExtendedTable *extended;
|
||||
struct _TableNode *extended;
|
||||
} TableNode;
|
||||
|
||||
struct ADF_AuthTableInst {
|
||||
@@ -101,7 +97,7 @@ close_node(TableNode *node)
|
||||
|
||||
if (node->extended != NULL) {
|
||||
for (i=0; i<TABLE_SIZE; i++) {
|
||||
child_node = &((*(node->extended))[i]);
|
||||
child_node = &(node->extended[i]);
|
||||
close_node(child_node);
|
||||
}
|
||||
Free(node->extended);
|
||||
@@ -124,10 +120,10 @@ open_node(TableNode *node)
|
||||
|
||||
if (node->extended == NULL) {
|
||||
|
||||
node->extended = MallocNew(ExtendedTable);
|
||||
node->extended = MallocArray(struct _TableNode, TABLE_SIZE);
|
||||
|
||||
for (i=0; i<TABLE_SIZE; i++) {
|
||||
child_node = &((*(node->extended))[i]);
|
||||
child_node = &(node->extended[i]);
|
||||
child_node->state = AS_PARENT;
|
||||
child_node->extended = NULL;
|
||||
}
|
||||
@@ -168,7 +164,7 @@ set_subnet(TableNode *start_node,
|
||||
if (!(node->extended)) {
|
||||
open_node(node);
|
||||
}
|
||||
node = &((*(node->extended))[subnet]);
|
||||
node = &(node->extended[subnet]);
|
||||
bits_to_go -= NBITS;
|
||||
}
|
||||
|
||||
@@ -187,7 +183,7 @@ set_subnet(TableNode *start_node,
|
||||
if (!(node->extended)) {
|
||||
open_node(node);
|
||||
}
|
||||
node = &((*(node->extended))[subnet]);
|
||||
node = &(node->extended[subnet]);
|
||||
bits_to_go -= NBITS;
|
||||
}
|
||||
|
||||
@@ -199,7 +195,7 @@ set_subnet(TableNode *start_node,
|
||||
}
|
||||
|
||||
for (i=subnet, j=0; j<N; i++, j++) {
|
||||
this_node = &((*(node->extended))[i]);
|
||||
this_node = &(node->extended[i]);
|
||||
if (delete_children) {
|
||||
close_node(this_node);
|
||||
}
|
||||
@@ -283,7 +279,7 @@ check_ip_in_node(TableNode *start_node, unsigned long ip)
|
||||
if (node->extended) {
|
||||
subnet = get_subnet(residual);
|
||||
residual = get_residual(residual);
|
||||
node = &((*(node->extended))[subnet]);
|
||||
node = &(node->extended[subnet]);
|
||||
} else {
|
||||
/* Make decision on this node */
|
||||
finished = 1;
|
||||
|
||||
45
build_kit
45
build_kit
@@ -1,45 +0,0 @@
|
||||
#!/usr/bin/env perl
|
||||
# $Header: /cvs/src/chrony/build_kit,v 1.13 2003/01/12 23:50:54 richard Exp $
|
||||
# Perl script for building a release
|
||||
|
||||
# Have to run it in the current directory
|
||||
if (($0 ne "build_kit") && ($0 ne "./build_kit")) {
|
||||
die "Have to be in the checked-out directory to run build_kit";
|
||||
}
|
||||
|
||||
$here=`pwd`;
|
||||
chomp $here;
|
||||
$version=$here;
|
||||
$version =~ s,^.*/chrony-([^/]+)$,$1, || die "Didn't recognize directory name";
|
||||
print "Building kit for version $version\n";
|
||||
|
||||
chmod 0755, "configure";
|
||||
|
||||
# Overwrite normal version.h file with version-specific one
|
||||
open (OUT, ">version.txt");
|
||||
print OUT $version."\n";
|
||||
close OUT;
|
||||
|
||||
# Construct chrony.spec file
|
||||
open (IN, "<chrony.spec.sample");
|
||||
open (OUT, ">chrony.spec");
|
||||
while (<IN>) {
|
||||
s/\@\@VERSION\@\@/$version/;
|
||||
print OUT;
|
||||
}
|
||||
close (IN);
|
||||
close (OUT);
|
||||
|
||||
|
||||
# Requires the makeinfo from texinfo v4
|
||||
system("makeinfo --no-headers --number-sections -o chrony.txt chrony.texi");
|
||||
system ("rm -rf ./{arch}");
|
||||
system ("rm -rf ./.arch-ids");
|
||||
unlink "chrony.spec.sample";
|
||||
unlink("build_kit");
|
||||
|
||||
chdir ("..");
|
||||
system ("tar cvf - chrony-$version | gzip -9 > chrony-$version.tar.gz");
|
||||
system ("gpg -b -a -o chrony-$version-tar-gz-asc.txt chrony-$version.tar.gz");
|
||||
|
||||
|
||||
3
chrony.1
3
chrony.1
@@ -63,3 +63,6 @@ Richard Curnow <rc@rc0.org.uk>
|
||||
This man-page was written by Jan Schaumann <jschauma@netmeister.org> as part
|
||||
of "The Missing Man Pages Project". Please see
|
||||
\fIhttp://www.netmeister.org/misc/m2p2/index.html\fR for details.
|
||||
|
||||
The complete chrony documentation is supplied in texinfo format.
|
||||
|
||||
|
||||
@@ -47,3 +47,6 @@ Richard Curnow <rc@rc0.org.uk>
|
||||
This man-page was written by Jan Schaumann <jschauma@netmeister.org> as part of "The Missing
|
||||
Man Pages Project". Please see \fIhttp://www.netmeister.org/misc/m2p2/index.html\fR
|
||||
for details.
|
||||
|
||||
The complete chrony documentation is supplied in texinfo format.
|
||||
|
||||
|
||||
@@ -40,10 +40,10 @@ interactively.
|
||||
1.17
|
||||
|
||||
.SH BUGS
|
||||
To report bugs, please contact the author and/or visit \fIhttp://go.to/chrony\fR
|
||||
To report bugs, please contact the author and/or visit \fIhttp://chrony.sunsite.dk/\fR
|
||||
|
||||
.SH "SEE ALSO"
|
||||
.BR chronyd(1),
|
||||
.BR chronyd(8),
|
||||
.BR chrony(1)
|
||||
|
||||
.I http://chrony.sunsite.dk/
|
||||
@@ -54,3 +54,6 @@ Richard Curnow <rc@rc0.org.uk>
|
||||
This man-page was written by Jan Schaumann <jschauma@netmeister.org> as part of "The Missing
|
||||
Man Pages Project". Please see \fIhttp://www.netmeister.org/misc/m2p2/index.html\fR
|
||||
for details.
|
||||
|
||||
The complete chrony documentation is supplied in texinfo format.
|
||||
|
||||
|
||||
@@ -109,3 +109,6 @@ Richard Curnow <rc@rc0.org.uk>
|
||||
This man-page was written by Jan Schaumann <jschauma@netmeister.org> as part
|
||||
of "The Missing Man Pages Project". Please see
|
||||
\fIhttp://www.netmeister.org/misc/m2p2/index.html\fR for details.
|
||||
|
||||
The complete chrony documentation is supplied in texinfo format.
|
||||
|
||||
|
||||
17
client.c
17
client.c
@@ -146,7 +146,7 @@ read_line(void)
|
||||
static unsigned long
|
||||
get_address(const char *hostname)
|
||||
{
|
||||
unsigned char *address0;
|
||||
char *address0;
|
||||
struct hostent *host;
|
||||
unsigned long result;
|
||||
|
||||
@@ -746,7 +746,7 @@ static int
|
||||
accheck_getaddr(char *line, unsigned long *addr)
|
||||
{
|
||||
unsigned long a, b, c, d, ip;
|
||||
unsigned char *p, *q;
|
||||
char *p, *q;
|
||||
p = line;
|
||||
while (*p && isspace(*p)) p++;
|
||||
if (!*p) {
|
||||
@@ -1124,7 +1124,7 @@ static int
|
||||
submit_request(CMD_Request *request, CMD_Reply *reply, int *reply_auth_ok)
|
||||
{
|
||||
unsigned long tx_sequence;
|
||||
int where_from_len;
|
||||
socklen_t where_from_len;
|
||||
struct sockaddr_in where_from;
|
||||
int bad_length, bad_sender, bad_sequence, bad_header;
|
||||
int select_status;
|
||||
@@ -1652,7 +1652,7 @@ process_cmd_tracking(char *line)
|
||||
ref_time.tv_usec = ntohl(reply.data.tracking.ref_time_us);
|
||||
ref_time_tm = *gmtime((time_t *)&ref_time.tv_sec);
|
||||
printf("Ref time (UTC) : %s", asctime(&ref_time_tm));
|
||||
correction_tv.tv_sec = ntohl(reply.data.tracking.current_correction_s);
|
||||
correction_tv.tv_sec = (int32_t)ntohl(reply.data.tracking.current_correction_s);
|
||||
correction_tv.tv_usec = ntohl(reply.data.tracking.current_correction_us);
|
||||
correction = (double) correction_tv.tv_sec + 1.0e-6 * correction_tv.tv_usec;
|
||||
printf("System time : %.6f seconds %s of NTP time\n", fabs(correction),
|
||||
@@ -2319,7 +2319,11 @@ process_line(char *line)
|
||||
/* Check for line being blank */
|
||||
p = line;
|
||||
while (*p && isspace((unsigned char)*p)) p++;
|
||||
if (!*p) return quit;
|
||||
if (!*p) {
|
||||
fflush(stderr);
|
||||
fflush(stdout);
|
||||
return quit;
|
||||
};
|
||||
|
||||
if (!strncmp(p, "offline", 7)) {
|
||||
do_normal_submit = process_cmd_offline(&tx_message, p+7);
|
||||
@@ -2480,7 +2484,8 @@ process_line(char *line)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fflush(stderr);
|
||||
fflush(stdout);
|
||||
return quit;
|
||||
}
|
||||
|
||||
|
||||
2
cmdmon.c
2
cmdmon.c
@@ -1584,7 +1584,7 @@ read_from_cmd_socket(void *anything)
|
||||
CMD_Reply tx_message, *prev_tx_message;
|
||||
int rx_message_length, tx_message_length;
|
||||
struct sockaddr_in where_from;
|
||||
int from_length;
|
||||
socklen_t from_length;
|
||||
unsigned long remote_ip;
|
||||
unsigned short remote_port;
|
||||
int md5_ok;
|
||||
|
||||
13
configure
vendored
13
configure
vendored
@@ -133,6 +133,7 @@ For better control, use the options below.
|
||||
--readline-inc-dir=DIR Specify where readline include directory is
|
||||
--readline-lib-dir=DIR Specify where readline lib directory is
|
||||
--with-ncurses-library=DIR Specify where ncurses lib directory is
|
||||
--disable-rtc Don't include RTC even on Linux
|
||||
|
||||
Fine tuning of the installation directories:
|
||||
--infodir=DIR info documentation [PREFIX/info]
|
||||
@@ -172,6 +173,7 @@ SYSDEFS=""
|
||||
|
||||
# Support for readline (on by default)
|
||||
feat_readline=1
|
||||
feat_rtc=1
|
||||
readline_lib=""
|
||||
readline_inc=""
|
||||
ncurses_lib=""
|
||||
@@ -206,6 +208,9 @@ do
|
||||
--mandir=* )
|
||||
SETMANDIR=`echo $option | sed -e 's/^.*=//;'`
|
||||
;;
|
||||
--disable-rtc)
|
||||
feat_rtc=0
|
||||
;;
|
||||
--help | -h )
|
||||
usage
|
||||
exit 0
|
||||
@@ -238,7 +243,11 @@ case $SYSTEM in
|
||||
esac
|
||||
;;
|
||||
Linux* )
|
||||
EXTRA_OBJECTS="sys_linux.o wrap_adjtimex.o rtc_linux.o"
|
||||
EXTRA_OBJECTS="sys_linux.o wrap_adjtimex.o"
|
||||
if [ $feat_rtc -eq 1 ] ; then
|
||||
EXTRA_OBJECTS+=" rtc_linux.o"
|
||||
EXTRA_DEFS+=" -DFEAT_RTC=1"
|
||||
fi
|
||||
SYSDEFS="-DLINUX"
|
||||
echo "Configuring for " $SYSTEM
|
||||
if [ "${MACHINE}" = "alpha" ]; then
|
||||
@@ -248,7 +257,7 @@ case $SYSTEM in
|
||||
fi
|
||||
;;
|
||||
|
||||
BSD/386-i[3456]86 )
|
||||
BSD/386-i[3456]86|FreeBSD-i386 )
|
||||
# Antti Jrvinen <costello@iki.fi> reported that this system can
|
||||
# be supported with the SunOS 4.x driver files.
|
||||
EXTRA_OBJECTS="sys_sunos.o strerror.o"
|
||||
|
||||
15
io_linux.h
15
io_linux.h
@@ -6,7 +6,7 @@
|
||||
|
||||
/* Hmm. These constants vary a bit between systems. */
|
||||
/* (__sh__ includes both sh and sh64) */
|
||||
#if defined(__i386__) || defined(__sh__)
|
||||
#if defined(__i386__) || defined(__sh__) || defined(__arm__)||defined(__x86_64__)
|
||||
#define CHRONY_IOC_NRBITS 8
|
||||
#define CHRONY_IOC_TYPEBITS 8
|
||||
#define CHRONY_IOC_SIZEBITS 14
|
||||
@@ -15,7 +15,8 @@
|
||||
#define CHRONY_IOC_NONE 0U
|
||||
#define CHRONY_IOC_WRITE 1U
|
||||
#define CHRONY_IOC_READ 2U
|
||||
#elif defined(__alpha__) || defined(__sparc__)
|
||||
|
||||
#elif defined(__alpha__) || defined(__sparc__) || defined(__ppc__) || defined(__ppc64__) || defined(__sparc64__)
|
||||
#define CHRONY_IOC_NRBITS 8
|
||||
#define CHRONY_IOC_TYPEBITS 8
|
||||
#define CHRONY_IOC_SIZEBITS 13
|
||||
@@ -24,6 +25,16 @@
|
||||
#define CHRONY_IOC_NONE 1U
|
||||
#define CHRONY_IOC_READ 2U
|
||||
#define CHRONY_IOC_WRITE 4U
|
||||
|
||||
#elif defined(__mips__) || defined(__mips32__)
|
||||
#define CHRONY_IOC_NRBITS 8
|
||||
#define CHRONY_IOC_TYPEBITS 8
|
||||
#define CHRONY_IOC_SIZEBITS 13
|
||||
#define CHRONY_IOC_DIRBITS 3
|
||||
#define CHRONY_IOC_NONE 1U
|
||||
#define CHRONY_IOC_READ 2U
|
||||
#define CHRONY_IOC_WRITE 4U
|
||||
|
||||
#else
|
||||
#error "I don't know the values of the _IOC_* constants for your architecture"
|
||||
#endif
|
||||
|
||||
@@ -116,7 +116,7 @@ LOG_Line_Function(LOG_Severity severity, LOG_Facility facility, const char *form
|
||||
|
||||
/* ================================================== */
|
||||
|
||||
volatile void
|
||||
void
|
||||
LOG_Fatal_Function(LOG_Facility facility, const char *format, ...)
|
||||
{
|
||||
char buf[2048];
|
||||
|
||||
@@ -77,7 +77,7 @@ extern void LOG_Finalise(void);
|
||||
extern void LOG_Line_Function(LOG_Severity severity, LOG_Facility facility, const char *format, ...);
|
||||
|
||||
/* Logging function for fatal errors */
|
||||
extern volatile void LOG_Fatal_Function(LOG_Facility facility, const char *format, ...);
|
||||
extern void LOG_Fatal_Function(LOG_Facility facility, const char *format, ...);
|
||||
|
||||
/* Position in code reporting function */
|
||||
extern void LOG_Position(const char *filename, int line_number, const char *function_name);
|
||||
|
||||
2
main.c
2
main.c
@@ -74,7 +74,7 @@ delete_pidfile(void)
|
||||
|
||||
/* ================================================== */
|
||||
|
||||
volatile void
|
||||
void
|
||||
MAI_CleanupAndExit(void)
|
||||
{
|
||||
if (!initialised) exit(0);
|
||||
|
||||
2
main.h
2
main.h
@@ -32,7 +32,7 @@
|
||||
#define GOT_MAIN_H
|
||||
|
||||
/* Function to clean up at end of run */
|
||||
extern volatile void MAI_CleanupAndExit(void);
|
||||
extern void MAI_CleanupAndExit(void);
|
||||
|
||||
#endif /* GOT_MAIN_H */
|
||||
|
||||
|
||||
52
make_release
Executable file
52
make_release
Executable file
@@ -0,0 +1,52 @@
|
||||
#!/usr/bin/env perl
|
||||
|
||||
$tool = "chrony";
|
||||
|
||||
$version = shift || die "Usage : $0 <version>\n";
|
||||
$subdir = "${tool}-${version}";
|
||||
|
||||
unless (-d ".git") {
|
||||
die "No .git subdirectory?"
|
||||
}
|
||||
|
||||
unless (-d "RELEASES") {
|
||||
mkdir "RELEASES", 0755;
|
||||
}
|
||||
|
||||
system ("git-tag -s $version");
|
||||
die "git-tag failed" if ($? != 0);
|
||||
if (-d "RELEASES/$subdir") {
|
||||
system ("rm -rf RELEASES/$subdir");
|
||||
}
|
||||
|
||||
system ("git-archive --format=tar --prefix=RELEASES/${subdir}/ $version | tar xf -");
|
||||
die "git-tar-tree failed" if ($? != 0);
|
||||
|
||||
chdir "RELEASES";
|
||||
$here = qx/pwd/;
|
||||
chomp $here;
|
||||
chdir $subdir;
|
||||
|
||||
open (OUT, ">version.txt");
|
||||
print OUT $version."\n";
|
||||
close OUT;
|
||||
|
||||
open (IN, "<${tool}.spec.sample");
|
||||
open (OUT, ">${tool}.spec");
|
||||
while (<IN>) {
|
||||
s/\@\@VERSION\@\@/$version/;
|
||||
print OUT;
|
||||
}
|
||||
close (IN);
|
||||
close (OUT);
|
||||
|
||||
system("makeinfo --no-headers --number-sections -o chrony.txt chrony.texi");
|
||||
unlink "make_release";
|
||||
unlink "${tool}.spec.sample";
|
||||
unlink ".gitignore";
|
||||
|
||||
chdir $here;
|
||||
system ("tar cvf - $subdir | gzip -9 > ${subdir}.tar.gz");
|
||||
system ("gpg -b -a -o ${subdir}-tar-gz-asc.txt ${subdir}.tar.gz");
|
||||
|
||||
|
||||
21
ntp_core.c
21
ntp_core.c
@@ -196,6 +196,9 @@ struct NCR_Instance_Record {
|
||||
/* Maximum allowed stratum */
|
||||
#define NTP_MAX_STRATUM 15
|
||||
|
||||
/* INVALID or Unkown stratum from external server as per the NTP 4 docs */
|
||||
#define NTP_INVALID_STRATUM 0
|
||||
|
||||
/* ================================================== */
|
||||
|
||||
static ADF_AuthTable access_auth_table;
|
||||
@@ -378,7 +381,7 @@ generate_packet_auth(NTP_Packet *pkt, unsigned long keyid)
|
||||
if (keyok) {
|
||||
pkt->auth_keyid = htonl(keyid);
|
||||
MD5Init(&ctx);
|
||||
MD5Update(&ctx, keytext, keylen);
|
||||
MD5Update(&ctx, (unsigned char *) keytext, keylen);
|
||||
MD5Update(&ctx, (unsigned char *) pkt, offsetof(NTP_Packet, auth_keyid));
|
||||
MD5Final(&ctx);
|
||||
memcpy(&(pkt->auth_data), &ctx.digest, 16);
|
||||
@@ -447,7 +450,7 @@ check_packet_auth(NTP_Packet *pkt, unsigned long keyid)
|
||||
if (keyok) {
|
||||
pkt->auth_keyid = htonl(keyid);
|
||||
MD5Init(&ctx);
|
||||
MD5Update(&ctx, keytext, keylen);
|
||||
MD5Update(&ctx, (unsigned char *) keytext, keylen);
|
||||
MD5Update(&ctx, (unsigned char *) pkt, offsetof(NTP_Packet, auth_keyid));
|
||||
MD5Final(&ctx);
|
||||
if (!memcmp((void *) &ctx.digest, (void *) &(pkt->auth_data), 16)) {
|
||||
@@ -539,7 +542,13 @@ transmit_packet(NTP_Mode my_mode, /* The mode this machine wants to be */
|
||||
|
||||
/* Generate transmit packet */
|
||||
message.lvm = ((leap << 6) &0xc0) | ((version << 3) & 0x38) | (my_mode & 0x07);
|
||||
message.stratum = our_stratum;
|
||||
if (our_stratum <= NTP_MAX_STRATUM) {
|
||||
message.stratum = our_stratum;
|
||||
} else {
|
||||
/* (WGU) to handle NTP "Invalid" stratum as per the NTP V4 documents. */
|
||||
message.stratum = NTP_INVALID_STRATUM;
|
||||
}
|
||||
|
||||
message.poll = my_poll;
|
||||
message.precision = LCL_GetSysPrecisionAsLog();
|
||||
|
||||
@@ -983,6 +992,12 @@ receive_packet(NTP_Packet *message, struct timeval *now, NCR_Instance inst, int
|
||||
test6 = 1; /* Succeeded */
|
||||
}
|
||||
|
||||
/* (WGU) Set stratum to greater than any valid if incoming is 0 */
|
||||
/* as per the NPT v4 documentation*/
|
||||
if (message->stratum <= NTP_INVALID_STRATUM) {
|
||||
message->stratum = NTP_MAX_STRATUM + 1;
|
||||
}
|
||||
|
||||
/* Test 7 checks that the stratum in the packet is appropriate */
|
||||
if ((message->stratum > REF_GetOurStratum()) ||
|
||||
(message->stratum > NTP_MAX_STRATUM)) {
|
||||
|
||||
6
ntp_io.c
6
ntp_io.c
@@ -184,7 +184,7 @@ read_from_socket(void *anything)
|
||||
ReceiveBuffer message;
|
||||
int message_length;
|
||||
struct sockaddr_in where_from;
|
||||
int from_length;
|
||||
socklen_t from_length;
|
||||
unsigned int flags = 0;
|
||||
struct timeval now;
|
||||
NTP_Remote_Address remote_addr;
|
||||
@@ -244,7 +244,7 @@ NIO_SendNormalPacket(NTP_Packet *packet, NTP_Remote_Address *remote_addr)
|
||||
|
||||
if (sendto(sock_fd, (void *) packet, NTP_NORMAL_PACKET_SIZE, 0,
|
||||
(struct sockaddr *) &remote, sizeof(remote)) < 0) {
|
||||
LOG(LOGS_WARN, LOGF_NtpIO, "Could not send to :%s%d : %s",
|
||||
LOG(LOGS_WARN, LOGF_NtpIO, "Could not send to %s:%d : %s",
|
||||
UTI_IPToDottedQuad(remote_addr->ip_addr), remote_addr->port, strerror(errno));
|
||||
}
|
||||
|
||||
@@ -267,7 +267,7 @@ NIO_SendAuthenticatedPacket(NTP_Packet *packet, NTP_Remote_Address *remote_addr)
|
||||
|
||||
if (sendto(sock_fd, (void *) packet, sizeof(NTP_Packet), 0,
|
||||
(struct sockaddr *) &remote, sizeof(remote)) < 0) {
|
||||
LOG(LOGS_WARN, LOGF_NtpIO, "Could not send to :%s%d : %s",
|
||||
LOG(LOGS_WARN, LOGF_NtpIO, "Could not send to %s:%d : %s",
|
||||
UTI_IPToDottedQuad(remote_addr->ip_addr), remote_addr->port, strerror(errno));
|
||||
}
|
||||
|
||||
|
||||
4
rtc.c
4
rtc.c
@@ -33,7 +33,7 @@
|
||||
#include "logging.h"
|
||||
#include "conf.h"
|
||||
|
||||
#if defined LINUX
|
||||
#if defined LINUX && defined FEAT_RTC
|
||||
#include "rtc_linux.h"
|
||||
#endif /* defined LINUX */
|
||||
|
||||
@@ -53,7 +53,7 @@ static struct {
|
||||
void (*cycle_logfile)(void);
|
||||
} driver =
|
||||
{
|
||||
#if defined LINUX
|
||||
#if defined LINUX && defined FEAT_RTC
|
||||
RTC_Linux_Initialise,
|
||||
RTC_Linux_Finalise,
|
||||
RTC_Linux_TimePreInit,
|
||||
|
||||
19
rtc_linux.c
19
rtc_linux.c
@@ -174,7 +174,7 @@ static double file_ref_offset, file_rate_ppm;
|
||||
/* ================================================== */
|
||||
|
||||
/* Flag to remember whether to assume the RTC is running on UTC */
|
||||
static int rtc_on_utc = 0;
|
||||
static int rtc_on_utc = 1;
|
||||
|
||||
/* ================================================== */
|
||||
|
||||
@@ -226,15 +226,18 @@ accumulate_sample(time_t rtc, struct timeval *sys)
|
||||
discard_samples(NEW_FIRST_WHEN_FULL);
|
||||
}
|
||||
|
||||
rtc_sec[n_samples] = rtc;
|
||||
|
||||
/* Always use most recent sample as reference */
|
||||
/* use sample only if n_sample is not negative*/
|
||||
if(n_samples >=0)
|
||||
{
|
||||
rtc_ref = rtc;
|
||||
|
||||
rtc_sec[n_samples] = rtc;
|
||||
rtc_trim[n_samples] = 0.0;
|
||||
system_times[n_samples] = *sys;
|
||||
++n_samples;
|
||||
++n_samples_since_regression;
|
||||
}
|
||||
++n_samples;
|
||||
return;
|
||||
|
||||
}
|
||||
@@ -742,7 +745,11 @@ handle_initial_trim(void)
|
||||
run_regression(1, &coefs_valid, &coef_ref_time, &coef_seconds_fast, &coef_gain_rate);
|
||||
|
||||
n_samples_since_regression = 0;
|
||||
n_samples = 0;
|
||||
|
||||
/* Set sample number to -1 so the next sample is not used, as it will not yet be corrected for System Trim*/
|
||||
|
||||
n_samples = -1;
|
||||
|
||||
|
||||
read_coefs_from_file();
|
||||
|
||||
@@ -866,6 +873,8 @@ read_from_device(void *any)
|
||||
int error = 0;
|
||||
|
||||
status = read(fd, &data, sizeof(data));
|
||||
if (operating_mode == OM_NORMAL)
|
||||
status = read(fd, &data, sizeof(data));
|
||||
if (status < 0) {
|
||||
/* This looks like a bad error : the file descriptor was indicating it was
|
||||
* ready to read but we couldn't read anything. Give up. */
|
||||
|
||||
@@ -373,9 +373,9 @@ find_best_sample_index(SST_Stats inst, double *times_back)
|
||||
/* This defines the assumed ratio between the standard deviation of
|
||||
the samples and the peer distance as measured from the round trip
|
||||
time. E.g. a value of 4 means that we think the standard deviation
|
||||
is a quarter of the peer distance */
|
||||
is four times the fluctuation of the peer distance */
|
||||
|
||||
#define SD_TO_DIST_RATIO 8.0
|
||||
#define SD_TO_DIST_RATIO 1.0
|
||||
|
||||
/* ================================================== */
|
||||
/* This function runs the linear regression operation on the data. It
|
||||
|
||||
@@ -98,7 +98,7 @@ static void handle_end_of_slew(void *anything);
|
||||
/* ================================================== */
|
||||
|
||||
inline static int
|
||||
round(double x) {
|
||||
our_round(double x) {
|
||||
int y;
|
||||
y = (int)(x + 0.5);
|
||||
while ((double)y < x - 0.5) y++;
|
||||
@@ -433,7 +433,7 @@ set_frequency(double freq_ppm) {
|
||||
neg = 0;
|
||||
}
|
||||
|
||||
required_delta_tick = round(freq_ppm / dhz);
|
||||
required_delta_tick = our_round(freq_ppm / dhz);
|
||||
required_freq = freq_ppm - dhz * (double) required_delta_tick;
|
||||
|
||||
if (neg) {
|
||||
|
||||
@@ -35,7 +35,7 @@
|
||||
|
||||
#if defined (SOLARIS) || defined(SUNOS) || defined(LINUX) || defined(__NetBSD__)
|
||||
|
||||
#if !defined(__NetBSD__)
|
||||
#if !defined(__NetBSD__) && !defined(__FreeBSD__)
|
||||
#include <alloca.h>
|
||||
#endif
|
||||
#include <assert.h>
|
||||
@@ -43,7 +43,9 @@
|
||||
#include <errno.h>
|
||||
#include <fcntl.h>
|
||||
#include <float.h>
|
||||
#if !defined(__FreeBSD__)
|
||||
#include <malloc.h>
|
||||
#endif
|
||||
#include <math.h>
|
||||
#include <netdb.h>
|
||||
#include <netinet/in.h>
|
||||
|
||||
@@ -1,4 +1 @@
|
||||
#ifndef VERSION_H
|
||||
#define VERSION_H
|
||||
#define PROGRAM_VERSION_STRING "$Name: V1_12 $"
|
||||
#endif /* VERSION_H */
|
||||
DEVELOPMENT
|
||||
|
||||
Reference in New Issue
Block a user