Lines Matching refs:copied
490 static void mptcp_subflow_cleanup_rbuf(struct sock *ssk, int copied) in mptcp_subflow_cleanup_rbuf() argument
496 tcp_cleanup_rbuf(ssk, copied); in mptcp_subflow_cleanup_rbuf()
513 static void mptcp_cleanup_rbuf(struct mptcp_sock *msk, int copied) in mptcp_cleanup_rbuf() argument
521 cleanup = (space > 0) && (space >= (old_space << 1)) && copied; in mptcp_cleanup_rbuf()
522 rx_empty = !sk_rmem_alloc_get(sk) && copied; in mptcp_cleanup_rbuf()
528 mptcp_subflow_cleanup_rbuf(ssk, copied); in mptcp_cleanup_rbuf()
1476 int len, copied = 0, err = 0; in __subflow_push_pending() local
1487 err = copied ? : ret; in __subflow_push_pending()
1492 copied += ret; in __subflow_push_pending()
1502 err = copied; in __subflow_push_pending()
1507 err = copied; in __subflow_push_pending()
1588 int copied = 0; in __mptcp_subflow_push_pending() local
1604 copied += ret; in __mptcp_subflow_push_pending()
1616 copied += ret; in __mptcp_subflow_push_pending()
1635 if (copied) { in __mptcp_subflow_push_pending()
1747 size_t copied = 0; in mptcp_sendmsg() local
1761 copied += copied_syn; in mptcp_sendmsg()
1827 copied += psize; in mptcp_sendmsg()
1857 if (copied) in mptcp_sendmsg()
1862 return copied; in mptcp_sendmsg()
1865 if (copied) in mptcp_sendmsg()
1868 copied = sk_stream_error(sk, msg->msg_flags, ret); in mptcp_sendmsg()
1872 static void mptcp_rcv_space_adjust(struct mptcp_sock *msk, int copied);
1882 int copied = 0; in __mptcp_recvmsg_mskq() local
1887 u32 count = min_t(size_t, len - copied, data_len); in __mptcp_recvmsg_mskq()
1893 if (!copied) in __mptcp_recvmsg_mskq()
1904 copied += count; in __mptcp_recvmsg_mskq()
1925 if (copied >= len) in __mptcp_recvmsg_mskq()
1929 mptcp_rcv_space_adjust(msk, copied); in __mptcp_recvmsg_mskq()
1930 return copied; in __mptcp_recvmsg_mskq()
1937 static void mptcp_rcv_space_adjust(struct mptcp_sock *msk, int copied) in mptcp_rcv_space_adjust() argument
1947 if (copied <= 0) in mptcp_rcv_space_adjust()
1953 msk->rcvq_space.copied += copied; in mptcp_rcv_space_adjust()
1983 if (msk->rcvq_space.copied <= msk->rcvq_space.space) in mptcp_rcv_space_adjust()
1991 rcvwin = ((u64)msk->rcvq_space.copied << 1) + 16 * advmss; in mptcp_rcv_space_adjust()
1993 grow = rcvwin * (msk->rcvq_space.copied - msk->rcvq_space.space); in mptcp_rcv_space_adjust()
2027 msk->rcvq_space.space = msk->rcvq_space.copied; in mptcp_rcv_space_adjust()
2029 msk->rcvq_space.copied = 0; in mptcp_rcv_space_adjust()
2120 int copied = 0, cmsg_flags = 0; in mptcp_recvmsg() local
2130 copied = -ENOTCONN; in mptcp_recvmsg()
2142 while (copied < len) { in mptcp_recvmsg()
2145 bytes_read = __mptcp_recvmsg_mskq(sk, msg, len - copied, flags, &tss, &cmsg_flags); in mptcp_recvmsg()
2147 if (!copied) in mptcp_recvmsg()
2148 copied = bytes_read; in mptcp_recvmsg()
2152 copied += bytes_read; in mptcp_recvmsg()
2160 if (copied >= target) in mptcp_recvmsg()
2163 if (copied) { in mptcp_recvmsg()
2172 copied = sock_error(sk); in mptcp_recvmsg()
2186 copied = -ENOTCONN; in mptcp_recvmsg()
2191 copied = -EAGAIN; in mptcp_recvmsg()
2196 copied = sock_intr_errno(timeo); in mptcp_recvmsg()
2202 mptcp_cleanup_rbuf(msk, copied); in mptcp_recvmsg()
2205 err = copied ? : err; in mptcp_recvmsg()
2210 mptcp_cleanup_rbuf(msk, copied); in mptcp_recvmsg()
2213 if (cmsg_flags && copied >= 0) { in mptcp_recvmsg()
2225 msk, skb_queue_empty(&sk->sk_receive_queue), copied); in mptcp_recvmsg()
2228 return copied; in mptcp_recvmsg()
2608 u16 copied = 0; in __mptcp_retrans() local
2638 copied += ret; in __mptcp_retrans()
2641 if (copied) { in __mptcp_retrans()
2642 len = max(copied, len); in __mptcp_retrans()
3328 msk->rcvq_space.copied = 0; in mptcp_rcv_space_init()