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
430 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetIdleWorkers() local
455 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyShrink() local
532 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in TryExpand() local
636 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CancelTask() local
651 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CancelTask() local
685 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerIdle() local
704 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerAdded() local
711 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerRunning() local
718 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetRunningWorkers() local
726 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetTimeoutWorkers() local
732 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in GetTaskNum() local
761 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetThreadNum() local
768 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in EnqueueTaskId() local
786 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in EraseWaitingTaskId() local
796 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in DequeueTaskId() local
825 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in IsChooseIdle() local
852 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyExecuteTask() local
911 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in RemoveWorker() local
919 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in RestoreWorker() local
941 std::lock_guard<std::mutex> lock(callbackMutex_); in RegisterCallback() local
947 std::lock_guard<std::mutex> lock(callbackMutex_); in GetCallbackInfo() local
961 std::lock_guard<std::mutex> lock(callbackMutex_); in IncreaseRefCount() local
974 std::lock_guard<std::mutex> lock(callbackMutex_); in DecreaseRefCount() local
994 std::lock_guard<std::mutex> lock(callbackMutex_); in ResetCallbackInfoWorker() local
1001 std::lock_guard<std::mutex> lock(callbackMutex_); in NotifyCallbackExecute() local
1036 std::lock_guard<std::mutex> lock(callbackMutex_); in GetMessageQueue() local
1050 std::lock_guard<std::mutex> lock(callbackMutex_); in GetMessageQueueFromCallbackInfo() local
1066 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in NotifyDependencyTaskInfo() local
1086 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in RemoveDependencyById() local
1098 std::shared_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in IsDependendByTaskId() local
1108 std::shared_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in IsDependentByTaskId() local
1120 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in StoreTaskDependency() local
1174 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in RemoveTaskDependency() local
1192 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in EnqueuePendingTaskInfo() local
1198 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in DequeuePendingTaskInfo() local
1216 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in RemovePendingTaskInfo() local
1223 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in StoreDependentTaskInfo() local
1238 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in RemoveDependentTaskInfo() local
1252 std::shared_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in GetTaskDependInfoToString() local
1266 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in StoreTaskDuration() local
1283 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in GetTaskDuration() local
1300 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTaskName() local
1311 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in RemoveTaskDuration() local
1320 std::unique_lock<std::shared_mutex> lock(longTasksMutex_); in StoreLongTaskInfo() local
1326 std::unique_lock<std::shared_mutex> lock(longTasksMutex_); in RemoveLongTaskInfo() local
1332 std::shared_lock<std::shared_mutex> lock(longTasksMutex_); in GetLongTaskInfo() local
1380 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in ReleaseTaskData() local
1389 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in ReleaseTaskData() local
1442 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in StoreTask() local
1448 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in RemoveTask() local
1454 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTask() local
1500 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in CheckTask() local
1525 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in AddTask() local
1546 std::lock_guard<RECURSIVE_MUTEX> lock(group->taskGroupMutex_); in ReleaseTaskGroupData() local
1577 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_); in CancelGroup() local
1616 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CancelGroupTask() local
1633 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in StoreSequenceRunner() local
1639 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in RemoveSequenceRunner() local
1645 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in GetSeqRunner() local
1656 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in AddTaskToSeqRunner() local
1684 std::unique_lock<std::shared_mutex> lock(seqRunner->seqRunnerMutex_); in TriggerSeqRunner() local
1725 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in StoreTaskGroup() local
1731 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in RemoveTaskGroup() local
1737 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in GetTaskGroup() local
1750 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in UpdateGroupState() local
1774 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in CreateOrGetGlobalRunner() local
1807 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in TriggerGlobalSeqRunner() local
1821 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in DecreaseSeqCount() local
1827 std::lock_guard<std::mutex> lock(globalSeqRunnerMutex_); in RemoveGlobalSeqRunnerRef() local
1837 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in RemoveSequenceRunner() local
1856 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in IncreaseGlobalSeqRunner() local