|
@@ -75,13 +75,11 @@ static int smc_tx_wait(struct smc_sock *smc, int flags)
|
|
|
DEFINE_WAIT_FUNC(wait, woken_wake_function);
|
|
DEFINE_WAIT_FUNC(wait, woken_wake_function);
|
|
|
struct smc_connection *conn = &smc->conn;
|
|
struct smc_connection *conn = &smc->conn;
|
|
|
struct sock *sk = &smc->sk;
|
|
struct sock *sk = &smc->sk;
|
|
|
- bool noblock;
|
|
|
|
|
long timeo;
|
|
long timeo;
|
|
|
int rc = 0;
|
|
int rc = 0;
|
|
|
|
|
|
|
|
/* similar to sk_stream_wait_memory */
|
|
/* similar to sk_stream_wait_memory */
|
|
|
timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT);
|
|
timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT);
|
|
|
- noblock = timeo ? false : true;
|
|
|
|
|
add_wait_queue(sk_sleep(sk), &wait);
|
|
add_wait_queue(sk_sleep(sk), &wait);
|
|
|
while (1) {
|
|
while (1) {
|
|
|
sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);
|
|
sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);
|
|
@@ -96,8 +94,8 @@ static int smc_tx_wait(struct smc_sock *smc, int flags)
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
if (!timeo) {
|
|
if (!timeo) {
|
|
|
- if (noblock)
|
|
|
|
|
- set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);
|
|
|
|
|
|
|
+ /* ensure EPOLLOUT is subsequently generated */
|
|
|
|
|
+ set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);
|
|
|
rc = -EAGAIN;
|
|
rc = -EAGAIN;
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|