Home
last modified time | relevance | path

Searched refs:schedule (Results 1 - 25 of 54) sorted by relevance

123

/6.6.0/testrunner/lib/couchbase_helper/
H A Dcluster.py29 self.task_manager.schedule(_task)
43 self.task_manager.schedule(_task)
56 self.task_manager.schedule(_task)
71 self.task_manager.schedule(_task)
84 self.task_manager.schedule(_task)
101 self.task_manager.schedule(_task)
133 self.task_manager.schedule(_task)
146 self.task_manager.schedule(_task)
153 self.task_manager.schedule(_task)
164 self.task_manager.schedule(_tas
[all...]
/6.6.0/testrunner/lib/old_tasks/
H A Dtask.py66 task_manager.schedule(self)
70 task_manager.schedule(self)
107 task_manager.schedule(self)
131 task_manager.schedule(self)
148 task_manager.schedule(self)
165 task_manager.schedule(self)
178 task_manager.schedule(self)
233 task_manager.schedule(self)
254 task_manager.schedule(self)
268 task_manager.schedule(sel
[all...]
H A Dtaskmanager.py14 def schedule(self, task, sleep_time=0): member in TaskManager
16 raise TypeError("Tried to schedule somthing that's not a task")
/6.6.0/kv_engine/engines/ep/tests/module_tests/
H A Dbackfill-manager_test.cc109 // Test: schedule both backfills, then instruct the backfill manager to in TEST_F()
112 backfillMgr->schedule(std::move(backfill0))); in TEST_F()
114 backfillMgr->schedule(std::move(backfill1))); in TEST_F()
116 backfillMgr->schedule(std::move(backfill2))); in TEST_F()
170 // Test: schedule all backfills, then instruct the backfill manager to in TEST_F()
174 backfillMgr->schedule(std::move(backfill0))); in TEST_F()
176 backfillMgr->schedule(std::move(backfill1))); in TEST_F()
178 backfillMgr->schedule(std::move(backfill2))); in TEST_F()
194 // schedule() is called, as that takes ownership of the object). in TEST_F()
197 // Calls to schedule() fo in TEST_F()
[all...]
H A Dexecutorpool_test.cc140 pool.schedule(task);
197 pool.schedule(task);
351 pool->schedule(task);
357 pool->schedule(task);
377 ASSERT_EQ(taskId, pool->schedule(task));
378 ASSERT_EQ(taskId, pool->schedule(task));
/6.6.0/testrunner/pytests/failover/
H A DAutoFailoverBaseTest.py211 self.task_manager.schedule(node_monitor_task, sleep_time=5)
231 self.node_failure_task_manager.schedule(node_down_timer_task, 2)
232 self.task_manager.schedule(task)
251 self.task_manager.schedule(task)
275 self.node_failure_task_manager.schedule(node_down_timer_task, 2)
276 self.task_manager.schedule(task)
300 self.node_failure_task_manager.schedule(node_down_timer_task, 2)
301 self.task_manager.schedule(task)
317 self.task_manager.schedule(task)
342 self.node_failure_task_manager.schedule(node_down_timer_tas
[all...]
/6.6.0/kv_engine/tests/executor/
H A Dexecutor_test.cc84 executorpool->schedule(task); in TEST_F()
101 executorpool->schedule(task); in TEST_F()
120 EXPECT_THROW(executorpool->schedule(task), std::logic_error); in TEST_F()
127 executorpool->schedule(task); in TEST_F()
169 executorpool->schedule(task, false); in TEST_F()
259 executorpool->schedule(task, false); in TEST_F()
339 executorpool->schedule(task, false); in TEST_F()
/6.6.0/kv_engine/daemon/
H A Dexecutorpool.cc39 void cb::ExecutorPool::schedule(std::shared_ptr<Task>& task, bool runnable) { in schedule() function in cb::ExecutorPool
43 "The mutex should be held when trying to schedule a event"); in schedule()
46 executors[++roundRobin % executors.size()]->schedule(task, runnable); in schedule()
H A Dexecutorpool.h61 void schedule(std::shared_ptr<Task>& task, bool runnable = true);
H A Dexecutor.h62 void schedule(const std::shared_ptr<Task>& command, bool runnable);
H A Dtracing.cc93 executorPool->schedule(task); in initializeTracing()
242 executorPool->schedule(basicTask, true); in ioctlGetTracingDumpChunk()
/6.6.0/testrunner/lib/tasks/
H A Dtask.py78 task_manager.schedule(self)
238 task_manager.schedule(self)
292 task_manager.schedule(self)
330 task_manager.schedule(self)
364 task_manager.schedule(self)
378 task_manager.schedule(self)
457 task_manager.schedule(self)
560 task_manager.schedule(self, 10)
619 task_manager.schedule(self)
642 task_manager.schedule(sel
[all...]
H A Dtaskmanager.py16 def schedule(self, task, sleep_time=0): member in TaskManager
18 raise TypeError("Tried to schedule somthing that's not a task")
/6.6.0/kv_engine/daemon/protocol/mcbp/
H A Dcreate_remove_bucket_command_context.cc86 executorPool->schedule(task, false); in create()
113 executorPool->schedule(task, false); in remove()
H A Drbac_reload_command_context.cc76 executorPool->schedule(task); in reload()
/6.6.0/kv_engine/engines/ep/src/
H A Dkv_bucket.cc461 ExecutorPool::get()->schedule(htrTask); in initialize()
466 ExecutorPool::get()->schedule(chkTask); in initialize()
472 ExecutorPool::get()->schedule(durabilityTimeoutTask); in initialize()
476 ExecutorPool::get()->schedule(durabilityCompletionTask); in initialize()
480 ExecutorPool::get()->schedule(workloadMonitorTask); in initialize()
487 ExecutorPool::get()->schedule(defragmenterTask); in initialize()
501 ExecutorPool::get()->schedule(itemFreqDecayerTask); in initialize()
846 ExecutorPool::get()->schedule(notifyTask); in releaseRegisteredSyncWrites()
914 ExecutorPool::get()->schedule(notifyTask); in setVBucketState_UNLOCKED()
981 ExecutorPool::get()->schedule(notifyTas in setVBucketState_UNLOCKED()
[all...]
H A Dwarmup.cc969 ExecutorPool::get()->schedule(task); in scheduleInitialize()
999 ExecutorPool::get()->schedule(task); in scheduleCreateVBuckets()
1134 ExecutorPool::get()->schedule(task); in scheduleLoadingCollectionCounts()
1177 ExecutorPool::get()->schedule(task); in scheduleEstimateDatabaseItemCount()
1218 ExecutorPool::get()->schedule(task); in scheduleLoadPreparedSyncWrites()
1252 ExecutorPool::get()->schedule(task); in schedulePopulateVBucketMap()
1281 ExecutorPool::get()->schedule(task); in scheduleKeyDump()
1315 ExecutorPool::get()->schedule(task); in scheduleCheckForAccessLog()
1357 ExecutorPool::get()->schedule(task); in scheduleLoadingAccessLog()
1474 ExecutorPool::get()->schedule(tas in scheduleLoadingKVPairs()
[all...]
H A Dconn_notifier.cc71 task = ExecutorPool::get()->schedule(connotifyTask); in start()
H A Dtaskqueue.h35 void schedule(ExTask &task);
H A Dephemeral_bucket.cc82 // Cancel and re-schedule the task to pick up the new interval.
124 // dynamic config changes (and later schedule it). in initialize()
146 ExecutorPool::get()->schedule(notifyHpReqTask); in initialize()
155 // No-eviction Ephemeral buckets don't schedule the item pager, which in attemptToFreeMemory()
246 ExecutorPool::get()->schedule(tombstonePurgerTask); in enableTombstonePurgerTask()
H A Dbgfetcher.cc52 iom->schedule(task); in start()
/6.6.0/kv_engine/engines/ep/src/dcp/
H A Dactive_stream_checkpoint_processor_task.h52 void schedule(std::shared_ptr<ActiveStream> stream);
H A Dactive_stream_checkpoint_processor_task.cc78 void ActiveStreamCheckpointProcessorTask::schedule( in schedule() function in ActiveStreamCheckpointProcessorTask
/6.6.0/kv_engine/engines/ep/benchmarks/
H A Daccess_scanner_bench.cc78 ExecutorPool::get()->schedule(task); in BENCHMARK_DEFINE_F()
/6.6.0/testrunner/pytests/fts/
H A Des_base.py414 self.task_manager.schedule(_task)
423 self.task_manager.schedule(_task)

Completed in 86 milliseconds

123