OpenSDN source code
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 >
inline
private
AtomicDecrementQueueCount
(QueueEntryT *entry)
WorkQueue< QueueEntryT >
inline
private
AtomicIncrementQueueCount
(QueueEntryT *entry)
WorkQueue< QueueEntryT >
inline
private
bounded_
WorkQueue< QueueEntryT >
private
busy_time
() const
WorkQueue< QueueEntryT >
inline
busy_time_
WorkQueue< QueueEntryT >
mutable
private
Callback
typedef
WorkQueue< 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 >
inline
private
DequeueInternalLocked
(QueueEntryT *entry)
WorkQueue< QueueEntryT >
inline
private
dequeues_
WorkQueue< QueueEntryT >
mutable
private
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 >
inline
private
EnqueueBoundedLocked
(QueueEntryT entry)
WorkQueue< QueueEntryT >
inline
private
EnqueueInternal
(QueueEntryT entry)
WorkQueue< QueueEntryT >
inline
private
EnqueueInternalLocked
(QueueEntryT entry)
WorkQueue< QueueEntryT >
inline
private
enqueues_
WorkQueue< QueueEntryT >
mutable
private
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
kMaxIterations
WorkQueue< QueueEntryT >
static
kMaxSize
WorkQueue< QueueEntryT >
static
Length
() const
WorkQueue< QueueEntryT >
inline
max_iterations_
WorkQueue< QueueEntryT >
private
max_queue_len
() const
WorkQueue< QueueEntryT >
inline
max_queue_len_
WorkQueue< QueueEntryT >
mutable
private
MayBeStartRunner
()
WorkQueue< QueueEntryT >
inline
measure_busy_time
() const
WorkQueue< QueueEntryT >
inline
measure_busy_time_
WorkQueue< QueueEntryT >
mutable
private
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 >
inline
private
ProcessLowWaterMarks
(size_t count)
WorkQueue< QueueEntryT >
inline
private
Queue
typedef
WorkQueue< QueueEntryT >
queue_
WorkQueue< QueueEntryT >
private
QueueTaskRunner< QueueEntryT, WorkQueue< QueueEntryT > >
class
WorkQueue< QueueEntryT >
friend
QueueTaskShutdownTest
class
WorkQueue< QueueEntryT >
friend
QueueTaskTest
class
WorkQueue< QueueEntryT >
friend
QueueTaskWaterMarkTest
class
WorkQueue< QueueEntryT >
friend
ResetHighWaterMark
()
WorkQueue< QueueEntryT >
inline
ResetLowWaterMark
()
WorkQueue< QueueEntryT >
inline
RunnerAbort
()
WorkQueue< QueueEntryT >
inline
private
RunnerAbortLocked
()
WorkQueue< QueueEntryT >
inline
private
RunnerDone
()
WorkQueue< QueueEntryT >
inline
private
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 >
inline
private
size_
WorkQueue< QueueEntryT >
private
start_runner_
WorkQueue< QueueEntryT >
private
StartRunnerFunc
typedef
WorkQueue< QueueEntryT >
task_starts
() const
WorkQueue< QueueEntryT >
inline
task_starts_
WorkQueue< QueueEntryT >
mutable
private
TaskEntryCallback
typedef
WorkQueue< QueueEntryT >
TaskExitCallback
typedef
WorkQueue< QueueEntryT >
taskId_
WorkQueue< QueueEntryT >
private
taskInstance_
WorkQueue< QueueEntryT >
private
water_mutex_
WorkQueue< QueueEntryT >
mutable
private
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
Generated by
1.9.1