提交 665b44ae 编写于 作者: M Mike Christie 提交者: James Bottomley

[SCSI] iscsi: dequeue all buffers from queue

debugged by wrwhitehead@novell.com
patch and analysis by fujita.tomonori@lab.ntt.co.jp

Only tcp_read_sock and recv_actor (iscsi_tcp_data_recv for us) see
desc.count. It is is used just for permitting tcp_read_sock to read
the portion of data in the socket.

When iscsi_tcp_data_recv sees a partial header, it sets
desc.count. However, it is possible that the next skb (containing the
rest of the header) still does not come. So I'm not sure that this
scheme is completely correct.

Ideally, we should use the exact length of the data in the socket for
desc.count. However, it is not so simple (see SIOCINQ in
tcp_ioctl). So I think that iscsi_tcp_data_recv can just stop playing
with desc.count and tell tcp_read_sock to read the all skbs. As
proposed already, if iscsi_tcp_data_ready sets desc.count to
non-zero, tcp_read_sock does that.
Signed-off-by: NMike Christie <michaelc@cs.wisc.edu>
Signed-off-by: NJames Bottomley <James.Bottomley@SteelEye.com>
上级 8d2860b3
...@@ -922,11 +922,8 @@ iscsi_tcp_data_recv(read_descriptor_t *rd_desc, struct sk_buff *skb, ...@@ -922,11 +922,8 @@ iscsi_tcp_data_recv(read_descriptor_t *rd_desc, struct sk_buff *skb,
rc = iscsi_data_recv(conn); rc = iscsi_data_recv(conn);
if (rc) { if (rc) {
if (rc == -EAGAIN) { if (rc == -EAGAIN)
rd_desc->count = tcp_conn->in.datalen -
tcp_conn->in.ctask->data_count;
goto again; goto again;
}
iscsi_conn_failure(conn, rc); iscsi_conn_failure(conn, rc);
return 0; return 0;
} }
...@@ -983,9 +980,14 @@ iscsi_tcp_data_ready(struct sock *sk, int flag) ...@@ -983,9 +980,14 @@ iscsi_tcp_data_ready(struct sock *sk, int flag)
read_lock(&sk->sk_callback_lock); read_lock(&sk->sk_callback_lock);
/* use rd_desc to pass 'conn' to iscsi_tcp_data_recv */ /*
* Use rd_desc to pass 'conn' to iscsi_tcp_data_recv.
* We set count to 1 because we want the network layer to
* hand us all the skbs that are available. iscsi_tcp_data_recv
* handled pdus that cross buffers or pdus that still need data.
*/
rd_desc.arg.data = conn; rd_desc.arg.data = conn;
rd_desc.count = 0; rd_desc.count = 1;
tcp_read_sock(sk, &rd_desc, iscsi_tcp_data_recv); tcp_read_sock(sk, &rd_desc, iscsi_tcp_data_recv);
read_unlock(&sk->sk_callback_lock); read_unlock(&sk->sk_callback_lock);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册