Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_vacuum.cpp297 if (inTask.leftBranchCommits.empty() && inTask.rightBranchCommits.empty()) { in ExecuteSpecificVacuumTask()
299 …int errCode = inTask.databaseHandle->GetVacuumAbleCommits(inTask.leftBranchCommits, inTask.rightBr… in ExecuteSpecificVacuumTask()
330 FinishVaccumTask(inTask); in ExecuteSpecificVacuumTask()
336 if (inTask.status == VacuumTaskStatus::RUN_NING && inTask.autoRelaunchOnce) { in ExecuteSpecificVacuumTask()
347 return DoDealCommitOfLeftOrRight(inTask, inTask.leftBranchCommits, true); in DealWithLeftBranchCommit()
405 return DoDeleteRecordOfLeftShadowOrRightVacuumNeed(inTask, inTask.shadowRecords); in DealWithLeftBranchShadowRecord()
410 return DoDealCommitOfLeftOrRight(inTask, inTask.rightBranchCommits, false); in DealWithRightBranchCommit()
415 return DoDeleteRecordOfLeftShadowOrRightVacuumNeed(inTask, inTask.vacuumNeedRecords); in DealWithRightBranchVacuumNeedRecord()
504 FinishVaccumTask(inTask); in DoRollBackAndFinish()
657 inTask.pauseNeedCount++; in IncPauseNeedCount()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dmulti_ver_vacuum.h95 int DealWithLeftBranchCommit(VacuumTaskContext &inTask);
98 int DealWithRightBranchCommit(VacuumTaskContext &inTask);
109 void DoRollBackAndFinish(VacuumTaskContext &inTask);
113 int StartTransactionIfNotYet(VacuumTaskContext &inTask);
116 int CommitTransactionIfNeed(VacuumTaskContext &inTask);
122 void FinishVaccumTask(VacuumTaskContext &inTask);
123 void RelaunchVacuumTask(VacuumTaskContext &inTask);
124 void AbortVacuumTask(VacuumTaskContext &inTask);
128 void IncPauseNeedCount(VacuumTaskContext &inTask);
129 void DecPauseNeedCount(VacuumTaskContext &inTask);
[all …]
/ohos5.0/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.cpp375 ResetFrameRecordIfNeed(inTask.frameId, mtu); in SendPacketsAndDisposeTask()
379 startIndex = sendRecord_[inTask.frameId].sendIndex; in SendPacketsAndDisposeTask()
390 sendRecord_[inTask.frameId].sendIndex = index; in SendPacketsAndDisposeTask()
401 retryCount_[inTask.dstTarget] = 0; in SendPacketsAndDisposeTask()
408 TaskFinalizer(inTask, errCode); in SendPacketsAndDisposeTask()
410 sendRecord_.erase(inTask.frameId); in SendPacketsAndDisposeTask()
419 auto retryFunc = [this, inPrio, &inTask]()->bool { in RetryUntilTimeout()
421 delete inTask.buffer; in RetryUntilTimeout()
422 inTask.buffer = nullptr; in RetryUntilTimeout()
453 if (inTask.onEnd) { in TaskFinalizer()
[all …]
/ohos5.0/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);
/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_handler.h42 void Dispatch(QueueTask* inTask);
H A Dqueue_handler.cpp221 void QueueHandler::Dispatch(QueueTask* inTask) in Dispatch() argument
224 for (QueueTask* task = inTask; task != nullptr; task = nextTask) { in Dispatch()