addToPool(Client &client, uint64_t poolThreadAffinityIn=0xfffffffffffffffful) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
addToPool(Client &client, uint64_t poolThreadAffinityIn, Args &&...args) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
Allocator typedef (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | |
allocator_ (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | protected |
Base typedef (defined in hmbdc::app::Context< MaxMessageSize, ContextProperties >) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | |
Buffer typedef (defined in hmbdc::app::Context< MaxMessageSize, ContextProperties >) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | |
buffer() | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
buffer_ (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | protected |
BUFFER_VALUE_SIZE enum value (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | |
bufferptr_ (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | protected |
clientCountInPool() const | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
Context(uint32_t messageQueueSizePower2Num=20, size_t maxPoolClientCount=128, size_t maxMessageSizeRuntime=MaxMessageSize) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
Context(char const *ipcTransportName, uint32_t messageQueueSizePower2Num=20, size_t maxPoolClientCount=128, size_t maxMessageSizeRuntime=MaxMessageSize, uint64_t purgerCpuAffinityMask=0xfffffffffffffffful) (defined in hmbdc::app::Context< MaxMessageSize, ContextProperties >) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
cpa typedef (defined in hmbdc::app::Context< MaxMessageSize, ContextProperties >) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | |
join() | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
markDeadFrom(hmbdc::pattern::MonoLockFreeBuffer &buffer, uint16_t) (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inlineprotectedstatic |
markDeadFrom(BroadCastBuf &buffer, uint16_t poolThreadCount) (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inlineprotectedstatic |
MAX_MESSAGE_SIZE enum value (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | |
maxMessageSize() const (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
parallelConsumerAlive() const | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
Pool typedef (defined in hmbdc::app::Context< MaxMessageSize, ContextProperties >) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | |
runClientThreadOnce(uint16_t threadSerialNumber, Client &c) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
runPoolThreadOnce(uint16_t threadSerialNumber) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
send(M0 &&m0, M1 &&m1, Messages &&...msgs) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
send(ForwardIt begin, size_t n) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
send(Message &&m) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
sendInPlace(Args &&...args) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
setSecondsBetweenPurge(uint32_t s) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
start(uint16_t poolThreadCount, uint64_t poolThreadsCpuAffinityMask, Args &&...args) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
start(Client &c, uint64_t cpuAffinity, Args &&...args) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
start() (defined in hmbdc::app::Context< MaxMessageSize, ContextProperties >) | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
stop() | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
ThreadCommBase(uint32_t messageQueueSizePower2Num, size_t maxMessageSizeRuntime=MAX_MESSAGE_SIZE, char const *shmName=nullptr) (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inlineprotected |
trySend(M0 &&m0, M1 &&m1, Messages &&...msgs) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
trySend(ForwardIt begin, size_t n) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
trySend(Message &&m) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inline |
~Context() | hmbdc::app::Context< MaxMessageSize, ContextProperties > | inline |
~ThreadCommBase() (defined in hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... >) | hmbdc::app::ThreadCommBase< MaxMessageSize, ContextProperties... > | inlineprotected |