Brief description of class still missing. More...
#include <TimeSlaveBuffer.h>
Public Member Functions | |
TimeSlaveBuffer (int fileDescriptor, TimeSlaveStream *stream) | |
~TimeSlaveBuffer () | |
Protected Member Functions | |
virtual int | bytesAvailable (char *buffer, int byteCount) |
Brief description of class still missing.
Full description of class still missing
TimeSlaveBuffer::TimeSlaveBuffer | ( | int | fileDescriptor, |
TimeSlaveStream * | stream | ||
) |
Description of constructor still missing
: DynamicBuffer(fileDescriptor) { _stream=stream; }
Description of destructor still missing
{ }
int TimeSlaveBuffer::bytesAvailable | ( | char * | buffer, |
int | byteCount | ||
) | [protected, virtual] |
Peers having a GPS time reference send back their time and the broadcast time I sent in the request.
Implements GpCoreTools::DynamicBuffer.
References GpCoreTools::MessageRawHeader::isValid(), GpCoreTools::MessageRawHeader::lengthLittleEndian(), GpCoreTools::DynamicBuffer::read(), and TRACE.
{ TRACE; // If less bytes are available, just wait for more data. int readBytes=MessageRawHeader::SynchronizationSize+ MessageRawHeader::HeaderSize+ MessageRawHeader::CheckSumSize; if(byteCount<readBytes) { return 0; } MessageRawHeader * hdr=reinterpret_cast<MessageRawHeader *>(buffer); if(!hdr->isValid()) { return 1; } unsigned short length=hdr->lengthLittleEndian(); readBytes+=length; if(byteCount<readBytes) { return 0; } buffer+=MessageRawHeader::SynchronizationSize+MessageRawHeader::HeaderSize; char * payload=buffer; buffer+=length; if(hdr->isValid(*reinterpret_cast<const FletcherChecksum *>(buffer), payload, length)) { read(payload, length); } return readBytes; }