#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include 



#include



#define  int8      char

#define  uint8     unsigned char

#define  uint32    unsigned int

#define  ulong32   unsigned long

#define  long32    long

#define  int32     int

#define  long64    long long



//3600s*24h*(365days*70years+17days)

#define  From00to70 0x83aa7e80U



char NTPSVR[17];

//#define  NTPSVR            "192.168.2.8"                        //MY server

//#define  LOCAL              "192.168.2.109"

#define  LOCALPORT       8000

#define  NTPPORT           123



#define            maxpkt                   5             //一次发包量 

#define            max_fork                 1             //fork最大的循环次数  

int                pthreads              =  0;            //定义线程的数量

int                timer                 =  0;             // 计算每x us发一个包                 

long int           total_pkt             =  0;            //   计算发包量，初始化为0个   

int                 counter              =  0;            //发送临时算数器

int                 fd[2];

int                 send_tmp             =  0;             //发送临时计数器



pthread_mutex_t ntppack_mutex = PTHREAD_MUTEX_INITIALIZER;//init pthread



int32  sockfd;

struct sockaddr_in addr,local_addr;



/*

*NTP包的结构

*

*/

typedef struct NTPPACKET

{

  uint8       li_vn_mode;

  uint8       stratum;

  uint8        poll;

  uint8        precision;                //有符号整数表示本地时钟精确度

  ulong32   root_delay;                  //到达服务器的一次往返的总延时，是15到16位有符号的定点小数

  ulong32   root_dispersion;             // 到达服务器的一次标准误差，是15－16位的无符号的定点小数

  int8          ref_id[4];

  ulong32   reftimestamphigh;            //本地时钟最后被设定或校正的时间T4

  ulong32   reftimestamplow;

  ulong32   oritimestamphigh;            //向服务器请求分离客户机的时间戳，采用64位时标格式T1

  ulong32   oritimestamplow;

  ulong32   recvtimestamphigh;           //向服务器请求到客户机的时间戳，采用64位时标格式T2

  ulong32   recvtimestamplow;

  ulong32   trantimestamphigh;           //向客户机答复分离服务器的时间戳，采用64位时标格式T3，用T3来校正本地时间 

  ulong32   trantimestamplow;

}NTPPacket;



NTPPacket  ntppack;



//定义为long64,解决32位数的符号位问题

long64   firsttimestamp,finaltimestamp;

long64   diftime,delaytime;



void NTP_Init()

{

  bzero(&ntppack,sizeof(ntppack));

  ntppack.li_vn_mode=0x1b;//0|(3