Lines Matching defs:cu
121 struct cu_data *cu;
133 cu = (struct cu_data *)bkmem_alloc(sizeof (*cu) + sendsz + recvsz);
134 if (cu == NULL) {
140 cu->cu_outbuf = &cu->cu_inbuf[recvsz];
151 cl->cl_private = (caddr_t)cu;
152 cu->cu_raddr = *raddr;
153 cu->cu_rlen = sizeof (cu->cu_raddr);
154 cu->cu_wait = wait;
155 cu->cu_total.tv_sec = -1;
156 cu->cu_total.tv_usec = -1;
157 cu->cu_sendsz = sendsz;
158 cu->cu_recvsz = recvsz;
164 xdrmem_create(&(cu->cu_outxdrs), cu->cu_outbuf,
166 if (! xdr_callhdr(&(cu->cu_outxdrs), &call_msg)) {
169 cu->cu_xdrpos = XDR_GETPOS(&(cu->cu_outxdrs));
170 cu->cu_closeit = FALSE;
199 cu->cu_closeit = TRUE;
202 cu->cu_sock = *sockp;
206 if (cu)
207 bkmem_free((caddr_t)cu, sizeof (*cu) + sendsz + recvsz);
236 struct cu_data *cu;
252 cu = (struct cu_data *)cl->cl_private;
253 if (cu->cu_total.tv_usec == -1)
256 timeout = cu->cu_total; /* use default timeout */
261 xdelay = cu->cu_wait.tv_sec + 1000 + cu->cu_wait.tv_usec / 1000;
262 (void) setsockopt(cu->cu_sock, SOL_SOCKET, SO_RCVTIMEO,
273 xdrs = &(cu->cu_outxdrs);
275 XDR_SETPOS(xdrs, cu->cu_xdrpos);
279 (*(ushort_t *)(cu->cu_outbuf))++;
283 return (cu->cu_error.re_status = RPC_CANTENCODEARGS);
287 if (sendto(cu->cu_sock, cu->cu_outbuf, outlen, 0,
288 (struct sockaddr *)&(cu->cu_raddr), cu->cu_rlen)
302 cu->cu_error.re_status = RPC_TIMEDOUT;
304 cu->cu_error.re_status = RPC_CANTSEND;
306 cu->cu_error.re_errno = errno;
307 return (cu->cu_error.re_status);
322 return (cu->cu_error.re_status);
325 cu->cu_error.re_errno = ETIMEDOUT;
326 return (cu->cu_error.re_status = RPC_TIMEDOUT);
335 inlen = recvfrom(cu->cu_sock, cu->cu_inbuf,
336 (int)cu->cu_recvsz, MSG_DONTWAIT,
348 cu->cu_error.re_status = RPC_CANTRECV;
351 cu->cu_error.re_status = RPC_TIMEDOUT;
354 cu->cu_error.re_errno = errno;
355 return (cu->cu_error.re_status);
362 if (*((uint32_t *)(cu->cu_inbuf)) !=
363 *((uint32_t *)(cu->cu_outbuf))) {
365 *(uint32_t *)(cu->cu_inbuf),
366 *(uint32_t *)(cu->cu_outbuf));
376 xdrmem_create(&reply_xdrs, cu->cu_inbuf, (uint_t)inlen, XDR_DECODE);
380 cu->cu_error.re_status = RPC_CANTDECODERES;
381 return (cu->cu_error.re_status);
384 _seterr_reply(&reply_msg, &(cu->cu_error));
385 if (cu->cu_error.re_status == RPC_SUCCESS) {
388 cu->cu_error.re_status = RPC_AUTHERROR;
389 cu->cu_error.re_why = AUTH_INVALIDRESP;
398 return (cu->cu_error.re_status);
401 if (cu->cu_error.re_status == RPC_AUTHERROR) {
415 rpc_disperr(&cu->cu_error);
424 struct cu_data *cu = (struct cu_data *)cl->cl_private;
426 *errp = cu->cu_error;
436 struct cu_data *cu = (struct cu_data *)cl->cl_private;
437 XDR *xdrs = &(cu->cu_outxdrs);
464 struct cu_data *cu = (struct cu_data *)cl->cl_private;
466 if (cu->cu_closeit) {
467 (void) socket_close(cu->cu_sock);
469 XDR_DESTROY(&(cu->cu_outxdrs));
470 bkmem_free((caddr_t)cu, (sizeof (*cu) + cu->cu_sendsz + cu->cu_recvsz));