| /mirbsd/src/include/rpc/ |
| D | svc.h | 119 #define SVC_RECV(xprt, msg) \ argument
120 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
121 #define svc_recv(xprt, msg) \ argument
122 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
124 #define SVC_STAT(xprt) \ argument
125 (*(xprt)->xp_ops->xp_stat)(xprt)
126 #define svc_stat(xprt) \ argument
127 (*(xprt)->xp_ops->xp_stat)(xprt)
129 #define SVC_GETARGS(xprt, xargs, argsp) \ argument
130 (*(xprt)->xp_ops->xp_getargs)((xprt), (xargs), (argsp))
[all …]
|
| /mirbsd/src/lib/libc/rpc/ |
| D | svc_tcp.c | 60 static bool_t svctcp_recv(SVCXPRT *xprt, struct rpc_msg *msg);
61 static enum xprt_stat svctcp_stat(SVCXPRT *xprt);
62 static bool_t svctcp_getargs(SVCXPRT *xprt, xdrproc_t xdr_args,
64 static bool_t svctcp_reply(SVCXPRT *xprt, struct rpc_msg *msg);
65 static bool_t svctcp_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args,
67 static void svctcp_destroy(SVCXPRT *xprt);
81 static bool_t rendezvous_request(SVCXPRT *xprt, struct rpc_msg *);
82 static enum xprt_stat rendezvous_stat(SVCXPRT *xprt);
94 static int readtcp(SVCXPRT *xprt, caddr_t buf, int len),
95 writetcp(SVCXPRT *xprt, caddr_t buf, int len);
[all …]
|
| D | svc_udp.c | 50 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument
81 #define su_data(xprt) ((struct svcudp_data *)(xprt->xp_p2)) argument
107 SVCXPRT *xprt; in svcudp_bufcreate_withport() local
138 xprt = (SVCXPRT *)mem_alloc(sizeof(SVCXPRT)); in svcudp_bufcreate_withport()
139 if (xprt == NULL) { in svcudp_bufcreate_withport()
150 free(xprt); in svcudp_bufcreate_withport()
154 if ((rpc_buffer(xprt) = mem_alloc(su->su_iosz)) == NULL) { in svcudp_bufcreate_withport()
158 free(xprt); in svcudp_bufcreate_withport()
162 xdrmem_create(&(su->su_xdrs), rpc_buffer(xprt), su->su_iosz, in svcudp_bufcreate_withport()
165 xprt->xp_p2 = (caddr_t)su; in svcudp_bufcreate_withport()
[all …]
|
| D | svc.c | 85 xprt_register(SVCXPRT *xprt) in xprt_register() argument
88 (void) __xprt_register(xprt); in xprt_register()
95 __xprt_register(SVCXPRT *xprt) in __xprt_register() argument
97 int sock = xprt->xp_sock; in __xprt_register()
119 xports[sock] = xprt; in __xprt_register()
272 xprt_unregister(SVCXPRT *xprt) in xprt_unregister() argument
274 int sock = xprt->xp_sock; in xprt_unregister()
276 if (xports[sock] == xprt) { in xprt_unregister()
291 svc_register(SVCXPRT *xprt, u_long prog, u_long vers, void (*dispatch)(), in svc_register() argument
314 return (pmap_set(prog, vers, protocol, xprt->xp_port)); in svc_register()
[all …]
|
| D | svc_raw.c | 54 static bool_t svcraw_recv(SVCXPRT *xprt, struct rpc_msg *msg);
55 static enum xprt_stat svcraw_stat(SVCXPRT *xprt);
56 static bool_t svcraw_getargs(SVCXPRT *xprt, xdrproc_t xdr_args,
58 static bool_t svcraw_reply(SVCXPRT *xprt, struct rpc_msg *msg);
59 static bool_t svcraw_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args,
61 static void svcraw_destroy(SVCXPRT *xprt);
92 svcraw_stat(SVCXPRT *xprt) in svcraw_stat() argument
100 svcraw_recv(SVCXPRT *xprt, struct rpc_msg *msg) in svcraw_recv() argument
117 svcraw_reply(SVCXPRT *xprt, struct rpc_msg *msg) in svcraw_reply() argument
135 svcraw_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) in svcraw_getargs() argument
[all …]
|
| /mirbsd/src/usr.sbin/portmap/ |
| D | portmap.c | 111 SVCXPRT *xprt; in main() local
156 if ((xprt = svcudp_create(sock)) == (SVCXPRT *)NULL) { in main()
198 if ((xprt = svctcp_create(sock, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE)) in main()
250 if (svc_register(xprt, PMAPPROG, PMAPVERS, reg_service, FALSE) == 0) { in main()
292 reg_service(struct svc_req *rqstp, SVCXPRT *xprt) in reg_service() argument
300 fromsin = svc_getcaller(xprt); in reg_service()
310 if (!svc_sendreply(xprt, xdr_void, (caddr_t)0) && debugging) { in reg_service()
319 if (xprt != ltcpxprt && xprt != ludpxprt) { in reg_service()
323 svcerr_noproc(xprt); in reg_service()
326 if (!svc_getargs(xprt, xdr_pmap, (caddr_t)®)) { in reg_service()
[all …]
|