Lines Matching refs:rv

79     PRStatus rv = PR_PushIOLayer(stack, PR_GetLayersIdentity(stack), layer);
82 PR_ASSERT(PR_SUCCESS == rv);
90 PRStatus rv;
95 rv = PR_PushIOLayer(stack, PR_GetLayersIdentity(stack), layer);
99 PR_ASSERT(PR_SUCCESS == rv);
103 rv = PR_PushIOLayer(stack, PR_GetLayersIdentity(stack), layer);
107 PR_ASSERT(PR_SUCCESS == rv);
112 rv = PR_PushIOLayer(stack, PR_GetLayersIdentity(stack), layer);
116 PR_ASSERT(PR_SUCCESS == rv);
134 PRStatus rv;
143 rv = PR_Connect(stack, &server_address, PR_INTERVAL_NO_TIMEOUT);
144 PR_ASSERT(PR_SUCCESS == rv);
162 rv = PR_Shutdown(stack, PR_SHUTDOWN_BOTH); PR_ASSERT(PR_SUCCESS == rv);
167 PRStatus rv;
199 rv = PR_Shutdown(service, PR_SHUTDOWN_BOTH); PR_ASSERT(PR_SUCCESS == rv);
200 rv = PR_Close(service); PR_ASSERT(PR_SUCCESS == rv);
210 PRInt32 rv, readin = 0, request = 0;
211 rv = lo->methods->recv(lo, &request, sizeof(request), flags, timeout);
214 if (0 < rv)
218 rv = lo->methods->send(
220 if (0 < rv)
226 rv = lo->methods->recv(
228 if (rv <= 0) break;
230 logFile, "MyRecv received %d bytes\n", rv);
231 readin += rv;
233 rv = readin;
236 return rv;
245 PRInt32 rv, wroteout = 0, request;
248 rv = lo->methods->send(lo, &amount, sizeof(amount), flags, timeout);
249 if (0 < rv)
251 rv = lo->methods->recv(
253 if (0 < rv)
260 rv = lo->methods->send(
262 if (rv <= 0) break;
264 logFile, "MySend wrote %d bytes\n", rv);
265 wroteout += rv;
267 rv = amount;
270 return rv;
283 PRStatus rv;
344 rv = PR_InitializeNetAddr(
348 rv = PR_StringToNetAddr(server_name, &server_address);
349 PR_ASSERT(PR_SUCCESS == rv);
350 rv = PR_InitializeNetAddr(
353 PR_ASSERT(PR_SUCCESS == rv);
364 rv = PR_InitializeNetAddr(PR_IpAddrAny, default_port, &any_address);
365 PR_ASSERT(PR_SUCCESS == rv);
366 rv = PR_Bind(service, &any_address); PR_ASSERT(PR_SUCCESS == rv);
367 rv = PR_Listen(service, 10); PR_ASSERT(PR_SUCCESS == rv);
382 rv = PR_JoinThread(client_thread);
383 PR_ASSERT(PR_SUCCESS == rv);
384 rv = PR_JoinThread(server_thread);
385 PR_ASSERT(PR_SUCCESS == rv);
387 rv = PR_Close(client); PR_ASSERT(PR_SUCCESS == rv);
388 rv = PR_Close(service); PR_ASSERT(PR_SUCCESS == rv);
399 rv = PR_InitializeNetAddr(PR_IpAddrAny, default_port, &any_address);
400 PR_ASSERT(PR_SUCCESS == rv);
401 rv = PR_Bind(service, &any_address); PR_ASSERT(PR_SUCCESS == rv);
402 rv = PR_Listen(service, 10); PR_ASSERT(PR_SUCCESS == rv);
417 rv = PR_JoinThread(client_thread);
418 PR_ASSERT(PR_SUCCESS == rv);
419 rv = PR_JoinThread(server_thread);
420 PR_ASSERT(PR_SUCCESS == rv);
422 rv = PR_Close(client); PR_ASSERT(PR_SUCCESS == rv);
423 rv = PR_Close(service); PR_ASSERT(PR_SUCCESS == rv);
434 rv = PR_InitializeNetAddr(PR_IpAddrAny, default_port, &any_address);
435 PR_ASSERT(PR_SUCCESS == rv);
436 rv = PR_Bind(service, &any_address); PR_ASSERT(PR_SUCCESS == rv);
437 rv = PR_Listen(service, 10); PR_ASSERT(PR_SUCCESS == rv);
452 rv = PR_JoinThread(client_thread);
453 PR_ASSERT(PR_SUCCESS == rv);
454 rv = PR_JoinThread(server_thread);
455 PR_ASSERT(PR_SUCCESS == rv);
457 rv = PR_Close(client_stack); PR_ASSERT(PR_SUCCESS == rv);
458 rv = PR_Close(service_stack); PR_ASSERT(PR_SUCCESS == rv);