Lines Matching +full:recv +full:- +full:not +full:- +full:empty
1 /*-
19 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
69 /*----------------------------- DevdCtl::Consumer ----------------------------*/
70 //- Consumer Static Private Data -----------------------------------------------
73 //- Consumer Public Methods ----------------------------------------------------
77 : m_devdSockFD(-1), in Consumer()
96 if (m_devdSockFD != -1) { in ConnectToDevd()
109 if (m_devdSockFD == -1) in ConnectToDevd()
114 if (result == -1) { in ConnectToDevd()
127 if (m_devdSockFD != -1) { in DisconnectFromDevd()
131 m_devdSockFD = -1; in DisconnectFromDevd()
140 len = ::recv(m_devdSockFD, buf, MAX_EVENT_SIZE, MSG_WAITALL); in ReadEvent()
141 if (len == -1) in ReadEvent()
144 /* NULL-terminate the result */ in ReadEvent()
160 bool consumed((*event)->Process()); in ReplayUnconsumedEvents()
193 if (! evString.empty()) { in NextEvent()
210 if (event->Process()) in ProcessEvents()
223 while (! s.empty()) ; in FlushEvents()
233 fds->fd = m_devdSockFD; in EventsPending()
234 fds->events = POLLIN; in EventsPending()
235 fds->revents = 0; in EventsPending()
237 } while (result == -1 && errno == EINTR); in EventsPending()
239 if (result == -1) in EventsPending()
242 if ((fds->revents & POLLERR) != 0) in EventsPending()
246 if ((fds->revents & POLLHUP) != 0) in EventsPending()
250 return ((fds->revents & POLLIN) != 0); in EventsPending()