Lines Matching refs:cu
122 register struct cu_data *cu; local
135 cu = (struct cu_data *)mem_alloc(sizeof (*cu) + sendsz + recvsz);
136 if (cu == NULL) {
142 cu->cu_outbuf = &cu->cu_inbuf[recvsz];
154 cl->cl_private = (caddr_t)cu;
155 cu->cu_raddr = *raddr;
156 cu->cu_rlen = sizeof (cu->cu_raddr);
157 cu->cu_wait = wait;
158 cu->cu_total.tv_sec = -1;
159 cu->cu_total.tv_usec = -1;
160 cu->cu_sendsz = sendsz;
161 cu->cu_recvsz = recvsz;
167 xdrmem_create(&(cu->cu_outxdrs), cu->cu_outbuf,
169 if (! xdr_callhdr(&(cu->cu_outxdrs), &call_msg)) {
172 cu->cu_xdrpos = XDR_GETPOS(&(cu->cu_outxdrs));
186 cu->cu_closeit = TRUE;
188 cu->cu_closeit = FALSE;
190 cu->cu_sock = *sockp;
194 if (cu)
195 mem_free((caddr_t)cu, sizeof (*cu) + sendsz + recvsz);
224 register struct cu_data *cu = (struct cu_data *)cl->cl_private; local
242 if (cu->cu_total.tv_usec == -1) {
245 timeout = cu->cu_total; /* use default timeout */
250 retransmit_time = cu->cu_wait;
253 xdrs = &(cu->cu_outxdrs);
255 XDR_SETPOS(xdrs, cu->cu_xdrpos);
259 (*(u_short *)(cu->cu_outbuf))++;
263 return (cu->cu_error.re_status = RPC_CANTENCODEARGS);
267 if (_sendto(cu->cu_sock, cu->cu_outbuf, outlen, 0,
268 (struct sockaddr *)&(cu->cu_raddr), cu->cu_rlen)
270 cu->cu_error.re_errno = errno;
271 return (cu->cu_error.re_status = RPC_CANTSEND);
278 return (cu->cu_error.re_status = RPC_TIMEDOUT);
289 FD_SET(cu->cu_sock, &mask);
318 return (cu->cu_error.re_status = RPC_TIMEDOUT);
326 cu->cu_error.re_errno = errno;
327 return (cu->cu_error.re_status = RPC_CANTRECV);
369 return (cu->cu_error.re_status = RPC_TIMEDOUT);
377 inlen = _recvfrom(cu->cu_sock, cu->cu_inbuf,
378 (int) cu->cu_recvsz, 0,
384 cu->cu_error.re_errno = errno;
385 return (cu->cu_error.re_status = RPC_CANTRECV);
390 if (*((uint32_t *)(cu->cu_inbuf)) !=
391 *((uint32_t *)(cu->cu_outbuf)))
400 xdrmem_create(&reply_xdrs, cu->cu_inbuf, (u_int)inlen, XDR_DECODE);
404 __seterr_reply(&reply_msg, &(cu->cu_error));
405 if (cu->cu_error.re_status == RPC_SUCCESS) {
408 cu->cu_error.re_status = RPC_AUTHERROR;
409 cu->cu_error.re_why = AUTH_INVALIDRESP;
427 cu->cu_error.re_status = RPC_CANTDECODERES;
429 return (cu->cu_error.re_status);
437 register struct cu_data *cu = (struct cu_data *)cl->cl_private; local
439 *errp = cu->cu_error;
449 register struct cu_data *cu = (struct cu_data *)cl->cl_private; local
450 register XDR *xdrs = &(cu->cu_outxdrs);
468 register struct cu_data *cu = (struct cu_data *)cl->cl_private; local
472 cu->cu_total = *(struct timeval *)info;
475 *(struct timeval *)info = cu->cu_total;
478 cu->cu_wait = *(struct timeval *)info;
481 *(struct timeval *)info = cu->cu_wait;
484 *(struct sockaddr_in *)info = cu->cu_raddr;
487 *(int *)info = cu->cu_sock;
490 cu->cu_closeit = TRUE;
493 cu->cu_closeit = FALSE;
505 register struct cu_data *cu = (struct cu_data *)cl->cl_private; local
507 if (cu->cu_closeit) {
508 (void) close(cu->cu_sock);
510 XDR_DESTROY(&(cu->cu_outxdrs));
511 mem_free((caddr_t)cu, (sizeof (*cu) + cu->cu_sendsz + cu->cu_recvsz));