Lines Matching refs:globals

267 static Globals& globals() {  in globals()  function
268 static Globals globals; in globals() local
269 return globals; in globals()
369 !tryFactory(globals().dataLoaderFactory, /*withFeatures=*/true, params, in onCreate()
374 !tryFactory(globals().legacyDataLoaderFactory, /*withFeatures=*/false, params, in onCreate()
379 !tryFactory(globals().managedDataLoaderFactory, /*withFeatures=*/false, params, in onCreate()
574 if (globals().stopped) { in onPendingReadsLooperEvent()
579 return dataLoaderConnector->onPendingReadsLooperEvent(globals().pendingReads, in onPendingReadsLooperEvent()
580 globals().pendingReadsWithUid); in onPendingReadsLooperEvent()
584 if (globals().stopped) { in onLogLooperEvent()
589 return dataLoaderConnector->onLogLooperEvent(globals().pageReads, globals().pageReadsWithUid); in onLogLooperEvent()
660 while (!globals().stopped) { in pendingReadsLooperThread()
667 while (!globals().stopped) { in logLooperThread()
706 globals().legacyDataLoaderFactory = factory; in DataLoader_Initialize()
711 globals().dataLoaderFactory = factory; in DataLoader_Initialize_WithFeatures()
755 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnCreate()
756 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnCreate()
757 if (dlIt != globals().dataLoaderConnectors.end()) { in DataLoaderService_OnCreate()
800 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnCreate()
802 globals().dataLoaderConnectors.try_emplace(storageId, in DataLoaderService_OnCreate()
810 globals().dataLoaderConnectors.erase(dlIt); in DataLoaderService_OnCreate()
837 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStart()
838 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnStart()
839 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnStart()
856 if (!globals().pendingReadsLooperThread.joinable()) { in DataLoaderService_OnStart()
857 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStart()
858 if (!globals().pendingReadsLooperThread.joinable()) { in DataLoaderService_OnStart()
859 globals().pendingReadsLooperThread = std::thread(&pendingReadsLooperThread); in DataLoaderService_OnStart()
871 if (!globals().logLooperThread.joinable()) { in DataLoaderService_OnStart()
872 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStart()
873 if (!globals().logLooperThread.joinable()) { in DataLoaderService_OnStart()
874 globals().logLooperThread = std::thread(&logLooperThread); in DataLoaderService_OnStart()
905 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnStop()
906 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnStop()
907 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnStop()
928 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnDestroy()
929 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnDestroy()
930 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnDestroy()
935 globals().dataLoaderConnectors.erase(dlIt); in DataLoaderService_OnDestroy()
1016 std::lock_guard lock{globals().dataLoaderConnectorsLock}; in DataLoaderService_OnPrepareImage()
1017 auto dlIt = globals().dataLoaderConnectors.find(storageId); in DataLoaderService_OnPrepareImage()
1018 if (dlIt == globals().dataLoaderConnectors.end()) { in DataLoaderService_OnPrepareImage()