dunedaq::datahandlinglibs Namespace Reference

Namespaces
namespace	logging
namespace	types
namespace	test
namespace	unittest
namespace	opmon

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

Concepts
concept	SupportsDelayedPostprocessing

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();
}