Commit ec8a09fb authored by Jon Paul Maloy's avatar Jon Paul Maloy Committed by David S. Miller

tipc: refactor function tipc_sk_recv_stream()

We try to make this function more readable by improving variable names
and comments, using more stack variables, and doing some smaller changes
to the logics. We also rename the function to make it consistent with
naming conventions used elsewhere in the code.
Reviewed-by: default avatarParthasarathy Bhuvaragan <parthasarathy.bhuvaragan@ericsson.com>
Signed-off-by: default avatarJon Maloy <jon.maloy@ericsson.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent e9f8b101
...@@ -1375,9 +1375,9 @@ static int tipc_recvmsg(struct socket *sock, struct msghdr *m, ...@@ -1375,9 +1375,9 @@ static int tipc_recvmsg(struct socket *sock, struct msghdr *m,
} }
/** /**
* tipc_recv_stream - receive stream-oriented data * tipc_recvstream - receive stream-oriented data
* @m: descriptor for message info * @m: descriptor for message info
* @buf_len: total size of user buffer area * @buflen: total size of user buffer area
* @flags: receive flags * @flags: receive flags
* *
* Used for SOCK_STREAM messages only. If not enough data is available * Used for SOCK_STREAM messages only. If not enough data is available
...@@ -1385,111 +1385,98 @@ static int tipc_recvmsg(struct socket *sock, struct msghdr *m, ...@@ -1385,111 +1385,98 @@ static int tipc_recvmsg(struct socket *sock, struct msghdr *m,
* *
* Returns size of returned message data, errno otherwise * Returns size of returned message data, errno otherwise
*/ */
static int tipc_recv_stream(struct socket *sock, struct msghdr *m, static int tipc_recvstream(struct socket *sock, struct msghdr *m,
size_t buf_len, int flags) size_t buflen, int flags)
{ {
struct sock *sk = sock->sk; struct sock *sk = sock->sk;
struct tipc_sock *tsk = tipc_sk(sk); struct tipc_sock *tsk = tipc_sk(sk);
struct sk_buff *buf; struct sk_buff *skb;
struct tipc_msg *msg; struct tipc_msg *hdr;
long timeo; struct tipc_skb_cb *skb_cb;
unsigned int sz; bool peek = flags & MSG_PEEK;
int target; int offset, required, copy, copied = 0;
int sz_copied = 0; int hlen, dlen, err, rc;
u32 err; long timeout;
int res = 0, hlen;
/* Catch invalid receive attempts */ /* Catch invalid receive attempts */
if (unlikely(!buf_len)) if (unlikely(!buflen))
return -EINVAL; return -EINVAL;
lock_sock(sk); lock_sock(sk);
if (unlikely(sk->sk_state == TIPC_OPEN)) { if (unlikely(sk->sk_state == TIPC_OPEN)) {
res = -ENOTCONN; rc = -ENOTCONN;
goto exit;
}
target = sock_rcvlowat(sk, flags & MSG_WAITALL, buf_len);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
restart:
/* Look for a message in receive queue; wait if necessary */
res = tipc_wait_for_rcvmsg(sock, &timeo);
if (res)
goto exit; goto exit;
/* Look at first message in receive queue */
buf = skb_peek(&sk->sk_receive_queue);
msg = buf_msg(buf);
sz = msg_data_sz(msg);
hlen = msg_hdr_sz(msg);
err = msg_errcode(msg);
/* Discard an empty non-errored message & try again */
if ((!sz) && (!err)) {
tsk_advance_rx_queue(sk);
goto restart;
} }
required = sock_rcvlowat(sk, flags & MSG_WAITALL, buflen);
timeout = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
/* Optionally capture sender's address & ancillary data of first msg */ do {
if (sz_copied == 0) { /* Look at first msg in receive queue; wait if necessary */
set_orig_addr(m, msg); rc = tipc_wait_for_rcvmsg(sock, &timeout);
res = tipc_sk_anc_data_recv(m, msg, tsk); if (unlikely(rc))
if (res) break;
goto exit; skb = skb_peek(&sk->sk_receive_queue);
} skb_cb = TIPC_SKB_CB(skb);
hdr = buf_msg(skb);
/* Capture message data (if valid) & compute return value (always) */ dlen = msg_data_sz(hdr);
if (!err) { hlen = msg_hdr_sz(hdr);
u32 offset = TIPC_SKB_CB(buf)->bytes_read; err = msg_errcode(hdr);
u32 needed;
int sz_to_copy;
sz -= offset;
needed = (buf_len - sz_copied);
sz_to_copy = min(sz, needed);
res = skb_copy_datagram_msg(buf, hlen + offset, m, sz_to_copy); /* Discard any empty non-errored (SYN-) message */
if (res) if (unlikely(!dlen && !err)) {
goto exit; tsk_advance_rx_queue(sk);
continue;
}
sz_copied += sz_to_copy; /* Collect msg meta data, incl. error code and rejected data */
if (!copied) {
set_orig_addr(m, hdr);
rc = tipc_sk_anc_data_recv(m, hdr, tsk);
if (rc)
break;
}
if (sz_to_copy < sz) { /* Copy data if msg ok, otherwise return error/partial data */
if (!(flags & MSG_PEEK)) if (likely(!err)) {
TIPC_SKB_CB(buf)->bytes_read = offset = skb_cb->bytes_read;
offset + sz_to_copy; copy = min_t(int, dlen - offset, buflen - copied);
goto exit; rc = skb_copy_datagram_msg(skb, hlen + offset, m, copy);
if (unlikely(rc))
break;
copied += copy;
offset += copy;
if (unlikely(offset < dlen)) {
if (!peek)
skb_cb->bytes_read = offset;
break;
}
} else {
rc = 0;
if ((err != TIPC_CONN_SHUTDOWN) && !m->msg_control)
rc = -ECONNRESET;
if (copied || rc)
break;
} }
} else {
if (sz_copied != 0)
goto exit; /* can't add error msg to valid data */
if ((err == TIPC_CONN_SHUTDOWN) || m->msg_control) if (unlikely(peek))
res = 0; break;
else
res = -ECONNRESET;
}
if (unlikely(flags & MSG_PEEK)) tsk_advance_rx_queue(sk);
goto exit;
tsk->rcv_unacked += tsk_inc(tsk, hlen + msg_data_sz(msg)); /* Send connection flow control advertisement when applicable */
if (unlikely(tsk->rcv_unacked >= (tsk->rcv_win / 4))) tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen);
tipc_sk_send_ack(tsk); if (unlikely(tsk->rcv_unacked >= tsk->rcv_win / TIPC_ACK_RATE))
tsk_advance_rx_queue(sk); tipc_sk_send_ack(tsk);
/* Loop around if more data is required */ /* Exit if all requested data or FIN/error received */
if ((sz_copied < buf_len) && /* didn't get all requested data */ if (copied == buflen || err)
(!skb_queue_empty(&sk->sk_receive_queue) || break;
(sz_copied < target)) && /* and more is ready or required */
(!err)) /* and haven't reached a FIN */
goto restart;
} while (!skb_queue_empty(&sk->sk_receive_queue) || copied < required);
exit: exit:
release_sock(sk); release_sock(sk);
return sz_copied ? sz_copied : res; return copied ? copied : rc;
} }
/** /**
...@@ -2584,7 +2571,7 @@ static const struct proto_ops stream_ops = { ...@@ -2584,7 +2571,7 @@ static const struct proto_ops stream_ops = {
.setsockopt = tipc_setsockopt, .setsockopt = tipc_setsockopt,
.getsockopt = tipc_getsockopt, .getsockopt = tipc_getsockopt,
.sendmsg = tipc_sendstream, .sendmsg = tipc_sendstream,
.recvmsg = tipc_recv_stream, .recvmsg = tipc_recvstream,
.mmap = sock_no_mmap, .mmap = sock_no_mmap,
.sendpage = sock_no_sendpage .sendpage = sock_no_sendpage
}; };
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment