36 _sharedQueueErrorCount = 0;
38 _sharedQueueCompletedCount = 0;
40 _highPriorityCount = 0;
76 return _sharedQueueErrorCount;
82 ++_sharedQueueErrorCount;
88 return _completedCount;
100 return _sharedQueueCompletedCount;
106 ++_sharedQueueCompletedCount;
124 return _highPriorityCount;
130 ++_highPriorityCount;
136 out <<
"Num elemetns: " << _numElements << std::endl;
137 out <<
"Num queued: " << _errorCount << std::endl;
138 out <<
"Num completed: " << _completedCount << std::endl;
139 out <<
"Num shared completed: " << _sharedQueueCompletedCount << std::endl;
140 out <<
"Num errors: " << _errorCount << std::endl;
141 out <<
"Num shared errors: " << _sharedQueueErrorCount << std::endl;
142 out <<
"Num high priority count: " << _highPriorityCount << std::endl;
virtual size_t highPriorityCount() const =0
Count of all coroutine and IO tasks which were posted on this queue at higher priority.
Definition: quantum_buffer_impl.h:22
size_t sharedQueueCompletedCount() const final
Count of all IO tasks which were dequeued from the shared queue and completed successfully.
Definition: quantum_queue_statistics_impl.h:98
QueueStatistics()
Definition: quantum_queue_statistics_impl.h:26
void reset() final
Reset all the counters to 0.
Definition: quantum_queue_statistics_impl.h:32
void incHighPriorityCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:128
size_t postedCount() const final
Count of all coroutine and IO tasks which were posted on this queue.
Definition: quantum_queue_statistics_impl.h:110
virtual size_t numElements() const =0
Gets the current size of the queue.
virtual size_t errorCount() const =0
Count of all coroutine and IO task execution errors on this queue.
void incSharedQueueErrorCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:80
void incPostedCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:116
virtual void print(std::ostream &out) const =0
Print to std::cout the value of all internal counters.
Provides various counters related to queues and task execution.
Definition: quantum_queue_statistics.h:30
size_t errorCount() const final
Count of all coroutine and IO task execution errors on this queue.
Definition: quantum_queue_statistics_impl.h:62
virtual size_t completedCount() const =0
Count of all coroutine and IO tasks which completed successfully.
void incSharedQueueCompletedCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:104
virtual size_t postedCount() const =0
Count of all coroutine and IO tasks which were posted on this queue.
virtual size_t sharedQueueErrorCount() const =0
Count of all IO tasks which were dequeued from the shared queue and failed.
size_t sharedQueueErrorCount() const final
Count of all IO tasks which were dequeued from the shared queue and failed.
Definition: quantum_queue_statistics_impl.h:74
void incCompletedCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:92
size_t highPriorityCount() const final
Count of all coroutine and IO tasks which were posted on this queue at higher priority.
Definition: quantum_queue_statistics_impl.h:122
std::ostream & operator<<(std::ostream &out, const IQueueStatistics &stats)
Overloads stream operator for IQueueStatistics object.
Definition: quantum_queue_statistics_impl.h:167
void incErrorCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:68
size_t completedCount() const final
Count of all coroutine and IO tasks which completed successfully.
Definition: quantum_queue_statistics_impl.h:86
QueueStatistics & operator+=(const IQueueStatistics &rhs)
Definition: quantum_queue_statistics_impl.h:146
QueueStatistics operator+(QueueStatistics lhs, const IQueueStatistics &rhs)
Definition: quantum_queue_statistics_impl.h:159
Interface to access and manipulate a QueueStatistics object.
Definition: quantum_iqueue_statistics.h:29
virtual size_t sharedQueueCompletedCount() const =0
Count of all IO tasks which were dequeued from the shared queue and completed successfully.
size_t numElements() const final
Gets the current size of the queue.
Definition: quantum_queue_statistics_impl.h:44
void incNumElements() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:50
void print(std::ostream &out) const final
Print to std::cout the value of all internal counters.
Definition: quantum_queue_statistics_impl.h:134
void decNumElements() final
Decrement this counter.
Definition: quantum_queue_statistics_impl.h:56