|
@@ -1318,12 +1318,12 @@ static int tipc_wait_for_rcvmsg(struct socket *sock, long *timeop)
|
|
err = 0;
|
|
err = 0;
|
|
if (!skb_queue_empty(&sk->sk_receive_queue))
|
|
if (!skb_queue_empty(&sk->sk_receive_queue))
|
|
break;
|
|
break;
|
|
- err = sock_intr_errno(timeo);
|
|
|
|
- if (signal_pending(current))
|
|
|
|
- break;
|
|
|
|
err = -EAGAIN;
|
|
err = -EAGAIN;
|
|
if (!timeo)
|
|
if (!timeo)
|
|
break;
|
|
break;
|
|
|
|
+ err = sock_intr_errno(timeo);
|
|
|
|
+ if (signal_pending(current))
|
|
|
|
+ break;
|
|
}
|
|
}
|
|
finish_wait(sk_sleep(sk), &wait);
|
|
finish_wait(sk_sleep(sk), &wait);
|
|
*timeop = timeo;
|
|
*timeop = timeo;
|
|
@@ -2026,12 +2026,12 @@ static int tipc_wait_for_accept(struct socket *sock, long timeo)
|
|
err = -EINVAL;
|
|
err = -EINVAL;
|
|
if (sock->state != SS_LISTENING)
|
|
if (sock->state != SS_LISTENING)
|
|
break;
|
|
break;
|
|
- err = sock_intr_errno(timeo);
|
|
|
|
- if (signal_pending(current))
|
|
|
|
- break;
|
|
|
|
err = -EAGAIN;
|
|
err = -EAGAIN;
|
|
if (!timeo)
|
|
if (!timeo)
|
|
break;
|
|
break;
|
|
|
|
+ err = sock_intr_errno(timeo);
|
|
|
|
+ if (signal_pending(current))
|
|
|
|
+ break;
|
|
}
|
|
}
|
|
finish_wait(sk_sleep(sk), &wait);
|
|
finish_wait(sk_sleep(sk), &wait);
|
|
return err;
|
|
return err;
|