Lines Matching defs:ExecutorPool

37 std::mutex ExecutorPool::initGuard;
38 std::atomic<ExecutorPool*> ExecutorPool::instance;
51 size_t ExecutorPool::getNumNonIO(void) {
66 size_t ExecutorPool::getNumAuxIO(void) {
83 size_t ExecutorPool::getNumWriters(void) {
103 size_t ExecutorPool::getNumReaders(void) {
124 ExecutorPool *ExecutorPool::get(void) {
137 tmp = new ExecutorPool(config.getMaxThreads(),
150 void ExecutorPool::shutdown(void) {
159 ExecutorPool::ExecutorPool(size_t maxThreads, size_t nTaskSets,
181 ExecutorPool::~ExecutorPool(void) {
200 TaskQueue *ExecutorPool::_nextTask(ExecutorThread &t, uint8_t tick) {
238 TaskQueue *ExecutorPool::nextTask(ExecutorThread &t, uint8_t tick) {
245 void ExecutorPool::addWork(size_t newWork, task_type_t qType) {
252 void ExecutorPool::lessWork(task_type_t qType) {
254 throw std::logic_error("ExecutorPool::lessWork: number of ready "
261 void ExecutorPool::startWork(task_type_t taskType) {
264 "ExecutorPool::startWork: worker is starting task with invalid "
279 void ExecutorPool::doneWork(task_type_t taskType) {
282 "ExecutorPool::doneWork: worker is finishing task with invalid "
294 bool ExecutorPool::_cancel(size_t taskId, bool eraseTask) {
315 throw std::logic_error("ExecutorPool::_cancel: task '" +
330 bool ExecutorPool::cancel(size_t taskId, bool eraseTask) {
337 bool ExecutorPool::_wake(size_t taskId) {
347 bool ExecutorPool::wake(size_t taskId) {
354 bool ExecutorPool::_snooze(size_t taskId, double toSleep) {
364 bool ExecutorPool::snooze(size_t taskId, double toSleep) {
371 TaskQueue* ExecutorPool::_getTaskQueue(const Taskable& t,
379 throw std::invalid_argument("ExecutorPool::_getTaskQueue: qidx "
402 throw std::logic_error("ExecutorPool::_getTaskQueue: At "
412 throw std::logic_error("ExecutorPool::_getTaskQueue: At "
421 throw std::logic_error("ExecutorPool::_getTaskQueue: Invalid "
428 size_t ExecutorPool::_schedule(ExTask task) {
447 size_t ExecutorPool::schedule(ExTask task) {
454 void ExecutorPool::_registerTaskable(Taskable& taskable) {
496 void ExecutorPool::registerTaskable(Taskable& taskable) {
502 ssize_t ExecutorPool::_adjustWorkers(task_type_t type, size_t desiredNumItems) {
591 void ExecutorPool::adjustWorkers(task_type_t type, size_t newCount) {
598 bool ExecutorPool::_startWorkers(void) {
617 bool ExecutorPool::_stopTaskGroup(task_gid_t taskGID,
656 bool ExecutorPool::stopTaskGroup(task_gid_t taskGID,
665 void ExecutorPool::_unregisterTaskable(Taskable& taskable, bool force) {
676 throw std::logic_error("ExecutorPool::_unregisterTaskable: "
717 void ExecutorPool::unregisterTaskable(Taskable& taskable, bool force) {
724 void ExecutorPool::doTaskQStat(EventuallyPersistentEngine *engine,
781 "ExecutorPool::doTaskQStat: Failed to build stats: %s",
819 void ExecutorPool::doWorkerStat(EventuallyPersistentEngine *engine,
835 void ExecutorPool::doTasksStat(EventuallyPersistentEngine* engine,
925 void ExecutorPool::_stopAndJoinThreads() {