| /onnv/onnv-gate/usr/src/cmd/gss/gssd/ |
| gssd_generic.c | 61 SVCXPRT *xprt; local
127 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0);
130 if (xprt == NULL) {
137 if (svc_reg(xprt, prognum, versnum, dispatch, nconf)
143 SVC_DESTROY(xprt); /* also t_closes fd */
|
| gssd_proc.c | 2557 SVCXPRT *xprt = rqstp->rq_xprt; local
[all...] |
| /onnv/onnv-gate/usr/src/cmd/krb5/kwarn/ |
| kwarnd_generic.c | 39 SVCXPRT *xprt; local
105 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0);
108 if (xprt == NULL) {
115 if (svc_reg(xprt, prognum, versnum, dispatch, nconf)
121 SVC_DESTROY(xprt); /* also t_closes fd */
|
| /onnv/onnv-gate/usr/src/uts/common/rpc/ |
| svc_gen.c | 110 SVCMASTERXPRT *xprt = NULL; /* service handle */ local
161 error = svc_clts_kcreate(fp, max_msgsize, &tinfo, &xprt);
165 error = svc_cots_kcreate(fp, max_msgsize, &tinfo, &xprt);
178 xprt->xp_req_head = (mblk_t *)0;
179 xprt->xp_req_tail = (mblk_t *)0;
180 mutex_init(&xprt->xp_req_lock, NULL, MUTEX_DEFAULT, NULL);
181 mutex_init(&xprt->xp_thread_lock, NULL, MUTEX_DEFAULT, NULL);
182 xprt->xp_type = tinfo.SERV_type;
183 xprt->xp_threads = 0;
184 xprt->xp_detached_threads = 0
[all...] |
| svc_mt.h | 46 #define SVC_DEFUNCT 0x0002 /* xprt is defunct, release asap */
55 #define svc_flags(xprt) (SVCEXT(xprt)->flags)
56 #define version_keepquiet(xprt) (svc_flags(xprt) & SVC_VERSQUIET)
57 #define svc_defunct(xprt) ((svc_flags(xprt) & SVC_DEFUNCT) ? TRUE : FALSE)
58 #define svc_failed(xprt) ((svc_flags(xprt) & SVC_FAILED) ? TRUE : FALSE)
59 #define svc_type(xprt) (svc_flags(xprt) & SVC_TYPE_MASK
96 SVCXPRT *xprt; member in struct:svcxprt_list_t
[all...] |
| svc_cots.c | 101 svc_cots_kclone_destroy, /* Destroy a clone xprt */
107 * Kept in xprt->xp_p2.
188 SVCMASTERXPRT *xprt; local
199 xprt = kmem_zalloc(sizeof (SVCMASTERXPRT), KM_SLEEP);
208 xprt->xp_msg_size = COTS_MAX_ALLOCSIZE;
210 xprt->xp_msg_size = tinfo->TIDU_size -
214 xprt->xp_ops = &svc_cots_op;
215 xprt->xp_p2 = (caddr_t)cmd;
230 kmem_free(xprt, sizeof (SVCMASTERXPRT));
234 xprt->xp_rtaddr.maxlen = ack_p->REMADDR_length
[all...] |
| svc_clts.c | 96 svc_clts_kclone_destroy, /* Destroy a clone xprt */
102 * Kept in xprt->xp_p2buf.
154 SVCMASTERXPRT *xprt; local
163 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP);
164 xprt->xp_lcladdr.buf = kmem_zalloc(sizeof (sin6_t), KM_SLEEP);
165 xprt->xp_p2 = (caddr_t)rpcstat->rpc_clts_server;
166 xprt->xp_ops = &svc_clts_op;
167 xprt->xp_msg_size = tinfo->TSDU_size;
169 xprt->xp_rtaddr.buf = NULL
[all...] |
| svc_rdma.c | 143 svc_rdma_kclone_destroy, /* Destroy a clone xprt */
194 SVCMASTERXPRT *xprt; local
246 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP);
247 xprt->xp_ops = &rdma_svc_ops;
248 xprt->xp_sct = sct;
249 xprt->xp_type = T_RDMA;
250 mutex_init(&xprt->xp_req_lock, NULL, MUTEX_DEFAULT, NULL);
251 mutex_init(&xprt->xp_thread_lock, NULL, MUTEX_DEFAULT, NULL);
252 xprt->xp_req_head = (mblk_t *)0
[all...] |
| /onnv/onnv-gate/usr/src/cmd/keyserv/ |
| key_generic.c | 76 SVCXPRT *xprt; /* Server handle */ member in struct:xlist
81 SVCXPRT *xprt; local
98 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
101 if (svc_reg(l->xprt, prognum, versnum,
158 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0);
161 if (xprt) {
163 if (svc_reg(xprt, prognum, versnum,
168 SVC_DESTROY(xprt);
175 SVC_DESTROY(xprt);
178 l->xprt = xprt
[all...] |
| /onnv/onnv-gate/usr/src/cmd/fm/fmd/common/ |
| fmd_rpc.c | 69 SVCXPRT *xprt; local
104 svc_fd_negotiate_ucred(fd); /* enable ucred option on xprt */
106 if ((xprt = svc_tli_create(fd, ncp, NULL, ssz, rsz)) == NULL) {
111 if (svc_reg(xprt, prog, vers, disp, ncp) == FALSE) {
114 svc_destroy(xprt);
139 if ((xprt = svc_door_create(disp, prog, vers, ssz)) == NULL) {
143 (void) svc_control(xprt, SVCSET_CONNMAXREC, &rsz);
237 * Utillity function to fetch the XPRT's ucred and determine if we should deny
|
| /onnv/onnv-gate/usr/src/cmd/rpcsvc/nis/rpc.nisd/resolv_server/ |
| rpc_as.c | 98 rpc_as_register(rpc_as *xprt)
104 if (xprt->as_fd < 0)
111 if (xprt->as_fd >= rpc_as_pollfd_allocd) {
118 } while (xprt->as_fd >= rpc_as_pollfd_allocd);
147 rpc_as_handles[xprt->as_fd] = xprt;
148 rpc_as_pollset[xprt->as_fd].fd = xprt->as_fd;
149 rpc_as_pollset[xprt->as_fd].events =
151 rpc_as_pollset[xprt->as_fd].revents = 0
201 rpc_as *xprt; local
[all...] |
| ypresolv_proc.c | 64 SVCXPRT *xprt; member in struct:cache_ent
136 * since we never did a recv on this unreg'ed xprt.
374 svc_setxid(xprt, xid)
375 register SVCXPRT *xprt;
379 struct svc_dg_data *su = get_svc_dg_data(xprt);
431 chl->xprt = transp;
531 chl->xprt = transp;
622 transp = chl->xprt;
|
| /onnv/onnv-gate/usr/src/lib/libnsl/rpc/ |
| svc_generic.c | 119 SVCXPRT *xprt; local
143 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
163 if (svc_reg(l->xprt, prognum, versnum,
176 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
177 if (xprt) {
178 if (!__svc_add_to_xlist(&_svc_xprtlist, xprt,
205 SVCXPRT *xprt; local
218 xprt = svc_tli_create_common(RPC_ANYFD, nconf, NULL, 0, 0, anon_mlp);
219 if (xprt == NULL)
240 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE)
271 SVCXPRT *xprt = NULL; \/* service handle *\/ local
[all...] |
| svc_run.c | 261 SVCXPRT *xprt; local
274 xprt = svc_xports[fd];
275 if (xprt) {
276 SVC_DESTROY(xprt);
393 SVCXPRT *parent_xprt, *xprt; local
629 * Get parent xprt. It is possible for the parent service
645 * Make a copy of parent xprt, update svc_fdset.
647 if ((xprt = make_xprt_copy(parent_xprt)) == NULL)
671 msg = SVCEXT(xprt)->msg;
673 r = SVCEXT(xprt)->req
848 SVCXPRT *xprt; local
[all...] |
| svc_door.c | 70 * kept in xprt->xp_p2
83 #define su_data(xprt) ((struct svc_door_data *)(xprt->xp_p2))
95 __svc_add_to_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp)
101 l->xprt = xprt;
112 __svc_rm_from_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp)
119 if ((*l)->xprt == xprt) {
157 svc_door_destroy_pvt(l->xprt);
226 SVCXPRT *xprt; local
313 SVCXPRT *xprt; local
440 SVCXPRT *xprt; local
496 SVCXPRT *xprt; local
[all...] |
| /onnv/onnv-gate/usr/src/cmd/rpcsvc/nis/rpc.nisd/ |
| resolv.c | 70 SVCXPRT *xprt = NULL; local
93 if (!getprognum(&prognum, &xprt, fd_str, prog_str, YPDNSVERS, tp)) {
94 syslog(LOG_ERR, "can't create resolv xprt for transient.\n");
126 /* close fd, free xprt, but leave mapping */
127 if (xprt) svc_destroy(xprt);
165 getprognum(prognum, xprt, fd_str, prog_str, vers, tp_type)
167 SVCXPRT **xprt;
180 *xprt = NULL;
191 * - close the fd (after exec), free xprt, leave mapping intac
[all...] |
| nis_main.c | 335 SVCXPRT *xprt; local
362 xprt = svc_tli_create(fd, nconf, (struct t_bind *)NULL, 0, 0);
363 if (xprt == (SVCXPRT *)NULL) {
367 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE) {
371 SVC_DESTROY(xprt);
374 return (xprt);
387 SVCXPRT *xprt; /* Server handle */ member in struct:xlist
410 SVCXPRT *xprt; local
423 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
426 if (svc_reg(l->xprt, prognum, versnum
[all...] |
| /onnv/onnv-gate/usr/src/cmd/ypcmd/ |
| ypserv_resolv.c | 66 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str,
75 SVCXPRT *xprt = NULL; local
108 if (!getprognum(&prognum, &xprt, fd_str, prog_str, YPDNSVERS, tp)) {
109 syslog(LOG_ERR, "can't create resolv xprt for transient.\n");
141 /* close fd, free xprt, but leave mapping */
142 if (xprt)
143 svc_destroy(xprt);
200 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str,
215 *xprt = NULL;
226 * - close the fd (after exec), free xprt, leave mapping intac
[all...] |
| yp_b_svc.c | 340 SVCXPRT *xprt; local
346 if ((xprt = svc_tp_create(ypbindprog_3,
352 cache_transport(nconf, xprt, YPBINDVERS);
367 if (!svc_reg(xprt, YPBINDPROG, YPBINDVERS_2,
375 cache_transport(nconf, xprt, YPBINDVERS_2);
381 if (!svc_reg(xprt, YPBINDPROG, YPBINDVERS_1,
389 cache_transport(nconf, xprt, YPBINDVERS_1);
403 __rpc_negotiate_uid(xprt->xp_fd)) {
|
| ypserv.c | 155 SVCXPRT *xprt; member in struct:__anon1918
304 if ((service[i].xprt = svc_tli_create(service[i].fd, nconf,
314 if (!svc_reg(service[i].xprt, YPPROG, YPVERS, ypdispatch,
317 svc_destroy(service[i].xprt);
318 service[i].xprt = 0;
325 if (service[i].olddispatch && !svc_reg(service[i].xprt, YPPROG,
330 svc_destroy(service[i].xprt);
331 service[i].xprt = 0;
|
| ypxfrd_server.c | 127 SVCXPRT *xprt; local
136 xprt = rqstp->rq_xprt;
185 if ((nbuf = svc_getrpccaller(xprt)) == 0) {
187 if (!svc_sendreply(xprt, xdr_answer, (caddr_t)&res)) {
188 svcerr_systemerr(xprt);
196 if (!svc_sendreply(xprt, xdr_answer, (caddr_t)&res)) {
197 svcerr_systemerr(xprt);
218 if (!svc_sendreply(xprt, xdr_answer, (caddr_t)&res)) {
219 svcerr_systemerr(xprt);
|
| /onnv/onnv-gate/usr/src/ucblib/librpcsoc/ |
| svc_tcp.c | 75 struct tcp_rendezvous { /* kept in xprt->xp_p1 */
80 struct tcp_conn { /* kept in xprt->xp_p1 */
89 * xprt = svctcp_create(sock, send_buf_size, recv_buf_size);
92 * Once *xprt is initialized, it is registered as a transporter
100 * xprt->xp_sock is the registered socket number and xprt->xp_port is the
114 register SVCXPRT *xprt; local
150 xprt = svc_xprt_alloc();
151 if (xprt == NULL) {
158 xprt->xp_p2 = NULL
190 register SVCXPRT *xprt; local
[all...] |
| svc_udp.c | 57 #define rpc_buffer(xprt) ((xprt)->xp_p1)
80 * kept in xprt->xp_p2
89 #define su_data(xprt) ((struct svcudp_data *)(xprt->xp_p2))
93 * xprt = svcudp_create(sock);
98 * xprt->xp_sock is the registered socket number and xprt->xp_port is the
100 * Once *xprt is initialized, it is registered as a transporter;
110 register SVCXPRT *xprt; local
[all...] |
| /onnv/onnv-gate/usr/src/uts/common/avs/ns/rdc/ |
| rdcsrv.c | 76 static void rdcsrv_xprtclose(const SVCXPRT *xprt);
168 rdcsrv_dispdup(struct svc_req *req, SVCXPRT *xprt)
180 dupstat = SVC_DUP(xprt, req, 0, 0, &dr);
185 svcerr_systemerr(xprt);
195 (*fn)(xprt, req);
196 SVC_DUPDONE(xprt, dr, 0, 0, DUP_DONE);
211 rdcsrv_dispatch(struct svc_req *req, SVCXPRT *xprt)
227 svcerr_noproc(xprt);
230 /* svcerr_noproc does a freeargs on xprt */
239 svcerr_noproc(xprt);
280 SVCXPRT *xprt; local
282 SVCMASTERXPRT *xprt; local
[all...] |
| /onnv/onnv-gate/usr/src/cmd/idmap/idmapd/ |
| idmapd.c | 64 SVCXPRT *xprt = NULL; variable
399 xprt = svc_door_create(idmap_prog_1, IDMAP_PROG, IDMAP_V1, connmaxrec);
400 if (xprt == NULL) {
405 if (!svc_control(xprt, SVCSET_CONNMAXREC, &connmaxrec)) {
410 dfd = xprt->xp_fd;
448 if (xprt != NULL)
449 svc_destroy(xprt);
|
