Seastar
High performance C++ framework for concurrent servers
|
Public Member Functions | |
smp_message_queue (reactor *from, reactor *to) | |
template<typename Func > | |
futurize_t< std::invoke_result_t< Func > > | submit (shard_id t, smp_submit_to_options options, Func &&func) noexcept |
void | start (unsigned cpuid) |
template<size_t PrefetchCnt, typename Func > | |
size_t | process_queue (lf_queue &q, Func process) |
size_t | process_incoming () |
size_t | process_completions (shard_id t) |
void | stop () |