Home
last modified time | relevance | path

Searched refs:looper (Results 1 – 7 of 7) sorted by relevance

/system/core/libutils/
DLooper_fuzz.cpp41 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe) -> void { in __anon46cfd9970102()
42 looper->pollOnce(dataProvider->ConsumeIntegralInRange<int>(0, MAX_POLL_DELAY)); in __anon46cfd9970102()
44 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe) -> void { in __anon46cfd9970202()
45 looper->pollAll(dataProvider->ConsumeIntegralInRange<int>(0, MAX_POLL_DELAY)); in __anon46cfd9970202()
48 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon46cfd9970302()
49 looper->addFd(pipeObj.receiveFd, dataProvider->ConsumeIntegral<int>(), in __anon46cfd9970302()
53 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon46cfd9970402()
54 looper->addFd(pipeObj.receiveFd, dataProvider->ConsumeIntegral<int>(), in __anon46cfd9970402()
58 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon46cfd9970502()
59 looper->addFd(pipeObj.receiveFd, dataProvider->ConsumeIntegral<int>(), in __anon46cfd9970502()
[all …]
DLooper.cpp106 void Looper::setForThread(const sp<Looper>& looper) { in setForThread() argument
109 if (looper != nullptr) { in setForThread()
110 looper->incStrong((void*)threadDestructor); in setForThread()
113 pthread_setspecific(gTLSKey, looper.get()); in setForThread()
124 Looper* looper = (Looper*)pthread_getspecific(gTLSKey); in getForThread() local
125 return sp<Looper>::fromExisting(looper); in getForThread()
130 sp<Looper> looper = Looper::getForThread(); in prepare() local
131 if (looper == nullptr) { in prepare()
132 looper = sp<Looper>::make(allowNonCallbacks); in prepare()
133 Looper::setForThread(looper); in prepare()
[all …]
DLooper_test.cpp53 DelayedWake(int delayMillis, const sp<Looper> looper) : in DelayedWake() argument
54 DelayedTask(delayMillis), mLooper(looper) { in DelayedWake()
79 void setCallback(const sp<Looper>& looper, int fd, int events) { in setCallback() argument
80 looper->addFd(fd, 0, events, staticHandler, this); in setCallback()
406 sp<Looper> looper = new Looper(false /*allowNonCallbacks*/); in TEST_F() local
407 int result = looper->addFd(pipe.receiveFd, 0, 0, nullptr, nullptr); in TEST_F()
730 explicit ThreadedLooperUtil(const sp<Looper>& looper) : mLooper(looper), mRunning(true) { in ThreadedLooperUtil() argument
/system/hwservicemanager/
Dservice.cpp67 static sp<HwBinderCallback> setupTo(const sp<Looper>& looper) { in setupTo() argument
77 int ret = looper->addFd(fdHwBinder, in setupTo()
96 …static sp<ClientCallbackCallback> setupTo(const sp<Looper>& looper, const sp<ServiceManager>& mana… in setupTo() argument
116 int addRes = looper->addFd(fdTimer, in setupTo()
174 sp<Looper> looper = Looper::prepare(0 /* opts */); in main() local
176 (void)HwBinderCallback::setupTo(looper); in main()
177 (void)ClientCallbackCallback::setupTo(looper, manager); in main()
182 looper->pollAll(-1 /* timeoutMillis */); in main()
/system/incremental_delivery/libdataloader/
DDataLoaderConnector.cpp855 auto&& looper = pendingReadsLooper(); in DataLoaderService_OnStart()
863 looper.addFd(control->pendingReads(), android::Looper::POLL_CALLBACK, in DataLoaderService_OnStart()
866 looper.wake(); in DataLoaderService_OnStart()
870 auto&& looper = logLooper(); in DataLoaderService_OnStart()
878 looper.addFd(control->logs(), android::Looper::POLL_CALLBACK, android::Looper::EVENT_INPUT, in DataLoaderService_OnStart()
880 looper.wake(); in DataLoaderService_OnStart()
/system/core/libutils/include/utils/
DLooper.h416 static void setForThread(const sp<Looper>& looper);
/system/tools/aidl/tests/
Daidl_test_service.cpp964 sp<Looper> looper(Looper::prepare(0 /* opts */)); in Run() local
974 if (looper->addFd(binder_fd, Looper::POLL_CALLBACK, Looper::EVENT_INPUT, cb, in Run()
1022 const int result = looper->pollAll(-1 /* timeoutMillis */); in Run()