Lines Matching refs:cu
142 struct cu_data *cu = NULL;
160 cu = (struct cu_data *)mem_alloc(sizeof(*cu) + sendsz + recvsz);
161 if (cu == NULL)
168 cu->cu_outbuf = &cu->cu_inbuf[recvsz];
179 cl->cl_private = (caddr_t)cu;
180 cu->cu_raddr = *raddr;
181 cu->cu_rlen = sizeof (cu->cu_raddr);
182 cu->cu_sendsz = sendsz;
183 cu->cu_recvsz = recvsz;
185 cu->cu_retry_timeout.tv_sec = 1;
186 cu->cu_retry_timeout.tv_usec = 0;
187 if (retry_timeout != NULL) cu->cu_retry_timeout = *retry_timeout;
189 cu->cu_total_timeout.tv_sec = -1;
190 cu->cu_total_timeout.tv_usec = -1;
191 if (total_timeout != NULL) cu->cu_total_timeout = *total_timeout;
206 xdrmem_create(&(cu->cu_outxdrs), cu->cu_outbuf, sendsz, XDR_ENCODE);
207 if (! xdr_callhdr(&(cu->cu_outxdrs), &call_msg)) goto fooy;
209 cu->cu_xdrpos = XDR_GETPOS(&(cu->cu_outxdrs));
227 cu->cu_closeit = TRUE;
249 cu->cu_closeit = FALSE;
252 cu->cu_sock = *sockp;
257 if (cu) mem_free((caddr_t)cu, sizeof(*cu) + sendsz + recvsz);
319 register struct cu_data *cu = (struct cu_data *)cl->cl_private;
334 if (cu->cu_total_timeout.tv_sec == -1)
342 timeout = cu->cu_total_timeout;
349 xdrs = &(cu->cu_outxdrs);
351 XDR_SETPOS(xdrs, cu->cu_xdrpos);
356 (*(u_short *)(cu->cu_outbuf))++;
361 return (cu->cu_error.re_status = RPC_CANTENCODEARGS);
366 return (cu->cu_error.re_status = RPC_CANTENCODEARGS);
371 if (sendto(cu->cu_sock, cu->cu_outbuf, outlen, 0, (struct sockaddr *)&(cu->cu_raddr), cu->cu_rlen) != outlen)
373 cu->cu_error.re_errno = errno;
374 return (cu->cu_error.re_status = RPC_CANTSEND);
382 return (cu->cu_error.re_status = RPC_TIMEDOUT);
394 FD_SET(cu->cu_sock, &mask);
398 switch (select(cu->cu_sock+1, &readfds, NULL, NULL, &(cu->cu_retry_timeout))) {
400 time_waited.tv_sec += cu->cu_retry_timeout.tv_sec;
401 time_waited.tv_usec += cu->cu_retry_timeout.tv_usec;
410 return (cu->cu_error.re_status = RPC_TIMEDOUT);
419 cu->cu_error.re_errno = errno;
420 return (cu->cu_error.re_status = RPC_CANTRECV);
424 inlen = recvfrom(cu->cu_sock, cu->cu_inbuf,
425 (int) cu->cu_recvsz, 0,
431 cu->cu_error.re_errno = errno;
432 return (cu->cu_error.re_status = RPC_CANTRECV);
438 if (*((uint32_t *)(cu->cu_inbuf)) != *((uint32_t *)(cu->cu_outbuf))) continue;
443 if (*((u_long *)(cu->cu_inbuf)) != *((u_long *)(cu->cu_outbuf))) continue;
452 xdrmem_create(&reply_xdrs, cu->cu_inbuf, (u_int)inlen, XDR_DECODE);
456 _seterr_reply(&reply_msg, &(cu->cu_error));
457 if (cu->cu_error.re_status == RPC_SUCCESS) {
460 cu->cu_error.re_status = RPC_AUTHERROR;
461 cu->cu_error.re_why = AUTH_INVALIDRESP;
478 cu->cu_error.re_status = RPC_CANTDECODERES;
480 return (cu->cu_error.re_status);
488 register struct cu_data *cu = (struct cu_data *)cl->cl_private;
490 *errp = cu->cu_error;
500 register struct cu_data *cu = (struct cu_data *)cl->cl_private;
501 register XDR *xdrs = &(cu->cu_outxdrs);
519 register struct cu_data *cu = (struct cu_data *)cl->cl_private;
523 cu->cu_total_timeout = *(struct timeval *)info;
526 *(struct timeval *)info = cu->cu_total_timeout;
529 cu->cu_retry_timeout = *(struct timeval *)info;
532 *(struct timeval *)info = cu->cu_retry_timeout;
535 *(struct sockaddr_in *)info = cu->cu_raddr;
547 register struct cu_data *cu = (struct cu_data *)cl->cl_private;
549 if (cu->cu_closeit) {
550 (void)close(cu->cu_sock);
552 XDR_DESTROY(&(cu->cu_outxdrs));
553 mem_free((caddr_t)cu, (sizeof(*cu) + cu->cu_sendsz + cu->cu_recvsz));