#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/wait.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <netdb.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/ioctl.h>
#include<pthread.h>

#include<math.h>

#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

#define  NTPSVR            "192.168.2.30"                        //MY server
//#define  LOCAL              "192.168.2.109"
#define  LOCALPORT       8000
#define  NTPPORT           123
  
int                pthreads                    =  0;            //定义线程的数量
#define            timer                      200                   // 计算每x us发一个包                 
long int           total_pkt             =   0;                       //   计算发包量，初始化为0个   
int                 maxpkt                 =   0  ;               //一次发包量   
int                 counter                =      0;            //发送临时算数器
int                 fd[2];
int                 send_tmp             =     0;                 //发送临时计数器
int                 rec_maxpkt;                                   //接收总量
int                 rec_pkt                =     0;              //接收计数
    
 
pthread_mutex_t ntppack_mutex = PTHREAD_MUTEX_INITIALIZER;//init pthread
pthread_mutex_t newpack_mutex = PTHREAD_MUTEX_INITIALIZER;//init pthread


  int32  sockfd;
  struct timeval tv_start,tv_end;
  struct timezone tz_start,tz_end;
  struct sockaddr_in addr,local_addr;   
  pthread_t tidA;

/*
*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,newpack;

//定义为long64,解决32位数的符号位问题
long64   firsttimestamp,finaltimestamp;
long64   diftime,delaytime;

void NTP_Init()
{
  bzero(&ntppack,sizeof(ntppack));
  ntppack.li_vn_mode=0x1b;//0|(3<<2)|(3<<5);
  //获取初始时间戳T1
  firsttimestamp="From00to70"+time(NULL);//-8*3600;
  ntppack.oritimestamphigh=htonl(firsttimestamp);
}


/*
*按给定的要求每x us 发送一个请求
*
*/
void *send_pkt(void *);

void  *send_pkt  (void *vptr)
   { 
    //every pthread need send X packets
         int  num =0;
    struct timeval tv_send_start,tv_send_end;
    struct timezone tz_send_start,tz_send_end;

    for(num;num<maxpkt;num++)
        {
           
        pthread_mutex_trylock(&ntppack_mutex);                     //加锁   
         counter=send_tmp+1;
                 //发送数据请求包
         sendto(sockfd,&ntppack,sizeof(ntppack),0,
                                  (struct sockaddr *)&addr,sizeof(struct sockaddr));           
         send_tmp=counter;        
         printf(" A have been send  %d  packets\n",counter);        
         pthread_mutex_unlock(&