Lines Matching refs:xprt
156 SVCXPRT *xprt; in svctcp_create() local
186 xprt = (SVCXPRT *) mem_alloc (sizeof (SVCXPRT)); in svctcp_create()
187 if (r == NULL || xprt == NULL) in svctcp_create()
191 mem_free (xprt, sizeof (SVCXPRT)); in svctcp_create()
196 xprt->xp_p2 = NULL; in svctcp_create()
197 xprt->xp_p1 = (caddr_t) r; in svctcp_create()
198 xprt->xp_verf = _null_auth; in svctcp_create()
199 xprt->xp_ops = &svctcp_rendezvous_op; in svctcp_create()
200 xprt->xp_port = ntohs (addr.sin_port); in svctcp_create()
201 xprt->xp_sock = sock; in svctcp_create()
202 xprt_register (xprt); in svctcp_create()
203 return xprt; in svctcp_create()
225 SVCXPRT *xprt; in libc_hidden_nolink_sunrpc() local
228 xprt = (SVCXPRT *) mem_alloc (sizeof (SVCXPRT)); in libc_hidden_nolink_sunrpc()
230 if (xprt == (SVCXPRT *) NULL || cd == NULL) in libc_hidden_nolink_sunrpc()
234 mem_free (xprt, sizeof (SVCXPRT)); in libc_hidden_nolink_sunrpc()
240 (caddr_t) xprt, readtcp, writetcp); in libc_hidden_nolink_sunrpc()
241 xprt->xp_p2 = NULL; in libc_hidden_nolink_sunrpc()
242 xprt->xp_p1 = (caddr_t) cd; in libc_hidden_nolink_sunrpc()
243 xprt->xp_verf.oa_base = cd->verf_body; in libc_hidden_nolink_sunrpc()
244 xprt->xp_addrlen = 0; in libc_hidden_nolink_sunrpc()
245 xprt->xp_ops = &svctcp_op; /* truly deals with calls */ in libc_hidden_nolink_sunrpc()
246 xprt->xp_port = 0; /* this is a connection, not a rendezvouser */ in libc_hidden_nolink_sunrpc()
247 xprt->xp_sock = fd; in libc_hidden_nolink_sunrpc()
248 xprt_register (xprt); in libc_hidden_nolink_sunrpc()
249 return xprt; in libc_hidden_nolink_sunrpc()
253 rendezvous_request (SVCXPRT *xprt, struct rpc_msg *errmsg) in rendezvous_request() argument
260 r = (struct tcp_rendezvous *) xprt->xp_p1; in rendezvous_request()
263 if ((sock = accept (xprt->xp_sock, (struct sockaddr *) &addr, &len)) < 0) in rendezvous_request()
273 xprt = makefd_xprt (sock, r->sendsize, r->recvsize); in rendezvous_request()
276 if (xprt == NULL) in rendezvous_request()
282 memcpy (&xprt->xp_raddr, &addr, sizeof (addr)); in rendezvous_request()
283 xprt->xp_addrlen = len; in rendezvous_request()
288 rendezvous_stat (SVCXPRT *xprt) in rendezvous_stat() argument
294 svctcp_destroy (SVCXPRT *xprt) in svctcp_destroy() argument
296 struct tcp_conn *cd = (struct tcp_conn *) xprt->xp_p1; in svctcp_destroy()
298 xprt_unregister (xprt); in svctcp_destroy()
299 (void) __close (xprt->xp_sock); in svctcp_destroy()
300 if (xprt->xp_port != 0) in svctcp_destroy()
303 xprt->xp_port = 0; in svctcp_destroy()
311 mem_free ((caddr_t) xprt, sizeof (SVCXPRT)); in svctcp_destroy()
323 SVCXPRT *xprt = (SVCXPRT *)xprtptr; in readtcp() local
324 int sock = xprt->xp_sock; in readtcp()
353 ((struct tcp_conn *) (xprt->xp_p1))->strm_stat = XPRT_DIED; in readtcp()
364 SVCXPRT *xprt = (SVCXPRT *)xprtptr; in writetcp() local
369 if ((i = __write (xprt->xp_sock, buf, cnt)) < 0) in writetcp()
371 ((struct tcp_conn *) (xprt->xp_p1))->strm_stat = XPRT_DIED; in writetcp()
379 svctcp_stat (SVCXPRT *xprt) in svctcp_stat() argument
382 (struct tcp_conn *) (xprt->xp_p1); in svctcp_stat()
392 svctcp_recv (SVCXPRT *xprt, struct rpc_msg *msg) in svctcp_recv() argument
394 struct tcp_conn *cd = (struct tcp_conn *) (xprt->xp_p1); in svctcp_recv()
409 svctcp_getargs (SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) in svctcp_getargs() argument
412 (xprt->xp_p1))->xdrs), args_ptr)); in svctcp_getargs()
416 svctcp_freeargs (SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) in svctcp_freeargs() argument
418 XDR *xdrs = &(((struct tcp_conn *) (xprt->xp_p1))->xdrs); in svctcp_freeargs()
425 svctcp_reply (SVCXPRT *xprt, struct rpc_msg *msg) in svctcp_reply() argument
427 struct tcp_conn *cd = (struct tcp_conn *) (xprt->xp_p1); in svctcp_reply()