Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 45a96b9b authored by Pavel Emelyanov's avatar Pavel Emelyanov Committed by David S. Miller
Browse files

unix_diag: Dumping all sockets core 



Walk the unix sockets table and fill the core response structure,
which includes type, state and inode.

Signed-off-by: default avatarPavel Emelyanov <xemul@parallels.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 22931d3b

net/unix/diag.c

+75 −1
Original line number Diff line number Diff line
@@ -10,9 +10,83 @@ 
#define UNIX_DIAG_PUT(skb, attrtype, attrlen) \

	RTA_DATA(__RTA_PUT(skb, attrtype, attrlen))



static int unix_diag_dump(struct sk_buff *skb, struct netlink_callback *cb)

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)

{

	unsigned char *b = skb_tail_pointer(skb);

	struct nlmsghdr *nlh;

	struct unix_diag_msg *rep;



	nlh = NLMSG_PUT(skb, pid, seq, SOCK_DIAG_BY_FAMILY, sizeof(*rep));

	nlh->nlmsg_flags = flags;



	rep = NLMSG_DATA(nlh);



	rep->udiag_family = AF_UNIX;

	rep->udiag_type = sk->sk_type;

	rep->udiag_state = sk->sk_state;

	rep->udiag_ino = sk_ino;

	sock_diag_save_cookie(sk, rep->udiag_cookie);



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

	return skb->len;



nlmsg_failure:

	nlmsg_trim(skb, b);

	return -EMSGSIZE;

}



static int sk_diag_dump(struct sock *sk, struct sk_buff *skb, struct unix_diag_req *req,

		u32 pid, u32 seq, u32 flags)

{

	int sk_ino;



	unix_state_lock(sk);

	sk_ino = sock_i_ino(sk);

	unix_state_unlock(sk);



	if (!sk_ino)

		return 0;



	return sk_diag_fill(sk, skb, req, pid, seq, flags, sk_ino);

}



static int unix_diag_dump(struct sk_buff *skb, struct netlink_callback *cb)

{

	struct unix_diag_req *req;

	int num, s_num, slot, s_slot;



	req = NLMSG_DATA(cb->nlh);



	s_slot = cb->args[0];

	num = s_num = cb->args[1];



	spin_lock(&unix_table_lock);

	for (slot = s_slot; slot <= UNIX_HASH_SIZE; s_num = 0, slot++) {

		struct sock *sk;

		struct hlist_node *node;



		num = 0;

		sk_for_each(sk, node, &unix_socket_table[slot]) {

			if (num < s_num)

				goto next;

			if (!(req->udiag_states & (1 << sk->sk_state)))

				goto next;

			if (sk_diag_dump(sk, skb, req,

						NETLINK_CB(cb->skb).pid,

						cb->nlh->nlmsg_seq,

						NLM_F_MULTI) < 0)

				goto done;

next:

			num++;

		}

	}

done:

	spin_unlock(&unix_table_lock);

	cb->args[0] = slot;

	cb->args[1] = num;



	return skb->len;

}



static int unix_diag_get_exact(struct sk_buff *in_skb,