dunedaq::datahandlinglibs Namespace Reference

Namespaces
namespace	logging
namespace	opmon
namespace	test
namespace	types

Classes
class	BinarySearchQueueModel
class	BufferedFileReader
class	BufferedFileWriter
class	CallbackConcept
class	DataHandlingConcept
class	DataHandlingModel
class	DataMoveCallback
class	DataMoveCallbackRegistry
class	DataSubscriberModel
class	DefaultRequestHandlerModel
class	DefaultSkipListRequestHandler
class	EmptyFragmentRequestHandlerModel
class	ErrorBitGenerator
class	FakeCardReaderBase
class	FileSourceBuffer
class	FixedRateQueueModel
class	FrameErrorRegistry
struct	IterableQueueModel
class	LatencyBufferConcept
class	RateLimiter
class	RawDataHandlerBase
class	RawDataProcessorConcept
class	RecorderConcept
class	RecorderModel
class	RequestHandlerConcept
class	SkipListLatencyBufferModel
class	SourceConcept
class	SourceEmulatorConcept
class	SourceEmulatorModel
class	SourceEmulatorPatternGenerator
class	TaskRawDataProcessorModel
class	ZeroCopyRecordingRequestHandlerModel

Functions
template<class T >
uint64_t	get_frame_iterator_timestamp (T iter)
void	buffer_copy (const char *data, std::size_t size, void *buffer, std::uint32_t buffer_pos, const std::size_t &buffer_size)

Function Documentation

buffer_copy()

void dunedaq::datahandlinglibs::buffer_copy ( const char * data, std::size_t size, void * buffer, std::uint32_t buffer_pos, const std::size_t & buffer_size )

inline

Definition at line 44 of file BufferCopy.hpp.

{
  auto bytes_to_copy = size; // NOLINT
  while (bytes_to_copy > 0) {
    auto n = std::min(bytes_to_copy, buffer_size - buffer_pos); // NOLINT
    std::memcpy(static_cast<char*>(buffer) + buffer_pos, data, n);
    buffer_pos += n; 
    bytes_to_copy -= n;
    if (buffer_pos == buffer_size) {
      buffer_pos = 0;
    }
  }
}

get_frame_iterator_timestamp()

template<class T >

uint64_t dunedaq::datahandlinglibs::get_frame_iterator_timestamp

(

T

iter

)

Definition at line 75 of file DefaultRequestHandlerModel.hpp.

{
  return iter->get_timestamp();
}