Lines Matching refs:copied

1528 	int len, copied = 0, err = 0;  in __subflow_push_pending()  local
1539 err = copied ? : ret; in __subflow_push_pending()
1544 copied += ret; in __subflow_push_pending()
1554 err = copied; in __subflow_push_pending()
1559 err = copied; in __subflow_push_pending()
1640 int copied = 0; in __mptcp_subflow_push_pending() local
1656 copied += ret; in __mptcp_subflow_push_pending()
1668 copied += ret; in __mptcp_subflow_push_pending()
1687 if (copied) { in __mptcp_subflow_push_pending()
1797 size_t copied = 0; in mptcp_sendmsg() local
1811 copied += copied_syn; in mptcp_sendmsg()
1877 copied += psize; in mptcp_sendmsg()
1907 if (copied) in mptcp_sendmsg()
1912 return copied; in mptcp_sendmsg()
1915 if (copied) in mptcp_sendmsg()
1918 copied = sk_stream_error(sk, msg->msg_flags, ret); in mptcp_sendmsg()
1929 int copied = 0; in __mptcp_recvmsg_mskq() local
1934 u32 count = min_t(size_t, len - copied, data_len); in __mptcp_recvmsg_mskq()
1940 if (!copied) in __mptcp_recvmsg_mskq()
1951 copied += count; in __mptcp_recvmsg_mskq()
1971 if (copied >= len) in __mptcp_recvmsg_mskq()
1975 return copied; in __mptcp_recvmsg_mskq()
1982 static void mptcp_rcv_space_adjust(struct mptcp_sock *msk, int copied) in mptcp_rcv_space_adjust() argument
1992 if (copied <= 0) in mptcp_rcv_space_adjust()
1998 msk->rcvq_space.copied += copied; in mptcp_rcv_space_adjust()
2028 if (msk->rcvq_space.copied <= msk->rcvq_space.space) in mptcp_rcv_space_adjust()
2036 rcvwin = ((u64)msk->rcvq_space.copied << 1) + 16 * advmss; in mptcp_rcv_space_adjust()
2038 grow = rcvwin * (msk->rcvq_space.copied - msk->rcvq_space.space); in mptcp_rcv_space_adjust()
2071 msk->rcvq_space.space = msk->rcvq_space.copied; in mptcp_rcv_space_adjust()
2073 msk->rcvq_space.copied = 0; in mptcp_rcv_space_adjust()
2165 int copied = 0, cmsg_flags = 0; in mptcp_recvmsg() local
2175 copied = -ENOTCONN; in mptcp_recvmsg()
2187 while (copied < len) { in mptcp_recvmsg()
2190 bytes_read = __mptcp_recvmsg_mskq(msk, msg, len - copied, flags, &tss, &cmsg_flags); in mptcp_recvmsg()
2192 if (!copied) in mptcp_recvmsg()
2193 copied = bytes_read; in mptcp_recvmsg()
2197 copied += bytes_read; in mptcp_recvmsg()
2208 if (copied >= target) in mptcp_recvmsg()
2211 if (copied) { in mptcp_recvmsg()
2220 copied = sock_error(sk); in mptcp_recvmsg()
2234 copied = -ENOTCONN; in mptcp_recvmsg()
2239 copied = -EAGAIN; in mptcp_recvmsg()
2244 copied = sock_intr_errno(timeo); in mptcp_recvmsg()
2254 if (cmsg_flags && copied >= 0) { in mptcp_recvmsg()
2267 skb_queue_empty(&msk->receive_queue), copied); in mptcp_recvmsg()
2269 mptcp_rcv_space_adjust(msk, copied); in mptcp_recvmsg()
2272 return copied; in mptcp_recvmsg()
2643 u16 copied = 0; in __mptcp_retrans() local
2661 copied += ret; in __mptcp_retrans()
2664 if (copied) { in __mptcp_retrans()
2665 len = max(copied, len); in __mptcp_retrans()
3347 msk->rcvq_space.copied = 0; in mptcp_rcv_space_init()