Lines Matching refs:ipcRecver
322 inline LocIpcRunnable(LocIpc& locIpc, unique_ptr<LocIpcRecver>& ipcRecver) : in LocIpcRunnable() argument
325 mIpcRecver(move(ipcRecver)) {} in LocIpcRunnable()
344 bool LocIpc::startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver) { in startNonBlockingListening() argument
345 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() argument
357 if (ipcRecver.isRecvable()) { in startBlockingListening()
359 ipcRecver.onListenerReady(); in startBlockingListening()
360 while (ipcRecver.recvData()); in startBlockingListening()
375 void LocIpc::stopBlockingListening(LocIpcRecver& ipcRecver) { in stopBlockingListening() argument
376 if (ipcRecver.isRecvable()) { in stopBlockingListening()
377 ipcRecver.abort(); in stopBlockingListening()