103     PRRecvWait *desc_out = PR_NEWZAP(PRRecvWait);  in CreateRecvWait()  local
104     MW_ASSERT(NULL != desc_out);  in CreateRecvWait()
107     desc_out->fd = fd;  in CreateRecvWait()
108     desc_out->timeout = timeout;  in CreateRecvWait()
109     desc_out->buffer.length = 120;  in CreateRecvWait()
110     desc_out->buffer.start = PR_CALLOC(120);  in CreateRecvWait()
115         PrintRecvDesc(desc_out, "Allocated");  in CreateRecvWait()
117     return desc_out;  in CreateRecvWait()
120 static void DestroyRecvWait(PRRecvWait *desc_out)  in DestroyRecvWait()  argument
123         PrintRecvDesc(desc_out, "Destroying");  in DestroyRecvWait()
125     PR_Close(desc_out->fd);  in DestroyRecvWait()
126     if (NULL != desc_out->buffer.start) {  in DestroyRecvWait()
127         PR_DELETE(desc_out->buffer.start);  in DestroyRecvWait()
129     PR_Free(desc_out);  in DestroyRecvWait()
135     PRRecvWait *desc_out;  in CancelGroup()  local
143         desc_out = PR_CancelWaitGroup(shared->group);  in CancelGroup()
144         if (NULL != desc_out) {  in CancelGroup()
145             DestroyRecvWait(desc_out);  in CancelGroup()
147     } while (NULL != desc_out);  in CancelGroup()
223     PRRecvWait *desc_out, *desc_in = PR_NEWZAP(PRRecvWait);  in OneInThenCancelled()  local
243     desc_out = PR_WaitRecvReady(shared->group);  in OneInThenCancelled()
244     MW_ASSERT(desc_out == desc_in);  in OneInThenCancelled()
245     MW_ASSERT(PR_MW_INTERRUPT == desc_out->outcome);  in OneInThenCancelled()
248         PrintRecvDesc(desc_out, "Ready");  in OneInThenCancelled()
264     PRRecvWait *desc_out, *desc_in = PR_NEWZAP(PRRecvWait);  in OneOpOneThread()  local
275     desc_out = PR_WaitRecvReady(shared->group);  in OneOpOneThread()
276     MW_ASSERT(desc_out == desc_in);  in OneOpOneThread()
277     MW_ASSERT(PR_MW_TIMEOUT == desc_out->outcome);  in OneOpOneThread()
280         PrintRecvDesc(desc_out, "Ready");  in OneOpOneThread()
294     PRRecvWait *desc_out;  in ManyOpOneThread()  local
310         desc_out = PR_WaitRecvReady(shared->group);  in ManyOpOneThread()
311         MW_ASSERT(PR_MW_TIMEOUT == desc_out->outcome);  in ManyOpOneThread()
314             PrintRecvDesc(desc_out, "Ready/readding");  in ManyOpOneThread()
316         rv = PR_AddWaitFileDesc(shared->group, desc_out);  in ManyOpOneThread()
326     PRRecvWait *desc_out;  in SomeOpsThread()  local
331         desc_out = PR_WaitRecvReady(shared->group);  in SomeOpsThread()
332         if (NULL == desc_out)  in SomeOpsThread()
340         MW_ASSERT(PR_MW_TIMEOUT == desc_out->outcome);  in SomeOpsThread()
343             PrintRecvDesc(desc_out, "Ready");  in SomeOpsThread()
347             PrintRecvDesc(desc_out, "Re-Adding");  in SomeOpsThread()
349         desc_out->timeout = shared->timeout;  in SomeOpsThread()
350         rv = PR_AddWaitFileDesc(shared->group, desc_out);  in SomeOpsThread()
454     PRRecvWait *desc_out = NULL;  in ServiceThread()  local
458         if (NULL != desc_out)  in ServiceThread()
460             desc_out->timeout = PR_INTERVAL_NO_TIMEOUT;  in ServiceThread()
462                 PrintRecvDesc(desc_out, "Service re-adding");  in ServiceThread()
464             rv = PR_AddWaitFileDesc(shared->group, desc_out);  in ServiceThread()
468         desc_out = PR_WaitRecvReady(shared->group);  in ServiceThread()
469         if (NULL == desc_out)  in ServiceThread()
475         switch (desc_out->outcome)  in ServiceThread()
481                     PrintRecvDesc(desc_out, "Service ready");  in ServiceThread()
483                 rv = ServiceRequest(shared, desc_out);  in ServiceThread()
502     if (NULL != desc_out) {  in ServiceThread()
503         DestroyRecvWait(desc_out);  in ServiceThread()