39 int index(
void)
const;
42 const std::string &name(
void)
const;
45 const DType &dtype(
void)
const;
48 const std::string &domain(
void)
const;
60 size_t elements(
void)
const;
67 unsigned long long totalElements(
void)
const;
74 unsigned long long totalMessages(
void)
const;
77 bool hasMessage(
void)
const;
94 void removeLabel(
const Label &label);
102 void consume(
const size_t numElements);
119 void setReserve(
const size_t numElements);
124 bool isSlot(
void)
const;
141 void pushLabel(
const Label &label);
147 void pushMessage(
const Object &message);
156 InputPortImpl *_impl;
161 std::reference_wrapper<const BufferChunk> _buffer;
163 unsigned long long _totalElements;
164 unsigned long long _totalMessages;
166 size_t _pendingElements;
167 size_t _reserveElements;
173 friend class WorkerActor;
210 return _totalElements;
215 return _totalMessages;
225 _pendingElements += numElements;
#define POTHOS_API
Definition: Config.hpp:41
Definition: Object.hpp:55
Definition: BufferChunk.hpp:26
static const BufferChunk & null(void)
Get a const reference to a null/empty BufferChunk.