ntp-client-0.0.1
Safe Haskell None
Language Haskell2010

Network.NTP.Client

Synopsis

The API for starting an ntp client-thread.

withNtpClient :: IOManager -> Tracer IO NtpTrace -> NtpSettings -> ( NtpClient -> IO a) -> IO a Source #

Setup a NtpClient and run an application that uses provided NtpClient . The NtpClient is terminated when the callback returns. The application can waitCatch on ntpThread .

data NtpSettings Source #

Settings of the ntp client.

Constructors

NtpSettings

Fields

  • ntpServers :: [ String ]

    List of server addresses. At least three servers are needed.

  • ntpRequiredNumberOfResults :: Int

    Minimum number of results to compute the offset, this should be less or equal to the length of ntpServers (we send a single tnp packet / query to a each server, if the dns name resolves to many addresses we pick the first one).

  • ntpResponseTimeout :: Microsecond

    Timeout for receiving a response from an ntp server.

  • ntpPollDelay :: Microsecond

    How long to wait between two rounds of requests. This should be set to something of an order of one hour, ntp servers should not be abused.

data NtpClient Source #

NtpClient which recieves updates of the wall clcok drift every ntpPollDelay . It also allows to force engaging in ntp protocol.

Constructors

NtpClient

Fields

data NtpStatus Source #

The Ntp client state: either cached results is availbale, or the ntp client is engaged in ntp-protocol or there was a failure: e.g. connection lost, or dns lookups did not return at least ntpRequiredNumberOfResults addresses.

Constructors

NtpDrift !NtpOffset

The difference between NTP time and local system time

NtpSyncPending

NTP client has send requests to the servers

NtpSyncUnavailable

NTP is not available: the client has not received any respond within ntpResponseTimeout from at least ntpRequiredNumberOfResults servers.

Instances

Instances details
Eq NtpStatus Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

(==) :: NtpStatus -> NtpStatus -> Bool Source #

(/=) :: NtpStatus -> NtpStatus -> Bool Source #

Show NtpStatus Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

showsPrec :: Int -> NtpStatus -> ShowS Source #

show :: NtpStatus -> String Source #

showList :: [ NtpStatus ] -> ShowS Source #

Low level interface

Running an ntp query

ntpQuery :: IOManager -> Tracer IO NtpTrace -> NtpSettings -> IO NtpStatus Source #

Perform a series of NTP queries: one for each dns name. Resolve each dns name, get local addresses: both IPv4 and IPv6 and engage in ntp protocol towards one ip address per address family per dns name, but only for address families for which we have a local address. This is to avoid trying to send IPv4/6 requests if IPv4/6 gateway is not configured.

It may throw an IOException :

  • if neither IPv4 nor IPv6 address is configured
  • if network I/O errors

Logging interface

data NtpTrace Source #

Constructors

NtpTraceStartNtpClient
NtpTraceRestartDelay Int
NtpTraceRestartingClient
NtpTraceIOError IOError
NtpTraceLookupsFails
NtpTraceClientStartQuery
NtpTraceNoLocalAddr
NtpTraceResult NtpStatus
NtpTraceRunProtocolResults ( ResultOrFailure [NtpOffset])
NtpTracePacketSent SockAddr NtpPacket
NtpTracePacketSendError SockAddr IOException
NtpTracePacketDecodeError SockAddr String
NtpTracePacketReceived SockAddr NtpPacket
NtpTraceWaitingForRepliesTimeout IPVersion

Instances

Instances details
Show NtpTrace Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

showsPrec :: Int -> NtpTrace -> ShowS Source #

show :: NtpTrace -> String Source #

showList :: [ NtpTrace ] -> ShowS Source #

data IPVersion Source #

A tag which describes which version of the ip protocol was used.

Constructors

IPv4
IPv6

Instances

Instances details
Eq IPVersion Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

(==) :: IPVersion -> IPVersion -> Bool Source #

(/=) :: IPVersion -> IPVersion -> Bool Source #

Show IPVersion Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

showsPrec :: Int -> IPVersion -> ShowS Source #

show :: IPVersion -> String Source #

showList :: [ IPVersion ] -> ShowS Source #

data ResultOrFailure a Source #

Result of two threads running concurrently.

Constructors

BothSucceeded !a

both threads suceeded

SuccessAndFailure !a ! IPVersion ! IOException

one of the threads errors. IPVersion indicates which one.

BothFailed ! IOException ! IOException

both threads failed

Instances

Instances details
Foldable ResultOrFailure Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

fold :: Monoid m => ResultOrFailure m -> m Source #

foldMap :: Monoid m => (a -> m) -> ResultOrFailure a -> m Source #

foldMap' :: Monoid m => (a -> m) -> ResultOrFailure a -> m Source #

foldr :: (a -> b -> b) -> b -> ResultOrFailure a -> b Source #

foldr' :: (a -> b -> b) -> b -> ResultOrFailure a -> b Source #

foldl :: (b -> a -> b) -> b -> ResultOrFailure a -> b Source #

foldl' :: (b -> a -> b) -> b -> ResultOrFailure a -> b Source #

foldr1 :: (a -> a -> a) -> ResultOrFailure a -> a Source #

foldl1 :: (a -> a -> a) -> ResultOrFailure a -> a Source #

toList :: ResultOrFailure a -> [a] Source #

null :: ResultOrFailure a -> Bool Source #

length :: ResultOrFailure a -> Int Source #

elem :: Eq a => a -> ResultOrFailure a -> Bool Source #

maximum :: Ord a => ResultOrFailure a -> a Source #

minimum :: Ord a => ResultOrFailure a -> a Source #

sum :: Num a => ResultOrFailure a -> a Source #

product :: Num a => ResultOrFailure a -> a Source #

Eq a => Eq ( ResultOrFailure a) Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

(==) :: ResultOrFailure a -> ResultOrFailure a -> Bool Source #

(/=) :: ResultOrFailure a -> ResultOrFailure a -> Bool Source #

Show a => Show ( ResultOrFailure a) Source #
Instance details

Defined in Network.NTP.Client.Query

Methods

showsPrec :: Int -> ResultOrFailure a -> ShowS Source #

show :: ResultOrFailure a -> String Source #

showList :: [ ResultOrFailure a] -> ShowS Source #