Home
last modified time | relevance | path

Searched refs:inTask (Results 1 - 8 of 8) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_vacuum.cpp293 void MultiVerVacuum::ExecuteSpecificVacuumTask(VacuumTaskContext &inTask) in ExecuteSpecificVacuumTask() argument
297 if (inTask.leftBranchCommits.empty() && inTask.rightBranchCommits.empty()) { in ExecuteSpecificVacuumTask()
299 int errCode = inTask.databaseHandle->GetVacuumAbleCommits(inTask.leftBranchCommits, inTask.rightBranchCommits); in ExecuteSpecificVacuumTask()
303 FinishVaccumTask(inTask); in ExecuteSpecificVacuumTask()
309 while (!inTask.leftBranchCommits.empty()) { in ExecuteSpecificVacuumTask()
310 int errCode = DealWithLeftBranchCommit(inTask); in ExecuteSpecificVacuumTask()
318 while (!inTask in ExecuteSpecificVacuumTask()
345 DealWithLeftBranchCommit(VacuumTaskContext &inTask) DealWithLeftBranchCommit() argument
350 DealWithLeftBranchVacuumNeedRecord(VacuumTaskContext &inTask) DealWithLeftBranchVacuumNeedRecord() argument
403 DealWithLeftBranchShadowRecord(VacuumTaskContext &inTask) DealWithLeftBranchShadowRecord() argument
408 DealWithRightBranchCommit(VacuumTaskContext &inTask) DealWithRightBranchCommit() argument
413 DealWithRightBranchVacuumNeedRecord(VacuumTaskContext &inTask) DealWithRightBranchVacuumNeedRecord() argument
418 DoDealCommitOfLeftOrRight(VacuumTaskContext &inTask, std::list<MultiVerCommitInfo> &commitList, bool isLeft) DoDealCommitOfLeftOrRight() argument
470 DoDeleteRecordOfLeftShadowOrRightVacuumNeed(VacuumTaskContext &inTask, std::list<MultiVerRecordInfo> &recordList) DoDeleteRecordOfLeftShadowOrRightVacuumNeed() argument
500 DoRollBackAndFinish(VacuumTaskContext &inTask) DoRollBackAndFinish() argument
507 DoCommitAndQuitIfWaitStatusObserved(VacuumTaskContext &inTask) DoCommitAndQuitIfWaitStatusObserved() argument
539 StartTransactionIfNotYet(VacuumTaskContext &inTask) StartTransactionIfNotYet() argument
552 CommitTransactionIfNeed(VacuumTaskContext &inTask) CommitTransactionIfNeed() argument
566 RollBackTransactionIfNeed(VacuumTaskContext &inTask) RollBackTransactionIfNeed() argument
578 FinishVaccumTask(VacuumTaskContext &inTask) FinishVaccumTask() argument
588 RelaunchVacuumTask(VacuumTaskContext &inTask) RelaunchVacuumTask() argument
597 AbortVacuumTask(VacuumTaskContext &inTask) AbortVacuumTask() argument
605 ResetNodeAndRecordContextInfo(VacuumTaskContext &inTask) ResetNodeAndRecordContextInfo() argument
655 IncPauseNeedCount(VacuumTaskContext &inTask) IncPauseNeedCount() argument
660 DecPauseNeedCount(VacuumTaskContext &inTask) DecPauseNeedCount() argument
669 IsPauseNotNeed(VacuumTaskContext &inTask) IsPauseNotNeed() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dmulti_ver_vacuum.h93 void ExecuteSpecificVacuumTask(VacuumTaskContext &inTask);
95 int DealWithLeftBranchCommit(VacuumTaskContext &inTask);
96 int DealWithLeftBranchVacuumNeedRecord(VacuumTaskContext &inTask);
97 int DealWithLeftBranchShadowRecord(VacuumTaskContext &inTask);
98 int DealWithRightBranchCommit(VacuumTaskContext &inTask);
99 int DealWithRightBranchVacuumNeedRecord(VacuumTaskContext &inTask);
102 int DoDealCommitOfLeftOrRight(VacuumTaskContext &inTask, std::list<MultiVerCommitInfo> &commitList, bool isLeft);
105 int DoDeleteRecordOfLeftShadowOrRightVacuumNeed(VacuumTaskContext &inTask,
109 void DoRollBackAndFinish(VacuumTaskContext &inTask);
110 int DoCommitAndQuitIfWaitStatusObserved(VacuumTaskContext &inTask); // Retur
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dsend_task_scheduler.cpp67 int SendTaskScheduler::AddSendTaskIntoSchedule(const SendTask &inTask, Priority inPrio) in AddSendTaskIntoSchedule() argument
74 uint32_t taskSizeByByte = inTask.buffer->GetSize(); in AddSendTaskIntoSchedule()
77 totalBytesByTarget_[inTask.dstTarget] += taskSizeByByte; in AddSendTaskIntoSchedule()
78 if (policyMap_.count(inTask.dstTarget) == 0) { in AddSendTaskIntoSchedule()
79 policyMap_[inTask.dstTarget] = TargetPolicy::NO_DELAY; in AddSendTaskIntoSchedule()
81 if (policyMap_[inTask.dstTarget] == TargetPolicy::DELAY) { in AddSendTaskIntoSchedule()
87 taskOrderByPrio_[inPrio].push_back(inTask.dstTarget); in AddSendTaskIntoSchedule()
88 taskGroupByPrio_[inPrio][inTask.dstTarget].push_back(inTask); in AddSendTaskIntoSchedule()
H A Dcommunicator_aggregator.cpp370 void CommunicatorAggregator::SendPacketsAndDisposeTask(const SendTask &inTask, uint32_t mtu, in SendPacketsAndDisposeTask() argument
375 ResetFrameRecordIfNeed(inTask.frameId, mtu); in SendPacketsAndDisposeTask()
379 startIndex = sendRecord_[inTask.frameId].sendIndex; in SendPacketsAndDisposeTask()
381 uint64_t currentSendSequenceId = IncreaseSendSequenceId(inTask.dstTarget); in SendPacketsAndDisposeTask()
382 for (uint32_t index = startIndex; index < static_cast<uint32_t>(eachPacket.size()) && inTask.isValid; ++index) { in SendPacketsAndDisposeTask()
385 ", packetLength=%" PRIu32 ".", inTask.dstTarget.c_str(), entry.second.first, entry.second.second); in SendPacketsAndDisposeTask()
387 errCode = adapterHandle_->SendBytes(inTask.dstTarget, entry.first, entry.second.second, totalLength); in SendPacketsAndDisposeTask()
390 sendRecord_[inTask.frameId].sendIndex = index; in SendPacketsAndDisposeTask()
401 retryCount_[inTask.dstTarget] = 0; in SendPacketsAndDisposeTask()
405 RetrySendTaskIfNeed(inTask in SendPacketsAndDisposeTask()
414 RetryUntilTimeout(SendTask &inTask, uint32_t timeout, Priority inPrio) RetryUntilTimeout() argument
450 TaskFinalizer(const SendTask &inTask, int result) TaskFinalizer() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dcommunicator_aggregator.h97 void SendPacketsAndDisposeTask(const SendTask &inTask, uint32_t mtu,
100 int RetryUntilTimeout(SendTask &inTask, uint32_t timeout, Priority inPrio);
101 void TaskFinalizer(const SendTask &inTask, int result);
H A Dsend_task_scheduler.h64 int AddSendTaskIntoSchedule(const SendTask &inTask, Priority inPrio);
/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_handler.h41 void Dispatch(QueueTask* inTask);
H A Dqueue_handler.cpp204 void QueueHandler::Dispatch(QueueTask* inTask) in Dispatch() argument
207 for (QueueTask* task = inTask; task != nullptr; task = nextTask) { in Dispatch()

Completed in 6 milliseconds