1/* 2 * Copyright (c) 1998 Mark Newton 3 * Copyright (c) 1996 Christos Zoulas. 4 * All rights reserved. 5 * 6 * Redistribution and use in source and binary forms, with or without 7 * modification, are permitted provided that the following conditions 8 * are met: 9 * 1. Redistributions of source code must retain the above copyright 10 * notice, this list of conditions and the following disclaimer. 11 * 2. Redistributions in binary form must reproduce the above copyright 12 * notice, this list of conditions and the following disclaimer in the 13 * documentation and/or other materials provided with the distribution. 14 * 3. All advertising materials mentioning features or use of this software 15 * must display the following acknowledgement: 16 * This product includes software developed by Christos Zoulas. 17 * 4. The name of the author may not be used to endorse or promote products 18 * derived from this software without specific prior written permission. 19 * 20 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR 21 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 22 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. 23 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, 24 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT 25 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 26 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 27 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 28 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF 29 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 30 */ 31 32/* 33 * In SVR4 unix domain sockets are referenced sometimes 34 * (in putmsg(2) for example) as a [device, inode] pair instead of a pathname. 35 * Since there is no iname() routine in the kernel, and we need access to 36 * a mapping from inode to pathname, we keep our own table. This is a simple 37 * linked list that contains the pathname, the [device, inode] pair, the 38 * file corresponding to that socket and the process. When the 39 * socket gets closed we remove the item from the list. The list gets loaded 40 * every time a stat(2) call finds a socket. 41 */ 42 43#include <sys/cdefs.h>
|
71 ino_t ino; 72{ 73 struct svr4_sockcache_entry *e; 74 void *cookie = ((struct socket *)fp->f_data)->so_emuldata; 75 76 if (svr4_str_initialized != 2) { 77 if (atomic_cmpset_acq_int(&svr4_str_initialized, 0, 1)) { 78 DPRINTF(("svr4_find_socket: uninitialized [%p,%d,%d]\n", 79 td, dev, ino)); 80 TAILQ_INIT(&svr4_head); 81 atomic_store_rel_int(&svr4_str_initialized, 2); 82 } 83 return NULL; 84 } 85 86 87 DPRINTF(("svr4_find_socket: [%p,%d,%d]: ", td, dev, ino)); 88 TAILQ_FOREACH(e, &svr4_head, entries) 89 if (e->p == td->td_proc && e->dev == dev && e->ino == ino) { 90#ifdef DIAGNOSTIC 91 if (e->cookie != NULL && e->cookie != cookie) 92 panic("svr4 socket cookie mismatch"); 93#endif 94 e->cookie = cookie; 95 DPRINTF(("%s\n", e->sock.sun_path)); 96 return &e->sock; 97 } 98 99 DPRINTF(("not found\n")); 100 return NULL; 101} 102 103 104/* 105 * svr4_delete_socket() is in sys/dev/streams.c (because it's called by 106 * the streams "soo_close()" routine). 107 */ 108int 109svr4_add_socket(td, path, st) 110 struct thread *td; 111 const char *path; 112 struct stat *st; 113{ 114 struct svr4_sockcache_entry *e; 115 int len, error; 116 117 /* 118 * Wait for the TAILQ to be initialized. Only the very first CPU 119 * will succeed on the atomic_cmpset(). The other CPU's will spin 120 * until the first one finishes the initialization. Once the 121 * initialization is complete, the condition will always fail 122 * avoiding expensive atomic operations in the common case. 123 */ 124 while (svr4_str_initialized != 2) 125 if (atomic_cmpset_acq_int(&svr4_str_initialized, 0, 1)) { 126 TAILQ_INIT(&svr4_head); 127 atomic_store_rel_int(&svr4_str_initialized, 2); 128 } 129 130 e = malloc(sizeof(*e), M_TEMP, M_WAITOK); 131 e->cookie = NULL; 132 e->dev = st->st_dev; 133 e->ino = st->st_ino; 134 e->p = td->td_proc; 135 136 if ((error = copyinstr(path, e->sock.sun_path, 137 sizeof(e->sock.sun_path), &len)) != 0) { 138 DPRINTF(("svr4_add_socket: copyinstr failed %d\n", error)); 139 free(e, M_TEMP); 140 return error; 141 } 142 143 e->sock.sun_family = AF_LOCAL; 144 e->sock.sun_len = len; 145 146 TAILQ_INSERT_HEAD(&svr4_head, e, entries); 147 DPRINTF(("svr4_add_socket: %s [%p,%d,%d]\n", e->sock.sun_path, 148 td->td_proc, e->dev, e->ino)); 149 return 0; 150} 151 152 153int 154svr4_sys_socket(td, uap) 155 struct thread *td; 156 struct svr4_sys_socket_args *uap; 157{ 158 switch (uap->type) { 159 case SVR4_SOCK_DGRAM: 160 uap->type = SOCK_DGRAM; 161 break; 162 163 case SVR4_SOCK_STREAM: 164 uap->type = SOCK_STREAM; 165 break; 166 167 case SVR4_SOCK_RAW: 168 uap->type = SOCK_RAW; 169 break; 170 171 case SVR4_SOCK_RDM: 172 uap->type = SOCK_RDM; 173 break; 174 175 case SVR4_SOCK_SEQPACKET: 176 uap->type = SOCK_SEQPACKET; 177 break; 178 default: 179 return EINVAL; 180 } 181 return socket(td, (struct socket_args *)uap); 182}
|