libc/rpc/clnt_dg.c

167 	struct cu_data *cu = NULL;	/* private data */
239 	cu = mem_alloc(sizeof (*cu) + sendsz + recvsz);
240 	if (cu == NULL)
242 	(void) memcpy(&cu->cu_raddr, svcaddr->buf, (size_t)svcaddr->len);
243 	cu->cu_rlen = svcaddr->len;
244 	cu->cu_outbuf = &cu->cu_inbuf[recvsz];
246 	cu->cu_wait.tv_sec = 15;	/* heuristically chosen */
247 	cu->cu_wait.tv_usec = 0;
248 	cu->cu_total.tv_sec = -1;
249 	cu->cu_total.tv_usec = -1;
250 	cu->cu_sendsz = sendsz;
251 	cu->cu_recvsz = recvsz;
252 	cu->cu_async = FALSE;
253 	cu->cu_connect = FALSE;
254 	cu->cu_connected = FALSE;
259 	xdrmem_create(&(cu->cu_outxdrs), cu->cu_outhdr, MCALL_MSG_SIZE,
261 	if (! xdr_callhdr(&cu->cu_outxdrs, &call_msg)) {
266 	cu->cu_xdrpos = XDR_GETPOS(&(cu->cu_outxdrs));
267 	XDR_DESTROY(&cu->cu_outxdrs);
268 	xdrmem_create(&cu->cu_outxdrs, cu->cu_outbuf, sendsz, XDR_ENCODE);
281 	cu->cu_closeit = FALSE;
282 	cu->cu_fd = fd;
284 	cl->cl_private = (caddr_t)(void *)cu;
288 	cu->cu_kq = -1;
289 	EV_SET(&cu->cu_kin, cu->cu_fd, EVFILT_READ, EV_ADD, 0, 0, 0);
298 		if (cu)
299 			mem_free(cu, sizeof (*cu) + sendsz + recvsz);
314 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
339 	while (dg_fd_locks[cu->cu_fd])
340 		cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
345 	dg_fd_locks[cu->cu_fd] = rpc_lock_value;
347 	if (cu->cu_total.tv_usec == -1) {
350 		timeout = cu->cu_total;	/* use default timeout */
353 	if (cu->cu_connect && !cu->cu_connected) {
354 		if (_connect(cu->cu_fd, (struct sockaddr *)&cu->cu_raddr,
355 		    cu->cu_rlen) < 0) {
356 			cu->cu_error.re_errno = errno;
357 			cu->cu_error.re_status = RPC_CANTSEND;
360 		cu->cu_connected = 1;
362 	if (cu->cu_connected) {
366 		sa = (struct sockaddr *)&cu->cu_raddr;
367 		salen = cu->cu_rlen;
371 	retransmit_time = next_sendtime = cu->cu_wait;
375 	if (cu->cu_kq >= 0)
376 		_close(cu->cu_kq);
377 	if ((cu->cu_kq = kqueue()) < 0) {
378 		cu->cu_error.re_errno = errno;
379 		cu->cu_error.re_status = RPC_CANTSEND;
385 	if (cu->cu_async == TRUE && xargs == NULL)
392 	xid = ntohl(*(u_int32_t *)(void *)(cu->cu_outhdr));
394 	*(u_int32_t *)(void *)(cu->cu_outhdr) = htonl(xid);
396 	xdrs = &(cu->cu_outxdrs);
401 		if ((! XDR_PUTBYTES(xdrs, cu->cu_outhdr, cu->cu_xdrpos)) ||
405 			cu->cu_error.re_status = RPC_CANTENCODEARGS;
409 		*(uint32_t *) &cu->cu_outhdr[cu->cu_xdrpos] = htonl(proc);
410 		if (!__rpc_gss_wrap(cl->cl_auth, cu->cu_outhdr,
411 			cu->cu_xdrpos + sizeof(uint32_t),
413 			cu->cu_error.re_status = RPC_CANTENCODEARGS;
420 	if (_sendto(cu->cu_fd, cu->cu_outbuf, outlen, 0, sa, salen) != outlen) {
421 		cu->cu_error.re_errno = errno;
422 		cu->cu_error.re_status = RPC_CANTSEND;
430 		cu->cu_error.re_status = RPC_TIMEDOUT;
460 		n = _kevent(cu->cu_kq, &cu->cu_kin, kin_len, &kv, 1, &ts);
466 				cu->cu_error.re_errno = kv.data;
467 				cu->cu_error.re_status = RPC_CANTRECV;
472 				recvlen = _recvfrom(cu->cu_fd, cu->cu_inbuf,
473 				    cu->cu_recvsz, 0, NULL, NULL);
476 				cu->cu_error.re_errno = errno;
477 				cu->cu_error.re_status = RPC_CANTRECV;
481 			    (cu->cu_async == TRUE ||
482 			    *((u_int32_t *)(void *)(cu->cu_inbuf)) ==
483 			    *((u_int32_t *)(void *)(cu->cu_outbuf)))) {
489 			cu->cu_error.re_errno = errno;
490 			cu->cu_error.re_status = RPC_CANTRECV;
498 			cu->cu_error.re_status = RPC_TIMEDOUT;
529 	xdrmem_create(&reply_xdrs, cu->cu_inbuf, (u_int)recvlen, XDR_DECODE);
535 			cu->cu_error.re_status = RPC_SUCCESS;
537 			_seterr_reply(&reply_msg, &(cu->cu_error));
539 		if (cu->cu_error.re_status == RPC_SUCCESS) {
562 				cu->cu_error.re_status = RPC_AUTHERROR;
563 				cu->cu_error.re_why = AUTH_INVALIDRESP;
570 						cu->cu_error.re_status =
584 		else if (cu->cu_error.re_status == RPC_AUTHERROR)
594 		cu->cu_error.re_status = RPC_CANTDECODERES;
598 	if (cu->cu_kq >= 0)
599 		_close(cu->cu_kq);
600 	cu->cu_kq = -1;
601 	release_fd_lock(cu->cu_fd, mask);
602 	return (cu->cu_error.re_status);
610 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
612 	*errp = cu->cu_error;
621 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
622 	XDR *xdrs = &(cu->cu_outxdrs);
630 	while (dg_fd_locks[cu->cu_fd])
631 		cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
636 	cond_signal(&dg_cv[cu->cu_fd]);
653 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
662 	while (dg_fd_locks[cu->cu_fd])
663 		cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
668 	dg_fd_locks[cu->cu_fd] = rpc_lock_value;
672 		cu->cu_closeit = TRUE;
673 		release_fd_lock(cu->cu_fd, mask);
676 		cu->cu_closeit = FALSE;
677 		release_fd_lock(cu->cu_fd, mask);
683 		release_fd_lock(cu->cu_fd, mask);
689 			release_fd_lock(cu->cu_fd, mask);
692 		cu->cu_total = *(struct timeval *)info;
695 		*(struct timeval *)info = cu->cu_total;
699 		(void) memcpy(info, &cu->cu_raddr, (size_t)cu->cu_rlen);
703 			release_fd_lock(cu->cu_fd, mask);
706 		cu->cu_wait = *(struct timeval *)info;
709 		*(struct timeval *)info = cu->cu_wait;
712 		*(int *)info = cu->cu_fd;
716 		addr->buf = &cu->cu_raddr;
717 		addr->len = cu->cu_rlen;
718 		addr->maxlen = sizeof cu->cu_raddr;
722 		if (addr->len < sizeof cu->cu_raddr) {
723 			release_fd_lock(cu->cu_fd, mask);
726 		(void) memcpy(&cu->cu_raddr, addr->buf, addr->len);
727 		cu->cu_rlen = addr->len;
736 		    ntohl(*(u_int32_t *)(void *)cu->cu_outhdr);
741 		*(u_int32_t *)(void *)cu->cu_outhdr =
754 		    ntohl(*(u_int32_t *)(void *)(cu->cu_outhdr +
759 		*(u_int32_t *)(void *)(cu->cu_outhdr + 4 * BYTES_PER_XDR_UNIT)
771 		    ntohl(*(u_int32_t *)(void *)(cu->cu_outhdr +
776 		*(u_int32_t *)(void *)(cu->cu_outhdr + 3 * BYTES_PER_XDR_UNIT)
780 		cu->cu_async = *(int *)info;
783 		cu->cu_connect = *(int *)info;
786 		release_fd_lock(cu->cu_fd, mask);
789 	release_fd_lock(cu->cu_fd, mask);
797 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
798 	int cu_fd = cu->cu_fd;
807 	if (cu->cu_closeit)
809 	if (cu->cu_kq >= 0)
810 		_close(cu->cu_kq);
811 	XDR_DESTROY(&(cu->cu_outxdrs));
812 	mem_free(cu, (sizeof (*cu) + cu->cu_sendsz + cu->cu_recvsz));