Ñò B xic@sùdZddkZddkZddkZddkZdefd„ƒYZddd„ƒYZddd„ƒYZd efd „ƒYZ d dd „ƒYZ d „Z dd„Z dd„Z d„Zd„Zd„Zd„Zd„Zdd„ZdS(sePython NTP library. Implementation of client-side NTP (RFC-1305), and useful NTP-related functions. iÿÿÿÿNt NTPExceptioncBseZdZRS(s Exception raised by this module.(t__name__t __module__t__doc__(((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyR%stNTPcBs±eZdZeieidƒdd!ŒZeidddƒZeei ddZ h dd6d d 6d d 6d d6dd6dd6dd6dd6dd6dd6dd6dd6dd 6d!d"6d#d$6d%d&6d%d'6d(d)6d*d+6d,d-6d.d/6d0d16d2d36d4d56d6d76d8d96d:d;6d<d=6d>d?6d@dA6dBdC6dDdE6Z hdFd6dGd6Z hdHd6dId6dJdK6dLd6dMdN6dOdP6dQdR6dSdT6Z hdUd6dVd6dWdK6dXd6ZRS(Ys Helper class defining constants.iiiliiis)Geostationary Orbit Environment SatellitetGOESsGlobal Position SystemtGPSsGalileo Positioning SystemtGALsGeneric pulse-per-secondtPPSs!Inter-Range Instrumentation GrouptIRIGs$LF Radio WWVB Ft. Collins, CO 60 kHztWWVBs'LF Radio DCF77 Mainflingen, DE 77.5 kHztDCFs LF Radio HBG Prangins, HB 75 kHztHBGsLF Radio MSF Anthorn, UK 60 kHztMSFs2LF Radio JJY Fukushima, JP 40 kHz, Saga, JP 60 kHztJJYs!MF Radio LORAN C station, 100 kHztLORCsMF Radio Allouis, FR 162 kHztTDFsHF Radio CHU Ottawa, OntariotCHUsHF Radio WWV Ft. Collins, COtWWVsHF Radio WWVH Kauai, HItWWVHsNIST telephone modemtNISTtACTSsUSNO telephone modemtUSNOsEuropean telephone modemtPTBsuncalibrated local clocktLOCLscalibrated Cesium clocktCESMscalibrated Rubidium clocktRBDMsOMEGA radionavigation systemtOMEGsDCN routing protocoltDCNsTSP time protocoltTSPsDigital Time ServicetDTSsAtomic clock (calibrated)tATOMsVLF radio (OMEGA,, etc.)tVLFsExternal 1 PPS inputt1PPSs(Internal clock)tFREEs(Initialization)tINITtNULLtsunspecified or invalidsprimary reference (%s)treservedssymmetric activessymmetric passiveitclienttserverit broadcastis!reserved for NTP control messagesisreserved for private useis no warnings%last minute of the day has 61 secondss%last minute of the day has 59 secondssunknown (clock unsynchronized)(RRRtdatetimetdatettimetgmtimet _SYSTEM_EPOCHt _NTP_EPOCHtdayst NTP_DELTAt REF_ID_TABLEt STRATUM_TABLEt MODE_TABLEt LEAP_TABLE(((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyR*sn    t NTPPacketcBs8eZdZdZdddd„Zd„Zd„ZRS(s:NTP packet class. This represents an NTP packet. s !B B B b 11IiiicCsyd|_||_||_d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ ||_ dS(sµConstructor. Parameters: version -- NTP version mode -- packet mode (client, server) tx_timestamp -- packet transmit timestamp iN( tleaptversiontmodetstratumtpollt precisiont root_delaytroot_dispersiontref_idt ref_timestamptorig_timestamptrecv_timestampt tx_timestamp(tselfR8R9RC((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt__init__|s             cCsyêtiti|id>|id>B|iB|i|i|i t |i ƒd>t |i dƒBt |i ƒd>t |i dƒB|it |iƒt |iƒt |iƒt |iƒt |iƒt |iƒt |iƒt |iƒƒ}Wn"tij otdƒ‚nX|S(sÇConvert this NTPPacket to a buffer that can be sent over a socket. Returns: buffer representing this packet Raises: NTPException -- in case of invalid field iiisInvalid NTP packet fields.(tstructtpackR6t_PACKET_FORMATR7R8R9R:R;R<t_to_intR=t_to_fracR>R?R@RARBRCterrorR(RDtpacked((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pytto_dataŸs*          c CsZy,titi|dtitiƒ!ƒ}Wn"tij otdƒ‚nX|dd?d@|_|dd?d@|_|dd@|_ |d|_ |d|_ |d|_ t |dƒd|_t |d ƒd|_|d|_t|d|d ƒ|_t|d |d ƒ|_t|d|dƒ|_t|d|dƒ|_dS(sÚPopulate this instance from a NTP packet payload received from the network. Parameters: data -- buffer payload Raises: NTPException -- in case of invalid packet format isInvalid NTP packet.iiiiiiiiii i i i i iNii(RFtunpackR6RHtcalcsizeRKRR7R8R9R:R;R<tfloatR=R>R?t_to_timeR@RARBRC(RDtdatatunpacked((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt from_data¾s$       (RRRRHRERMRT(((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyR6ss # tNTPStatscBs€eZdZd„Zed„ƒZed„ƒZed„ƒZed„ƒZed„ƒZ ed„ƒZ ed„ƒZ RS( s“NTP statistics. Wrapper for NTPPacket, offering additional statistics like offset and delay, and timestamps converted to system time. cCsti|ƒd|_dS(s Constructor.iN(R6REtdest_timestamp(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyREäs  cCs |i|i|i|idS(toffseti(RBRARCRV(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRWês cCs|i|i|i|iS(sround-trip delay(RVRARCRB(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pytdelayðs cCs t|iƒS(s"Transmit timestamp in system time.(tntp_to_system_timeRC(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyttx_timeöscCs t|iƒS(s!Receive timestamp in system time.(RYRB(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt recv_timeûscCs t|iƒS(s#Originate timestamp in system time.(RYRA(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt orig_timescCs t|iƒS(s#Reference timestamp in system time.(RYR@(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pytref_timescCs t|iƒS(s%Destination timestamp in system time.(RYRV(RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt dest_time s( RRRREtpropertyRWRXRZR[R\R]R^(((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRUÝs t NTPClientcBs)eZdZd„Zdddd„ZRS(sNTP client session.cCsdS(s Constructor.N((RD((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyREsitntpicCs6ti||ƒd}|d|d}}ti|tiƒ}zÅy˜|i|ƒtddd|dttiƒƒƒ} |i| iƒ|ƒd } x/| d|djo|i dƒ\} } q™Wttiƒƒ} Wn&ti j ot d|ƒ‚nXWd |i ƒXtƒ} | i| ƒ| | _| S( s÷Query a NTP server. Parameters: host -- server name/address version -- NTP version to use port -- server port timeout -- timeout on socket operations Returns: NTPStats object iiR9iR8RCisNo response received from %s.N(N(tsockett getaddrinfot SOCK_DGRAMt settimeoutR6tsystem_to_ntp_timeR,tsendtoRMtNonetrecvfromttimeoutRtcloseRURTRV(RDthostR8tportRjtaddrinfotfamilytsockaddrtst query_packettsrc_addrtresponse_packetRVtstats((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pytrequests*      (RRRRERv(((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyR`s cCs t|ƒS(s|Return the integral part of a timestamp. Parameters: timestamp -- NTP timestamp Retuns: integral part (tint(t timestamp((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRIHs i cCs"tt|t|ƒƒd|ƒS(s·Return the fractional part of a timestamp. Parameters: timestamp -- NTP timestamp n -- number of bits of the fractional part Retuns: fractional part i(RwtabsRI(Rxtn((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRJTs cCs|t|ƒd|S(sÔReturn a timestamp from an integral and fractional part. Parameters: integ -- integral part frac -- fractional part n -- number of bits of the fractional part Retuns: timestamp i(RP(tintegtfracRz((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRQas cCs |tiS(s‹Convert a NTP time to system time. Parameters: timestamp -- timestamp in NTP time Returns: corresponding system time (RR1(Rx((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRYos cCs |tiS(sConvert a system time to a NTP time. Parameters: timestamp -- timestamp in system time Returns: corresponding NTP time (RR1(Rx((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyRf{s cCs,|tijo ti|Stdƒ‚dS(sÃConvert a leap indicator to text. Parameters: leap -- leap indicator value Returns: corresponding message Raises: NTPException -- in case of invalid leap indicator sInvalid leap indicator.N(RR5R(R7((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt leap_to_text‡s  cCs,|tijo ti|Stdƒ‚dS(s­Convert a NTP mode value to text. Parameters: mode -- NTP mode Returns: corresponding message Raises: NTPException -- in case of invalid mode s Invalid mode.N(RR4R(R9((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyt mode_to_text™s  cCsm|tijoti||Sd|jo djno d|S|djo d|Stdƒ‚dS(sµConvert a stratum value to text. Parameters: stratum -- NTP stratum Returns: corresponding message Raises: NTPException -- in case of invalid stratum iissecondary reference (%s)sunsynchronized (%s)sInvalid stratum or reserved.N(RR3R(R:((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pytstratum_to_text«s    icCsµ|d?d@|d?d@|d?d@|d@f}d|jo djno2d|}|tijo ti|Sd|Sn4d |jo djno d |Std ƒ‚d S( sConvert a reference clock identifier to text according to its stratum. Parameters: ref_id -- reference clock indentifier stratum -- NTP stratum Returns: corresponding message Raises: NTPException -- in case of invalid stratum iiÿiiiis%c%c%c%cs"Unidentified reference source '%s'is %d.%d.%d.%dsInvalid stratum.N(RR2R(R?R:tfieldsttext((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pytref_id_to_textÁs     ((((RR*RbRFR,t ExceptionRRR6RUR`RIRJRQRYRfR}R~RR‚(((s-/usr/local/qcloud/monitor/barad/lib/ntplib.pyts$    Ij38