diff options
| -rw-r--r-- | net/unix/af_unix.c | 46 | ||||
| -rw-r--r-- | net/unix/garbage.c | 14 |
2 files changed, 30 insertions, 30 deletions
diff --git a/net/unix/af_unix.c b/net/unix/af_unix.c index 2f208c7f4d43..ac9478d0ca8b 100644 --- a/net/unix/af_unix.c +++ b/net/unix/af_unix.c | |||
| @@ -195,7 +195,7 @@ static inline void unix_release_addr(struct unix_address *addr) | |||
| 195 | * - if started by not zero, should be NULL terminated (FS object) | 195 | * - if started by not zero, should be NULL terminated (FS object) |
| 196 | * - if started by zero, it is abstract name. | 196 | * - if started by zero, it is abstract name. |
| 197 | */ | 197 | */ |
| 198 | 198 | ||
| 199 | static int unix_mkname(struct sockaddr_un * sunaddr, int len, unsigned *hashp) | 199 | static int unix_mkname(struct sockaddr_un * sunaddr, int len, unsigned *hashp) |
| 200 | { | 200 | { |
| 201 | if (len <= sizeof(short) || len > sizeof(*sunaddr)) | 201 | if (len <= sizeof(short) || len > sizeof(*sunaddr)) |
| @@ -432,7 +432,7 @@ static int unix_release_sock (struct sock *sk, int embrion) | |||
| 432 | */ | 432 | */ |
| 433 | 433 | ||
| 434 | if (atomic_read(&unix_tot_inflight)) | 434 | if (atomic_read(&unix_tot_inflight)) |
| 435 | unix_gc(); /* Garbage collect fds */ | 435 | unix_gc(); /* Garbage collect fds */ |
| 436 | 436 | ||
| 437 | return 0; | 437 | return 0; |
| 438 | } | 438 | } |
| @@ -698,7 +698,7 @@ static struct sock *unix_find_other(struct sockaddr_un *sunname, int len, | |||
| 698 | struct sock *u; | 698 | struct sock *u; |
| 699 | struct nameidata nd; | 699 | struct nameidata nd; |
| 700 | int err = 0; | 700 | int err = 0; |
| 701 | 701 | ||
| 702 | if (sunname->sun_path[0]) { | 702 | if (sunname->sun_path[0]) { |
| 703 | err = path_lookup(sunname->sun_path, LOOKUP_FOLLOW, &nd); | 703 | err = path_lookup(sunname->sun_path, LOOKUP_FOLLOW, &nd); |
| 704 | if (err) | 704 | if (err) |
| @@ -915,7 +915,7 @@ static int unix_dgram_connect(struct socket *sock, struct sockaddr *addr, | |||
| 915 | unix_peer(sk)=other; | 915 | unix_peer(sk)=other; |
| 916 | unix_state_wunlock(sk); | 916 | unix_state_wunlock(sk); |
| 917 | } | 917 | } |
| 918 | return 0; | 918 | return 0; |
| 919 | 919 | ||
| 920 | out_unlock: | 920 | out_unlock: |
| 921 | unix_state_wunlock(sk); | 921 | unix_state_wunlock(sk); |
| @@ -1021,7 +1021,7 @@ restart: | |||
| 1021 | goto out; | 1021 | goto out; |
| 1022 | sock_put(other); | 1022 | sock_put(other); |
| 1023 | goto restart; | 1023 | goto restart; |
| 1024 | } | 1024 | } |
| 1025 | 1025 | ||
| 1026 | /* Latch our state. | 1026 | /* Latch our state. |
| 1027 | 1027 | ||
| @@ -1415,7 +1415,7 @@ out: | |||
| 1415 | return err; | 1415 | return err; |
| 1416 | } | 1416 | } |
| 1417 | 1417 | ||
| 1418 | 1418 | ||
| 1419 | static int unix_stream_sendmsg(struct kiocb *kiocb, struct socket *sock, | 1419 | static int unix_stream_sendmsg(struct kiocb *kiocb, struct socket *sock, |
| 1420 | struct msghdr *msg, size_t len) | 1420 | struct msghdr *msg, size_t len) |
| 1421 | { | 1421 | { |
| @@ -1467,11 +1467,11 @@ static int unix_stream_sendmsg(struct kiocb *kiocb, struct socket *sock, | |||
| 1467 | 1467 | ||
| 1468 | if (size > SKB_MAX_ALLOC) | 1468 | if (size > SKB_MAX_ALLOC) |
| 1469 | size = SKB_MAX_ALLOC; | 1469 | size = SKB_MAX_ALLOC; |
| 1470 | 1470 | ||
| 1471 | /* | 1471 | /* |
| 1472 | * Grab a buffer | 1472 | * Grab a buffer |
| 1473 | */ | 1473 | */ |
| 1474 | 1474 | ||
| 1475 | skb=sock_alloc_send_skb(sk,size,msg->msg_flags&MSG_DONTWAIT, &err); | 1475 | skb=sock_alloc_send_skb(sk,size,msg->msg_flags&MSG_DONTWAIT, &err); |
| 1476 | 1476 | ||
| 1477 | if (skb==NULL) | 1477 | if (skb==NULL) |
| @@ -1530,7 +1530,7 @@ static int unix_seqpacket_sendmsg(struct kiocb *kiocb, struct socket *sock, | |||
| 1530 | { | 1530 | { |
| 1531 | int err; | 1531 | int err; |
| 1532 | struct sock *sk = sock->sk; | 1532 | struct sock *sk = sock->sk; |
| 1533 | 1533 | ||
| 1534 | err = sock_error(sk); | 1534 | err = sock_error(sk); |
| 1535 | if (err) | 1535 | if (err) |
| 1536 | return err; | 1536 | return err; |
| @@ -1543,7 +1543,7 @@ static int unix_seqpacket_sendmsg(struct kiocb *kiocb, struct socket *sock, | |||
| 1543 | 1543 | ||
| 1544 | return unix_dgram_sendmsg(kiocb, sock, msg, len); | 1544 | return unix_dgram_sendmsg(kiocb, sock, msg, len); |
| 1545 | } | 1545 | } |
| 1546 | 1546 | ||
| 1547 | static void unix_copy_addr(struct msghdr *msg, struct sock *sk) | 1547 | static void unix_copy_addr(struct msghdr *msg, struct sock *sk) |
| 1548 | { | 1548 | { |
| 1549 | struct unix_sock *u = unix_sk(sk); | 1549 | struct unix_sock *u = unix_sk(sk); |
| @@ -1605,7 +1605,7 @@ static int unix_dgram_recvmsg(struct kiocb *iocb, struct socket *sock, | |||
| 1605 | if (UNIXCB(skb).fp) | 1605 | if (UNIXCB(skb).fp) |
| 1606 | unix_detach_fds(siocb->scm, skb); | 1606 | unix_detach_fds(siocb->scm, skb); |
| 1607 | } | 1607 | } |
| 1608 | else | 1608 | else |
| 1609 | { | 1609 | { |
| 1610 | /* It is questionable: on PEEK we could: | 1610 | /* It is questionable: on PEEK we could: |
| 1611 | - do not return fds - good, but too simple 8) | 1611 | - do not return fds - good, but too simple 8) |
| @@ -1613,11 +1613,11 @@ static int unix_dgram_recvmsg(struct kiocb *iocb, struct socket *sock, | |||
| 1613 | apparently wrong) | 1613 | apparently wrong) |
| 1614 | - clone fds (I chose it for now, it is the most universal | 1614 | - clone fds (I chose it for now, it is the most universal |
| 1615 | solution) | 1615 | solution) |
| 1616 | 1616 | ||
| 1617 | POSIX 1003.1g does not actually define this clearly | 1617 | POSIX 1003.1g does not actually define this clearly |
| 1618 | at all. POSIX 1003.1g doesn't define a lot of things | 1618 | at all. POSIX 1003.1g doesn't define a lot of things |
| 1619 | clearly however! | 1619 | clearly however! |
| 1620 | 1620 | ||
| 1621 | */ | 1621 | */ |
| 1622 | if (UNIXCB(skb).fp) | 1622 | if (UNIXCB(skb).fp) |
| 1623 | siocb->scm->fp = scm_fp_dup(UNIXCB(skb).fp); | 1623 | siocb->scm->fp = scm_fp_dup(UNIXCB(skb).fp); |
| @@ -1637,7 +1637,7 @@ out: | |||
| 1637 | /* | 1637 | /* |
| 1638 | * Sleep until data has arrive. But check for races.. | 1638 | * Sleep until data has arrive. But check for races.. |
| 1639 | */ | 1639 | */ |
| 1640 | 1640 | ||
| 1641 | static long unix_stream_data_wait(struct sock * sk, long timeo) | 1641 | static long unix_stream_data_wait(struct sock * sk, long timeo) |
| 1642 | { | 1642 | { |
| 1643 | DEFINE_WAIT(wait); | 1643 | DEFINE_WAIT(wait); |
| @@ -1721,7 +1721,7 @@ static int unix_stream_recvmsg(struct kiocb *iocb, struct socket *sock, | |||
| 1721 | /* | 1721 | /* |
| 1722 | * POSIX 1003.1g mandates this order. | 1722 | * POSIX 1003.1g mandates this order. |
| 1723 | */ | 1723 | */ |
| 1724 | 1724 | ||
| 1725 | if ((err = sock_error(sk)) != 0) | 1725 | if ((err = sock_error(sk)) != 0) |
| 1726 | break; | 1726 | break; |
| 1727 | if (sk->sk_shutdown & RCV_SHUTDOWN) | 1727 | if (sk->sk_shutdown & RCV_SHUTDOWN) |
| @@ -1937,7 +1937,7 @@ static struct sock *unix_seq_idx(int *iter, loff_t pos) | |||
| 1937 | struct sock *s; | 1937 | struct sock *s; |
| 1938 | 1938 | ||
| 1939 | for (s = first_unix_socket(iter); s; s = next_unix_socket(iter, s)) { | 1939 | for (s = first_unix_socket(iter); s; s = next_unix_socket(iter, s)) { |
| 1940 | if (off == pos) | 1940 | if (off == pos) |
| 1941 | return s; | 1941 | return s; |
| 1942 | ++off; | 1942 | ++off; |
| 1943 | } | 1943 | } |
| @@ -1955,7 +1955,7 @@ static void *unix_seq_next(struct seq_file *seq, void *v, loff_t *pos) | |||
| 1955 | { | 1955 | { |
| 1956 | ++*pos; | 1956 | ++*pos; |
| 1957 | 1957 | ||
| 1958 | if (v == (void *)1) | 1958 | if (v == (void *)1) |
| 1959 | return first_unix_socket(seq->private); | 1959 | return first_unix_socket(seq->private); |
| 1960 | return next_unix_socket(seq->private, v); | 1960 | return next_unix_socket(seq->private, v); |
| 1961 | } | 1961 | } |
| @@ -1967,7 +1967,7 @@ static void unix_seq_stop(struct seq_file *seq, void *v) | |||
| 1967 | 1967 | ||
| 1968 | static int unix_seq_show(struct seq_file *seq, void *v) | 1968 | static int unix_seq_show(struct seq_file *seq, void *v) |
| 1969 | { | 1969 | { |
| 1970 | 1970 | ||
| 1971 | if (v == (void *)1) | 1971 | if (v == (void *)1) |
| 1972 | seq_puts(seq, "Num RefCount Protocol Flags Type St " | 1972 | seq_puts(seq, "Num RefCount Protocol Flags Type St " |
| 1973 | "Inode Path\n"); | 1973 | "Inode Path\n"); |
| @@ -2064,8 +2064,8 @@ static int __init af_unix_init(void) | |||
| 2064 | BUILD_BUG_ON(sizeof(struct unix_skb_parms) > sizeof(dummy_skb->cb)); | 2064 | BUILD_BUG_ON(sizeof(struct unix_skb_parms) > sizeof(dummy_skb->cb)); |
| 2065 | 2065 | ||
| 2066 | rc = proto_register(&unix_proto, 1); | 2066 | rc = proto_register(&unix_proto, 1); |
| 2067 | if (rc != 0) { | 2067 | if (rc != 0) { |
| 2068 | printk(KERN_CRIT "%s: Cannot create unix_sock SLAB cache!\n", | 2068 | printk(KERN_CRIT "%s: Cannot create unix_sock SLAB cache!\n", |
| 2069 | __FUNCTION__); | 2069 | __FUNCTION__); |
| 2070 | goto out; | 2070 | goto out; |
| 2071 | } | 2071 | } |
diff --git a/net/unix/garbage.c b/net/unix/garbage.c index f14ad6635fcc..f8bcf5d114d9 100644 --- a/net/unix/garbage.c +++ b/net/unix/garbage.c | |||
| @@ -63,7 +63,7 @@ | |||
| 63 | * Damn. Added missing check for ->dead in listen queues scanning. | 63 | * Damn. Added missing check for ->dead in listen queues scanning. |
| 64 | * | 64 | * |
| 65 | */ | 65 | */ |
| 66 | 66 | ||
| 67 | #include <linux/kernel.h> | 67 | #include <linux/kernel.h> |
| 68 | #include <linux/sched.h> | 68 | #include <linux/sched.h> |
| 69 | #include <linux/string.h> | 69 | #include <linux/string.h> |
| @@ -118,7 +118,7 @@ static struct sock *unix_get_socket(struct file *filp) | |||
| 118 | * Keep the number of times in flight count for the file | 118 | * Keep the number of times in flight count for the file |
| 119 | * descriptor if it is for an AF_UNIX socket. | 119 | * descriptor if it is for an AF_UNIX socket. |
| 120 | */ | 120 | */ |
| 121 | 121 | ||
| 122 | void unix_inflight(struct file *fp) | 122 | void unix_inflight(struct file *fp) |
| 123 | { | 123 | { |
| 124 | struct sock *s = unix_get_socket(fp); | 124 | struct sock *s = unix_get_socket(fp); |
| @@ -190,7 +190,7 @@ void unix_gc(void) | |||
| 190 | unix_sk(s)->gc_tree = GC_ORPHAN; | 190 | unix_sk(s)->gc_tree = GC_ORPHAN; |
| 191 | } | 191 | } |
| 192 | /* | 192 | /* |
| 193 | * Everything is now marked | 193 | * Everything is now marked |
| 194 | */ | 194 | */ |
| 195 | 195 | ||
| 196 | /* Invariant to be maintained: | 196 | /* Invariant to be maintained: |
| @@ -227,7 +227,7 @@ void unix_gc(void) | |||
| 227 | } | 227 | } |
| 228 | 228 | ||
| 229 | /* | 229 | /* |
| 230 | * Mark phase | 230 | * Mark phase |
| 231 | */ | 231 | */ |
| 232 | 232 | ||
| 233 | while (!empty_stack()) | 233 | while (!empty_stack()) |
| @@ -237,11 +237,11 @@ void unix_gc(void) | |||
| 237 | 237 | ||
| 238 | spin_lock(&x->sk_receive_queue.lock); | 238 | spin_lock(&x->sk_receive_queue.lock); |
| 239 | skb = skb_peek(&x->sk_receive_queue); | 239 | skb = skb_peek(&x->sk_receive_queue); |
| 240 | 240 | ||
| 241 | /* | 241 | /* |
| 242 | * Loop through all but first born | 242 | * Loop through all but first born |
| 243 | */ | 243 | */ |
| 244 | 244 | ||
| 245 | while (skb && skb != (struct sk_buff *)&x->sk_receive_queue) { | 245 | while (skb && skb != (struct sk_buff *)&x->sk_receive_queue) { |
| 246 | /* | 246 | /* |
| 247 | * Do we have file descriptors ? | 247 | * Do we have file descriptors ? |
