diff options
Diffstat (limited to 'libdiskfs/ifsock.c')
| -rw-r--r-- | libdiskfs/ifsock.c | 135 |
1 files changed, 135 insertions, 0 deletions
diff --git a/libdiskfs/ifsock.c b/libdiskfs/ifsock.c new file mode 100644 index 00000000..3e9b8325 --- /dev/null +++ b/libdiskfs/ifsock.c @@ -0,0 +1,135 @@ +/* Implement ifsock inteface + Copyright (C) 1994, 1996 Free Software Foundation + + This program is free software; you can redistribute it and/or + modify it under the terms of the GNU General Public License as + published by the Free Software Foundation; either version 2, or (at + your option) any later version. + + This program is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */ + +#include "priv.h" +#include "ifsock_S.h" +#include <hurd/paths.h> +#include <sys/socket.h> +#include <stdio.h> +#include <hurd/socket.h> + +static spin_lock_t pflocalserverlock = SPIN_LOCK_INITIALIZER; +static mach_port_t pflocalserver = MACH_PORT_NULL; + +kern_return_t +diskfs_S_ifsock_getsockaddr (struct protid *cred, + mach_port_t *address) +{ + error_t err; + struct node *np; + unsigned restart_tries = 0; + + /* Make sure this is a socket */ + if (!cred) + return EOPNOTSUPP; + np = cred->po->np; + + retry: + mutex_lock (&np->lock); + if ((np->dn_stat.st_mode & S_IFMT) != S_IFSOCK) + { + mutex_unlock (&np->lock); + return EOPNOTSUPP; + } + err = fshelp_access (&np->dn_stat, S_IWRITE, cred->user); + if (err) + { + mutex_unlock (&np->lock); + return err; + } + + if (np->sockaddr == MACH_PORT_NULL) + { + mach_port_t server; + mach_port_t sockaddr; + mach_port_t old; + + mutex_unlock (&np->lock); + + /* Fetch a port to the PF_LOCAL server, caching it. */ + + spin_lock (&pflocalserverlock); + if (pflocalserver == MACH_PORT_NULL) + { + /* Find out who the PF_LOCAL server is. */ + char buf[100]; + + spin_unlock (&pflocalserverlock); + + /* Look it up */ + sprintf (buf, "%s/%d", _SERVERS_SOCKET, PF_LOCAL); + server = file_name_lookup (buf, 0, 0); + if (server == MACH_PORT_NULL) + return EIEIO; + + /* Set it unless someone is already here */ + spin_lock (&pflocalserverlock); + if (pflocalserver != MACH_PORT_NULL) + mach_port_deallocate (mach_task_self (), server); + else + pflocalserver = server; + spin_unlock (&pflocalserverlock); + + goto retry; + } + server = pflocalserver; + spin_unlock (&pflocalserverlock); + + /* Create an address for the node */ + err = socket_fabricate_address (server, AF_LOCAL, &sockaddr); + if ((err == MACH_SEND_INVALID_DEST || err == MIG_SERVER_DIED) + && restart_tries++ == 0) + /* The PF_LOCAL server died; try to restart it. */ + { + spin_lock (&pflocalserverlock); + if (pflocalserver == server) + pflocalserver = MACH_PORT_NULL; + spin_unlock (&pflocalserverlock); + goto retry; + } + if (err) + { + mutex_unlock (&np->lock); + return EIEIO; + } + + mutex_lock (&np->lock); + if (np->sockaddr != MACH_PORT_NULL) + /* Someone beat us */ + mach_port_deallocate (mach_task_self (), sockaddr); + else + { + /* The receive right of the sockaddr holds a reference; + when we get a dead name on that right we drop our + reference. */ + mach_port_request_notification (mach_task_self (), sockaddr, + MACH_NOTIFY_DEAD_NAME, 1, + cred->pi.port_right, + MACH_MSG_TYPE_MAKE_SEND_ONCE, + &old); + if (old != MACH_PORT_NULL) + mach_port_deallocate (mach_task_self (), old); + np->sockaddr = sockaddr; + diskfs_nref (np); + } + } + + *address = np->sockaddr; + mutex_unlock (&np->lock); + return 0; +} + |