Lines Matching refs:pds

96     PRPollDesc pds0[10], pds1[10], *pds, *other_pds;
155 pds = pds0;
157 memset(pds, 0, sizeof(pds));
159 pds[npds].fd = listenSock1;
160 pds[npds].in_flags = PR_POLL_READ;
162 pds[npds].fd = listenSock2;
163 pds[npds].in_flags = PR_POLL_READ;
182 pds[npds].fd = socket_poll_fd = PR_CreateSocketPollFd(sd);
183 PR_ASSERT(pds[npds].fd);
184 pds[npds].in_flags = PR_POLL_READ;
193 retVal = PR_Poll(pds, npds, PR_SecondsToInterval(5));
210 pds[npds].fd = badFD;
211 pds[npds].in_flags = PR_POLL_READ;
215 retVal = PR_Poll(pds, npds, PR_INTERVAL_NO_TIMEOUT);
216 if (retVal != 1 || (unsigned short) pds[2].out_flags != PR_POLL_NVAL) {
219 retVal, pds[npds - 1].out_flags);
267 retVal = PR_Poll(pds, npds, PR_INTERVAL_NO_TIMEOUT);
277 other_pds[j] = pds[j];
278 PR_ASSERT((pds[j].out_flags & PR_POLL_WRITE) == 0
279 && (pds[j].out_flags & PR_POLL_EXCEPT) == 0);
280 if (pds[j].out_flags & PR_POLL_READ) {
286 newsd = accept(PR_FileDesc2NativeHandle(pds[j].fd), NULL, 0);
295 sock = PR_Accept(pds[j].fd, NULL, PR_INTERVAL_NO_TIMEOUT);
304 } else if (pds[j].out_flags & PR_POLL_ERR) {
307 } else if (pds[j].out_flags & PR_POLL_NVAL) {
309 PR_FileDesc2NativeHandle(pds[j].fd));
315 PR_ASSERT((pds[j].out_flags & PR_POLL_WRITE) == 0
316 && (pds[j].out_flags & PR_POLL_EXCEPT) == 0);
317 if (pds[j].out_flags & PR_POLL_READ) {
322 if (PR_GetDescType(pds[j].fd) == (PRDescType) 0) {
323 nBytes = recv(PR_FileDesc2NativeHandle(pds[j].fd), buf,
330 PR_FileDesc2NativeHandle(pds[j].fd));
332 closesocket((SOCKET)PR_FileDesc2NativeHandle(pds[j].fd));
334 close(PR_FileDesc2NativeHandle(pds[j].fd));
336 PR_DestroySocketPollFd(pds[j].fd);
338 nBytes = PR_Read(pds[j].fd, buf, sizeof(buf));
343 PR_Close(pds[j].fd);
348 } else if (pds[j].out_flags & PR_POLL_ERR) {
351 } else if (pds[j].out_flags & PR_POLL_NVAL) {
355 other_pds[nextIndex] = pds[j];
362 tmp = pds;
363 pds = other_pds;