ntptime.pas

VC++实现的时间同步程序

{ ************************************************************************

   NetTime is copyrighted by Graham Mainwaring. Permission is hereby
   granted to use, modify, redistribute and create derivative works
   provided this attribution is not removed. I also request that if you
   make any useful changes, please e-mail the diffs to [e-mail]
   so that I can include them in an 'official' release.

  ************************************************************************ }

unit ntptime;

interface

uses classes, windows, messages, sysutils, timeconv, winsock, winsockutil,
  NetTimeCommon;

type

  TNTPRequest = record
    LI_VN_Mode: byte;
    Stratum: byte;
    Poll: byte;
    Precision: shortint;
    RootDelay: longword;
    RootDispersion: longword;
    ReferenceID: longword;
    ReferenceTimestamp: TNTPTimestamp;
    OriginateTimestamp: TNTPTimestamp;
    ReceiveTimestamp: TNTPTimestamp;
    TransmitTimestamp: TNTPTimestamp;
  end;

  TNTPServerThread = class(TQuickUDPServerThread)
  protected
    procedure DoRequest; override;
  end;

procedure GetTimeFromNTP(const h: string; const port: integer;
  var status: TSyncServerStatus; var Time: TDateTime; var NetLag: TDateTime);

procedure FindServersViaBroadcast(const ResultList: TStrings);

type
  TTimeSyncGoodFunc = function: boolean of object;
  TTimeLastUpdatedFunc = function: TDateTime of object;

var
  TimeSyncGoodFunc: TTimeSyncGoodFunc;
  TimeLastUpdatedFunc: TTimeLastUpdatedFunc;

implementation

procedure PackLI_VN_Mode(const LI, VN, Mode: byte; var LI_VN_Mode: byte);
begin
  LI_VN_Mode := (LI*64) + (VN*8) + Mode;
end;

procedure UnpackLI_VN_Mode(const LI_VN_Mode: byte; var LI, VN, Mode: byte);
begin
  LI := (LI_VN_Mode div 64) mod 4;
  VN := (LI_VN_Mode div 8) mod 8;
  Mode := LI_VN_Mode mod 8;
end;

procedure GetTimeFromNTP(const h: string; const port: integer;
  var status: TSyncServerStatus; var Time: TDateTime; var NetLag: TDateTime);

var
  addr: LongWord;
  sock: TSocket;
  req: TNTPRequest;
  remote: sockaddr_in;
  T1, T2, T3, T4: TDateTime;
  arg: integer;

begin
  status := ssFailed;
  addr := StrToAddr(h);
  if addr = longword(INADDR_NONE) then
    exit;
  sock := Socket(AF_INET, SOCK_DGRAM, 0);
  if sock = INVALID_SOCKET then
    exit;
  try
    arg := 10000; // 10 seconds
    if setsockopt(sock,SOL_SOCKET,SO_RCVTIMEO,@arg,sizeof(arg)) = SOCKET_ERROR then
      abort;
    T1 := Now;
    FillChar(req,sizeof(req),0);
    PackLI_VN_Mode(0,3,3,req.LI_VN_Mode);
    req.TransmitTimestamp := DateTimeToNTP(Now);
    remote.sin_family := AF_INET;
    remote.sin_addr.s_addr := addr;
    remote.sin_port := htons(Port);
    if sendto(sock,req,sizeof(req),0,remote,sizeof(remote)) = SOCKET_ERROR then
      abort;
    arg := sizeof(remote);
    if recvfrom(sock,req,sizeof(req),0,remote,arg) <> sizeof(req) then
      abort;
    T2 := NTPToDateTime(Req.ReceiveTimestamp);
    T3 := NTPToDateTime(Req.TransmitTimestamp);
    T4 := Now;
    NetLag := (T4 - T1) - (T2 - T3);
    Time := T3 + NetLag/2;
    if (Req.TransmitTimestamp.Seconds = 0) then
      status := ssFailed
    else
      status := ssGood;
  finally
    CloseSocket(Sock);
  end;
end;

procedure FindServersViaBroadcast(const ResultList: TStrings);

var
  sock: TSocket;
  req: TNTPRequest;
  remote: sockaddr_in;
  arg: integer;
  siz: integer;
  hostptr: PHostEnt;
  MyHostName: ShortString;

begin
  GetHostName(@(MyHostName[1]),sizeof(MyHostName)-1);
  SetLength(MyHostName,pos(#0,MyHostName)-1);
  sock := Socket(AF_INET, SOCK_DGRAM, 0);
  if sock = INVALID_SOCKET then
    exit;
  arg := 2000; // 2 seconds - if it takes longer than that, it's not local!
  if setsockopt(sock,SOL_SOCKET,SO_RCVTIMEO,@arg,sizeof(arg)) = SOCKET_ERROR then
    exit;
  arg := 1;
  if setsockopt(sock,SOL_SOCKET,SO_BROADCAST,@arg,sizeof(arg)) = SOCKET_ERROR then
    exit;
  FillChar(req,sizeof(req),0);
  PackLI_VN_Mode(0,3,3,req.LI_VN_Mode);
  req.TransmitTimestamp := DateTimeToNTP(Now);
  remote.sin_family := AF_INET;
  remote.sin_addr.s_addr := integer(INADDR_BROADCAST);
  remote.sin_port := htons(NTP_Port);
  if sendto(sock,req,sizeof(req),0,remote,sizeof(remote)) = SOCKET_ERROR then
    exit;
  arg := sizeof(remote);
  siz := recvfrom(sock,req,sizeof(req),0,remote,arg);
  while siz <> SOCKET_ERROR do
    begin
      if siz = sizeof(req) then
        begin
          hostptr := GetHostByAddr(@remote.sin_addr, SizeOf(remote.sin_addr),
            PF_INET);
          if hostptr = nil then
            ResultList.Add(inet_ntoa(remote.sin_addr))
          else if hostptr^.h_name <> MyHostName then
            ResultList.Add(hostptr^.h_name)
        end;
      arg := sizeof(remote);
      siz := recvfrom(sock,req,sizeof(req),0,remote,arg);
    end;
end;

procedure TNTPServerThread.DoRequest;

var
  Request, Response: TNTPRequest;
  LI, VN, Mode: byte;
  ClockSyncGood: boolean;

begin
  if Req_Len <> sizeof(TNTPRequest) then
    exit;
  Move(Req,Request,sizeof(TNTPRequest));
  UnpackLI_VN_Mode(Request.LI_VN_Mode,LI,VN,Mode);
  if (Mode <> 3) or (VN > 4) then
    exit;
  FillChar(Response,sizeof(Response),0);
  if @TimeSyncGoodFunc = nil then
    ClockSyncGood := false
  else
    ClockSyncGood := TimeSyncGoodFunc;
  if ClockSyncGood then
    LI := 0
  else
    LI := 3;
  Mode := 4;
  PackLI_VN_Mode(LI,VN,Mode,Response.LI_VN_Mode);
  Response.Stratum := 15;
  Response.Poll := Request.Poll;
  Response.Precision := -6;
  if ClockSyncGood then
    begin
      Response.ReferenceTimestamp := DateTimeToNTP(TimeLastUpdatedFunc);
      Response.OriginateTimestamp := Request.TransmitTimestamp;
      Response.ReceiveTimestamp := DateTimeToNTP(Now);
      Response.TransmitTimestamp := Response.ReceiveTimestamp;
    end;
  sendto(sock,response,sizeof(response),0,remote,sizeof(remote));
end;

initialization
  TimeSyncGoodFunc := nil;
  TimeLastUpdatedFunc := nil;
end.