NTPServer.h

/*NB_REVISION*/
 
/*NB_COPYRIGHT*/
 
#ifndef NTPSERVER_H
#define NTPSERVER_H
 
#include <nbrtos.h>
#include <udp.h>
#include <cstdint>
#include "IEEE1588Timer.h"
#include "GPSChip.h"
 
class NTPServer
{
   public:
    class NtpTimeStamp
    {
    private:
        void SetFutureTime(uint32_t cap_1588, uint32_t cur_time, uint32_t interval, uint32_t From1588);
 
       public:
        beuint32_t sec;    
        beuint32_t frac;   
 
        bool SetFrom(uint32_t tt, uint32_t From1588);
 
        NtpTimeStamp() : sec(0), frac(0) {}
 
        static NtpTimeStamp Now();
 
        NtpTimeStamp &operator=(UDPPacket &upkt);
 
        NtpTimeStamp &operator=(const NtpTimeStamp &src);
bool operator<(const NtpTimeStamp &other) const
{
    uint32_t this_sec = sec;
    uint32_t other_sec = other.sec;
    
    if (this_sec != other_sec)
        return this_sec < other_sec;
    
    // Seconds are equal, compare fractional part
    uint32_t this_frac = frac;
    uint32_t other_frac = other.frac;
    return this_frac < other_frac;
}
 
bool operator>(const NtpTimeStamp &other) const
{
    return other < *this;
}
 
bool operator<=(const NtpTimeStamp &other) const
{
    return !(other < *this);
}
 
bool operator>=(const NtpTimeStamp &other) const
{
    return !(*this < other);
}
 
bool operator==(const NtpTimeStamp &other) const
{
    return (sec == other.sec) && (frac == other.frac);
}
 
bool operator!=(const NtpTimeStamp &other) const
{
    return !(*this == other);
}
 
 
    };
 
   private:
    struct NTP_Packet
    {
        uint8_t LV_VN_Mode;   
        uint8_t Stratum;      
        uint8_t Poll;         
        int8_t Precision;     
 
        beuint32_t Root_Delay;        
        beuint32_t Root_Dispersion;   
        uint8_t Ref_Id[4];            
        NtpTimeStamp Ref_Time;        
        NtpTimeStamp Org_Time;        
        NtpTimeStamp Rx_Time;         
        NtpTimeStamp Tx_Time;         
    };
 
    // Constants for NTP server operation
    static const uint32_t DISPERSION = 0;   
    static const int8_t PRECISION = 0xE9;   
 
    // References to external components
    IEEE1588Timer &timer;   
    GPSChip &gps;           
    uint16_t port;          
 
    // Server task management
    OS_FIFO rxFifo;                           
    bool running;                             
    uint32_t taskStack[USER_TASK_STK_SIZE];   
 
    void serverTaskImpl();
 
 
/*  struct TxTimeMeasure
    {
        uint32_t now_1588;
        uint32_t now_tt;
        PoolPtr packet;
    };
 
    TxTimeMeasure TxRecords[256];
    uint8_t  txmeas_put_index;
    uint8_t  txmeas_get_index;
    uint32_t nTxMeas;
    uint32_t nTxMeasSum;
*/
    void CleanupTxRecords();
    void InitTxRecords();
    void SaveTxRecord(PoolPtr,uint32_t now);
    uint32_t GetTxTimeOffset();
 
public:
 
 
    NTPServer(IEEE1588Timer &timer, GPSChip &gps, uint16_t port = 123);
 
    bool start();
 
    void stop();
 
    static void serverTask(void *param);
 
    bool isRunning() const { return running; }
 
    uint16_t getPort() const { return port; }
};
 
#endif   // NTPSERVER_H