libc/rpc/clnt_dg.c

169 	struct cu_data *cu = NULL;	/* private data */
241 	cu = mem_alloc(sizeof (*cu) + sendsz + recvsz);
242 	if (cu == NULL)
244 	(void) memcpy(&cu->cu_raddr, svcaddr->buf, (size_t)svcaddr->len);
245 	cu->cu_rlen = svcaddr->len;
246 	cu->cu_outbuf = &cu->cu_inbuf[recvsz];
248 	cu->cu_wait.tv_sec = 15;	/* heuristically chosen */
249 	cu->cu_wait.tv_usec = 0;
250 	cu->cu_total.tv_sec = -1;
251 	cu->cu_total.tv_usec = -1;
252 	cu->cu_sendsz = sendsz;
253 	cu->cu_recvsz = recvsz;
254 	cu->cu_async = FALSE;
255 	cu->cu_connect = FALSE;
256 	cu->cu_connected = FALSE;
261 	xdrmem_create(&(cu->cu_outxdrs), cu->cu_outhdr, MCALL_MSG_SIZE,
263 	if (! xdr_callhdr(&cu->cu_outxdrs, &call_msg)) {
268 	cu->cu_xdrpos = XDR_GETPOS(&(cu->cu_outxdrs));
269 	XDR_DESTROY(&cu->cu_outxdrs);
270 	xdrmem_create(&cu->cu_outxdrs, cu->cu_outbuf, sendsz, XDR_ENCODE);
283 	cu->cu_closeit = FALSE;
284 	cu->cu_fd = fd;
286 	cl->cl_private = (caddr_t)(void *)cu;
290 	cu->cu_kq = -1;
291 	EV_SET(&cu->cu_kin, cu->cu_fd, EVFILT_READ, EV_ADD, 0, 0, 0);
300 		if (cu)
301 			mem_free(cu, sizeof (*cu) + sendsz + recvsz);
319 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
344 	while (dg_fd_locks[cu->cu_fd])
345 		cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
350 	dg_fd_locks[cu->cu_fd] = rpc_lock_value;
352 	if (cu->cu_total.tv_usec == -1) {
355 		timeout = cu->cu_total;	/* use default timeout */
358 	if (cu->cu_connect && !cu->cu_connected) {
359 		if (_connect(cu->cu_fd, (struct sockaddr *)&cu->cu_raddr,
360 		    cu->cu_rlen) < 0) {
361 			cu->cu_error.re_errno = errno;
362 			cu->cu_error.re_status = RPC_CANTSEND;
365 		cu->cu_connected = 1;
367 	if (cu->cu_connected) {
371 		sa = (struct sockaddr *)&cu->cu_raddr;
372 		salen = cu->cu_rlen;
376 	retransmit_time = next_sendtime = cu->cu_wait;
380 	if (cu->cu_kq >= 0)
381 		_close(cu->cu_kq);
382 	if ((cu->cu_kq = kqueue()) < 0) {
383 		cu->cu_error.re_errno = errno;
384 		cu->cu_error.re_status = RPC_CANTSEND;
390 	if (cu->cu_async == TRUE && xargs == NULL)
397 	xid = ntohl(*(u_int32_t *)(void *)(cu->cu_outhdr));
399 	*(u_int32_t *)(void *)(cu->cu_outhdr) = htonl(xid);
401 	xdrs = &(cu->cu_outxdrs);
406 		if ((! XDR_PUTBYTES(xdrs, cu->cu_outhdr, cu->cu_xdrpos)) ||
410 			cu->cu_error.re_status = RPC_CANTENCODEARGS;
414 		*(uint32_t *) &cu->cu_outhdr[cu->cu_xdrpos] = htonl(proc);
415 		if (!__rpc_gss_wrap(cl->cl_auth, cu->cu_outhdr,
416 			cu->cu_xdrpos + sizeof(uint32_t),
418 			cu->cu_error.re_status = RPC_CANTENCODEARGS;
425 	if (_sendto(cu->cu_fd, cu->cu_outbuf, outlen, 0, sa, salen) != outlen) {
426 		cu->cu_error.re_errno = errno;
427 		cu->cu_error.re_status = RPC_CANTSEND;
435 		cu->cu_error.re_status = RPC_TIMEDOUT;
465 		n = _kevent(cu->cu_kq, &cu->cu_kin, kin_len, &kv, 1, &ts);
471 				cu->cu_error.re_errno = kv.data;
472 				cu->cu_error.re_status = RPC_CANTRECV;
477 				recvlen = _recvfrom(cu->cu_fd, cu->cu_inbuf,
478 				    cu->cu_recvsz, 0, NULL, NULL);
481 				cu->cu_error.re_errno = errno;
482 				cu->cu_error.re_status = RPC_CANTRECV;
486 			    (cu->cu_async == TRUE ||
487 			    *((u_int32_t *)(void *)(cu->cu_inbuf)) ==
488 			    *((u_int32_t *)(void *)(cu->cu_outbuf)))) {
494 			cu->cu_error.re_errno = errno;
495 			cu->cu_error.re_status = RPC_CANTRECV;
503 			cu->cu_error.re_status = RPC_TIMEDOUT;
533 	xdrmem_create(&reply_xdrs, cu->cu_inbuf, (u_int)recvlen, XDR_DECODE);
539 			cu->cu_error.re_status = RPC_SUCCESS;
541 			_seterr_reply(&reply_msg, &(cu->cu_error));
543 		if (cu->cu_error.re_status == RPC_SUCCESS) {
566 				cu->cu_error.re_status = RPC_AUTHERROR;
567 				cu->cu_error.re_why = AUTH_INVALIDRESP;
574 						cu->cu_error.re_status =
588 		else if (cu->cu_error.re_status == RPC_AUTHERROR)
598 		cu->cu_error.re_status = RPC_CANTDECODERES;
602 	if (cu->cu_kq >= 0)
603 		_close(cu->cu_kq);
604 	cu->cu_kq = -1;
605 	release_fd_lock(cu->cu_fd, mask);
606 	return (cu->cu_error.re_status);
612 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
614 	*errp = cu->cu_error;
620 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
621 	XDR *xdrs = &(cu->cu_outxdrs);
629 	while (dg_fd_locks[cu->cu_fd])
630 		cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
635 	cond_signal(&dg_cv[cu->cu_fd]);
648 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
657 	while (dg_fd_locks[cu->cu_fd])
658 		cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
663 	dg_fd_locks[cu->cu_fd] = rpc_lock_value;
667 		cu->cu_closeit = TRUE;
668 		release_fd_lock(cu->cu_fd, mask);
671 		cu->cu_closeit = FALSE;
672 		release_fd_lock(cu->cu_fd, mask);
678 		release_fd_lock(cu->cu_fd, mask);
684 			release_fd_lock(cu->cu_fd, mask);
687 		cu->cu_total = *(struct timeval *)info;
690 		*(struct timeval *)info = cu->cu_total;
694 		(void) memcpy(info, &cu->cu_raddr, (size_t)cu->cu_rlen);
698 			release_fd_lock(cu->cu_fd, mask);
701 		cu->cu_wait = *(struct timeval *)info;
704 		*(struct timeval *)info = cu->cu_wait;
707 		*(int *)info = cu->cu_fd;
711 		addr->buf = &cu->cu_raddr;
712 		addr->len = cu->cu_rlen;
713 		addr->maxlen = sizeof cu->cu_raddr;
717 		if (addr->len < sizeof cu->cu_raddr) {
718 			release_fd_lock(cu->cu_fd, mask);
721 		(void) memcpy(&cu->cu_raddr, addr->buf, addr->len);
722 		cu->cu_rlen = addr->len;
731 		    ntohl(*(u_int32_t *)(void *)cu->cu_outhdr);
736 		*(u_int32_t *)(void *)cu->cu_outhdr =
749 		    ntohl(*(u_int32_t *)(void *)(cu->cu_outhdr +
754 		*(u_int32_t *)(void *)(cu->cu_outhdr + 4 * BYTES_PER_XDR_UNIT)
766 		    ntohl(*(u_int32_t *)(void *)(cu->cu_outhdr +
771 		*(u_int32_t *)(void *)(cu->cu_outhdr + 3 * BYTES_PER_XDR_UNIT)
775 		cu->cu_async = *(int *)info;
778 		cu->cu_connect = *(int *)info;
781 		release_fd_lock(cu->cu_fd, mask);
784 	release_fd_lock(cu->cu_fd, mask);
791 	struct cu_data *cu = (struct cu_data *)cl->cl_private;
792 	int cu_fd = cu->cu_fd;
801 	if (cu->cu_closeit)
803 	if (cu->cu_kq >= 0)
804 		_close(cu->cu_kq);
805 	XDR_DESTROY(&(cu->cu_outxdrs));
806 	mem_free(cu, (sizeof (*cu) + cu->cu_sendsz + cu->cu_recvsz));