Lines Matching refs:ct
112 struct ct_data *ct; in clnttcp_create() local
123 ct = (struct ct_data *)mem_alloc(sizeof (*ct)); in clnttcp_create()
124 if (ct == NULL) { in clnttcp_create()
138 mem_free((caddr_t)ct, sizeof (struct ct_data)); in clnttcp_create()
159 ct->ct_closeit = TRUE; in clnttcp_create()
161 ct->ct_closeit = FALSE; in clnttcp_create()
167 ct->ct_sock = *sockp; in clnttcp_create()
168 ct->ct_wait.tv_usec = 0; in clnttcp_create()
169 ct->ct_waitset = FALSE; in clnttcp_create()
170 ct->ct_addr = *raddr; in clnttcp_create()
185 xdrmem_create(&(ct->ct_xdrs), ct->ct_mcall, MCALL_MSG_SIZE, in clnttcp_create()
187 if (! xdr_callhdr(&(ct->ct_xdrs), &call_msg)) { in clnttcp_create()
188 if (ct->ct_closeit) { in clnttcp_create()
193 ct->ct_mpos = XDR_GETPOS(&(ct->ct_xdrs)); in clnttcp_create()
194 XDR_DESTROY(&(ct->ct_xdrs)); in clnttcp_create()
200 xdrrec_create(&(ct->ct_xdrs), sendsz, recvsz, in clnttcp_create()
201 (caddr_t)ct, readtcp, writetcp); in clnttcp_create()
203 h->cl_private = (caddr_t)ct; in clnttcp_create()
211 mem_free((caddr_t)ct, sizeof (struct ct_data)); in clnttcp_create()
220 struct ct_data *ct; in clnttcp_call() local
228 ct = (struct ct_data *)h->cl_private; in clnttcp_call()
229 xdrs = &(ct->ct_xdrs); in clnttcp_call()
230 msg_x_id = (uint32_t *)(ct->ct_mcall); /* yuk */ in clnttcp_call()
233 if (!ct->ct_waitset) { in clnttcp_call()
234 ct->ct_wait = timeout; in clnttcp_call()
243 ct->ct_error.re_status = RPC_SUCCESS; in clnttcp_call()
245 if ((! XDR_PUTBYTES(xdrs, ct->ct_mcall, ct->ct_mpos)) || in clnttcp_call()
249 if (ct->ct_error.re_status == RPC_SUCCESS) in clnttcp_call()
250 ct->ct_error.re_status = RPC_CANTENCODEARGS; in clnttcp_call()
252 return (ct->ct_error.re_status); in clnttcp_call()
255 return (ct->ct_error.re_status = RPC_CANTSEND); in clnttcp_call()
262 return (ct->ct_error.re_status = RPC_TIMEDOUT); in clnttcp_call()
275 return (ct->ct_error.re_status); in clnttcp_call()
278 if (ct->ct_error.re_status == RPC_SUCCESS) in clnttcp_call()
280 return (ct->ct_error.re_status); in clnttcp_call()
289 __seterr_reply(&reply_msg, &(ct->ct_error)); in clnttcp_call()
290 if (ct->ct_error.re_status == RPC_SUCCESS) { in clnttcp_call()
293 ct->ct_error.re_status = RPC_AUTHERROR; in clnttcp_call()
294 ct->ct_error.re_why = AUTH_INVALIDRESP; in clnttcp_call()
296 if (ct->ct_error.re_status == RPC_SUCCESS) in clnttcp_call()
297 ct->ct_error.re_status = RPC_CANTDECODERES; in clnttcp_call()
311 return (ct->ct_error.re_status); in clnttcp_call()
317 struct ct_data *ct; in clnttcp_geterr() local
319 ct = (struct ct_data *)h->cl_private; in clnttcp_geterr()
320 *errp = ct->ct_error; in clnttcp_geterr()
326 struct ct_data *ct; in clnttcp_freeres() local
329 ct = (struct ct_data *)cl->cl_private; in clnttcp_freeres()
330 xdrs = &(ct->ct_xdrs); in clnttcp_freeres()
343 struct ct_data *ct; in clnttcp_control() local
345 ct = (struct ct_data *)cl->cl_private; in clnttcp_control()
348 ct->ct_wait = *(struct timeval *)info; in clnttcp_control()
349 ct->ct_waitset = TRUE; in clnttcp_control()
352 *(struct timeval *)info = ct->ct_wait; in clnttcp_control()
355 *(struct sockaddr_in *)info = ct->ct_addr; in clnttcp_control()
358 *(int *)info = ct->ct_sock; in clnttcp_control()
361 ct->ct_closeit = TRUE; in clnttcp_control()
364 ct->ct_closeit = FALSE; in clnttcp_control()
376 struct ct_data *ct; in clnttcp_destroy() local
378 ct = (struct ct_data *)h->cl_private; in clnttcp_destroy()
379 if (ct->ct_closeit) { in clnttcp_destroy()
380 (void) close(ct->ct_sock); in clnttcp_destroy()
382 XDR_DESTROY(&(ct->ct_xdrs)); in clnttcp_destroy()
383 mem_free((caddr_t)ct, sizeof (struct ct_data)); in clnttcp_destroy()
397 struct ct_data *ct; in readtcp() local
402 ct = data; in readtcp()
404 FD_SET(ct->ct_sock, &mask); in readtcp()
408 &readfds, NULL, NULL, &(ct->ct_wait))) { in readtcp()
410 ct->ct_error.re_status = RPC_TIMEDOUT; in readtcp()
416 ct->ct_error.re_status = RPC_CANTRECV; in readtcp()
417 ct->ct_error.re_errno = errno; in readtcp()
422 switch (len = read(ct->ct_sock, buf, len)) { in readtcp()
426 ct->ct_error.re_errno = ECONNRESET; in readtcp()
427 ct->ct_error.re_status = RPC_CANTRECV; in readtcp()
432 ct->ct_error.re_errno = errno; in readtcp()
433 ct->ct_error.re_status = RPC_CANTRECV; in readtcp()
442 struct ct_data *ct; in writetcp() local
445 ct = data; in writetcp()
447 if ((i = write(ct->ct_sock, buf, cnt)) == -1) { in writetcp()
448 ct->ct_error.re_errno = errno; in writetcp()
449 ct->ct_error.re_status = RPC_CANTSEND; in writetcp()