Lines Matching defs:lock
97 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in ~TaskManager() local
105 std::lock_guard<std::mutex> lock(callbackMutex_); in ~TaskManager() local
116 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in ~TaskManager() local
128 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in CountTraceForWorker() local
143 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetThreadInfos() local
156 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in GetThreadInfos() local
180 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTaskInfos() local
188 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in GetTaskInfos() local
241 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in CheckForBlockedWorkers() local
328 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetIdleWorkers() local
429 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetIdleWorkers() local
454 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyShrink() local
531 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in TryExpand() local
623 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CancelTask() local
672 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerIdle() local
691 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerAdded() local
698 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerRunning() local
705 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetRunningWorkers() local
713 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetTimeoutWorkers() local
719 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in GetTaskNum() local
748 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetThreadNum() local
755 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in EnqueueTaskId() local
773 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in EraseWaitingTaskId() local
781 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in DequeueTaskId() local
810 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in IsChooseIdle() local
837 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyExecuteTask() local
900 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in RemoveWorker() local
908 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in RestoreWorker() local
930 std::lock_guard<std::mutex> lock(callbackMutex_); in RegisterCallback() local
936 std::lock_guard<std::mutex> lock(callbackMutex_); in GetCallbackInfo() local
950 std::lock_guard<std::mutex> lock(callbackMutex_); in IncreaseRefCount() local
963 std::lock_guard<std::mutex> lock(callbackMutex_); in DecreaseRefCount() local
983 std::lock_guard<std::mutex> lock(callbackMutex_); in ResetCallbackInfoWorker() local
990 std::lock_guard<std::mutex> lock(callbackMutex_); in NotifyCallbackExecute() local
1025 std::lock_guard<std::mutex> lock(callbackMutex_); in GetMessageQueue() local
1039 std::lock_guard<std::mutex> lock(callbackMutex_); in GetMessageQueueFromCallbackInfo() local
1055 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in NotifyDependencyTaskInfo() local
1075 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in RemoveDependencyById() local
1087 std::shared_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in IsDependendByTaskId() local
1097 std::shared_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in IsDependentByTaskId() local
1109 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in StoreTaskDependency() local
1163 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in RemoveTaskDependency() local
1181 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in EnqueuePendingTaskInfo() local
1187 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in DequeuePendingTaskInfo() local
1205 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in RemovePendingTaskInfo() local
1212 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in StoreDependentTaskInfo() local
1227 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in RemoveDependentTaskInfo() local
1241 std::shared_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in GetTaskDependInfoToString() local
1255 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in StoreTaskDuration() local
1272 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in GetTaskDuration() local
1289 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTaskName() local
1300 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in RemoveTaskDuration() local
1309 std::unique_lock<std::shared_mutex> lock(longTasksMutex_); in StoreLongTaskInfo() local
1315 std::unique_lock<std::shared_mutex> lock(longTasksMutex_); in RemoveLongTaskInfo() local
1321 std::shared_lock<std::shared_mutex> lock(longTasksMutex_); in GetLongTaskInfo() local
1369 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in ReleaseTaskData() local
1378 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in ReleaseTaskData() local
1431 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in StoreTask() local
1437 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in RemoveTask() local
1443 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTask() local
1489 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in CheckTask() local
1503 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in AddTask() local
1551 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_); in CancelGroup() local
1590 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CancelGroupTask() local
1606 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in StoreSequenceRunner() local
1612 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in RemoveSequenceRunner() local
1618 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in GetSeqRunner() local
1629 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in AddTaskToSeqRunner() local
1657 std::unique_lock<std::shared_mutex> lock(seqRunner->seqRunnerMutex_); in TriggerSeqRunner() local
1698 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in StoreTaskGroup() local
1704 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in RemoveTaskGroup() local
1710 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in GetTaskGroup() local
1723 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in UpdateGroupState() local
1747 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in CreateOrGetGlobalRunner() local
1780 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in TriggerGlobalSeqRunner() local
1794 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in DecreaseSeqCount() local
1800 std::lock_guard<std::mutex> lock(globalSeqRunnerMutex_); in RemoveGlobalSeqRunnerRef() local
1810 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in RemoveSequenceRunner() local