Lines Matching refs:ipcRecver
275 inline LocIpcRunnable(LocIpc& locIpc, unique_ptr<LocIpcRecver>& ipcRecver) : in LocIpcRunnable() argument
278 mIpcRecver(move(ipcRecver)) {} in LocIpcRunnable()
297 bool LocIpc::startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver) { in startNonBlockingListening() argument
298 if (ipcRecver != nullptr && ipcRecver->isRecvable()) { in startNonBlockingListening()
300 threadName.append(ipcRecver->getName()); in startNonBlockingListening()
301 mRunnable = new LocIpcRunnable(*this, ipcRecver); in startNonBlockingListening()
309 bool LocIpc::startBlockingListening(LocIpcRecver& ipcRecver) { in startBlockingListening() argument
310 if (ipcRecver.isRecvable()) { in startBlockingListening()
312 ipcRecver.onListenerReady(); in startBlockingListening()
313 while (ipcRecver.recvData()); in startBlockingListening()
328 void LocIpc::stopBlockingListening(LocIpcRecver& ipcRecver) { in stopBlockingListening() argument
329 if (ipcRecver.isRecvable()) { in stopBlockingListening()
330 ipcRecver.abort(); in stopBlockingListening()