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 class	Bloomberg::quantum::Context< RET >	friend
Bloomberg::ContextTag typedef	Bloomberg::quantum::IThreadContext< RET >
Bloomberg::quantum::ICoroContext::ContextTag typedef	Bloomberg::quantum::ICoroContext< RET >
CoroCtx typedef	Bloomberg::quantum::Context< RET >
deleter(Context< RET > *p)	Bloomberg::quantum::Context< RET >	static
Dispatcher class	Bloomberg::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() const	Bloomberg::quantum::Context< RET >
getNumCoroutineThreads() const	Bloomberg::quantum::Context< RET >
getNumIoThreads() const	Bloomberg::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() const	Bloomberg::quantum::Context< RET >
getRef(ICoroSync::Ptr sync) const	Bloomberg::quantum::Context< RET >
getRefAt(int num) const	Bloomberg::quantum::Context< RET >
getRefAt(int num, ICoroSync::Ptr sync) const	Bloomberg::quantum::Context< RET >
getTask() const final	Bloomberg::quantum::Context< RET >	virtual
getYieldHandle() final	Bloomberg::quantum::Context< RET >	virtual
Bloomberg::Impl typedef	Bloomberg::quantum::IThreadContext< RET >
Bloomberg::quantum::ICoroContext::Impl typedef	Bloomberg::quantum::ICoroContext< RET >
isBlocked() const final	Bloomberg::quantum::Context< RET >	virtual
isSleeping(bool updateTimer=false) final	Bloomberg::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 typedef	Bloomberg::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) final	Bloomberg::quantum::Context< RET >	virtual
setTask(ITask::Ptr task) final	Bloomberg::quantum::Context< RET >	virtual
setYieldHandle(Traits::Yield &yield) final	Bloomberg::quantum::Context< RET >	virtual
signal() final	Bloomberg::quantum::Context< RET >	virtual
sleep(const std::chrono::milliseconds &timeMs) final	Bloomberg::quantum::Context< RET >	virtual
sleep(const std::chrono::microseconds &timeUs) final	Bloomberg::quantum::Context< RET >	virtual
Task class	Bloomberg::quantum::Context< RET >	friend
terminate() final	Bloomberg::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 typedef	Bloomberg::quantum::Context< RET >
Util	Bloomberg::quantum::Context< RET >	friend
valid() const final	Bloomberg::quantum::Context< RET >	virtual
validAt(int num) const final	Bloomberg::quantum::Context< RET >	virtual
wait() const final	Bloomberg::quantum::Context< RET >	virtual
wait(ICoroSync::Ptr sync) const final	Bloomberg::quantum::Context< RET >	virtual
waitAll() const final	Bloomberg::quantum::Context< RET >	virtual
waitAll(ICoroSync::Ptr sync) const final	Bloomberg::quantum::Context< RET >	virtual
waitAt(int num) const final	Bloomberg::quantum::Context< RET >	virtual
waitAt(int num, ICoroSync::Ptr sync) const final	Bloomberg::quantum::Context< RET >	virtual
waitFor(std::chrono::milliseconds timeMs) const final	Bloomberg::quantum::Context< RET >	virtual
waitFor(ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const final	Bloomberg::quantum::Context< RET >	virtual
waitForAt(int num, std::chrono::milliseconds timeMs) const final	Bloomberg::quantum::Context< RET >	virtual
waitForAt(int num, ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const final	Bloomberg::quantum::Context< RET >	virtual
yield() final	Bloomberg::quantum::Context< RET >	virtual
~Context()	Bloomberg::quantum::Context< RET >
~IContextBase()=default	Bloomberg::quantum::IContextBase	virtual
~ICoroSync()=default	Bloomberg::quantum::ICoroSync	virtual
~ITerminate()=default	Bloomberg::quantum::ITerminate	virtual