Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 278813
b: refs/heads/master
c: 2aac7a2
h: refs/heads/master
i:
  278811: cc0a98e
v: v3
  • Loading branch information
Pavel Emelyanov authored and David S. Miller committed Dec 16, 2011
1 parent 2fcf121 commit 0e140d7
Show file tree
Hide file tree
Showing 3 changed files with 42 additions and 1 deletion.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: ac02be8d96af9f66a4de86781ee9facc2dff99d4
refs/heads/master: 2aac7a2cb0d9d8c65fc7dde3e19e46b3e878d23d
2 changes: 2 additions & 0 deletions trunk/include/linux/unix_diag.h
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ struct unix_diag_req {
#define UDIAG_SHOW_NAME 0x00000001 /* show name (not path) */
#define UDIAG_SHOW_VFS 0x00000002 /* show VFS inode info */
#define UDIAG_SHOW_PEER 0x00000004 /* show peer socket info */
#define UDIAG_SHOW_ICONS 0x00000008 /* show pending connections */

struct unix_diag_msg {
__u8 udiag_family;
Expand All @@ -29,6 +30,7 @@ enum {
UNIX_DIAG_NAME,
UNIX_DIAG_VFS,
UNIX_DIAG_PEER,
UNIX_DIAG_ICONS,

UNIX_DIAG_MAX,
};
Expand Down
39 changes: 39 additions & 0 deletions trunk/net/unix/diag.c
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,41 @@ static int sk_diag_dump_peer(struct sock *sk, struct sk_buff *nlskb)
return -EMSGSIZE;
}

static int sk_diag_dump_icons(struct sock *sk, struct sk_buff *nlskb)
{
struct sk_buff *skb;
u32 *buf;
int i;

if (sk->sk_state == TCP_LISTEN) {
spin_lock(&sk->sk_receive_queue.lock);
buf = UNIX_DIAG_PUT(nlskb, UNIX_DIAG_ICONS, sk->sk_receive_queue.qlen);
i = 0;
skb_queue_walk(&sk->sk_receive_queue, skb) {
struct sock *req, *peer;

req = skb->sk;
/*
* The state lock is outer for the same sk's
* queue lock. With the other's queue locked it's
* OK to lock the state.
*/
unix_state_lock_nested(req);
peer = unix_sk(req)->peer;
if (peer)
buf[i++] = sock_i_ino(peer);
unix_state_unlock(req);
}
spin_unlock(&sk->sk_receive_queue.lock);
}

return 0;

rtattr_failure:
spin_unlock(&sk->sk_receive_queue.lock);
return -EMSGSIZE;
}

static int sk_diag_fill(struct sock *sk, struct sk_buff *skb, struct unix_diag_req *req,
u32 pid, u32 seq, u32 flags, int sk_ino)
{
Expand Down Expand Up @@ -93,6 +128,10 @@ static int sk_diag_fill(struct sock *sk, struct sk_buff *skb, struct unix_diag_r
sk_diag_dump_peer(sk, skb))
goto nlmsg_failure;

if ((req->udiag_show & UDIAG_SHOW_ICONS) &&
sk_diag_dump_icons(sk, skb))
goto nlmsg_failure;

nlh->nlmsg_len = skb_tail_pointer(skb) - b;
return skb->len;

Expand Down

0 comments on commit 0e140d7

Please sign in to comment.