poco/Net/src/NTPClient.cpp at develop · cppfool/poco · GitHub

History

89 lines (65 loc) · 1.52 KB

Raw

// NTPClient.cpp

// $Id: //poco/1.4/Net/src/NTPClient.cpp#1 $

// Library: Net

// Package: NTP

// Module: NTPClient

// and Contributors.

// SPDX-License-Identifier: BSL-1.0

#include "Poco/Net/SocketAddress.h"

#include "Poco/Net/NTPClient.h"

#include "Poco/Net/NTPPacket.h"

#include "Poco/Net/DatagramSocket.h"

#include "Poco/Net/NetException.h"

using Poco::TimeoutException;

namespace Poco {

namespace Net {

NTPClient::NTPClient(IPAddress::Family family, int timeout):

_family(family), _timeout(timeout)

{

}

NTPClient::~NTPClient()

{

}

int NTPClient::request(const std::string& address) const

{

SocketAddress addr(address, 123);

return request(addr);

}

int NTPClient::request(SocketAddress& address) const

{

Poco::Net::SocketAddress sa;

DatagramSocket ntpSocket(_family);

ntpSocket.setReceiveTimeout(_timeout);

ntpSocket.bind(sa);

SocketAddress returnAddress;

NTPEventArgs eventArgs(address);

NTPPacket packet;

Poco::UInt8 p[1024];

packet.packet(&p[0]);

ntpSocket.sendTo(p, 48, address);

int received = 0;

try

{

Poco::Net::SocketAddress sender;

int n = ntpSocket.receiveFrom(p, sizeof(p)-1, sender);

if (n < 48) // NTP packet must have at least 48 bytes

throw Poco::Net::NTPException("Invalid response received");

packet.setPacket(p);

eventArgs.setPacket(packet);

++received;

response.notify(this, eventArgs);

}

catch (Poco::TimeoutException &)

{

// ignore

}

return received;

}

} } // namespace Poco::Net

poco/Net/src/NTPClient.cpp at develop · cppfool/poco · GitHub

Expand file tree

Breadcrumbs

NTPClient.cpp

Latest commit

History

Breadcrumbs

NTPClient.cpp

File metadata and controls