2 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
3 * unrestricted use provided that this legend is included on all tape
4 * media and as a part of the software program in whole or part. Users
5 * may copy or modify Sun RPC without charge, but are not authorized
6 * to license or distribute it to anyone else except as part of a product or
7 * program developed by the user.
9 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
10 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
11 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
13 * Sun RPC is provided with no support and without any obligation on the
14 * part of Sun Microsystems, Inc. to assist in its use, correction,
15 * modification or enhancement.
17 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
18 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
19 * OR ANY PART THEREOF.
21 * In no event will Sun Microsystems, Inc. be liable for any lost revenue
22 * or profits or other special, indirect and consequential damages, even if
23 * Sun has been advised of the possibility of such damages.
25 * Sun Microsystems, Inc.
27 * Mountain View, California 94043
31 * svc_unix.c, Server side for TCP/IP based RPC.
33 * Copyright (C) 1984, Sun Microsystems, Inc.
35 * Actually implements two flavors of transporter -
36 * a unix rendezvouser (a listener and connection establisher)
37 * and a record/unix stream.
48 #include <sys/socket.h>
60 * Ops vector for AF_UNIX based rpc service handle
62 static bool_t
svcunix_recv (SVCXPRT
*, struct rpc_msg
*);
63 static enum xprt_stat
svcunix_stat (SVCXPRT
*);
64 static bool_t
svcunix_getargs (SVCXPRT
*, xdrproc_t
, caddr_t
);
65 static bool_t
svcunix_reply (SVCXPRT
*, struct rpc_msg
*);
66 static bool_t
svcunix_freeargs (SVCXPRT
*, xdrproc_t
, caddr_t
);
67 static void svcunix_destroy (SVCXPRT
*);
69 static const struct xp_ops svcunix_op
=
80 * Ops vector for AF_UNIX rendezvous handler
82 static bool_t
rendezvous_request (SVCXPRT
*, struct rpc_msg
*);
83 static enum xprt_stat
rendezvous_stat (SVCXPRT
*);
84 static void svcunix_rendezvous_abort (void) attribute_noreturn
;
86 /* This function makes sure abort() relocation goes through PLT
87 and thus can be lazy bound. */
89 svcunix_rendezvous_abort (void)
94 static const struct xp_ops svcunix_rendezvous_op
=
98 (bool_t (*) (SVCXPRT
*, xdrproc_t
, caddr_t
)) svcunix_rendezvous_abort
,
99 (bool_t (*) (SVCXPRT
*, struct rpc_msg
*)) svcunix_rendezvous_abort
,
100 (bool_t (*) (SVCXPRT
*, xdrproc_t
, caddr_t
)) svcunix_rendezvous_abort
,
104 static int readunix (char*, char *, int);
105 static int writeunix (char *, char *, int);
106 static SVCXPRT
*makefd_xprt (int, u_int
, u_int
) internal_function
;
108 struct unix_rendezvous
{ /* kept in xprt->xp_p1 */
113 struct unix_conn
{ /* kept in xprt->xp_p1 */
114 enum xprt_stat strm_stat
;
117 char verf_body
[MAX_AUTH_BYTES
];
122 * xprt = svcunix_create(sock, send_buf_size, recv_buf_size);
124 * Creates, registers, and returns a (rpc) unix based transporter.
125 * Once *xprt is initialized, it is registered as a transporter
126 * see (svc.h, xprt_register). This routine returns
127 * a NULL if a problem occurred.
129 * If sock<0 then a socket is created, else sock is used.
130 * If the socket, sock is not bound to a port then svcunix_create
131 * binds it to an arbitrary port. The routine then starts a unix
132 * listener on the socket's associated port. In any (successful) case,
133 * xprt->xp_sock is the registered socket number and xprt->xp_port is the
134 * associated port number.
136 * Since unix streams do buffered io similar to stdio, the caller can specify
137 * how big the send and receive buffers are via the second and third parms;
138 * 0 => use the system default.
141 svcunix_create (int sock
, u_int sendsize
, u_int recvsize
, char *path
)
143 bool_t madesock
= FALSE
;
145 struct unix_rendezvous
*r
;
146 struct sockaddr_un addr
;
147 socklen_t len
= sizeof (struct sockaddr_in
);
149 if (sock
== RPC_ANYSOCK
)
151 if ((sock
= socket (AF_UNIX
, SOCK_STREAM
, 0)) < 0)
153 perror (_("svc_unix.c - AF_UNIX socket creation problem"));
154 return (SVCXPRT
*) NULL
;
158 memset (&addr
, '\0', sizeof (addr
));
159 addr
.sun_family
= AF_UNIX
;
160 len
= strlen (path
) + 1;
161 memcpy (addr
.sun_path
, path
, len
);
162 len
+= sizeof (addr
.sun_family
);
164 bind (sock
, (struct sockaddr
*) &addr
, len
);
166 if (getsockname (sock
, (struct sockaddr
*) &addr
, &len
) != 0
167 || listen (sock
, 2) != 0)
169 perror (_("svc_unix.c - cannot getsockname or listen"));
172 return (SVCXPRT
*) NULL
;
175 r
= (struct unix_rendezvous
*) mem_alloc (sizeof (*r
));
176 xprt
= (SVCXPRT
*) mem_alloc (sizeof (SVCXPRT
));
177 if (r
== NULL
|| xprt
== NULL
)
180 if (_IO_fwide (stderr
, 0) > 0)
181 __fwprintf (stderr
, L
"%s", _("svcunix_create: out of memory\n"));
184 fputs (_("svcunix_create: out of memory\n"), stderr
);
185 mem_free (r
, sizeof (*r
));
186 mem_free (xprt
, sizeof (SVCXPRT
));
189 r
->sendsize
= sendsize
;
190 r
->recvsize
= recvsize
;
192 xprt
->xp_p1
= (caddr_t
) r
;
193 xprt
->xp_verf
= _null_auth
;
194 xprt
->xp_ops
= &svcunix_rendezvous_op
;
196 xprt
->xp_sock
= sock
;
197 xprt_register (xprt
);
202 * Like svunix_create(), except the routine takes any *open* UNIX file
203 * descriptor as its first input.
206 svcunixfd_create (int fd
, u_int sendsize
, u_int recvsize
);
208 svcunixfd_create (int fd
, u_int sendsize
, u_int recvsize
)
210 return makefd_xprt (fd
, sendsize
, recvsize
);
215 makefd_xprt (int fd
, u_int sendsize
, u_int recvsize
)
218 struct unix_conn
*cd
;
220 xprt
= (SVCXPRT
*) mem_alloc (sizeof (SVCXPRT
));
221 cd
= (struct unix_conn
*) mem_alloc (sizeof (struct unix_conn
));
222 if (xprt
== (SVCXPRT
*) NULL
|| cd
== (struct unix_conn
*) NULL
)
225 if (_IO_fwide (stderr
, 0) > 0)
226 (void) __fwprintf (stderr
, L
"%s",
227 _("svc_unix: makefd_xprt: out of memory\n"));
230 (void) fputs (_("svc_unix: makefd_xprt: out of memory\n"), stderr
);
231 mem_free (xprt
, sizeof (SVCXPRT
));
232 mem_free (cd
, sizeof (struct unix_conn
));
235 cd
->strm_stat
= XPRT_IDLE
;
236 xdrrec_create (&(cd
->xdrs
), sendsize
, recvsize
,
237 (caddr_t
) xprt
, readunix
, writeunix
);
239 xprt
->xp_p1
= (caddr_t
) cd
;
240 xprt
->xp_verf
.oa_base
= cd
->verf_body
;
241 xprt
->xp_addrlen
= 0;
242 xprt
->xp_ops
= &svcunix_op
; /* truly deals with calls */
243 xprt
->xp_port
= 0; /* this is a connection, not a rendezvouser */
245 xprt_register (xprt
);
250 rendezvous_request (SVCXPRT
*xprt
, struct rpc_msg
*errmsg attribute_unused
)
253 struct unix_rendezvous
*r
;
254 struct sockaddr_un addr
;
255 struct sockaddr_in in_addr
;
258 r
= (struct unix_rendezvous
*) xprt
->xp_p1
;
260 len
= sizeof (struct sockaddr_un
);
261 if ((sock
= accept (xprt
->xp_sock
, (struct sockaddr
*) &addr
, &len
)) < 0)
268 * make a new transporter (re-uses xprt)
270 memset (&in_addr
, '\0', sizeof (in_addr
));
271 in_addr
.sin_family
= AF_UNIX
;
272 xprt
= makefd_xprt (sock
, r
->sendsize
, r
->recvsize
);
273 memcpy (&xprt
->xp_raddr
, &in_addr
, sizeof (in_addr
));
274 xprt
->xp_addrlen
= len
;
275 return FALSE
; /* there is never an rpc msg to be processed */
278 static enum xprt_stat
279 rendezvous_stat (SVCXPRT
*xprt attribute_unused
)
285 svcunix_destroy (SVCXPRT
*xprt
)
287 struct unix_conn
*cd
= (struct unix_conn
*) xprt
->xp_p1
;
289 xprt_unregister (xprt
);
290 close (xprt
->xp_sock
);
291 if (xprt
->xp_port
!= 0)
293 /* a rendezvouser socket */
298 /* an actual connection socket */
299 XDR_DESTROY (&(cd
->xdrs
));
301 mem_free ((caddr_t
) cd
, sizeof (struct unix_conn
));
302 mem_free ((caddr_t
) xprt
, sizeof (SVCXPRT
));
305 #ifdef SCM_CREDENTIALS
309 /* hack to make sure we have enough memory */
310 char dummy
[(CMSG_ALIGN (sizeof (struct ucred
)) - sizeof (struct ucred
) + sizeof (long))];
313 /* XXX This is not thread safe, but since the main functions in svc.c
314 and the rpcgen generated *_svc functions for the daemon are also not
315 thread safe and uses static global variables, it doesn't matter. */
316 static struct cmessage cm
;
320 __msgread (int sock
, void *data
, size_t cnt
)
333 #ifdef SCM_CREDENTIALS
334 msg
.msg_control
= (caddr_t
) &cm
;
335 msg
.msg_controllen
= sizeof (struct cmessage
);
342 if (setsockopt (sock
, SOL_SOCKET
, SO_PASSCRED
, &on
, sizeof (on
)))
348 len
= recvmsg (sock
, &msg
, 0);
351 if (msg
.msg_flags
& MSG_CTRUNC
|| len
== 0)
362 __msgwrite (int sock
, void *data
, size_t cnt
)
364 #ifndef SCM_CREDENTIALS
365 /* We cannot implement this reliably. */
366 __set_errno (ENOSYS
);
371 struct cmsghdr
*cmsg
= &cm
.cmsg
;
375 /* XXX I'm not sure, if gete?id() is always correct, or if we should use
376 get?id(). But since keyserv needs geteuid(), we have no other chance.
377 It would be much better, if the kernel could pass both to the server. */
378 cred
.pid
= getpid ();
379 cred
.uid
= geteuid ();
380 cred
.gid
= getegid ();
382 memcpy (CMSG_DATA(cmsg
), &cred
, sizeof (struct ucred
));
383 cmsg
->cmsg_level
= SOL_SOCKET
;
384 cmsg
->cmsg_type
= SCM_CREDENTIALS
;
385 cmsg
->cmsg_len
= sizeof(*cmsg
) + sizeof(struct ucred
);
394 msg
.msg_control
= cmsg
;
395 msg
.msg_controllen
= CMSG_ALIGN(cmsg
->cmsg_len
);
399 len
= sendmsg (sock
, &msg
, 0);
410 * reads data from the unix connection.
411 * any error is fatal and the connection is closed.
412 * (And a read of zero bytes is a half closed stream => error.)
415 readunix (char *xprtptr
, char *buf
, int len
)
417 SVCXPRT
*xprt
= (SVCXPRT
*) xprtptr
;
418 int sock
= xprt
->xp_sock
;
419 int milliseconds
= 35 * 1000;
420 struct pollfd pollfd
;
425 pollfd
.events
= POLLIN
;
426 switch (poll (&pollfd
, 1, milliseconds
))
435 if ((pollfd
.revents
& POLLERR
) || (pollfd
.revents
& POLLHUP
)
436 || (pollfd
.revents
& POLLNVAL
))
441 while ((pollfd
.revents
& POLLIN
) == 0);
443 if ((len
= __msgread (sock
, buf
, len
)) > 0)
447 ((struct unix_conn
*) (xprt
->xp_p1
))->strm_stat
= XPRT_DIED
;
452 * writes data to the unix connection.
453 * Any error is fatal and the connection is closed.
456 writeunix (char *xprtptr
, char * buf
, int len
)
458 SVCXPRT
*xprt
= (SVCXPRT
*) xprtptr
;
461 for (cnt
= len
; cnt
> 0; cnt
-= i
, buf
+= i
)
463 if ((i
= __msgwrite (xprt
->xp_sock
, buf
, cnt
)) < 0)
465 ((struct unix_conn
*) (xprt
->xp_p1
))->strm_stat
= XPRT_DIED
;
472 static enum xprt_stat
473 svcunix_stat (SVCXPRT
*xprt
)
475 struct unix_conn
*cd
=
476 (struct unix_conn
*) (xprt
->xp_p1
);
478 if (cd
->strm_stat
== XPRT_DIED
)
480 if (!xdrrec_eof (&(cd
->xdrs
)))
481 return XPRT_MOREREQS
;
486 svcunix_recv (SVCXPRT
*xprt
, struct rpc_msg
*msg
)
488 struct unix_conn
*cd
= (struct unix_conn
*) (xprt
->xp_p1
);
489 XDR
*xdrs
= &(cd
->xdrs
);
491 xdrs
->x_op
= XDR_DECODE
;
492 xdrrec_skiprecord (xdrs
);
493 if (xdr_callmsg (xdrs
, msg
))
495 cd
->x_id
= msg
->rm_xid
;
496 /* set up verifiers */
497 #ifdef SCM_CREDENTIALS
498 msg
->rm_call
.cb_verf
.oa_flavor
= AUTH_UNIX
;
499 msg
->rm_call
.cb_verf
.oa_base
= (caddr_t
) &cm
;
500 msg
->rm_call
.cb_verf
.oa_length
= sizeof (cm
);
504 cd
->strm_stat
= XPRT_DIED
; /* XXXX */
509 svcunix_getargs (SVCXPRT
*xprt
, xdrproc_t xdr_args
, caddr_t args_ptr
)
511 return (*xdr_args
) (&(((struct unix_conn
*) (xprt
->xp_p1
))->xdrs
),
516 svcunix_freeargs (SVCXPRT
*xprt
, xdrproc_t xdr_args
, caddr_t args_ptr
)
518 XDR
*xdrs
= &(((struct unix_conn
*) (xprt
->xp_p1
))->xdrs
);
520 xdrs
->x_op
= XDR_FREE
;
521 return (*xdr_args
) (xdrs
, args_ptr
);
525 svcunix_reply (SVCXPRT
*xprt
, struct rpc_msg
*msg
)
527 struct unix_conn
*cd
= (struct unix_conn
*) (xprt
->xp_p1
);
528 XDR
*xdrs
= &(cd
->xdrs
);
531 xdrs
->x_op
= XDR_ENCODE
;
532 msg
->rm_xid
= cd
->x_id
;
533 stat
= xdr_replymsg (xdrs
, msg
);
534 (void) xdrrec_endofrecord (xdrs
, TRUE
);