Lines Matching refs:LocIpcRecver
45 class LocIpcRecver; variable
56 virtual void onReceive(const char* data, uint32_t len, const LocIpcRecver* recver) = 0;
76 static unique_ptr<LocIpcRecver>
79 static unique_ptr<LocIpcRecver>
82 static unique_ptr<LocIpcRecver>
85 static unique_ptr<LocIpcRecver>
89 static pair<shared_ptr<LocIpcSender>, unique_ptr<LocIpcRecver>>
97 static bool startBlockingListening(LocIpcRecver& ipcRecver);
98 static void stopBlockingListening(LocIpcRecver& ipcRecver);
103 bool startNonBlockingListening(unique_ptr<LocIpcRecver>& ipcRecver);
135 virtual unique_ptr<LocIpcRecver> getRecver(const shared_ptr<ILocIpcListener>& listener) { in getRecver()
140 class LocIpcRecver {
144 inline LocIpcRecver(const shared_ptr<ILocIpcListener>& listener, LocIpcSender& sender) : in LocIpcRecver() function
146 LocIpcRecver(LocIpcRecver const& recver) = delete;
147 LocIpcRecver& operator=(LocIpcRecver const& recver) = delete;
150 virtual ~LocIpcRecver() = default;
167 ssize_t recvfrom(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb,
176 ssize_t recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags,
187 class SockRecver : public LocIpcRecver {
196 LocIpcRecver(listener, sender), mSock(sock) { in SockRecver()