git.oblomov.eu Git - linux-2.6/blob - net/unix/af_unix.c

   1 /*
   2  * NET4:        Implementation of BSD Unix domain sockets.
   3  *
   4  * Authors:     Alan Cox, <alan.cox@linux.org>
   5  *
   6  *              This program is free software; you can redistribute it and/or
   7  *              modify it under the terms of the GNU General Public License
   8  *              as published by the Free Software Foundation; either version
   9  *              2 of the License, or (at your option) any later version.
  10  *
  11  * Version:     $Id: af_unix.c,v 1.133 2002/02/08 03:57:19 davem Exp $
  12  *
  13  * Fixes:
  14  *              Linus Torvalds  :       Assorted bug cures.
  15  *              Niibe Yutaka    :       async I/O support.
  16  *              Carsten Paeth   :       PF_UNIX check, address fixes.
  17  *              Alan Cox        :       Limit size of allocated blocks.
  18  *              Alan Cox        :       Fixed the stupid socketpair bug.
  19  *              Alan Cox        :       BSD compatibility fine tuning.
  20  *              Alan Cox        :       Fixed a bug in connect when interrupted.
  21  *              Alan Cox        :       Sorted out a proper draft version of
  22  *                                      file descriptor passing hacked up from
  23  *                                      Mike Shaver's work.
  24  *              Marty Leisner   :       Fixes to fd passing
  25  *              Nick Nevin      :       recvmsg bugfix.
  26  *              Alan Cox        :       Started proper garbage collector
  27  *              Heiko EiBfeldt  :       Missing verify_area check
  28  *              Alan Cox        :       Started POSIXisms
  29  *              Andreas Schwab  :       Replace inode by dentry for proper
  30  *                                      reference counting
  31  *              Kirk Petersen   :       Made this a module
  32  *          Christoph Rohland   :       Elegant non-blocking accept/connect algorithm.
  33  *                                      Lots of bug fixes.
  34  *           Alexey Kuznetosv   :       Repaired (I hope) bugs introduces
  35  *                                      by above two patches.
  36  *           Andrea Arcangeli   :       If possible we block in connect(2)
  37  *                                      if the max backlog of the listen socket
  38  *                                      is been reached. This won't break
  39  *                                      old apps and it will avoid huge amount
  40  *                                      of socks hashed (this for unix_gc()
  41  *                                      performances reasons).
  42  *                                      Security fix that limits the max
  43  *                                      number of socks to 2*max_files and
  44  *                                      the number of skb queueable in the
  45  *                                      dgram receiver.
  46  *              Artur Skawina   :       Hash function optimizations
  47  *           Alexey Kuznetsov   :       Full scale SMP. Lot of bugs are introduced 8)
  48  *            Malcolm Beattie   :       Set peercred for socketpair
  49  *           Michal Ostrowski   :       Module initialization cleanup.
  50  *           Arnaldo C. Melo    :       Remove MOD_{INC,DEC}_USE_COUNT,
  51  *                                      the core infrastructure is doing that
  52  *                                      for all net proto families now (2.5.69+)
  53  *
  54  *
  55  * Known differences from reference BSD that was tested:
  56  *
  57  *      [TO FIX]
  58  *      ECONNREFUSED is not returned from one end of a connected() socket to the
  59  *              other the moment one end closes.
  60  *      fstat() doesn't return st_dev=0, and give the blksize as high water mark
  61  *              and a fake inode identifier (nor the BSD first socket fstat twice bug).
  62  *      [NOT TO FIX]
  63  *      accept() returns a path name even if the connecting socket has closed
  64  *              in the meantime (BSD loses the path and gives up).
  65  *      accept() returns 0 length path for an unbound connector. BSD returns 16
  66  *              and a null first byte in the path (but not for gethost/peername - BSD bug ??)
  67  *      socketpair(...SOCK_RAW..) doesn't panic the kernel.
  68  *      BSD af_unix apparently has connect forgetting to block properly.
  69  *              (need to check this with the POSIX spec in detail)
  70  *
  71  * Differences from 2.0.0-11-... (ANK)
  72  *      Bug fixes and improvements.
  73  *              - client shutdown killed server socket.
  74  *              - removed all useless cli/sti pairs.
  75  *
  76  *      Semantic changes/extensions.
  77  *              - generic control message passing.
  78  *              - SCM_CREDENTIALS control message.
  79  *              - "Abstract" (not FS based) socket bindings.
  80  *                Abstract names are sequences of bytes (not zero terminated)
  81  *                started by 0, so that this name space does not intersect
  82  *                with BSD names.
  83  */
  84
  85 #include <linux/module.h>
  86 #include <linux/kernel.h>
  87 #include <linux/signal.h>
  88 #include <linux/sched.h>
  89 #include <linux/errno.h>
  90 #include <linux/string.h>
  91 #include <linux/stat.h>
  92 #include <linux/dcache.h>
  93 #include <linux/namei.h>
  94 #include <linux/socket.h>
  95 #include <linux/un.h>
  96 #include <linux/fcntl.h>
  97 #include <linux/termios.h>
  98 #include <linux/sockios.h>
  99 #include <linux/net.h>
 100 #include <linux/in.h>
 101 #include <linux/fs.h>
 102 #include <linux/slab.h>
 103 #include <asm/uaccess.h>
 104 #include <linux/skbuff.h>
 105 #include <linux/netdevice.h>
 106 #include <net/sock.h>
 107 #include <net/tcp_states.h>
 108 #include <net/af_unix.h>
 109 #include <linux/proc_fs.h>
 110 #include <linux/seq_file.h>
 111 #include <net/scm.h>
 112 #include <linux/init.h>
 113 #include <linux/poll.h>
 114 #include <linux/smp_lock.h>
 115 #include <linux/rtnetlink.h>
 116 #include <linux/mount.h>
 117 #include <net/checksum.h>
 118 #include <linux/security.h>
 119
 120 int sysctl_unix_max_dgram_qlen __read_mostly = 10;
 121
 122 struct hlist_head unix_socket_table[UNIX_HASH_SIZE + 1];
 123 DEFINE_SPINLOCK(unix_table_lock);
 124 static atomic_t unix_nr_socks = ATOMIC_INIT(0);
 125
 126 #define unix_sockets_unbound    (&unix_socket_table[UNIX_HASH_SIZE])
 127
 128 #define UNIX_ABSTRACT(sk)       (unix_sk(sk)->addr->hash != UNIX_HASH_SIZE)
 129
 130 #ifdef CONFIG_SECURITY_NETWORK
 131 static void unix_get_secdata(struct scm_cookie *scm, struct sk_buff *skb)
 132 {
 133         memcpy(UNIXSID(skb), &scm->secid, sizeof(u32));
 134 }
 135
 136 static inline void unix_set_secdata(struct scm_cookie *scm, struct sk_buff *skb)
 137 {
 138         scm->secid = *UNIXSID(skb);
 139 }
 140 #else
 141 static inline void unix_get_secdata(struct scm_cookie *scm, struct sk_buff *skb)
 142 { }
 143
 144 static inline void unix_set_secdata(struct scm_cookie *scm, struct sk_buff *skb)
 145 { }
 146 #endif /* CONFIG_SECURITY_NETWORK */
 147
 148 /*
 149  *  SMP locking strategy:
 150  *    hash table is protected with spinlock unix_table_lock
 151  *    each socket state is protected by separate rwlock.
 152  */
 153
 154 static inline unsigned unix_hash_fold(__wsum n)
 155 {
 156         unsigned hash = (__force unsigned)n;
 157         hash ^= hash>>16;
 158         hash ^= hash>>8;
 159         return hash&(UNIX_HASH_SIZE-1);
 160 }
 161
 162 #define unix_peer(sk) (unix_sk(sk)->peer)
 163
 164 static inline int unix_our_peer(struct sock *sk, struct sock *osk)
 165 {
 166         return unix_peer(osk) == sk;
 167 }
 168
 169 static inline int unix_may_send(struct sock *sk, struct sock *osk)
 170 {
 171         return (unix_peer(osk) == NULL || unix_our_peer(sk, osk));
 172 }
 173
 174 static struct sock *unix_peer_get(struct sock *s)
 175 {
 176         struct sock *peer;
 177
 178         unix_state_rlock(s);
 179         peer = unix_peer(s);
 180         if (peer)
 181                 sock_hold(peer);
 182         unix_state_runlock(s);
 183         return peer;
 184 }
 185
 186 static inline void unix_release_addr(struct unix_address *addr)
 187 {
 188         if (atomic_dec_and_test(&addr->refcnt))
 189                 kfree(addr);
 190 }
 191
 192 /*
 193  *      Check unix socket name:
 194  *              - should be not zero length.
 195  *              - if started by not zero, should be NULL terminated (FS object)
 196  *              - if started by zero, it is abstract name.
 197  */
 198
 199 static int unix_mkname(struct sockaddr_un * sunaddr, int len, unsigned *hashp)
 200 {
 201         if (len <= sizeof(short) || len > sizeof(*sunaddr))
 202                 return -EINVAL;
 203         if (!sunaddr || sunaddr->sun_family != AF_UNIX)
 204                 return -EINVAL;
 205         if (sunaddr->sun_path[0]) {
 206                 /*
 207                  * This may look like an off by one error but it is a bit more
 208                  * subtle. 108 is the longest valid AF_UNIX path for a binding.
 209                  * sun_path[108] doesnt as such exist.  However in kernel space
 210                  * we are guaranteed that it is a valid memory location in our
 211                  * kernel address buffer.
 212                  */
 213                 ((char *)sunaddr)[len]=0;
 214                 len = strlen(sunaddr->sun_path)+1+sizeof(short);
 215                 return len;
 216         }
 217
 218         *hashp = unix_hash_fold(csum_partial((char*)sunaddr, len, 0));
 219         return len;
 220 }
 221
 222 static void __unix_remove_socket(struct sock *sk)
 223 {
 224         sk_del_node_init(sk);
 225 }
 226
 227 static void __unix_insert_socket(struct hlist_head *list, struct sock *sk)
 228 {
 229         BUG_TRAP(sk_unhashed(sk));
 230         sk_add_node(sk, list);
 231 }
 232
 233 static inline void unix_remove_socket(struct sock *sk)
 234 {
 235         spin_lock(&unix_table_lock);
 236         __unix_remove_socket(sk);
 237         spin_unlock(&unix_table_lock);
 238 }
 239
 240 static inline void unix_insert_socket(struct hlist_head *list, struct sock *sk)
 241 {
 242         spin_lock(&unix_table_lock);
 243         __unix_insert_socket(list, sk);
 244         spin_unlock(&unix_table_lock);
 245 }
 246
 247 static struct sock *__unix_find_socket_byname(struct sockaddr_un *sunname,
 248                                               int len, int type, unsigned hash)
 249 {
 250         struct sock *s;
 251         struct hlist_node *node;
 252
 253         sk_for_each(s, node, &unix_socket_table[hash ^ type]) {
 254                 struct unix_sock *u = unix_sk(s);
 255
 256                 if (u->addr->len == len &&
 257                     !memcmp(u->addr->name, sunname, len))
 258                         goto found;
 259         }
 260         s = NULL;
 261 found:
 262         return s;
 263 }
 264
 265 static inline struct sock *unix_find_socket_byname(struct sockaddr_un *sunname,
 266                                                    int len, int type,
 267                                                    unsigned hash)
 268 {
 269         struct sock *s;
 270
 271         spin_lock(&unix_table_lock);
 272         s = __unix_find_socket_byname(sunname, len, type, hash);
 273         if (s)
 274                 sock_hold(s);
 275         spin_unlock(&unix_table_lock);
 276         return s;
 277 }
 278
 279 static struct sock *unix_find_socket_byinode(struct inode *i)
 280 {
 281         struct sock *s;
 282         struct hlist_node *node;
 283
 284         spin_lock(&unix_table_lock);
 285         sk_for_each(s, node,
 286                     &unix_socket_table[i->i_ino & (UNIX_HASH_SIZE - 1)]) {
 287                 struct dentry *dentry = unix_sk(s)->dentry;
 288
 289                 if(dentry && dentry->d_inode == i)
 290                 {
 291                         sock_hold(s);
 292                         goto found;
 293                 }
 294         }
 295         s = NULL;
 296 found:
 297         spin_unlock(&unix_table_lock);
 298         return s;
 299 }
 300
 301 static inline int unix_writable(struct sock *sk)
 302 {
 303         return (atomic_read(&sk->sk_wmem_alloc) << 2) <= sk->sk_sndbuf;
 304 }
 305
 306 static void unix_write_space(struct sock *sk)
 307 {
 308         read_lock(&sk->sk_callback_lock);
 309         if (unix_writable(sk)) {
 310                 if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
 311                         wake_up_interruptible(sk->sk_sleep);
 312                 sk_wake_async(sk, 2, POLL_OUT);
 313         }
 314         read_unlock(&sk->sk_callback_lock);
 315 }
 316
 317 /* When dgram socket disconnects (or changes its peer), we clear its receive
 318  * queue of packets arrived from previous peer. First, it allows to do
 319  * flow control based only on wmem_alloc; second, sk connected to peer
 320  * may receive messages only from that peer. */
 321 static void unix_dgram_disconnected(struct sock *sk, struct sock *other)
 322 {
 323         if (!skb_queue_empty(&sk->sk_receive_queue)) {
 324                 skb_queue_purge(&sk->sk_receive_queue);
 325                 wake_up_interruptible_all(&unix_sk(sk)->peer_wait);
 326
 327                 /* If one link of bidirectional dgram pipe is disconnected,
 328                  * we signal error. Messages are lost. Do not make this,
 329                  * when peer was not connected to us.
 330                  */
 331                 if (!sock_flag(other, SOCK_DEAD) && unix_peer(other) == sk) {
 332                         other->sk_err = ECONNRESET;
 333                         other->sk_error_report(other);
 334                 }
 335         }
 336 }
 337
 338 static void unix_sock_destructor(struct sock *sk)
 339 {
 340         struct unix_sock *u = unix_sk(sk);
 341
 342         skb_queue_purge(&sk->sk_receive_queue);
 343
 344         BUG_TRAP(!atomic_read(&sk->sk_wmem_alloc));
 345         BUG_TRAP(sk_unhashed(sk));
 346         BUG_TRAP(!sk->sk_socket);
 347         if (!sock_flag(sk, SOCK_DEAD)) {
 348                 printk("Attempt to release alive unix socket: %p\n", sk);
 349                 return;
 350         }
 351
 352         if (u->addr)
 353                 unix_release_addr(u->addr);
 354
 355         atomic_dec(&unix_nr_socks);
 356 #ifdef UNIX_REFCNT_DEBUG
 357         printk(KERN_DEBUG "UNIX %p is destroyed, %d are still alive.\n", sk, atomic_read(&unix_nr_socks));
 358 #endif
 359 }
 360
 361 static int unix_release_sock (struct sock *sk, int embrion)
 362 {
 363         struct unix_sock *u = unix_sk(sk);
 364         struct dentry *dentry;
 365         struct vfsmount *mnt;
 366         struct sock *skpair;
 367         struct sk_buff *skb;
 368         int state;
 369
 370         unix_remove_socket(sk);
 371
 372         /* Clear state */
 373         unix_state_wlock(sk);
 374         sock_orphan(sk);
 375         sk->sk_shutdown = SHUTDOWN_MASK;
 376         dentry       = u->dentry;
 377         u->dentry    = NULL;
 378         mnt          = u->mnt;
 379         u->mnt       = NULL;
 380         state = sk->sk_state;
 381         sk->sk_state = TCP_CLOSE;
 382         unix_state_wunlock(sk);
 383
 384         wake_up_interruptible_all(&u->peer_wait);
 385
 386         skpair=unix_peer(sk);
 387
 388         if (skpair!=NULL) {
 389                 if (sk->sk_type == SOCK_STREAM || sk->sk_type == SOCK_SEQPACKET) {
 390                         unix_state_wlock(skpair);
 391                         /* No more writes */
 392                         skpair->sk_shutdown = SHUTDOWN_MASK;
 393                         if (!skb_queue_empty(&sk->sk_receive_queue) || embrion)
 394                                 skpair->sk_err = ECONNRESET;
 395                         unix_state_wunlock(skpair);
 396                         skpair->sk_state_change(skpair);
 397                         read_lock(&skpair->sk_callback_lock);
 398                         sk_wake_async(skpair,1,POLL_HUP);
 399                         read_unlock(&skpair->sk_callback_lock);
 400                 }
 401                 sock_put(skpair); /* It may now die */
 402                 unix_peer(sk) = NULL;
 403         }
 404
 405         /* Try to flush out this socket. Throw out buffers at least */
 406
 407         while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) {
 408                 if (state==TCP_LISTEN)
 409                         unix_release_sock(skb->sk, 1);
 410                 /* passed fds are erased in the kfree_skb hook        */
 411                 kfree_skb(skb);
 412         }
 413
 414         if (dentry) {
 415                 dput(dentry);
 416                 mntput(mnt);
 417         }
 418
 419         sock_put(sk);
 420
 421         /* ---- Socket is dead now and most probably destroyed ---- */
 422
 423         /*
 424          * Fixme: BSD difference: In BSD all sockets connected to use get
 425          *        ECONNRESET and we die on the spot. In Linux we behave
 426          *        like files and pipes do and wait for the last
 427          *        dereference.
 428          *
 429          * Can't we simply set sock->err?
 430          *
 431          *        What the above comment does talk about? --ANK(980817)
 432          */
 433
 434         if (atomic_read(&unix_tot_inflight))
 435                 unix_gc();              /* Garbage collect fds */
 436
 437         return 0;
 438 }
 439
 440 static int unix_listen(struct socket *sock, int backlog)
 441 {
 442         int err;
 443         struct sock *sk = sock->sk;
 444         struct unix_sock *u = unix_sk(sk);
 445
 446         err = -EOPNOTSUPP;
 447         if (sock->type!=SOCK_STREAM && sock->type!=SOCK_SEQPACKET)
 448                 goto out;                       /* Only stream/seqpacket sockets accept */
 449         err = -EINVAL;
 450         if (!u->addr)
 451                 goto out;                       /* No listens on an unbound socket */
 452         unix_state_wlock(sk);
 453         if (sk->sk_state != TCP_CLOSE && sk->sk_state != TCP_LISTEN)
 454                 goto out_unlock;
 455         if (backlog > sk->sk_max_ack_backlog)
 456                 wake_up_interruptible_all(&u->peer_wait);
 457         sk->sk_max_ack_backlog  = backlog;
 458         sk->sk_state            = TCP_LISTEN;
 459         /* set credentials so connect can copy them */
 460         sk->sk_peercred.pid     = current->tgid;
 461         sk->sk_peercred.uid     = current->euid;
 462         sk->sk_peercred.gid     = current->egid;
 463         err = 0;
 464
 465 out_unlock:
 466         unix_state_wunlock(sk);
 467 out:
 468         return err;
 469 }
 470
 471 static int unix_release(struct socket *);
 472 static int unix_bind(struct socket *, struct sockaddr *, int);
 473 static int unix_stream_connect(struct socket *, struct sockaddr *,
 474                                int addr_len, int flags);
 475 static int unix_socketpair(struct socket *, struct socket *);
 476 static int unix_accept(struct socket *, struct socket *, int);
 477 static int unix_getname(struct socket *, struct sockaddr *, int *, int);
 478 static unsigned int unix_poll(struct file *, struct socket *, poll_table *);
 479 static int unix_ioctl(struct socket *, unsigned int, unsigned long);
 480 static int unix_shutdown(struct socket *, int);
 481 static int unix_stream_sendmsg(struct kiocb *, struct socket *,
 482                                struct msghdr *, size_t);
 483 static int unix_stream_recvmsg(struct kiocb *, struct socket *,
 484                                struct msghdr *, size_t, int);
 485 static int unix_dgram_sendmsg(struct kiocb *, struct socket *,
 486                               struct msghdr *, size_t);
 487 static int unix_dgram_recvmsg(struct kiocb *, struct socket *,
 488                               struct msghdr *, size_t, int);
 489 static int unix_dgram_connect(struct socket *, struct sockaddr *,
 490                               int, int);
 491 static int unix_seqpacket_sendmsg(struct kiocb *, struct socket *,
 492                                   struct msghdr *, size_t);
 493
 494 static const struct proto_ops unix_stream_ops = {
 495         .family =       PF_UNIX,
 496         .owner =        THIS_MODULE,
 497         .release =      unix_release,
 498         .bind =         unix_bind,
 499         .connect =      unix_stream_connect,
 500         .socketpair =   unix_socketpair,
 501         .accept =       unix_accept,
 502         .getname =      unix_getname,
 503         .poll =         unix_poll,
 504         .ioctl =        unix_ioctl,
 505         .listen =       unix_listen,
 506         .shutdown =     unix_shutdown,
 507         .setsockopt =   sock_no_setsockopt,
 508         .getsockopt =   sock_no_getsockopt,
 509         .sendmsg =      unix_stream_sendmsg,
 510         .recvmsg =      unix_stream_recvmsg,
 511         .mmap =         sock_no_mmap,
 512         .sendpage =     sock_no_sendpage,
 513 };
 514
 515 static const struct proto_ops unix_dgram_ops = {
 516         .family =       PF_UNIX,
 517         .owner =        THIS_MODULE,
 518         .release =      unix_release,
 519         .bind =         unix_bind,
 520         .connect =      unix_dgram_connect,
 521         .socketpair =   unix_socketpair,
 522         .accept =       sock_no_accept,
 523         .getname =      unix_getname,
 524         .poll =         datagram_poll,
 525         .ioctl =        unix_ioctl,
 526         .listen =       sock_no_listen,
 527         .shutdown =     unix_shutdown,
 528         .setsockopt =   sock_no_setsockopt,
 529         .getsockopt =   sock_no_getsockopt,
 530         .sendmsg =      unix_dgram_sendmsg,
 531         .recvmsg =      unix_dgram_recvmsg,
 532         .mmap =         sock_no_mmap,
 533         .sendpage =     sock_no_sendpage,
 534 };
 535
 536 static const struct proto_ops unix_seqpacket_ops = {
 537         .family =       PF_UNIX,
 538         .owner =        THIS_MODULE,
 539         .release =      unix_release,
 540         .bind =         unix_bind,
 541         .connect =      unix_stream_connect,
 542         .socketpair =   unix_socketpair,
 543         .accept =       unix_accept,
 544         .getname =      unix_getname,
 545         .poll =         datagram_poll,
 546         .ioctl =        unix_ioctl,
 547         .listen =       unix_listen,
 548         .shutdown =     unix_shutdown,
 549         .setsockopt =   sock_no_setsockopt,
 550         .getsockopt =   sock_no_getsockopt,
 551         .sendmsg =      unix_seqpacket_sendmsg,
 552         .recvmsg =      unix_dgram_recvmsg,
 553         .mmap =         sock_no_mmap,
 554         .sendpage =     sock_no_sendpage,
 555 };
 556
 557 static struct proto unix_proto = {
 558         .name     = "UNIX",
 559         .owner    = THIS_MODULE,
 560         .obj_size = sizeof(struct unix_sock),
 561 };
 562
 563 /*
 564  * AF_UNIX sockets do not interact with hardware, hence they
 565  * dont trigger interrupts - so it's safe for them to have
 566  * bh-unsafe locking for their sk_receive_queue.lock. Split off
 567  * this special lock-class by reinitializing the spinlock key:
 568  */
 569 static struct lock_class_key af_unix_sk_receive_queue_lock_key;
 570
 571 static struct sock * unix_create1(struct socket *sock)
 572 {
 573         struct sock *sk = NULL;
 574         struct unix_sock *u;
 575
 576         if (atomic_read(&unix_nr_socks) >= 2*get_max_files())
 577                 goto out;
 578
 579         sk = sk_alloc(PF_UNIX, GFP_KERNEL, &unix_proto, 1);
 580         if (!sk)
 581                 goto out;
 582
 583         atomic_inc(&unix_nr_socks);
 584
 585         sock_init_data(sock,sk);
 586         lockdep_set_class(&sk->sk_receive_queue.lock,
 587                                 &af_unix_sk_receive_queue_lock_key);
 588
 589         sk->sk_write_space      = unix_write_space;
 590         sk->sk_max_ack_backlog  = sysctl_unix_max_dgram_qlen;
 591         sk->sk_destruct         = unix_sock_destructor;
 592         u         = unix_sk(sk);
 593         u->dentry = NULL;
 594         u->mnt    = NULL;
 595         spin_lock_init(&u->lock);
 596         atomic_set(&u->inflight, sock ? 0 : -1);
 597         mutex_init(&u->readlock); /* single task reading lock */
 598         init_waitqueue_head(&u->peer_wait);
 599         unix_insert_socket(unix_sockets_unbound, sk);
 600 out:
 601         return sk;
 602 }
 603
 604 static int unix_create(struct socket *sock, int protocol)
 605 {
 606         if (protocol && protocol != PF_UNIX)
 607                 return -EPROTONOSUPPORT;
 608
 609         sock->state = SS_UNCONNECTED;
 610
 611         switch (sock->type) {
 612         case SOCK_STREAM:
 613                 sock->ops = &unix_stream_ops;
 614                 break;
 615                 /*
 616                  *      Believe it or not BSD has AF_UNIX, SOCK_RAW though
 617                  *      nothing uses it.
 618                  */
 619         case SOCK_RAW:
 620                 sock->type=SOCK_DGRAM;
 621         case SOCK_DGRAM:
 622                 sock->ops = &unix_dgram_ops;
 623                 break;
 624         case SOCK_SEQPACKET:
 625                 sock->ops = &unix_seqpacket_ops;
 626                 break;
 627         default:
 628                 return -ESOCKTNOSUPPORT;
 629         }
 630
 631         return unix_create1(sock) ? 0 : -ENOMEM;
 632 }
 633
 634 static int unix_release(struct socket *sock)
 635 {
 636         struct sock *sk = sock->sk;
 637
 638         if (!sk)
 639                 return 0;
 640
 641         sock->sk = NULL;
 642
 643         return unix_release_sock (sk, 0);
 644 }
 645
 646 static int unix_autobind(struct socket *sock)
 647 {
 648         struct sock *sk = sock->sk;
 649         struct unix_sock *u = unix_sk(sk);
 650         static u32 ordernum = 1;
 651         struct unix_address * addr;
 652         int err;
 653
 654         mutex_lock(&u->readlock);
 655
 656         err = 0;
 657         if (u->addr)
 658                 goto out;
 659
 660         err = -ENOMEM;
 661         addr = kzalloc(sizeof(*addr) + sizeof(short) + 16, GFP_KERNEL);
 662         if (!addr)
 663                 goto out;
 664
 665         addr->name->sun_family = AF_UNIX;
 666         atomic_set(&addr->refcnt, 1);
 667
 668 retry:
 669         addr->len = sprintf(addr->name->sun_path+1, "%05x", ordernum) + 1 + sizeof(short);
 670         addr->hash = unix_hash_fold(csum_partial((void*)addr->name, addr->len, 0));
 671
 672         spin_lock(&unix_table_lock);
 673         ordernum = (ordernum+1)&0xFFFFF;
 674
 675         if (__unix_find_socket_byname(addr->name, addr->len, sock->type,
 676                                       addr->hash)) {
 677                 spin_unlock(&unix_table_lock);
 678                 /* Sanity yield. It is unusual case, but yet... */
 679                 if (!(ordernum&0xFF))
 680                         yield();
 681                 goto retry;
 682         }
 683         addr->hash ^= sk->sk_type;
 684
 685         __unix_remove_socket(sk);
 686         u->addr = addr;
 687         __unix_insert_socket(&unix_socket_table[addr->hash], sk);
 688         spin_unlock(&unix_table_lock);
 689         err = 0;
 690
 691 out:    mutex_unlock(&u->readlock);
 692         return err;
 693 }
 694
 695 static struct sock *unix_find_other(struct sockaddr_un *sunname, int len,
 696                                     int type, unsigned hash, int *error)
 697 {
 698         struct sock *u;
 699         struct nameidata nd;
 700         int err = 0;
 701
 702         if (sunname->sun_path[0]) {
 703                 err = path_lookup(sunname->sun_path, LOOKUP_FOLLOW, &nd);
 704                 if (err)
 705                         goto fail;
 706                 err = vfs_permission(&nd, MAY_WRITE);
 707                 if (err)
 708                         goto put_fail;
 709
 710                 err = -ECONNREFUSED;
 711                 if (!S_ISSOCK(nd.dentry->d_inode->i_mode))
 712                         goto put_fail;
 713                 u=unix_find_socket_byinode(nd.dentry->d_inode);
 714                 if (!u)
 715                         goto put_fail;
 716
 717                 if (u->sk_type == type)
 718                         touch_atime(nd.mnt, nd.dentry);
 719
 720                 path_release(&nd);
 721
 722                 err=-EPROTOTYPE;
 723                 if (u->sk_type != type) {
 724                         sock_put(u);
 725                         goto fail;
 726                 }
 727         } else {
 728                 err = -ECONNREFUSED;
 729                 u=unix_find_socket_byname(sunname, len, type, hash);
 730                 if (u) {
 731                         struct dentry *dentry;
 732                         dentry = unix_sk(u)->dentry;
 733                         if (dentry)
 734                                 touch_atime(unix_sk(u)->mnt, dentry);
 735                 } else
 736                         goto fail;
 737         }
 738         return u;
 739
 740 put_fail:
 741         path_release(&nd);
 742 fail:
 743         *error=err;
 744         return NULL;
 745 }
 746
 747
 748 static int unix_bind(struct socket *sock, struct sockaddr *uaddr, int addr_len)
 749 {
 750         struct sock *sk = sock->sk;
 751         struct unix_sock *u = unix_sk(sk);
 752         struct sockaddr_un *sunaddr=(struct sockaddr_un *)uaddr;
 753         struct dentry * dentry = NULL;
 754         struct nameidata nd;
 755         int err;
 756         unsigned hash;
 757         struct unix_address *addr;
 758         struct hlist_head *list;
 759
 760         err = -EINVAL;
 761         if (sunaddr->sun_family != AF_UNIX)
 762                 goto out;
 763
 764         if (addr_len==sizeof(short)) {
 765                 err = unix_autobind(sock);
 766                 goto out;
 767         }
 768
 769         err = unix_mkname(sunaddr, addr_len, &hash);
 770         if (err < 0)
 771                 goto out;
 772         addr_len = err;
 773
 774         mutex_lock(&u->readlock);
 775
 776         err = -EINVAL;
 777         if (u->addr)
 778                 goto out_up;
 779
 780         err = -ENOMEM;
 781         addr = kmalloc(sizeof(*addr)+addr_len, GFP_KERNEL);
 782         if (!addr)
 783                 goto out_up;
 784
 785         memcpy(addr->name, sunaddr, addr_len);
 786         addr->len = addr_len;
 787         addr->hash = hash ^ sk->sk_type;
 788         atomic_set(&addr->refcnt, 1);
 789
 790         if (sunaddr->sun_path[0]) {
 791                 unsigned int mode;
 792                 err = 0;
 793                 /*
 794                  * Get the parent directory, calculate the hash for last
 795                  * component.
 796                  */
 797                 err = path_lookup(sunaddr->sun_path, LOOKUP_PARENT, &nd);
 798                 if (err)
 799                         goto out_mknod_parent;
 800
 801                 dentry = lookup_create(&nd, 0);
 802                 err = PTR_ERR(dentry);
 803                 if (IS_ERR(dentry))
 804                         goto out_mknod_unlock;
 805
 806                 /*
 807                  * All right, let's create it.
 808                  */
 809                 mode = S_IFSOCK |
 810                        (SOCK_INODE(sock)->i_mode & ~current->fs->umask);
 811                 err = vfs_mknod(nd.dentry->d_inode, dentry, mode, 0);
 812                 if (err)
 813                         goto out_mknod_dput;
 814                 mutex_unlock(&nd.dentry->d_inode->i_mutex);
 815                 dput(nd.dentry);
 816                 nd.dentry = dentry;
 817
 818                 addr->hash = UNIX_HASH_SIZE;
 819         }
 820
 821         spin_lock(&unix_table_lock);
 822
 823         if (!sunaddr->sun_path[0]) {
 824                 err = -EADDRINUSE;
 825                 if (__unix_find_socket_byname(sunaddr, addr_len,
 826                                               sk->sk_type, hash)) {
 827                         unix_release_addr(addr);
 828                         goto out_unlock;
 829                 }
 830
 831                 list = &unix_socket_table[addr->hash];
 832         } else {
 833                 list = &unix_socket_table[dentry->d_inode->i_ino & (UNIX_HASH_SIZE-1)];
 834                 u->dentry = nd.dentry;
 835                 u->mnt    = nd.mnt;
 836         }
 837
 838         err = 0;
 839         __unix_remove_socket(sk);
 840         u->addr = addr;
 841         __unix_insert_socket(list, sk);
 842
 843 out_unlock:
 844         spin_unlock(&unix_table_lock);
 845 out_up:
 846         mutex_unlock(&u->readlock);
 847 out:
 848         return err;
 849
 850 out_mknod_dput:
 851         dput(dentry);
 852 out_mknod_unlock:
 853         mutex_unlock(&nd.dentry->d_inode->i_mutex);
 854         path_release(&nd);
 855 out_mknod_parent:
 856         if (err==-EEXIST)
 857                 err=-EADDRINUSE;
 858         unix_release_addr(addr);
 859         goto out_up;
 860 }
 861
 862 static int unix_dgram_connect(struct socket *sock, struct sockaddr *addr,
 863                               int alen, int flags)
 864 {
 865         struct sock *sk = sock->sk;
 866         struct sockaddr_un *sunaddr=(struct sockaddr_un*)addr;
 867         struct sock *other;
 868         unsigned hash;
 869         int err;
 870
 871         if (addr->sa_family != AF_UNSPEC) {
 872                 err = unix_mkname(sunaddr, alen, &hash);
 873                 if (err < 0)
 874                         goto out;
 875                 alen = err;
 876
 877                 if (test_bit(SOCK_PASSCRED, &sock->flags) &&
 878                     !unix_sk(sk)->addr && (err = unix_autobind(sock)) != 0)
 879                         goto out;
 880
 881                 other=unix_find_other(sunaddr, alen, sock->type, hash, &err);
 882                 if (!other)
 883                         goto out;
 884
 885                 unix_state_wlock(sk);
 886
 887                 err = -EPERM;
 888                 if (!unix_may_send(sk, other))
 889                         goto out_unlock;
 890
 891                 err = security_unix_may_send(sk->sk_socket, other->sk_socket);
 892                 if (err)
 893                         goto out_unlock;
 894
 895         } else {
 896                 /*
 897                  *      1003.1g breaking connected state with AF_UNSPEC
 898                  */
 899                 other = NULL;
 900                 unix_state_wlock(sk);
 901         }
 902
 903         /*
 904          * If it was connected, reconnect.
 905          */
 906         if (unix_peer(sk)) {
 907                 struct sock *old_peer = unix_peer(sk);
 908                 unix_peer(sk)=other;
 909                 unix_state_wunlock(sk);
 910
 911                 if (other != old_peer)
 912                         unix_dgram_disconnected(sk, old_peer);
 913                 sock_put(old_peer);
 914         } else {
 915                 unix_peer(sk)=other;
 916                 unix_state_wunlock(sk);
 917         }
 918         return 0;
 919
 920 out_unlock:
 921         unix_state_wunlock(sk);
 922         sock_put(other);
 923 out:
 924         return err;
 925 }
 926
 927 static long unix_wait_for_peer(struct sock *other, long timeo)
 928 {
 929         struct unix_sock *u = unix_sk(other);
 930         int sched;
 931         DEFINE_WAIT(wait);
 932
 933         prepare_to_wait_exclusive(&u->peer_wait, &wait, TASK_INTERRUPTIBLE);
 934
 935         sched = !sock_flag(other, SOCK_DEAD) &&
 936                 !(other->sk_shutdown & RCV_SHUTDOWN) &&
 937                 (skb_queue_len(&other->sk_receive_queue) >
 938                  other->sk_max_ack_backlog);
 939
 940         unix_state_runlock(other);
 941
 942         if (sched)
 943                 timeo = schedule_timeout(timeo);
 944
 945         finish_wait(&u->peer_wait, &wait);
 946         return timeo;
 947 }
 948
 949 static int unix_stream_connect(struct socket *sock, struct sockaddr *uaddr,
 950                                int addr_len, int flags)
 951 {
 952         struct sockaddr_un *sunaddr=(struct sockaddr_un *)uaddr;
 953         struct sock *sk = sock->sk;
 954         struct unix_sock *u = unix_sk(sk), *newu, *otheru;
 955         struct sock *newsk = NULL;
 956         struct sock *other = NULL;
 957         struct sk_buff *skb = NULL;
 958         unsigned hash;
 959         int st;
 960         int err;
 961         long timeo;
 962
 963         err = unix_mkname(sunaddr, addr_len, &hash);
 964         if (err < 0)
 965                 goto out;
 966         addr_len = err;
 967
 968         if (test_bit(SOCK_PASSCRED, &sock->flags)
 969                 && !u->addr && (err = unix_autobind(sock)) != 0)
 970                 goto out;
 971
 972         timeo = sock_sndtimeo(sk, flags & O_NONBLOCK);
 973
 974         /* First of all allocate resources.
 975            If we will make it after state is locked,
 976            we will have to recheck all again in any case.
 977          */
 978
 979         err = -ENOMEM;
 980
 981         /* create new sock for complete connection */
 982         newsk = unix_create1(NULL);
 983         if (newsk == NULL)
 984                 goto out;
 985
 986         /* Allocate skb for sending to listening sock */
 987         skb = sock_wmalloc(newsk, 1, 0, GFP_KERNEL);
 988         if (skb == NULL)
 989                 goto out;
 990
 991 restart:
 992         /*  Find listening sock. */
 993         other = unix_find_other(sunaddr, addr_len, sk->sk_type, hash, &err);
 994         if (!other)
 995                 goto out;
 996
 997         /* Latch state of peer */
 998         unix_state_rlock(other);
 999
1000         /* Apparently VFS overslept socket death. Retry. */
1001         if (sock_flag(other, SOCK_DEAD)) {
1002                 unix_state_runlock(other);
1003                 sock_put(other);
1004                 goto restart;
1005         }
1006
1007         err = -ECONNREFUSED;
1008         if (other->sk_state != TCP_LISTEN)
1009                 goto out_unlock;
1010
1011         if (skb_queue_len(&other->sk_receive_queue) >
1012             other->sk_max_ack_backlog) {
1013                 err = -EAGAIN;
1014                 if (!timeo)
1015                         goto out_unlock;
1016
1017                 timeo = unix_wait_for_peer(other, timeo);
1018
1019                 err = sock_intr_errno(timeo);
1020                 if (signal_pending(current))
1021                         goto out;
1022                 sock_put(other);
1023                 goto restart;
1024         }
1025
1026         /* Latch our state.
1027
1028            It is tricky place. We need to grab write lock and cannot
1029            drop lock on peer. It is dangerous because deadlock is
1030            possible. Connect to self case and simultaneous
1031            attempt to connect are eliminated by checking socket
1032            state. other is TCP_LISTEN, if sk is TCP_LISTEN we
1033            check this before attempt to grab lock.
1034
1035            Well, and we have to recheck the state after socket locked.
1036          */
1037         st = sk->sk_state;
1038
1039         switch (st) {
1040         case TCP_CLOSE:
1041                 /* This is ok... continue with connect */
1042                 break;
1043         case TCP_ESTABLISHED:
1044                 /* Socket is already connected */
1045                 err = -EISCONN;
1046                 goto out_unlock;
1047         default:
1048                 err = -EINVAL;
1049                 goto out_unlock;
1050         }
1051
1052         unix_state_wlock_nested(sk);
1053
1054         if (sk->sk_state != st) {
1055                 unix_state_wunlock(sk);
1056                 unix_state_runlock(other);
1057                 sock_put(other);
1058                 goto restart;
1059         }
1060
1061         err = security_unix_stream_connect(sock, other->sk_socket, newsk);
1062         if (err) {
1063                 unix_state_wunlock(sk);
1064                 goto out_unlock;
1065         }
1066
1067         /* The way is open! Fastly set all the necessary fields... */
1068
1069         sock_hold(sk);
1070         unix_peer(newsk)        = sk;
1071         newsk->sk_state         = TCP_ESTABLISHED;
1072         newsk->sk_type          = sk->sk_type;
1073         newsk->sk_peercred.pid  = current->tgid;
1074         newsk->sk_peercred.uid  = current->euid;
1075         newsk->sk_peercred.gid  = current->egid;
1076         newu = unix_sk(newsk);
1077         newsk->sk_sleep         = &newu->peer_wait;
1078         otheru = unix_sk(other);
1079
1080         /* copy address information from listening to new sock*/
1081         if (otheru->addr) {
1082                 atomic_inc(&otheru->addr->refcnt);
1083                 newu->addr = otheru->addr;
1084         }
1085         if (otheru->dentry) {
1086                 newu->dentry    = dget(otheru->dentry);
1087                 newu->mnt       = mntget(otheru->mnt);
1088         }
1089
1090         /* Set credentials */
1091         sk->sk_peercred = other->sk_peercred;
1092
1093         sock->state     = SS_CONNECTED;
1094         sk->sk_state    = TCP_ESTABLISHED;
1095         sock_hold(newsk);
1096
1097         smp_mb__after_atomic_inc();     /* sock_hold() does an atomic_inc() */
1098         unix_peer(sk)   = newsk;
1099
1100         unix_state_wunlock(sk);
1101
1102         /* take ten and and send info to listening sock */
1103         spin_lock(&other->sk_receive_queue.lock);
1104         __skb_queue_tail(&other->sk_receive_queue, skb);
1105         /* Undo artificially decreased inflight after embrion
1106          * is installed to listening socket. */
1107         atomic_inc(&newu->inflight);
1108         spin_unlock(&other->sk_receive_queue.lock);
1109         unix_state_runlock(other);
1110         other->sk_data_ready(other, 0);
1111         sock_put(other);
1112         return 0;
1113
1114 out_unlock:
1115         if (other)
1116                 unix_state_runlock(other);
1117
1118 out:
1119         if (skb)
1120                 kfree_skb(skb);
1121         if (newsk)
1122                 unix_release_sock(newsk, 0);
1123         if (other)
1124                 sock_put(other);
1125         return err;
1126 }
1127
1128 static int unix_socketpair(struct socket *socka, struct socket *sockb)
1129 {
1130         struct sock *ska=socka->sk, *skb = sockb->sk;
1131
1132         /* Join our sockets back to back */
1133         sock_hold(ska);
1134         sock_hold(skb);
1135         unix_peer(ska)=skb;
1136         unix_peer(skb)=ska;
1137         ska->sk_peercred.pid = skb->sk_peercred.pid = current->tgid;
1138         ska->sk_peercred.uid = skb->sk_peercred.uid = current->euid;
1139         ska->sk_peercred.gid = skb->sk_peercred.gid = current->egid;
1140
1141         if (ska->sk_type != SOCK_DGRAM) {
1142                 ska->sk_state = TCP_ESTABLISHED;
1143                 skb->sk_state = TCP_ESTABLISHED;
1144                 socka->state  = SS_CONNECTED;
1145                 sockb->state  = SS_CONNECTED;
1146         }
1147         return 0;
1148 }
1149
1150 static int unix_accept(struct socket *sock, struct socket *newsock, int flags)
1151 {
1152         struct sock *sk = sock->sk;
1153         struct sock *tsk;
1154         struct sk_buff *skb;
1155         int err;
1156
1157         err = -EOPNOTSUPP;
1158         if (sock->type!=SOCK_STREAM && sock->type!=SOCK_SEQPACKET)
1159                 goto out;
1160
1161         err = -EINVAL;
1162         if (sk->sk_state != TCP_LISTEN)
1163                 goto out;
1164
1165         /* If socket state is TCP_LISTEN it cannot change (for now...),
1166          * so that no locks are necessary.
1167          */
1168
1169         skb = skb_recv_datagram(sk, 0, flags&O_NONBLOCK, &err);
1170         if (!skb) {
1171                 /* This means receive shutdown. */
1172                 if (err == 0)
1173                         err = -EINVAL;
1174                 goto out;
1175         }
1176
1177         tsk = skb->sk;
1178         skb_free_datagram(sk, skb);
1179         wake_up_interruptible(&unix_sk(sk)->peer_wait);
1180
1181         /* attach accepted sock to socket */
1182         unix_state_wlock(tsk);
1183         newsock->state = SS_CONNECTED;
1184         sock_graft(tsk, newsock);
1185         unix_state_wunlock(tsk);
1186         return 0;
1187
1188 out:
1189         return err;
1190 }
1191
1192
1193 static int unix_getname(struct socket *sock, struct sockaddr *uaddr, int *uaddr_len, int peer)
1194 {
1195         struct sock *sk = sock->sk;
1196         struct unix_sock *u;
1197         struct sockaddr_un *sunaddr=(struct sockaddr_un *)uaddr;
1198         int err = 0;
1199
1200         if (peer) {
1201                 sk = unix_peer_get(sk);
1202
1203                 err = -ENOTCONN;
1204                 if (!sk)
1205                         goto out;
1206                 err = 0;
1207         } else {
1208                 sock_hold(sk);
1209         }
1210
1211         u = unix_sk(sk);
1212         unix_state_rlock(sk);
1213         if (!u->addr) {
1214                 sunaddr->sun_family = AF_UNIX;
1215                 sunaddr->sun_path[0] = 0;
1216                 *uaddr_len = sizeof(short);
1217         } else {
1218                 struct unix_address *addr = u->addr;
1219
1220                 *uaddr_len = addr->len;
1221                 memcpy(sunaddr, addr->name, *uaddr_len);
1222         }
1223         unix_state_runlock(sk);
1224         sock_put(sk);
1225 out:
1226         return err;
1227 }
1228
1229 static void unix_detach_fds(struct scm_cookie *scm, struct sk_buff *skb)
1230 {
1231         int i;
1232
1233         scm->fp = UNIXCB(skb).fp;
1234         skb->destructor = sock_wfree;
1235         UNIXCB(skb).fp = NULL;
1236
1237         for (i=scm->fp->count-1; i>=0; i--)
1238                 unix_notinflight(scm->fp->fp[i]);
1239 }
1240
1241 static void unix_destruct_fds(struct sk_buff *skb)
1242 {
1243         struct scm_cookie scm;
1244         memset(&scm, 0, sizeof(scm));
1245         unix_detach_fds(&scm, skb);
1246
1247         /* Alas, it calls VFS */
1248         /* So fscking what? fput() had been SMP-safe since the last Summer */
1249         scm_destroy(&scm);
1250         sock_wfree(skb);
1251 }
1252
1253 static void unix_attach_fds(struct scm_cookie *scm, struct sk_buff *skb)
1254 {
1255         int i;
1256         for (i=scm->fp->count-1; i>=0; i--)
1257                 unix_inflight(scm->fp->fp[i]);
1258         UNIXCB(skb).fp = scm->fp;
1259         skb->destructor = unix_destruct_fds;
1260         scm->fp = NULL;
1261 }
1262
1263 /*
1264  *      Send AF_UNIX data.
1265  */
1266
1267 static int unix_dgram_sendmsg(struct kiocb *kiocb, struct socket *sock,
1268                               struct msghdr *msg, size_t len)
1269 {
1270         struct sock_iocb *siocb = kiocb_to_siocb(kiocb);
1271         struct sock *sk = sock->sk;
1272         struct unix_sock *u = unix_sk(sk);
1273         struct sockaddr_un *sunaddr=msg->msg_name;
1274         struct sock *other = NULL;
1275         int namelen = 0; /* fake GCC */
1276         int err;
1277         unsigned hash;
1278         struct sk_buff *skb;
1279         long timeo;
1280         struct scm_cookie tmp_scm;
1281
1282         if (NULL == siocb->scm)
1283                 siocb->scm = &tmp_scm;
1284         err = scm_send(sock, msg, siocb->scm);
1285         if (err < 0)
1286                 return err;
1287
1288         err = -EOPNOTSUPP;
1289         if (msg->msg_flags&MSG_OOB)
1290                 goto out;
1291
1292         if (msg->msg_namelen) {
1293                 err = unix_mkname(sunaddr, msg->msg_namelen, &hash);
1294                 if (err < 0)
1295                         goto out;
1296                 namelen = err;
1297         } else {
1298                 sunaddr = NULL;
1299                 err = -ENOTCONN;
1300                 other = unix_peer_get(sk);
1301                 if (!other)
1302                         goto out;
1303         }
1304
1305         if (test_bit(SOCK_PASSCRED, &sock->flags)
1306                 && !u->addr && (err = unix_autobind(sock)) != 0)
1307                 goto out;
1308
1309         err = -EMSGSIZE;
1310         if (len > sk->sk_sndbuf - 32)
1311                 goto out;
1312
1313         skb = sock_alloc_send_skb(sk, len, msg->msg_flags&MSG_DONTWAIT, &err);
1314         if (skb==NULL)
1315                 goto out;
1316
1317         memcpy(UNIXCREDS(skb), &siocb->scm->creds, sizeof(struct ucred));
1318         if (siocb->scm->fp)
1319                 unix_attach_fds(siocb->scm, skb);
1320         unix_get_secdata(siocb->scm, skb);
1321
1322         skb->h.raw = skb->data;
1323         err = memcpy_fromiovec(skb_put(skb,len), msg->msg_iov, len);
1324         if (err)
1325                 goto out_free;
1326
1327         timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
1328
1329 restart:
1330         if (!other) {
1331                 err = -ECONNRESET;
1332                 if (sunaddr == NULL)
1333                         goto out_free;
1334
1335                 other = unix_find_other(sunaddr, namelen, sk->sk_type,
1336                                         hash, &err);
1337                 if (other==NULL)
1338                         goto out_free;
1339         }
1340
1341         unix_state_rlock(other);
1342         err = -EPERM;
1343         if (!unix_may_send(sk, other))
1344                 goto out_unlock;
1345
1346         if (sock_flag(other, SOCK_DEAD)) {
1347                 /*
1348                  *      Check with 1003.1g - what should
1349                  *      datagram error
1350                  */
1351                 unix_state_runlock(other);
1352                 sock_put(other);
1353
1354                 err = 0;
1355                 unix_state_wlock(sk);
1356                 if (unix_peer(sk) == other) {
1357                         unix_peer(sk)=NULL;
1358                         unix_state_wunlock(sk);
1359
1360                         unix_dgram_disconnected(sk, other);
1361                         sock_put(other);
1362                         err = -ECONNREFUSED;
1363                 } else {
1364                         unix_state_wunlock(sk);
1365                 }
1366
1367                 other = NULL;
1368                 if (err)
1369                         goto out_free;
1370                 goto restart;
1371         }
1372
1373         err = -EPIPE;
1374         if (other->sk_shutdown & RCV_SHUTDOWN)
1375                 goto out_unlock;
1376
1377         if (sk->sk_type != SOCK_SEQPACKET) {
1378                 err = security_unix_may_send(sk->sk_socket, other->sk_socket);
1379                 if (err)
1380                         goto out_unlock;
1381         }
1382
1383         if (unix_peer(other) != sk &&
1384             (skb_queue_len(&other->sk_receive_queue) >
1385              other->sk_max_ack_backlog)) {
1386                 if (!timeo) {
1387                         err = -EAGAIN;
1388                         goto out_unlock;
1389                 }
1390
1391                 timeo = unix_wait_for_peer(other, timeo);
1392
1393                 err = sock_intr_errno(timeo);
1394                 if (signal_pending(current))
1395                         goto out_free;
1396
1397                 goto restart;
1398         }
1399
1400         skb_queue_tail(&other->sk_receive_queue, skb);
1401         unix_state_runlock(other);
1402         other->sk_data_ready(other, len);
1403         sock_put(other);
1404         scm_destroy(siocb->scm);
1405         return len;
1406
1407 out_unlock:
1408         unix_state_runlock(other);
1409 out_free:
1410         kfree_skb(skb);
1411 out:
1412         if (other)
1413                 sock_put(other);
1414         scm_destroy(siocb->scm);
1415         return err;
1416 }
1417
1418
1419 static int unix_stream_sendmsg(struct kiocb *kiocb, struct socket *sock,
1420                                struct msghdr *msg, size_t len)
1421 {
1422         struct sock_iocb *siocb = kiocb_to_siocb(kiocb);
1423         struct sock *sk = sock->sk;
1424         struct sock *other = NULL;
1425         struct sockaddr_un *sunaddr=msg->msg_name;
1426         int err,size;
1427         struct sk_buff *skb;
1428         int sent=0;
1429         struct scm_cookie tmp_scm;
1430
1431         if (NULL == siocb->scm)
1432                 siocb->scm = &tmp_scm;
1433         err = scm_send(sock, msg, siocb->scm);
1434         if (err < 0)
1435                 return err;
1436
1437         err = -EOPNOTSUPP;
1438         if (msg->msg_flags&MSG_OOB)
1439                 goto out_err;
1440
1441         if (msg->msg_namelen) {
1442                 err = sk->sk_state == TCP_ESTABLISHED ? -EISCONN : -EOPNOTSUPP;
1443                 goto out_err;
1444         } else {
1445                 sunaddr = NULL;
1446                 err = -ENOTCONN;
1447                 other = unix_peer(sk);
1448                 if (!other)
1449                         goto out_err;
1450         }
1451
1452         if (sk->sk_shutdown & SEND_SHUTDOWN)
1453                 goto pipe_err;
1454
1455         while(sent < len)
1456         {
1457                 /*
1458                  *      Optimisation for the fact that under 0.01% of X
1459                  *      messages typically need breaking up.
1460                  */
1461
1462                 size = len-sent;
1463
1464                 /* Keep two messages in the pipe so it schedules better */
1465                 if (size > ((sk->sk_sndbuf >> 1) - 64))
1466                         size = (sk->sk_sndbuf >> 1) - 64;
1467
1468                 if (size > SKB_MAX_ALLOC)
1469                         size = SKB_MAX_ALLOC;
1470
1471                 /*
1472                  *      Grab a buffer
1473                  */
1474
1475                 skb=sock_alloc_send_skb(sk,size,msg->msg_flags&MSG_DONTWAIT, &err);
1476
1477                 if (skb==NULL)
1478                         goto out_err;
1479
1480                 /*
1481                  *      If you pass two values to the sock_alloc_send_skb
1482                  *      it tries to grab the large buffer with GFP_NOFS
1483                  *      (which can fail easily), and if it fails grab the
1484                  *      fallback size buffer which is under a page and will
1485                  *      succeed. [Alan]
1486                  */
1487                 size = min_t(int, size, skb_tailroom(skb));
1488
1489                 memcpy(UNIXCREDS(skb), &siocb->scm->creds, sizeof(struct ucred));
1490                 if (siocb->scm->fp)
1491                         unix_attach_fds(siocb->scm, skb);
1492
1493                 if ((err = memcpy_fromiovec(skb_put(skb,size), msg->msg_iov, size)) != 0) {
1494                         kfree_skb(skb);
1495                         goto out_err;
1496                 }
1497
1498                 unix_state_rlock(other);
1499
1500                 if (sock_flag(other, SOCK_DEAD) ||
1501                     (other->sk_shutdown & RCV_SHUTDOWN))
1502                         goto pipe_err_free;
1503
1504                 skb_queue_tail(&other->sk_receive_queue, skb);
1505                 unix_state_runlock(other);
1506                 other->sk_data_ready(other, size);
1507                 sent+=size;
1508         }
1509
1510         scm_destroy(siocb->scm);
1511         siocb->scm = NULL;
1512
1513         return sent;
1514
1515 pipe_err_free:
1516         unix_state_runlock(other);
1517         kfree_skb(skb);
1518 pipe_err:
1519         if (sent==0 && !(msg->msg_flags&MSG_NOSIGNAL))
1520                 send_sig(SIGPIPE,current,0);
1521         err = -EPIPE;
1522 out_err:
1523         scm_destroy(siocb->scm);
1524         siocb->scm = NULL;
1525         return sent ? : err;
1526 }
1527
1528 static int unix_seqpacket_sendmsg(struct kiocb *kiocb, struct socket *sock,
1529                                   struct msghdr *msg, size_t len)
1530 {
1531         int err;
1532         struct sock *sk = sock->sk;
1533
1534         err = sock_error(sk);
1535         if (err)
1536                 return err;
1537
1538         if (sk->sk_state != TCP_ESTABLISHED)
1539                 return -ENOTCONN;
1540
1541         if (msg->msg_namelen)
1542                 msg->msg_namelen = 0;
1543
1544         return unix_dgram_sendmsg(kiocb, sock, msg, len);
1545 }
1546
1547 static void unix_copy_addr(struct msghdr *msg, struct sock *sk)
1548 {
1549         struct unix_sock *u = unix_sk(sk);
1550
1551         msg->msg_namelen = 0;
1552         if (u->addr) {
1553                 msg->msg_namelen = u->addr->len;
1554                 memcpy(msg->msg_name, u->addr->name, u->addr->len);
1555         }
1556 }
1557
1558 static int unix_dgram_recvmsg(struct kiocb *iocb, struct socket *sock,
1559                               struct msghdr *msg, size_t size,
1560                               int flags)
1561 {
1562         struct sock_iocb *siocb = kiocb_to_siocb(iocb);
1563         struct scm_cookie tmp_scm;
1564         struct sock *sk = sock->sk;
1565         struct unix_sock *u = unix_sk(sk);
1566         int noblock = flags & MSG_DONTWAIT;
1567         struct sk_buff *skb;
1568         int err;
1569
1570         err = -EOPNOTSUPP;
1571         if (flags&MSG_OOB)
1572                 goto out;
1573
1574         msg->msg_namelen = 0;
1575
1576         mutex_lock(&u->readlock);
1577
1578         skb = skb_recv_datagram(sk, flags, noblock, &err);
1579         if (!skb)
1580                 goto out_unlock;
1581
1582         wake_up_interruptible(&u->peer_wait);
1583
1584         if (msg->msg_name)
1585                 unix_copy_addr(msg, skb->sk);
1586
1587         if (size > skb->len)
1588                 size = skb->len;
1589         else if (size < skb->len)
1590                 msg->msg_flags |= MSG_TRUNC;
1591
1592         err = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, size);
1593         if (err)
1594                 goto out_free;
1595
1596         if (!siocb->scm) {
1597                 siocb->scm = &tmp_scm;
1598                 memset(&tmp_scm, 0, sizeof(tmp_scm));
1599         }
1600         siocb->scm->creds = *UNIXCREDS(skb);
1601         unix_set_secdata(siocb->scm, skb);
1602
1603         if (!(flags & MSG_PEEK))
1604         {
1605                 if (UNIXCB(skb).fp)
1606                         unix_detach_fds(siocb->scm, skb);
1607         }
1608         else
1609         {
1610                 /* It is questionable: on PEEK we could:
1611                    - do not return fds - good, but too simple 8)
1612                    - return fds, and do not return them on read (old strategy,
1613                      apparently wrong)
1614                    - clone fds (I chose it for now, it is the most universal
1615                      solution)
1616
1617                    POSIX 1003.1g does not actually define this clearly
1618                    at all. POSIX 1003.1g doesn't define a lot of things
1619                    clearly however!
1620
1621                 */
1622                 if (UNIXCB(skb).fp)
1623                         siocb->scm->fp = scm_fp_dup(UNIXCB(skb).fp);
1624         }
1625         err = size;
1626
1627         scm_recv(sock, msg, siocb->scm, flags);
1628
1629 out_free:
1630         skb_free_datagram(sk,skb);
1631 out_unlock:
1632         mutex_unlock(&u->readlock);
1633 out:
1634         return err;
1635 }
1636
1637 /*
1638  *      Sleep until data has arrive. But check for races..
1639  */
1640
1641 static long unix_stream_data_wait(struct sock * sk, long timeo)
1642 {
1643         DEFINE_WAIT(wait);
1644
1645         unix_state_rlock(sk);
1646
1647         for (;;) {
1648                 prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);
1649
1650                 if (!skb_queue_empty(&sk->sk_receive_queue) ||
1651                     sk->sk_err ||
1652                     (sk->sk_shutdown & RCV_SHUTDOWN) ||
1653                     signal_pending(current) ||
1654                     !timeo)
1655                         break;
1656
1657                 set_bit(SOCK_ASYNC_WAITDATA, &sk->sk_socket->flags);
1658                 unix_state_runlock(sk);
1659                 timeo = schedule_timeout(timeo);
1660                 unix_state_rlock(sk);
1661                 clear_bit(SOCK_ASYNC_WAITDATA, &sk->sk_socket->flags);
1662         }
1663
1664         finish_wait(sk->sk_sleep, &wait);
1665         unix_state_runlock(sk);
1666         return timeo;
1667 }
1668
1669
1670
1671 static int unix_stream_recvmsg(struct kiocb *iocb, struct socket *sock,
1672                                struct msghdr *msg, size_t size,
1673                                int flags)
1674 {
1675         struct sock_iocb *siocb = kiocb_to_siocb(iocb);
1676         struct scm_cookie tmp_scm;
1677         struct sock *sk = sock->sk;
1678         struct unix_sock *u = unix_sk(sk);
1679         struct sockaddr_un *sunaddr=msg->msg_name;
1680         int copied = 0;
1681         int check_creds = 0;
1682         int target;
1683         int err = 0;
1684         long timeo;
1685
1686         err = -EINVAL;
1687         if (sk->sk_state != TCP_ESTABLISHED)
1688                 goto out;
1689
1690         err = -EOPNOTSUPP;
1691         if (flags&MSG_OOB)
1692                 goto out;
1693
1694         target = sock_rcvlowat(sk, flags&MSG_WAITALL, size);
1695         timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT);
1696
1697         msg->msg_namelen = 0;
1698
1699         /* Lock the socket to prevent queue disordering
1700          * while sleeps in memcpy_tomsg
1701          */
1702
1703         if (!siocb->scm) {
1704                 siocb->scm = &tmp_scm;
1705                 memset(&tmp_scm, 0, sizeof(tmp_scm));
1706         }
1707
1708         mutex_lock(&u->readlock);
1709
1710         do
1711         {
1712                 int chunk;
1713                 struct sk_buff *skb;
1714
1715                 skb = skb_dequeue(&sk->sk_receive_queue);
1716                 if (skb==NULL)
1717                 {
1718                         if (copied >= target)
1719                                 break;
1720
1721                         /*
1722                          *      POSIX 1003.1g mandates this order.
1723                          */
1724
1725                         if ((err = sock_error(sk)) != 0)
1726                                 break;
1727                         if (sk->sk_shutdown & RCV_SHUTDOWN)
1728                                 break;
1729                         err = -EAGAIN;
1730                         if (!timeo)
1731                                 break;
1732                         mutex_unlock(&u->readlock);
1733
1734                         timeo = unix_stream_data_wait(sk, timeo);
1735
1736                         if (signal_pending(current)) {
1737                                 err = sock_intr_errno(timeo);
1738                                 goto out;
1739                         }
1740                         mutex_lock(&u->readlock);
1741                         continue;
1742                 }
1743
1744                 if (check_creds) {
1745                         /* Never glue messages from different writers */
1746                         if (memcmp(UNIXCREDS(skb), &siocb->scm->creds, sizeof(siocb->scm->creds)) != 0) {
1747                                 skb_queue_head(&sk->sk_receive_queue, skb);
1748                                 break;
1749                         }
1750                 } else {
1751                         /* Copy credentials */
1752                         siocb->scm->creds = *UNIXCREDS(skb);
1753                         check_creds = 1;
1754                 }
1755
1756                 /* Copy address just once */
1757                 if (sunaddr)
1758                 {
1759                         unix_copy_addr(msg, skb->sk);
1760                         sunaddr = NULL;
1761                 }
1762
1763                 chunk = min_t(unsigned int, skb->len, size);
1764                 if (memcpy_toiovec(msg->msg_iov, skb->data, chunk)) {
1765                         skb_queue_head(&sk->sk_receive_queue, skb);
1766                         if (copied == 0)
1767                                 copied = -EFAULT;
1768                         break;
1769                 }
1770                 copied += chunk;
1771                 size -= chunk;
1772
1773                 /* Mark read part of skb as used */
1774                 if (!(flags & MSG_PEEK))
1775                 {
1776                         skb_pull(skb, chunk);
1777
1778                         if (UNIXCB(skb).fp)
1779                                 unix_detach_fds(siocb->scm, skb);
1780
1781                         /* put the skb back if we didn't use it up.. */
1782                         if (skb->len)
1783                         {
1784                                 skb_queue_head(&sk->sk_receive_queue, skb);
1785                                 break;
1786                         }
1787
1788                         kfree_skb(skb);
1789
1790                         if (siocb->scm->fp)
1791                                 break;
1792                 }
1793                 else
1794                 {
1795                         /* It is questionable, see note in unix_dgram_recvmsg.
1796                          */
1797                         if (UNIXCB(skb).fp)
1798                                 siocb->scm->fp = scm_fp_dup(UNIXCB(skb).fp);
1799
1800                         /* put message back and return */
1801                         skb_queue_head(&sk->sk_receive_queue, skb);
1802                         break;
1803                 }
1804         } while (size);
1805
1806         mutex_unlock(&u->readlock);
1807         scm_recv(sock, msg, siocb->scm, flags);
1808 out:
1809         return copied ? : err;
1810 }
1811
1812 static int unix_shutdown(struct socket *sock, int mode)
1813 {
1814         struct sock *sk = sock->sk;
1815         struct sock *other;
1816
1817         mode = (mode+1)&(RCV_SHUTDOWN|SEND_SHUTDOWN);
1818
1819         if (mode) {
1820                 unix_state_wlock(sk);
1821                 sk->sk_shutdown |= mode;
1822                 other=unix_peer(sk);
1823                 if (other)
1824                         sock_hold(other);
1825                 unix_state_wunlock(sk);
1826                 sk->sk_state_change(sk);
1827
1828                 if (other &&
1829                         (sk->sk_type == SOCK_STREAM || sk->sk_type == SOCK_SEQPACKET)) {
1830
1831                         int peer_mode = 0;
1832
1833                         if (mode&RCV_SHUTDOWN)
1834                                 peer_mode |= SEND_SHUTDOWN;
1835                         if (mode&SEND_SHUTDOWN)
1836                                 peer_mode |= RCV_SHUTDOWN;
1837                         unix_state_wlock(other);
1838                         other->sk_shutdown |= peer_mode;
1839                         unix_state_wunlock(other);
1840                         other->sk_state_change(other);
1841                         read_lock(&other->sk_callback_lock);
1842                         if (peer_mode == SHUTDOWN_MASK)
1843                                 sk_wake_async(other,1,POLL_HUP);
1844                         else if (peer_mode & RCV_SHUTDOWN)
1845                                 sk_wake_async(other,1,POLL_IN);
1846                         read_unlock(&other->sk_callback_lock);
1847                 }
1848                 if (other)
1849                         sock_put(other);
1850         }
1851         return 0;
1852 }
1853
1854 static int unix_ioctl(struct socket *sock, unsigned int cmd, unsigned long arg)
1855 {
1856         struct sock *sk = sock->sk;
1857         long amount=0;
1858         int err;
1859
1860         switch(cmd)
1861         {
1862                 case SIOCOUTQ:
1863                         amount = atomic_read(&sk->sk_wmem_alloc);
1864                         err = put_user(amount, (int __user *)arg);
1865                         break;
1866                 case SIOCINQ:
1867                 {
1868                         struct sk_buff *skb;
1869
1870                         if (sk->sk_state == TCP_LISTEN) {
1871                                 err = -EINVAL;
1872                                 break;
1873                         }
1874
1875                         spin_lock(&sk->sk_receive_queue.lock);
1876                         if (sk->sk_type == SOCK_STREAM ||
1877                             sk->sk_type == SOCK_SEQPACKET) {
1878                                 skb_queue_walk(&sk->sk_receive_queue, skb)
1879                                         amount += skb->len;
1880                         } else {
1881                                 skb = skb_peek(&sk->sk_receive_queue);
1882                                 if (skb)
1883                                         amount=skb->len;
1884                         }
1885                         spin_unlock(&sk->sk_receive_queue.lock);
1886                         err = put_user(amount, (int __user *)arg);
1887                         break;
1888                 }
1889
1890                 default:
1891                         err = -ENOIOCTLCMD;
1892                         break;
1893         }
1894         return err;
1895 }
1896
1897 static unsigned int unix_poll(struct file * file, struct socket *sock, poll_table *wait)
1898 {
1899         struct sock *sk = sock->sk;
1900         unsigned int mask;
1901
1902         poll_wait(file, sk->sk_sleep, wait);
1903         mask = 0;
1904
1905         /* exceptional events? */
1906         if (sk->sk_err)
1907                 mask |= POLLERR;
1908         if (sk->sk_shutdown == SHUTDOWN_MASK)
1909                 mask |= POLLHUP;
1910         if (sk->sk_shutdown & RCV_SHUTDOWN)
1911                 mask |= POLLRDHUP;
1912
1913         /* readable? */
1914         if (!skb_queue_empty(&sk->sk_receive_queue) ||
1915             (sk->sk_shutdown & RCV_SHUTDOWN))
1916                 mask |= POLLIN | POLLRDNORM;
1917
1918         /* Connection-based need to check for termination and startup */
1919         if ((sk->sk_type == SOCK_STREAM || sk->sk_type == SOCK_SEQPACKET) && sk->sk_state == TCP_CLOSE)
1920                 mask |= POLLHUP;
1921
1922         /*
1923          * we set writable also when the other side has shut down the
1924          * connection. This prevents stuck sockets.
1925          */
1926         if (unix_writable(sk))
1927                 mask |= POLLOUT | POLLWRNORM | POLLWRBAND;
1928
1929         return mask;
1930 }
1931
1932
1933 #ifdef CONFIG_PROC_FS
1934 static struct sock *unix_seq_idx(int *iter, loff_t pos)
1935 {
1936         loff_t off = 0;
1937         struct sock *s;
1938
1939         for (s = first_unix_socket(iter); s; s = next_unix_socket(iter, s)) {
1940                 if (off == pos)
1941                         return s;
1942                 ++off;
1943         }
1944         return NULL;
1945 }
1946
1947
1948 static void *unix_seq_start(struct seq_file *seq, loff_t *pos)
1949 {
1950         spin_lock(&unix_table_lock);
1951         return *pos ? unix_seq_idx(seq->private, *pos - 1) : ((void *) 1);
1952 }
1953
1954 static void *unix_seq_next(struct seq_file *seq, void *v, loff_t *pos)
1955 {
1956         ++*pos;
1957
1958         if (v == (void *)1)
1959                 return first_unix_socket(seq->private);
1960         return next_unix_socket(seq->private, v);
1961 }
1962
1963 static void unix_seq_stop(struct seq_file *seq, void *v)
1964 {
1965         spin_unlock(&unix_table_lock);
1966 }
1967
1968 static int unix_seq_show(struct seq_file *seq, void *v)
1969 {
1970
1971         if (v == (void *)1)
1972                 seq_puts(seq, "Num       RefCount Protocol Flags    Type St "
1973                          "Inode Path\n");
1974         else {
1975                 struct sock *s = v;
1976                 struct unix_sock *u = unix_sk(s);
1977                 unix_state_rlock(s);
1978
1979                 seq_printf(seq, "%p: %08X %08X %08X %04X %02X %5lu",
1980                         s,
1981                         atomic_read(&s->sk_refcnt),
1982                         0,
1983                         s->sk_state == TCP_LISTEN ? __SO_ACCEPTCON : 0,
1984                         s->sk_type,
1985                         s->sk_socket ?
1986                         (s->sk_state == TCP_ESTABLISHED ? SS_CONNECTED : SS_UNCONNECTED) :
1987                         (s->sk_state == TCP_ESTABLISHED ? SS_CONNECTING : SS_DISCONNECTING),
1988                         sock_i_ino(s));
1989
1990                 if (u->addr) {
1991                         int i, len;
1992                         seq_putc(seq, ' ');
1993
1994                         i = 0;
1995                         len = u->addr->len - sizeof(short);
1996                         if (!UNIX_ABSTRACT(s))
1997                                 len--;
1998                         else {
1999                                 seq_putc(seq, '@');
2000                                 i++;
2001                         }
2002                         for ( ; i < len; i++)
2003                                 seq_putc(seq, u->addr->name->sun_path[i]);
2004                 }
2005                 unix_state_runlock(s);
2006                 seq_putc(seq, '\n');
2007         }
2008
2009         return 0;
2010 }
2011
2012 static struct seq_operations unix_seq_ops = {
2013         .start  = unix_seq_start,
2014         .next   = unix_seq_next,
2015         .stop   = unix_seq_stop,
2016         .show   = unix_seq_show,
2017 };
2018
2019
2020 static int unix_seq_open(struct inode *inode, struct file *file)
2021 {
2022         struct seq_file *seq;
2023         int rc = -ENOMEM;
2024         int *iter = kmalloc(sizeof(int), GFP_KERNEL);
2025
2026         if (!iter)
2027                 goto out;
2028
2029         rc = seq_open(file, &unix_seq_ops);
2030         if (rc)
2031                 goto out_kfree;
2032
2033         seq          = file->private_data;
2034         seq->private = iter;
2035         *iter = 0;
2036 out:
2037         return rc;
2038 out_kfree:
2039         kfree(iter);
2040         goto out;
2041 }
2042
2043 static struct file_operations unix_seq_fops = {
2044         .owner          = THIS_MODULE,
2045         .open           = unix_seq_open,
2046         .read           = seq_read,
2047         .llseek         = seq_lseek,
2048         .release        = seq_release_private,
2049 };
2050
2051 #endif
2052
2053 static struct net_proto_family unix_family_ops = {
2054         .family = PF_UNIX,
2055         .create = unix_create,
2056         .owner  = THIS_MODULE,
2057 };
2058
2059 static int __init af_unix_init(void)
2060 {
2061         int rc = -1;
2062         struct sk_buff *dummy_skb;
2063
2064         BUILD_BUG_ON(sizeof(struct unix_skb_parms) > sizeof(dummy_skb->cb));
2065
2066         rc = proto_register(&unix_proto, 1);
2067         if (rc != 0) {
2068                 printk(KERN_CRIT "%s: Cannot create unix_sock SLAB cache!\n",
2069                        __FUNCTION__);
2070                 goto out;
2071         }
2072
2073         sock_register(&unix_family_ops);
2074 #ifdef CONFIG_PROC_FS
2075         proc_net_fops_create("unix", 0, &unix_seq_fops);
2076 #endif
2077         unix_sysctl_register();
2078 out:
2079         return rc;
2080 }
2081
2082 static void __exit af_unix_exit(void)
2083 {
2084         sock_unregister(PF_UNIX);
2085         unix_sysctl_unregister();
2086         proc_net_remove("unix");
2087         proto_unregister(&unix_proto);
2088 }
2089
2090 module_init(af_unix_init);
2091 module_exit(af_unix_exit);
2092
2093 MODULE_LICENSE("GPL");
2094 MODULE_ALIAS_NETPROTO(PF_UNIX);