sys/rpc/clnt_rc.c

84 	struct rc_data *rc = NULL;	/* private data */
92 	rc = mem_alloc(sizeof (*rc));
93 	mtx_init(&rc->rc_lock, "rc->rc_lock", NULL, MTX_DEF);
94 	(void) memcpy(&rc->rc_addr, svcaddr, (size_t)svcaddr->sa_len);
95 	rc->rc_nconf = nconf;
96 	rc->rc_prog = program;
97 	rc->rc_vers = version;
98 	rc->rc_sendsz = sendsz;
99 	rc->rc_recvsz = recvsz;
100 	rc->rc_timeout.tv_sec = -1;
101 	rc->rc_timeout.tv_usec = -1;
102 	rc->rc_retry.tv_sec = 3;
103 	rc->rc_retry.tv_usec = 0;
104 	rc->rc_retries = INT_MAX;
105 	rc->rc_privport = FALSE;
106 	rc->rc_waitchan = "rpcrecv";
107 	rc->rc_intr = 0;
108 	rc->rc_connecting = FALSE;
109 	rc->rc_closed = FALSE;
110 	rc->rc_ucred = crdup(curthread->td_ucred);
111 	rc->rc_client = NULL;
112 	rc->rc_tls = false;
113 	rc->rc_tlscertname = NULL;
114 	rc->rc_reconcall = NULL;
115 	rc->rc_reconarg = NULL;
119 	cl->cl_private = (caddr_t)(void *)rc;
130 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
140 	mtx_lock(&rc->rc_lock);
141 	while (rc->rc_connecting) {
142 		error = msleep(rc, &rc->rc_lock,
143 		    rc->rc_intr ? PCATCH : 0, "rpcrecon", 0);
145 			mtx_unlock(&rc->rc_lock);
149 	if (rc->rc_closed) {
150 		mtx_unlock(&rc->rc_lock);
153 	if (rc->rc_client) {
154 		mtx_unlock(&rc->rc_lock);
164 	rc->rc_connecting = TRUE;
165 	mtx_unlock(&rc->rc_lock);
168 	td->td_ucred = rc->rc_ucred;
169 	so = __rpc_nconf2socket(rc->rc_nconf);
177 	if (rc->rc_privport)
180 	if (rc->rc_nconf->nc_semantics == NC_TPI_CLTS)
182 		    (struct sockaddr *) &rc->rc_addr, rc->rc_prog, rc->rc_vers,
183 		    rc->rc_sendsz, rc->rc_recvsz);
190 		if (rc->rc_timeout.tv_sec > 0 && rc->rc_timeout.tv_usec >= 0) {
192 			    &rc->rc_timeout, sizeof(struct timeval));
201 		    (struct sockaddr *) &rc->rc_addr, rc->rc_prog, rc->rc_vers,
202 		    rc->rc_sendsz, rc->rc_recvsz, rc->rc_intr);
203 		if (rc->rc_tls && newclient != NULL) {
204 			stat = rpctls_connect(newclient, rc->rc_tlscertname, so,
218 		if (newclient != NULL && rc->rc_reconcall != NULL)
219 			(*rc->rc_reconcall)(newclient, rc->rc_reconarg,
220 			    rc->rc_ucred);
226 		rc->rc_err = rpc_createerr.cf_error;
233 	CLNT_CONTROL(newclient, CLSET_TIMEOUT, &rc->rc_timeout);
234 	CLNT_CONTROL(newclient, CLSET_RETRY_TIMEOUT, &rc->rc_retry);
235 	CLNT_CONTROL(newclient, CLSET_WAITCHAN, rc->rc_waitchan);
236 	CLNT_CONTROL(newclient, CLSET_INTERRUPTIBLE, &rc->rc_intr);
237 	if (rc->rc_tls)
239 	if (rc->rc_backchannel != NULL)
240 		CLNT_CONTROL(newclient, CLSET_BACKCHANNEL, rc->rc_backchannel);
244 	mtx_lock(&rc->rc_lock);
245 	KASSERT(rc->rc_client == NULL, ("rc_client not null"));
246 	if (!rc->rc_closed) {
247 		rc->rc_client = newclient;
250 	rc->rc_connecting = FALSE;
251 	wakeup(rc);
252 	mtx_unlock(&rc->rc_lock);
277 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
284 		mtx_lock(&rc->rc_lock);
285 		if (rc->rc_closed) {
286 			mtx_unlock(&rc->rc_lock);
290 		if (!rc->rc_client) {
291 			mtx_unlock(&rc->rc_lock);
295 				    rc->rc_intr ? PCATCH : 0, "rpccon", hz);
299 				if (tries >= rc->rc_retries)
305 			mtx_lock(&rc->rc_lock);
308 		if (!rc->rc_client) {
309 			mtx_unlock(&rc->rc_lock);
313 		CLNT_ACQUIRE(rc->rc_client);
314 		client = rc->rc_client;
315 		mtx_unlock(&rc->rc_lock);
321 				CLNT_GETERR(client, &rc->rc_err);
329 			if ((rc->rc_timeout.tv_sec == 0
330 				&& rc->rc_timeout.tv_usec == 0)
331 			    || (rc->rc_timeout.tv_sec == -1
342 			if (tries >= rc->rc_retries) {
351 			mtx_lock(&rc->rc_lock);
360 			if (rc->rc_client == client) {
361 				rc->rc_client = NULL;
362 				mtx_unlock(&rc->rc_lock);
365 				mtx_unlock(&rc->rc_lock);
383 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
385 	*errp = rc->rc_err;
395 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
397 	return (CLNT_FREERES(rc->rc_client, xdr_res, res_ptr));
413 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
423 		rc->rc_timeout = *(struct timeval *)info;
424 		if (rc->rc_client)
425 			CLNT_CONTROL(rc->rc_client, request, info);
429 		*(struct timeval *)info = rc->rc_timeout;
433 		rc->rc_retry = *(struct timeval *)info;
434 		if (rc->rc_client)
435 			CLNT_CONTROL(rc->rc_client, request, info);
439 		*(struct timeval *)info = rc->rc_retry;
443 		*(uint32_t *)info = rc->rc_vers;
447 		rc->rc_vers = *(uint32_t *) info;
448 		if (rc->rc_client)
449 			CLNT_CONTROL(rc->rc_client, CLSET_VERS, info);
453 		*(uint32_t *)info = rc->rc_prog;
457 		rc->rc_prog = *(uint32_t *) info;
458 		if (rc->rc_client)
459 			CLNT_CONTROL(rc->rc_client, request, info);
463 		rc->rc_waitchan = (char *)info;
464 		if (rc->rc_client)
465 			CLNT_CONTROL(rc->rc_client, request, info);
469 		*(const char **) info = rc->rc_waitchan;
473 		rc->rc_intr = *(int *) info;
474 		if (rc->rc_client)
475 			CLNT_CONTROL(rc->rc_client, request, info);
479 		*(int *) info = rc->rc_intr;
483 		rc->rc_retries = *(int *) info;
487 		*(int *) info = rc->rc_retries;
491 		rc->rc_privport = *(int *) info;
495 		*(int *) info = rc->rc_privport;
501 		rc->rc_backchannel = info;
505 		rc->rc_tls = true;
518 		rc->rc_tlscertname = mem_alloc(slen);
519 		strlcpy(rc->rc_tlscertname, info, slen);
524 		rc->rc_reconcall = upcp->call;
525 		rc->rc_reconarg = upcp->arg;
538 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
541 	mtx_lock(&rc->rc_lock);
543 	if (rc->rc_closed) {
544 		mtx_unlock(&rc->rc_lock);
548 	rc->rc_closed = TRUE;
549 	client = rc->rc_client;
550 	rc->rc_client = NULL;
552 	mtx_unlock(&rc->rc_lock);
563 	struct rc_data *rc = (struct rc_data *)cl->cl_private;
566 	if (rc->rc_client)
567 		CLNT_DESTROY(rc->rc_client);
568 	if (rc->rc_backchannel) {
569 		xprt = (SVCXPRT *)rc->rc_backchannel;
575 	crfree(rc->rc_ucred);
576 	mtx_destroy(&rc->rc_lock);
577 	mem_free(rc->rc_tlscertname, 0);	/* 0 ok, since arg. ignored. */
578 	mem_free(rc->rc_reconarg, 0);
579 	mem_free(rc, sizeof(*rc));