|
@@ -161,7 +161,7 @@ static inline struct sk_buff *sock_queue_head(struct sock *sk)
|
|
for (skb = sock_queue_head(sk)->next, next = skb->next; \
|
|
for (skb = sock_queue_head(sk)->next, next = skb->next; \
|
|
skb != sock_queue_head(sk); skb = next, next = skb->next)
|
|
skb != sock_queue_head(sk); skb = next, next = skb->next)
|
|
|
|
|
|
-static void scan_inflight(struct sock *x, void (*func)(struct sock *),
|
|
|
|
|
|
+static void scan_inflight(struct sock *x, void (*func)(struct unix_sock *),
|
|
struct sk_buff_head *hitlist)
|
|
struct sk_buff_head *hitlist)
|
|
{
|
|
{
|
|
struct sk_buff *skb;
|
|
struct sk_buff *skb;
|
|
@@ -185,9 +185,9 @@ static void scan_inflight(struct sock *x, void (*func)(struct sock *),
|
|
* if it indeed does so
|
|
* if it indeed does so
|
|
*/
|
|
*/
|
|
struct sock *sk = unix_get_socket(*fp++);
|
|
struct sock *sk = unix_get_socket(*fp++);
|
|
- if(sk) {
|
|
|
|
|
|
+ if (sk) {
|
|
hit = true;
|
|
hit = true;
|
|
- func(sk);
|
|
|
|
|
|
+ func(unix_sk(sk));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (hit && hitlist != NULL) {
|
|
if (hit && hitlist != NULL) {
|
|
@@ -199,7 +199,7 @@ static void scan_inflight(struct sock *x, void (*func)(struct sock *),
|
|
spin_unlock(&x->sk_receive_queue.lock);
|
|
spin_unlock(&x->sk_receive_queue.lock);
|
|
}
|
|
}
|
|
|
|
|
|
-static void scan_children(struct sock *x, void (*func)(struct sock *),
|
|
|
|
|
|
+static void scan_children(struct sock *x, void (*func)(struct unix_sock *),
|
|
struct sk_buff_head *hitlist)
|
|
struct sk_buff_head *hitlist)
|
|
{
|
|
{
|
|
if (x->sk_state != TCP_LISTEN)
|
|
if (x->sk_state != TCP_LISTEN)
|
|
@@ -235,20 +235,18 @@ static void scan_children(struct sock *x, void (*func)(struct sock *),
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-static void dec_inflight(struct sock *sk)
|
|
|
|
|
|
+static void dec_inflight(struct unix_sock *usk)
|
|
{
|
|
{
|
|
- atomic_dec(&unix_sk(sk)->inflight);
|
|
|
|
|
|
+ atomic_dec(&usk->inflight);
|
|
}
|
|
}
|
|
|
|
|
|
-static void inc_inflight(struct sock *sk)
|
|
|
|
|
|
+static void inc_inflight(struct unix_sock *usk)
|
|
{
|
|
{
|
|
- atomic_inc(&unix_sk(sk)->inflight);
|
|
|
|
|
|
+ atomic_inc(&usk->inflight);
|
|
}
|
|
}
|
|
|
|
|
|
-static void inc_inflight_move_tail(struct sock *sk)
|
|
|
|
|
|
+static void inc_inflight_move_tail(struct unix_sock *u)
|
|
{
|
|
{
|
|
- struct unix_sock *u = unix_sk(sk);
|
|
|
|
-
|
|
|
|
atomic_inc(&u->inflight);
|
|
atomic_inc(&u->inflight);
|
|
/*
|
|
/*
|
|
* If this is still a candidate, move it to the end of the
|
|
* If this is still a candidate, move it to the end of the
|