Searched refs:ipcRecver (Results 1 – 6 of 6) sorted by relevance
322 inline LocIpcRunnable(LocIpc& locIpc, unique_ptr<LocIpcRecver>& ipcRecver) : in LocIpcRunnable() argument325 mIpcRecver(move(ipcRecver)) {} in LocIpcRunnable()344 bool LocIpc::startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver) { in startNonBlockingListening() argument345 if (ipcRecver != nullptr && ipcRecver->isRecvable()) { in startNonBlockingListening()347 threadName.append(ipcRecver->getName()); in startNonBlockingListening()348 mRunnable = new LocIpcRunnable(*this, ipcRecver); in startNonBlockingListening()356 bool LocIpc::startBlockingListening(LocIpcRecver& ipcRecver) { in startBlockingListening() argument357 if (ipcRecver.isRecvable()) { in startBlockingListening()359 ipcRecver.onListenerReady(); in startBlockingListening()360 while (ipcRecver.recvData()); in startBlockingListening()[all …]
97 static bool startBlockingListening(LocIpcRecver& ipcRecver);98 static void stopBlockingListening(LocIpcRecver& ipcRecver);103 bool startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver);
312 inline LocIpcRunnable(LocIpc& locIpc, unique_ptr<LocIpcRecver>& ipcRecver) : in LocIpcRunnable() argument315 mIpcRecver(move(ipcRecver)) {} in LocIpcRunnable()334 bool LocIpc::startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver) { in startNonBlockingListening() argument335 if (ipcRecver != nullptr && ipcRecver->isRecvable()) { in startNonBlockingListening()337 threadName.append(ipcRecver->getName()); in startNonBlockingListening()338 mRunnable = new LocIpcRunnable(*this, ipcRecver); in startNonBlockingListening()346 bool LocIpc::startBlockingListening(LocIpcRecver& ipcRecver) { in startBlockingListening() argument347 if (ipcRecver.isRecvable()) { in startBlockingListening()349 ipcRecver.onListenerReady(); in startBlockingListening()350 while (ipcRecver.recvData()); in startBlockingListening()[all …]