QuantumLibrary
Bloomberg::quantum::Context< RET > Member List

This is the complete list of members for Bloomberg::quantum::Context< RET >, including all inherited members.

closeBuffer()Bloomberg::quantum::Context< RET >
Context classBloomberg::quantum::Context< RET >friend
Bloomberg::ContextTag typedefBloomberg::quantum::IThreadContext< RET >
Bloomberg::quantum::ICoroContext::ContextTag typedefBloomberg::quantum::ICoroContext< RET >
CoroCtx typedefBloomberg::quantum::Context< RET >
deleter(Context< RET > *p)Bloomberg::quantum::Context< RET >static
Dispatcher classBloomberg::quantum::Context< RET >friend
end()Bloomberg::quantum::Context< RET >
finally(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
finally(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::Context< RET >
get()Bloomberg::quantum::Context< RET >
get(ICoroSync::Ptr sync)Bloomberg::quantum::Context< RET >
getAt(int num)Bloomberg::quantum::Context< RET >
getAt(int num, ICoroSync::Ptr sync)Bloomberg::quantum::Context< RET >
getCoroQueueIdRangeForAny() constBloomberg::quantum::Context< RET >
getNumCoroutineThreads() constBloomberg::quantum::Context< RET >
getNumIoThreads() constBloomberg::quantum::Context< RET >
getPrev(ICoroSync::Ptr sync)Bloomberg::quantum::Context< RET >
Bloomberg::quantum::ICoroContext::getPrev()Bloomberg::quantum::ICoroContext< RET >
getPrevRef(ICoroSync::Ptr sync)Bloomberg::quantum::Context< RET >
Bloomberg::quantum::ICoroContext::getPrevRef()Bloomberg::quantum::ICoroContext< RET >
getRef() constBloomberg::quantum::Context< RET >
getRef(ICoroSync::Ptr sync) constBloomberg::quantum::Context< RET >
getRefAt(int num) constBloomberg::quantum::Context< RET >
getRefAt(int num, ICoroSync::Ptr sync) constBloomberg::quantum::Context< RET >
getTask() const finalBloomberg::quantum::Context< RET >virtual
getYieldHandle() finalBloomberg::quantum::Context< RET >virtual
Bloomberg::Impl typedefBloomberg::quantum::IThreadContext< RET >
Bloomberg::quantum::ICoroContext::Impl typedefBloomberg::quantum::ICoroContext< RET >
isBlocked() const finalBloomberg::quantum::Context< RET >virtual
isSleeping(bool updateTimer=false) finalBloomberg::quantum::Context< RET >virtual
mapReduce(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduce(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduce(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduce(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduceBatch(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduceBatch(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduceBatch(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
mapReduceBatch(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::Context< RET >
onError(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
onError(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
operator delete(void *p)Bloomberg::quantum::Context< RET >static
operator new(size_t size)Bloomberg::quantum::Context< RET >static
post(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
post(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postAsyncIo(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postAsyncIo(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postFirst(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postFirst(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
postImpl(int queueId, bool isHighPriority, ITask::Type type, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
Ptr typedefBloomberg::quantum::Context< RET >
pull(bool &isBufferClosed)Bloomberg::quantum::Context< RET >
pull(ICoroSync::Ptr sync, bool &isBufferClosed)Bloomberg::quantum::Context< RET >
push(V &&value)Bloomberg::quantum::Context< RET >
push(ICoroSync::Ptr sync, V &&value)Bloomberg::quantum::Context< RET >
set(V &&value)Bloomberg::quantum::Context< RET >
set(ICoroSync::Ptr sync, V &&value)Bloomberg::quantum::Context< RET >
setException(std::exception_ptr ex) finalBloomberg::quantum::Context< RET >virtual
setTask(ITask::Ptr task) finalBloomberg::quantum::Context< RET >virtual
setYieldHandle(Traits::Yield &yield) finalBloomberg::quantum::Context< RET >virtual
signal() finalBloomberg::quantum::Context< RET >virtual
sleep(const std::chrono::milliseconds &timeMs) finalBloomberg::quantum::Context< RET >virtual
sleep(const std::chrono::microseconds &timeUs) finalBloomberg::quantum::Context< RET >virtual
Task classBloomberg::quantum::Context< RET >friend
terminate() finalBloomberg::quantum::Context< RET >virtual
then(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
then(FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
thenImpl(ITask::Type type, FUNC &&func, ARGS &&... args)Bloomberg::quantum::Context< RET >
ThreadCtx typedefBloomberg::quantum::Context< RET >
UtilBloomberg::quantum::Context< RET >friend
valid() const finalBloomberg::quantum::Context< RET >virtual
validAt(int num) const finalBloomberg::quantum::Context< RET >virtual
wait() const finalBloomberg::quantum::Context< RET >virtual
wait(ICoroSync::Ptr sync) const finalBloomberg::quantum::Context< RET >virtual
waitAll() const finalBloomberg::quantum::Context< RET >virtual
waitAll(ICoroSync::Ptr sync) const finalBloomberg::quantum::Context< RET >virtual
waitAt(int num) const finalBloomberg::quantum::Context< RET >virtual
waitAt(int num, ICoroSync::Ptr sync) const finalBloomberg::quantum::Context< RET >virtual
waitFor(std::chrono::milliseconds timeMs) const finalBloomberg::quantum::Context< RET >virtual
waitFor(ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const finalBloomberg::quantum::Context< RET >virtual
waitForAt(int num, std::chrono::milliseconds timeMs) const finalBloomberg::quantum::Context< RET >virtual
waitForAt(int num, ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const finalBloomberg::quantum::Context< RET >virtual
yield() finalBloomberg::quantum::Context< RET >virtual
~Context()Bloomberg::quantum::Context< RET >
~IContextBase()=defaultBloomberg::quantum::IContextBasevirtual
~ICoroSync()=defaultBloomberg::quantum::ICoroSyncvirtual
~ITerminate()=defaultBloomberg::quantum::ITerminatevirtual