mirror of
https://git.kernel.org/pub/scm/linux/kernel/git/stable/linux.git
synced 2024-09-12 13:55:32 +00:00
tipc: use existing sk_write_queue for outgoing packet chain
The list for outgoing traffic buffers from a socket is currently allocated on the stack. This forces us to initialize the queue for each sent message, something costing extra CPU cycles in the most critical data path. Later in this series we will introduce a new safe input buffer queue, something that would force us to initialize even the spinlock of the outgoing queue. A closer analysis reveals that the queue always is filled and emptied within the same lock_sock() session. It is therefore safe to use a queue aggregated in the socket itself for this purpose. Since there already exists a queue for this in struct sock, sk_write_queue, we introduce use of that queue in this commit. Reviewed-by: Ying Xue <ying.xue@windriver.com> Signed-off-by: Jon Maloy <jon.maloy@ericsson.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
parent
e3a77561e7
commit
94153e36e7
1 changed files with 13 additions and 18 deletions
|
@ -69,8 +69,6 @@
|
|||
* @pub_count: total # of publications port has made during its lifetime
|
||||
* @probing_state:
|
||||
* @probing_intv:
|
||||
* @port: port - interacts with 'sk' and with the rest of the TIPC stack
|
||||
* @peer_name: the peer of the connection, if any
|
||||
* @conn_timeout: the time we can wait for an unresponded setup request
|
||||
* @dupl_rcvcnt: number of bytes counted twice, in both backlog and rcv queue
|
||||
* @link_cong: non-zero if owner must sleep because of link congestion
|
||||
|
@ -737,7 +735,7 @@ static int tipc_sendmcast(struct socket *sock, struct tipc_name_seq *seq,
|
|||
struct tipc_sock *tsk = tipc_sk(sk);
|
||||
struct net *net = sock_net(sk);
|
||||
struct tipc_msg *mhdr = &tsk->phdr;
|
||||
struct sk_buff_head head;
|
||||
struct sk_buff_head *pktchain = &sk->sk_write_queue;
|
||||
struct iov_iter save = msg->msg_iter;
|
||||
uint mtu;
|
||||
int rc;
|
||||
|
@ -753,13 +751,12 @@ static int tipc_sendmcast(struct socket *sock, struct tipc_name_seq *seq,
|
|||
|
||||
new_mtu:
|
||||
mtu = tipc_bclink_get_mtu();
|
||||
__skb_queue_head_init(&head);
|
||||
rc = tipc_msg_build(mhdr, msg, 0, dsz, mtu, &head);
|
||||
rc = tipc_msg_build(mhdr, msg, 0, dsz, mtu, pktchain);
|
||||
if (unlikely(rc < 0))
|
||||
return rc;
|
||||
|
||||
do {
|
||||
rc = tipc_bclink_xmit(net, &head);
|
||||
rc = tipc_bclink_xmit(net, pktchain);
|
||||
if (likely(rc >= 0)) {
|
||||
rc = dsz;
|
||||
break;
|
||||
|
@ -773,7 +770,7 @@ static int tipc_sendmcast(struct socket *sock, struct tipc_name_seq *seq,
|
|||
tipc_sk(sk)->link_cong = 1;
|
||||
rc = tipc_wait_for_sndmsg(sock, &timeo);
|
||||
if (rc)
|
||||
__skb_queue_purge(&head);
|
||||
__skb_queue_purge(pktchain);
|
||||
} while (!rc);
|
||||
return rc;
|
||||
}
|
||||
|
@ -897,7 +894,7 @@ static int tipc_sendmsg(struct kiocb *iocb, struct socket *sock,
|
|||
struct net *net = sock_net(sk);
|
||||
struct tipc_msg *mhdr = &tsk->phdr;
|
||||
u32 dnode, dport;
|
||||
struct sk_buff_head head;
|
||||
struct sk_buff_head *pktchain = &sk->sk_write_queue;
|
||||
struct sk_buff *skb;
|
||||
struct tipc_name_seq *seq = &dest->addr.nameseq;
|
||||
struct iov_iter save;
|
||||
|
@ -972,15 +969,14 @@ static int tipc_sendmsg(struct kiocb *iocb, struct socket *sock,
|
|||
save = m->msg_iter;
|
||||
new_mtu:
|
||||
mtu = tipc_node_get_mtu(net, dnode, tsk->portid);
|
||||
__skb_queue_head_init(&head);
|
||||
rc = tipc_msg_build(mhdr, m, 0, dsz, mtu, &head);
|
||||
rc = tipc_msg_build(mhdr, m, 0, dsz, mtu, pktchain);
|
||||
if (rc < 0)
|
||||
goto exit;
|
||||
|
||||
do {
|
||||
skb = skb_peek(&head);
|
||||
skb = skb_peek(pktchain);
|
||||
TIPC_SKB_CB(skb)->wakeup_pending = tsk->link_cong;
|
||||
rc = tipc_link_xmit(net, &head, dnode, tsk->portid);
|
||||
rc = tipc_link_xmit(net, pktchain, dnode, tsk->portid);
|
||||
if (likely(rc >= 0)) {
|
||||
if (sock->state != SS_READY)
|
||||
sock->state = SS_CONNECTING;
|
||||
|
@ -996,7 +992,7 @@ static int tipc_sendmsg(struct kiocb *iocb, struct socket *sock,
|
|||
tsk->link_cong = 1;
|
||||
rc = tipc_wait_for_sndmsg(sock, &timeo);
|
||||
if (rc)
|
||||
__skb_queue_purge(&head);
|
||||
__skb_queue_purge(pktchain);
|
||||
} while (!rc);
|
||||
exit:
|
||||
if (iocb)
|
||||
|
@ -1054,7 +1050,7 @@ static int tipc_send_stream(struct kiocb *iocb, struct socket *sock,
|
|||
struct net *net = sock_net(sk);
|
||||
struct tipc_sock *tsk = tipc_sk(sk);
|
||||
struct tipc_msg *mhdr = &tsk->phdr;
|
||||
struct sk_buff_head head;
|
||||
struct sk_buff_head *pktchain = &sk->sk_write_queue;
|
||||
DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name);
|
||||
u32 portid = tsk->portid;
|
||||
int rc = -EINVAL;
|
||||
|
@ -1091,13 +1087,12 @@ static int tipc_send_stream(struct kiocb *iocb, struct socket *sock,
|
|||
save = m->msg_iter;
|
||||
mtu = tsk->max_pkt;
|
||||
send = min_t(uint, dsz - sent, TIPC_MAX_USER_MSG_SIZE);
|
||||
__skb_queue_head_init(&head);
|
||||
rc = tipc_msg_build(mhdr, m, sent, send, mtu, &head);
|
||||
rc = tipc_msg_build(mhdr, m, sent, send, mtu, pktchain);
|
||||
if (unlikely(rc < 0))
|
||||
goto exit;
|
||||
do {
|
||||
if (likely(!tsk_conn_cong(tsk))) {
|
||||
rc = tipc_link_xmit(net, &head, dnode, portid);
|
||||
rc = tipc_link_xmit(net, pktchain, dnode, portid);
|
||||
if (likely(!rc)) {
|
||||
tsk->sent_unacked++;
|
||||
sent += send;
|
||||
|
@ -1117,7 +1112,7 @@ static int tipc_send_stream(struct kiocb *iocb, struct socket *sock,
|
|||
}
|
||||
rc = tipc_wait_for_sndpkt(sock, &timeo);
|
||||
if (rc)
|
||||
__skb_queue_purge(&head);
|
||||
__skb_queue_purge(pktchain);
|
||||
} while (!rc);
|
||||
exit:
|
||||
if (iocb)
|
||||
|
|
Loading…
Reference in a new issue