Lines Matching refs:ct
122 struct ct_data *ct; in clntbtcp_create() local
137 ct = (struct ct_data *)bkmem_alloc(sizeof (*ct)); in clntbtcp_create()
138 if (ct == NULL) { in clntbtcp_create()
215 ct->ct_closeit = TRUE; in clntbtcp_create()
217 ct->ct_closeit = FALSE; in clntbtcp_create()
222 ct->ct_sock = *sockp; in clntbtcp_create()
223 ct->ct_wait_msec = 0; in clntbtcp_create()
224 ct->ct_total.tv_sec = wait.tv_sec; in clntbtcp_create()
225 ct->ct_total.tv_usec = -1; in clntbtcp_create()
226 ct->ct_raddr = *raddr; in clntbtcp_create()
246 xdrmem_create(&(ct->ct_xdrs), ct->ct_mcall, MCALL_MSG_SIZE, in clntbtcp_create()
248 if (! xdr_callhdr(&(ct->ct_xdrs), &call_msg)) { in clntbtcp_create()
249 if (ct->ct_closeit) in clntbtcp_create()
253 ct->ct_mpos = XDR_GETPOS(&(ct->ct_xdrs)); in clntbtcp_create()
254 XDR_DESTROY(&(ct->ct_xdrs)); in clntbtcp_create()
260 xdrrec_create(&(ct->ct_xdrs), sendsz, recvsz, (caddr_t)ct, readtcp, in clntbtcp_create()
264 cl->cl_private = (caddr_t)ct; in clntbtcp_create()
269 if (ct) in clntbtcp_create()
270 bkmem_free((caddr_t)ct, sizeof (*ct)); in clntbtcp_create()
286 struct ct_data *ct; in clntbtcp_call() local
295 ct = (struct ct_data *)cl->cl_private; in clntbtcp_call()
296 msg_x_id = (uint32_t *)ct->ct_mcall; in clntbtcp_call()
298 xdrs = &(ct->ct_xdrs); in clntbtcp_call()
300 ct->ct_total = utimeout; in clntbtcp_call()
306 if (ct->ct_total.tv_sec == 0) in clntbtcp_call()
307 ct->ct_total.tv_sec = RPC_RCVWAIT_MSEC / 1000; in clntbtcp_call()
309 ct->ct_wait_msec = ct->ct_total.tv_sec * 1000 + in clntbtcp_call()
310 ct->ct_total.tv_usec / 1000; in clntbtcp_call()
312 timeout = ct->ct_total; in clntbtcp_call()
319 ct->ct_error.re_status = RPC_SUCCESS; in clntbtcp_call()
321 if ((! XDR_PUTBYTES(xdrs, ct->ct_mcall, ct->ct_mpos)) || in clntbtcp_call()
326 ct->ct_error.re_status = RPC_CANTENCODEARGS; in clntbtcp_call()
328 return (ct->ct_error.re_status); in clntbtcp_call()
333 ct->ct_error.re_status = RPC_CANTSEND; in clntbtcp_call()
334 return (ct->ct_error.re_status); in clntbtcp_call()
341 ct->ct_error.re_status = RPC_TIMEDOUT; in clntbtcp_call()
342 return (ct->ct_error.re_status); in clntbtcp_call()
353 return (ct->ct_error.re_status); in clntbtcp_call()
357 if (ct->ct_error.re_status == RPC_SUCCESS) in clntbtcp_call()
359 return (ct->ct_error.re_status); in clntbtcp_call()
369 _seterr_reply(&reply_msg, &(ct->ct_error)); in clntbtcp_call()
370 if (ct->ct_error.re_status == RPC_SUCCESS) { in clntbtcp_call()
373 ct->ct_error.re_status = RPC_AUTHERROR; in clntbtcp_call()
374 ct->ct_error.re_why = AUTH_INVALIDRESP; in clntbtcp_call()
376 if (ct->ct_error.re_status == RPC_SUCCESS) { in clntbtcp_call()
377 ct->ct_error.re_status = RPC_CANTDECODERES; in clntbtcp_call()
391 return (ct->ct_error.re_status); in clntbtcp_call()
400 readtcp(struct ct_data *ct, in readtcp() argument
416 while ((inlen = recvfrom(ct->ct_sock, buf, len, 0, &from, in readtcp()
419 if (diff > ct->ct_wait_msec) { in readtcp()
431 ct->ct_error.re_errno = ECONNRESET; in readtcp()
432 ct->ct_error.re_status = RPC_CANTRECV; in readtcp()
436 ct->ct_error.re_errno = errno; in readtcp()
437 ct->ct_error.re_status = RPC_CANTRECV; in readtcp()
445 writetcp(ct, buf, len) in writetcp() argument
446 struct ct_data *ct; in writetcp()
453 if ((i = sendto(ct->ct_sock, (void *)buf, cnt, 0,
454 (struct sockaddr *)&(ct->ct_raddr),
455 sizeof (ct->ct_raddr))) == -1) {
456 ct->ct_error.re_errno = errno;
457 ct->ct_error.re_status = RPC_CANTSEND;
469 struct ct_data *ct = (struct ct_data *)cl->cl_private; in clntbtcp_geterr() local
471 *errp = ct->ct_error; in clntbtcp_geterr()
481 struct ct_data *ct = (struct ct_data *)cl->cl_private; in clntbtcp_freeres() local
482 XDR *xdrs = &(ct->ct_xdrs); in clntbtcp_freeres()
508 struct ct_data *ct = (struct ct_data *)cl->cl_private; in clntbtcp_destroy() local
510 if (ct->ct_closeit) { in clntbtcp_destroy()
511 (void) socket_close(ct->ct_sock); in clntbtcp_destroy()
513 XDR_DESTROY(&(ct->ct_xdrs)); in clntbtcp_destroy()
514 bkmem_free((caddr_t)ct, (sizeof (struct ct_data))); in clntbtcp_destroy()