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
673 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerIdle() local
692 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerAdded() local
699 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyWorkerRunning() local
706 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetRunningWorkers() local
714 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetTimeoutWorkers() local
720 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in GetTaskNum() local
749 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetThreadNum() local
756 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in EnqueueTaskId() local
774 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in EraseWaitingTaskId() local
782 std::lock_guard<std::mutex> lock(taskQueuesMutex_); in DequeueTaskId() local
811 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in IsChooseIdle() local
838 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in NotifyExecuteTask() local
897 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in RemoveWorker() local
905 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in RestoreWorker() local
927 std::lock_guard<std::mutex> lock(callbackMutex_); in RegisterCallback() local
933 std::lock_guard<std::mutex> lock(callbackMutex_); in GetCallbackInfo() local
947 std::lock_guard<std::mutex> lock(callbackMutex_); in IncreaseRefCount() local
960 std::lock_guard<std::mutex> lock(callbackMutex_); in DecreaseRefCount() local
980 std::lock_guard<std::mutex> lock(callbackMutex_); in ResetCallbackInfoWorker() local
987 std::lock_guard<std::mutex> lock(callbackMutex_); in NotifyCallbackExecute() local
1022 std::lock_guard<std::mutex> lock(callbackMutex_); in GetMessageQueue() local
1036 std::lock_guard<std::mutex> lock(callbackMutex_); in GetMessageQueueFromCallbackInfo() local
1052 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in NotifyDependencyTaskInfo() local
1072 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in RemoveDependencyById() local
1084 std::shared_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in IsDependendByTaskId() local
1094 std::shared_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in IsDependentByTaskId() local
1106 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in StoreTaskDependency() local
1160 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in RemoveTaskDependency() local
1178 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in EnqueuePendingTaskInfo() local
1184 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in DequeuePendingTaskInfo() local
1202 std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_); in RemovePendingTaskInfo() local
1209 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in StoreDependentTaskInfo() local
1224 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in RemoveDependentTaskInfo() local
1238 std::shared_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in GetTaskDependInfoToString() local
1252 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in StoreTaskDuration() local
1269 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in GetTaskDuration() local
1286 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTaskName() local
1297 std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_); in RemoveTaskDuration() local
1306 std::unique_lock<std::shared_mutex> lock(longTasksMutex_); in StoreLongTaskInfo() local
1312 std::unique_lock<std::shared_mutex> lock(longTasksMutex_); in RemoveLongTaskInfo() local
1318 std::shared_lock<std::shared_mutex> lock(longTasksMutex_); in GetLongTaskInfo() local
1366 std::unique_lock<std::shared_mutex> lock(dependentTaskInfosMutex_); in ReleaseTaskData() local
1375 std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_); in ReleaseTaskData() local
1428 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in StoreTask() local
1434 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in RemoveTask() local
1440 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTask() local
1486 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in CheckTask() local
1500 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in AddTask() local
1521 std::lock_guard<RECURSIVE_MUTEX> lock(group->taskGroupMutex_); in ReleaseTaskGroupData() local
1552 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_); in CancelGroup() local
1591 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CancelGroupTask() local
1608 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in StoreSequenceRunner() local
1614 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in RemoveSequenceRunner() local
1620 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in GetSeqRunner() local
1631 std::unique_lock<std::mutex> lock(seqRunnersMutex_); in AddTaskToSeqRunner() local
1659 std::unique_lock<std::shared_mutex> lock(seqRunner->seqRunnerMutex_); in TriggerSeqRunner() local
1700 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in StoreTaskGroup() local
1706 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in RemoveTaskGroup() local
1712 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in GetTaskGroup() local
1725 std::lock_guard<std::mutex> lock(taskGroupsMutex_); in UpdateGroupState() local
1749 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in CreateOrGetGlobalRunner() local
1782 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in TriggerGlobalSeqRunner() local
1796 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in DecreaseSeqCount() local
1802 std::lock_guard<std::mutex> lock(globalSeqRunnerMutex_); in RemoveGlobalSeqRunnerRef() local
1812 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in RemoveSequenceRunner() local
1831 std::unique_lock<std::mutex> lock(globalSeqRunnerMutex_); in IncreaseGlobalSeqRunner() local