Searched defs:inTask (Results 1 – 6 of 6) sorted by relevance
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| D | multi_ver_vacuum.cpp | 293 void MultiVerVacuum::ExecuteSpecificVacuumTask(VacuumTaskContext &inTask) in ExecuteSpecificVacuumTask()
345 int MultiVerVacuum::DealWithLeftBranchCommit(VacuumTaskContext &inTask) in DealWithLeftBranchCommit()
350 int MultiVerVacuum::DealWithLeftBranchVacuumNeedRecord(VacuumTaskContext &inTask) in DealWithLeftBranchVacuumNeedRecord()
403 int MultiVerVacuum::DealWithLeftBranchShadowRecord(VacuumTaskContext &inTask) in DealWithLeftBranchShadowRecord()
408 int MultiVerVacuum::DealWithRightBranchCommit(VacuumTaskContext &inTask) in DealWithRightBranchCommit()
413 int MultiVerVacuum::DealWithRightBranchVacuumNeedRecord(VacuumTaskContext &inTask) in DealWithRightBranchVacuumNeedRecord()
418 int MultiVerVacuum::DoDealCommitOfLeftOrRight(VacuumTaskContext &inTask, std::list<MultiVerCommitIn… in DoDealCommitOfLeftOrRight()
470 int MultiVerVacuum::DoDeleteRecordOfLeftShadowOrRightVacuumNeed(VacuumTaskContext &inTask, in DoDeleteRecordOfLeftShadowOrRightVacuumNeed()
500 void MultiVerVacuum::DoRollBackAndFinish(VacuumTaskContext &inTask) in DoRollBackAndFinish()
507 int MultiVerVacuum::DoCommitAndQuitIfWaitStatusObserved(VacuumTaskContext &inTask) in DoCommitAndQuitIfWaitStatusObserved()
[all …]
|
| /foundation/resourceschedule/ffrt/src/sync/ |
| D | sleep.cpp | 55 CoWait([&](TaskCtx* inTask) -> bool { return DelayedWakeup(to, &inTask->fq_we, cb); }); in sleep_until_impl()
75 CoWait([](ffrt::TaskCtx* inTask) -> bool { in ffrt_yield()
|
| D | wait_queue.cpp | 76 CoWait([&](TaskCtx* inTask) -> bool { in SuspendAndWait()
123 CoWait([&](TaskCtx* inTask) -> bool { in SuspendAndWaitUntil()
|
| D | mutex.cpp | 108 CoWait([this](TaskCtx* inTask) -> bool { in wait()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| D | send_task_scheduler.cpp | 67 int SendTaskScheduler::AddSendTaskIntoSchedule(const SendTask &inTask, Priority inPrio) in AddSendTaskIntoSchedule()
|
| D | communicator_aggregator.cpp | 360 void CommunicatorAggregator::SendPacketsAndDisposeTask(const SendTask &inTask, uint32_t mtu, in SendPacketsAndDisposeTask()
409 int CommunicatorAggregator::RetryUntilTimeout(SendTask &inTask, uint32_t timeout, Priority inPrio) in RetryUntilTimeout()
445 void CommunicatorAggregator::TaskFinalizer(const SendTask &inTask, int result) in TaskFinalizer()
|