Seastar
High performance C++ framework for concurrent servers
|
Base execution stage class.
#include <seastar/core/execution_stage.hh>
Classes | |
struct | stats |
Public Member Functions | |
execution_stage (const sstring &name, scheduling_group sg={}) | |
execution_stage (const execution_stage &)=delete | |
execution_stage (execution_stage &&) | |
const sstring & | name () const noexcept |
Returns execution stage name. | |
const stats & | get_stats () const noexcept |
Returns execution stage usage statistics. | |
bool | flush () noexcept |
bool | poll () const noexcept |
Protected Member Functions | |
virtual void | do_flush () noexcept=0 |
Protected Attributes | |
bool | _empty = true |
bool | _flush_scheduled = false |
scheduling_group | _sg |
stats | _stats |
sstring | _name |
metrics::metric_group | _metric_group |
struct seastar::execution_stage::stats |
seastar::execution_stage::execution_stage | ( | execution_stage && | ) |
Move constructor
|
noexcept |
Flushes execution stage
Ensures that a task which would execute all queued operations is scheduled. Does not schedule a new task if there is one already pending or the queue is empty.
|
inlinenoexcept |
Checks whether there are pending operations.