Lines Matching refs:globals
252 static Globals& globals() { in globals() function
253 static Globals globals; in globals() local
254 return globals; in globals()
316 if (auto factory = globals().dataLoaderFactory) { in onCreate()
327 auto factory = globals().managedDataLoaderFactory; in onCreate()
486 if (globals().stopped) { in onPendingReadsLooperEvent()
491 return dataLoaderConnector->onPendingReadsLooperEvent(globals().pendingReads); in onPendingReadsLooperEvent()
495 if (globals().stopped) { in onLogLooperEvent()
500 return dataLoaderConnector->onLogLooperEvent(globals().pageReads); in onLogLooperEvent()
568 while (!globals().stopped) { in pendingReadsLooperThread()
575 while (!globals().stopped) { in logLooperThread()
614 globals().dataLoaderFactory = factory; in DataLoader_Initialize()
658 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnCreate()
659 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnCreate()
660 if (dlIt != globals().dataLoaderConnectors.end()) { in DataLoaderService_OnCreate()
694 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnCreate()
696 globals().dataLoaderConnectors.try_emplace(storageId, in DataLoaderService_OnCreate()
703 globals().dataLoaderConnectors.erase(dlIt); in DataLoaderService_OnCreate()
732 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStart()
733 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnStart()
734 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnStart()
751 if (control->pendingReads() >= 0 && !globals().pendingReadsLooperThread.joinable()) { in DataLoaderService_OnStart()
753 globals().pendingReadsLooperThread = std::thread(&pendingReadsLooperThread); in DataLoaderService_OnStart()
755 if (control->logs() >= 0 && !globals().logLooperThread.joinable()) { in DataLoaderService_OnStart()
757 globals().logLooperThread = std::thread(&logLooperThread); in DataLoaderService_OnStart()
784 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStop_NoStatus()
785 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnStop_NoStatus()
786 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnStop_NoStatus()
803 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStop_NoStatus()
804 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnStop_NoStatus()
805 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnStop_NoStatus()
838 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnDestroy_NoStatus()
839 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnDestroy_NoStatus()
840 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnDestroy_NoStatus()
846 globals().dataLoaderConnectors.erase(dlIt); in DataLoaderService_OnDestroy_NoStatus()
933 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnPrepareImage()
934 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnPrepareImage()
935 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnPrepareImage()