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

Commit 90cacb2e authored by Ursula Braun's avatar Ursula Braun Committed by David S. Miller
Browse files

net/smc: guarantee reset of write_blocked for heavy workload



If peer indicates write_blocked, the cursor state of the received data
should be send to the peer immediately (in smc_tx_consumer_update()).
Afterwards the write_blocked indicator is cleared.

If there is no free slot for another write request, sending is postponed
to worker smc_tx_work, and the write_blocked indicator is not cleared.
Therefore another clearing check is needed in smc_tx_work().

Signed-off-by: default avatarUrsula Braun <ubraun@linux.vnet.ibm.com>
Reviewed-by: default avatarThomas Richter <tmricht@linux.vnet.ibm.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 5da7e4d3
Loading
Loading
Loading
Loading
+5 −1
Original line number Original line Diff line number Diff line
@@ -431,9 +431,13 @@ static void smc_tx_work(struct work_struct *work)
						   struct smc_connection,
						   struct smc_connection,
						   tx_work);
						   tx_work);
	struct smc_sock *smc = container_of(conn, struct smc_sock, conn);
	struct smc_sock *smc = container_of(conn, struct smc_sock, conn);
	int rc;


	lock_sock(&smc->sk);
	lock_sock(&smc->sk);
	smc_tx_sndbuf_nonempty(conn);
	rc = smc_tx_sndbuf_nonempty(conn);
	if (!rc && conn->local_rx_ctrl.prod_flags.write_blocked &&
	    !atomic_read(&conn->bytes_to_rcv))
		conn->local_rx_ctrl.prod_flags.write_blocked = 0;
	release_sock(&smc->sk);
	release_sock(&smc->sk);
}
}