Cross Reference: /illumos-gate/usr/src/ucblib/librpcsoc/clnt

Lines Matching defs:cu
124 	register struct cu_data *cu;
137 	cu = (struct cu_data *)mem_alloc(sizeof (*cu) + sendsz + recvsz);
138 	if (cu == NULL) {
144 	cu->cu_outbuf = &cu->cu_inbuf[recvsz];
156 	cl->cl_private = (caddr_t)cu;
157 	cu->cu_raddr = *raddr;
158 	cu->cu_rlen = sizeof (cu->cu_raddr);
159 	cu->cu_wait = wait;
160 	cu->cu_total.tv_sec = -1;
161 	cu->cu_total.tv_usec = -1;
162 	cu->cu_sendsz = sendsz;
163 	cu->cu_recvsz = recvsz;
169 	xdrmem_create(&(cu->cu_outxdrs), cu->cu_outbuf,
171 	if (! xdr_callhdr(&(cu->cu_outxdrs), &call_msg)) {
174 	cu->cu_xdrpos = XDR_GETPOS(&(cu->cu_outxdrs));
188 		cu->cu_closeit = TRUE;
190 		cu->cu_closeit = FALSE;
192 	cu->cu_sock = *sockp;
196 	if (cu)
197 		mem_free((caddr_t)cu, sizeof (*cu) + sendsz + recvsz);
226 	register struct cu_data *cu = (struct cu_data *)cl->cl_private;
244 	if (cu->cu_total.tv_usec == -1) {
247 		timeout = cu->cu_total; /* use default timeout */
252 	retransmit_time = cu->cu_wait;
255 	xdrs = &(cu->cu_outxdrs);
257 	XDR_SETPOS(xdrs, cu->cu_xdrpos);
261 	(*(u_short *)(cu->cu_outbuf))++;
265 		return (cu->cu_error.re_status = RPC_CANTENCODEARGS);
269 	if (_sendto(cu->cu_sock, cu->cu_outbuf, outlen, 0,
270 	    (struct sockaddr *)&(cu->cu_raddr), cu->cu_rlen)
272 		cu->cu_error.re_errno = errno;
273 		return (cu->cu_error.re_status = RPC_CANTSEND);
280 		return (cu->cu_error.re_status = RPC_TIMEDOUT);
291 	FD_SET(cu->cu_sock, &mask);
320 			return (cu->cu_error.re_status = RPC_TIMEDOUT);
328 				cu->cu_error.re_errno = errno;
329 				return (cu->cu_error.re_status = RPC_CANTRECV);
371 				return (cu->cu_error.re_status = RPC_TIMEDOUT);
379 			inlen = _recvfrom(cu->cu_sock, cu->cu_inbuf,
380 				(int) cu->cu_recvsz, 0,
386 			cu->cu_error.re_errno = errno;
387 			return (cu->cu_error.re_status = RPC_CANTRECV);
392 		if (*((uint32_t *)(cu->cu_inbuf)) !=
393 				*((uint32_t *)(cu->cu_outbuf)))
402 	xdrmem_create(&reply_xdrs, cu->cu_inbuf, (u_int)inlen, XDR_DECODE);
406 		__seterr_reply(&reply_msg, &(cu->cu_error));
407 		if (cu->cu_error.re_status == RPC_SUCCESS) {
410 				cu->cu_error.re_status = RPC_AUTHERROR;
411 				cu->cu_error.re_why = AUTH_INVALIDRESP;
429 		cu->cu_error.re_status = RPC_CANTDECODERES;
431 	return (cu->cu_error.re_status);
439 	register struct cu_data *cu = (struct cu_data *)cl->cl_private;
441 	*errp = cu->cu_error;
451 	register struct cu_data *cu = (struct cu_data *)cl->cl_private;
452 	register XDR *xdrs = &(cu->cu_outxdrs);
470 	register struct cu_data *cu = (struct cu_data *)cl->cl_private;
474 		cu->cu_total = *(struct timeval *)info;
477 		*(struct timeval *)info = cu->cu_total;
480 		cu->cu_wait = *(struct timeval *)info;
483 		*(struct timeval *)info = cu->cu_wait;
486 		*(struct sockaddr_in *)info = cu->cu_raddr;
489 		*(int *)info = cu->cu_sock;
492 		cu->cu_closeit = TRUE;
495 		cu->cu_closeit = FALSE;
507 	register struct cu_data *cu = (struct cu_data *)cl->cl_private;
509 	if (cu->cu_closeit) {
510 		(void) close(cu->cu_sock);
512 	XDR_DESTROY(&(cu->cu_outxdrs));
513 	mem_free((caddr_t)cu, (sizeof (*cu) + cu->cu_sendsz + cu->cu_recvsz));