OpenSDN source code
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
WorkQueue< QueueEntryT > Member List

This is the complete list of members for WorkQueue< QueueEntryT >, including all inherited members.

add_busy_time(uint64_t t)WorkQueue< QueueEntryT >inline
AreWaterMarksSet() const WorkQueue< QueueEntryT >inlineprivate
AtomicDecrementQueueCount(QueueEntryT *entry)WorkQueue< QueueEntryT >inlineprivate
AtomicIncrementQueueCount(QueueEntryT *entry)WorkQueue< QueueEntryT >inlineprivate
bounded_WorkQueue< QueueEntryT >private
busy_time() const WorkQueue< QueueEntryT >inline
busy_time_WorkQueue< QueueEntryT >mutableprivate
Callback typedefWorkQueue< QueueEntryT >
callback_WorkQueue< QueueEntryT >private
ClearStats() const WorkQueue< QueueEntryT >inline
count_WorkQueue< QueueEntryT >private
current_runner_WorkQueue< QueueEntryT >private
delete_entries_on_shutdown_WorkQueue< QueueEntryT >private
deleted() const WorkQueue< QueueEntryT >inline
deleted_WorkQueue< QueueEntryT >private
Dequeue(QueueEntryT *entry)WorkQueue< QueueEntryT >inline
DequeueInternal(QueueEntryT *entry)WorkQueue< QueueEntryT >inlineprivate
DequeueInternalLocked(QueueEntryT *entry)WorkQueue< QueueEntryT >inlineprivate
dequeues_WorkQueue< QueueEntryT >mutableprivate
Description() const WorkQueue< QueueEntryT >inline
disabled_WorkQueue< QueueEntryT >private
DISALLOW_COPY_AND_ASSIGN(WorkQueue)WorkQueue< QueueEntryT >private
drops_WorkQueue< QueueEntryT >private
Enqueue(QueueEntryT entry)WorkQueue< QueueEntryT >inline
EnqueueBounded(QueueEntryT entry)WorkQueue< QueueEntryT >inlineprivate
EnqueueBoundedLocked(QueueEntryT entry)WorkQueue< QueueEntryT >inlineprivate
EnqueueInternal(QueueEntryT entry)WorkQueue< QueueEntryT >inlineprivate
EnqueueInternalLocked(QueueEntryT entry)WorkQueue< QueueEntryT >inlineprivate
enqueues_WorkQueue< QueueEntryT >mutableprivate
GetBounded() const WorkQueue< QueueEntryT >inline
GetCallback() const WorkQueue< QueueEntryT >inline
GetHighWaterMark() const WorkQueue< QueueEntryT >inline
GetLowWaterMark() const WorkQueue< QueueEntryT >inline
GetTaskId() const WorkQueue< QueueEntryT >inline
GetTaskInstance() const WorkQueue< QueueEntryT >inline
IsDisabled() const WorkQueue< QueueEntryT >inline
IsQueueEmpty() const WorkQueue< QueueEntryT >inline
kMaxIterationsWorkQueue< QueueEntryT >static
kMaxSizeWorkQueue< QueueEntryT >static
Length() const WorkQueue< QueueEntryT >inline
max_iterations_WorkQueue< QueueEntryT >private
max_queue_len() const WorkQueue< QueueEntryT >inline
max_queue_len_WorkQueue< QueueEntryT >mutableprivate
MayBeStartRunner()WorkQueue< QueueEntryT >inline
measure_busy_time() const WorkQueue< QueueEntryT >inline
measure_busy_time_WorkQueue< QueueEntryT >mutableprivate
mutex_WorkQueue< QueueEntryT >private
name_WorkQueue< QueueEntryT >private
NumDequeues() const WorkQueue< QueueEntryT >inline
NumDrops() const WorkQueue< QueueEntryT >inline
NumEnqueues() const WorkQueue< QueueEntryT >inline
on_entry_cb_WorkQueue< QueueEntryT >private
on_entry_defer_count() const WorkQueue< QueueEntryT >inline
on_entry_defer_count_WorkQueue< QueueEntryT >private
on_exit_cb_WorkQueue< QueueEntryT >private
OnEntry()WorkQueue< QueueEntryT >inline
OnExit(bool done)WorkQueue< QueueEntryT >inline
ProcessHighWaterMarks(size_t count)WorkQueue< QueueEntryT >inlineprivate
ProcessLowWaterMarks(size_t count)WorkQueue< QueueEntryT >inlineprivate
Queue typedefWorkQueue< QueueEntryT >
queue_WorkQueue< QueueEntryT >private
QueueTaskRunner< QueueEntryT, WorkQueue< QueueEntryT > > classWorkQueue< QueueEntryT >friend
QueueTaskShutdownTest classWorkQueue< QueueEntryT >friend
QueueTaskTest classWorkQueue< QueueEntryT >friend
QueueTaskWaterMarkTest classWorkQueue< QueueEntryT >friend
ResetHighWaterMark()WorkQueue< QueueEntryT >inline
ResetLowWaterMark()WorkQueue< QueueEntryT >inline
RunnerAbort()WorkQueue< QueueEntryT >inlineprivate
RunnerAbortLocked()WorkQueue< QueueEntryT >inlineprivate
RunnerDone()WorkQueue< QueueEntryT >inlineprivate
running_WorkQueue< QueueEntryT >private
ScheduleShutdown(bool delete_entries=true)WorkQueue< QueueEntryT >inline
set_disable(bool disabled)WorkQueue< QueueEntryT >inline
set_measure_busy_time(bool val) const WorkQueue< QueueEntryT >inline
set_name(const std::string &name)WorkQueue< QueueEntryT >inline
SetBounded(bool bounded)WorkQueue< QueueEntryT >inline
SetEntryCallback(TaskEntryCallback on_entry)WorkQueue< QueueEntryT >inline
SetExitCallback(TaskExitCallback on_exit)WorkQueue< QueueEntryT >inline
SetHighWaterMark(const WaterMarkInfos &high_water)WorkQueue< QueueEntryT >inline
SetHighWaterMark(const WaterMarkInfo &hwm_info)WorkQueue< QueueEntryT >inline
SetLowWaterMark(const WaterMarkInfos &low_water)WorkQueue< QueueEntryT >inline
SetLowWaterMark(const WaterMarkInfo &lwm_info)WorkQueue< QueueEntryT >inline
SetSize(size_t size)WorkQueue< QueueEntryT >inline
SetStartRunnerFunc(StartRunnerFunc start_runner_fn)WorkQueue< QueueEntryT >inline
Shutdown(bool delete_entries=true)WorkQueue< QueueEntryT >inline
shutdown_scheduled_WorkQueue< QueueEntryT >private
ShutdownLocked(bool delete_entries)WorkQueue< QueueEntryT >inlineprivate
size_WorkQueue< QueueEntryT >private
start_runner_WorkQueue< QueueEntryT >private
StartRunnerFunc typedefWorkQueue< QueueEntryT >
task_starts() const WorkQueue< QueueEntryT >inline
task_starts_WorkQueue< QueueEntryT >mutableprivate
TaskEntryCallback typedefWorkQueue< QueueEntryT >
TaskExitCallback typedefWorkQueue< QueueEntryT >
taskId_WorkQueue< QueueEntryT >private
taskInstance_WorkQueue< QueueEntryT >private
water_mutex_WorkQueue< QueueEntryT >mutableprivate
watermarks_WorkQueue< QueueEntryT >private
WorkQueue(int taskId, int taskInstance, Callback callback, size_t size=kMaxSize, size_t max_iterations=kMaxIterations)WorkQueue< QueueEntryT >inline
~WorkQueue()WorkQueue< QueueEntryT >inline