Lines Matching refs:LocIpcRecver
46 class LocIpcRecver; variable
56 virtual void onReceive(const char* data, uint32_t len, const LocIpcRecver* recver) = 0;
105 static unique_ptr<LocIpcRecver>
108 static unique_ptr<LocIpcRecver>
111 static unique_ptr<LocIpcRecver>
114 inline static unique_ptr<LocIpcRecver>
120 static unique_ptr<LocIpcRecver>
125 static pair<shared_ptr<LocIpcSender>, unique_ptr<LocIpcRecver>>
133 static bool startBlockingListening(LocIpcRecver& ipcRecver);
134 static void stopBlockingListening(LocIpcRecver& ipcRecver);
139 bool startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver);
169 virtual unique_ptr<LocIpcRecver> getRecver(const shared_ptr<ILocIpcListener>& listener) { in getRecver()
175 class LocIpcRecver {
179 inline LocIpcRecver(const shared_ptr<ILocIpcListener>& listener, LocIpcSender& sender) : in LocIpcRecver() function
181 LocIpcRecver(LocIpcRecver const& recver) = delete;
182 LocIpcRecver& operator=(LocIpcRecver const& recver) = delete;
185 virtual ~LocIpcRecver() = default;
202 ssize_t recvfrom(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb,
211 ssize_t recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags,
222 class SockRecver : public LocIpcRecver {
231 LocIpcRecver(listener, sender), mSock(sock) { in SockRecver()