Lines Matching refs:copied
1176 size_t copied = 0; in mptcp_sendmsg() local
1261 copied += ret; in mptcp_sendmsg()
1308 if (copied) { in mptcp_sendmsg()
1321 return copied ? : ret; in mptcp_sendmsg()
1345 int copied = 0; in __mptcp_recvmsg_mskq() local
1350 u32 count = min_t(size_t, len - copied, data_len); in __mptcp_recvmsg_mskq()
1355 if (!copied) in __mptcp_recvmsg_mskq()
1360 copied += count; in __mptcp_recvmsg_mskq()
1370 if (copied >= len) in __mptcp_recvmsg_mskq()
1374 return copied; in __mptcp_recvmsg_mskq()
1381 static void mptcp_rcv_space_adjust(struct mptcp_sock *msk, int copied) in mptcp_rcv_space_adjust() argument
1390 if (copied <= 0) in mptcp_rcv_space_adjust()
1393 msk->rcvq_space.copied += copied; in mptcp_rcv_space_adjust()
1421 if (msk->rcvq_space.copied <= msk->rcvq_space.space) in mptcp_rcv_space_adjust()
1429 rcvwin = ((u64)msk->rcvq_space.copied << 1) + 16 * advmss; in mptcp_rcv_space_adjust()
1431 grow = rcvwin * (msk->rcvq_space.copied - msk->rcvq_space.space); in mptcp_rcv_space_adjust()
1469 msk->rcvq_space.space = msk->rcvq_space.copied; in mptcp_rcv_space_adjust()
1471 msk->rcvq_space.copied = 0; in mptcp_rcv_space_adjust()
1507 int copied = 0; in mptcp_recvmsg() local
1521 while (len > (size_t)copied) { in mptcp_recvmsg()
1524 bytes_read = __mptcp_recvmsg_mskq(msk, msg, len - copied); in mptcp_recvmsg()
1526 if (!copied) in mptcp_recvmsg()
1527 copied = bytes_read; in mptcp_recvmsg()
1531 copied += bytes_read; in mptcp_recvmsg()
1540 if (copied >= target) in mptcp_recvmsg()
1543 if (copied) { in mptcp_recvmsg()
1552 copied = sock_error(sk); in mptcp_recvmsg()
1563 copied = -ENOTCONN; in mptcp_recvmsg()
1568 copied = -EAGAIN; in mptcp_recvmsg()
1573 copied = sock_intr_errno(timeo); in mptcp_recvmsg()
1598 skb_queue_empty(&sk->sk_receive_queue), copied); in mptcp_recvmsg()
1599 mptcp_rcv_space_adjust(msk, copied); in mptcp_recvmsg()
1602 return copied; in mptcp_recvmsg()
1755 size_t copied = 0; in mptcp_worker() local
1804 copied += ret; in mptcp_worker()
1811 if (copied) in mptcp_worker()
2157 msk->rcvq_space.copied = 0; in mptcp_rcv_space_init()