Lines Matching refs:dlen
842 struct msghdr *msg, size_t dlen, long timeout) in tipc_sendmcast() argument
879 rc = tipc_msg_build(hdr, msg, 0, dlen, mtu, &pkts); in tipc_sendmcast()
882 if (unlikely(rc == dlen)) { in tipc_sendmcast()
891 return rc ? rc : dlen; in tipc_sendmcast()
906 u32 dnode, u32 dport, int dlen) in tipc_send_group_msg() argument
910 int blks = tsk_blocks(GROUP_H_SIZE + dlen); in tipc_send_group_msg()
925 rc = tipc_msg_build(hdr, m, 0, dlen, mtu, &pkts); in tipc_send_group_msg()
926 if (unlikely(rc != dlen)) in tipc_send_group_msg()
942 return dlen; in tipc_send_group_msg()
956 int dlen, long timeout) in tipc_send_group_unicast() argument
960 int blks = tsk_blocks(GROUP_H_SIZE + dlen); in tipc_send_group_unicast()
984 rc = tipc_send_group_msg(net, tsk, m, mb, node, port, dlen); in tipc_send_group_unicast()
986 return rc ? rc : dlen; in tipc_send_group_unicast()
1000 int dlen, long timeout) in tipc_send_group_anycast() argument
1006 int blks = tsk_blocks(GROUP_H_SIZE + dlen); in tipc_send_group_anycast()
1065 rc = tipc_send_group_msg(net, tsk, m, mbr, node, port, dlen); in tipc_send_group_anycast()
1067 return rc ? rc : dlen; in tipc_send_group_anycast()
1081 int dlen, long timeout) in tipc_send_group_bcast() argument
1090 int blks = tsk_blocks(MCAST_H_SIZE + dlen); in tipc_send_group_bcast()
1125 rc = tipc_msg_build(hdr, m, 0, dlen, mtu, &pkts); in tipc_send_group_bcast()
1126 if (unlikely(rc != dlen)) in tipc_send_group_bcast()
1141 return dlen; in tipc_send_group_bcast()
1155 int dlen, long timeout) in tipc_send_group_mcast() argument
1175 return tipc_send_group_unicast(sock, m, dlen, timeout); in tipc_send_group_mcast()
1179 return tipc_send_group_bcast(sock, m, dlen, timeout); in tipc_send_group_mcast()
1405 static int __tipc_sendmsg(struct socket *sock, struct msghdr *m, size_t dlen) in __tipc_sendmsg() argument
1420 if (unlikely(dlen > TIPC_MAX_USER_MSG_SIZE)) in __tipc_sendmsg()
1432 return tipc_send_group_bcast(sock, m, dlen, timeout); in __tipc_sendmsg()
1434 return tipc_send_group_anycast(sock, m, dlen, timeout); in __tipc_sendmsg()
1436 return tipc_send_group_unicast(sock, m, dlen, timeout); in __tipc_sendmsg()
1438 return tipc_send_group_mcast(sock, m, dlen, timeout); in __tipc_sendmsg()
1465 return tipc_sendmcast(sock, ua, m, dlen, timeout); in __tipc_sendmsg()
1501 rc = tipc_msg_build(hdr, m, 0, dlen, mtu, &pkts); in __tipc_sendmsg()
1502 if (unlikely(rc != dlen)) in __tipc_sendmsg()
1520 if (dlen && timeout) { in __tipc_sendmsg()
1526 return rc ? rc : dlen; in __tipc_sendmsg()
1552 static int __tipc_sendstream(struct socket *sock, struct msghdr *m, size_t dlen) in __tipc_sendstream() argument
1568 if (unlikely(dlen > INT_MAX)) in __tipc_sendstream()
1573 rc = __tipc_sendmsg(sock, m, dlen); in __tipc_sendstream()
1574 if (dlen && dlen == rc) { in __tipc_sendstream()
1576 tsk->snt_unacked = tsk_inc(tsk, dlen + msg_hdr_sz(hdr)); in __tipc_sendstream()
1588 send = min_t(size_t, dlen - sent, TIPC_MAX_USER_MSG_SIZE); in __tipc_sendstream()
1632 } while (sent < dlen && !rc); in __tipc_sendstream()
1738 int dlen, rc; in tipc_sk_anc_data_recv() local
1744 dlen = msg_data_sz(hdr); in tipc_sk_anc_data_recv()
1752 data[1] = dlen; in tipc_sk_anc_data_recv()
1754 if (rc || !dlen) in tipc_sk_anc_data_recv()
1756 rc = put_cmsg(m, SOL_TIPC, TIPC_RETDATA, dlen, msg_data(hdr)); in tipc_sk_anc_data_recv()
1887 int rc, err, hlen, dlen, copy; in tipc_recvmsg() local
1914 dlen = msg_data_sz(hdr); in tipc_recvmsg()
1918 if (likely(dlen || err)) in tipc_recvmsg()
1934 copy = min_t(int, dlen - offset, buflen); in tipc_recvmsg()
1938 if (unlikely(offset + copy < dlen)) { in tipc_recvmsg()
1975 tipc_group_update_rcv_win(tsk->group, tsk_blocks(hlen + dlen), in tipc_recvmsg()
1990 tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen); in tipc_recvmsg()
2020 int hlen, dlen, err, rc; in tipc_recvstream() local
2044 dlen = msg_data_sz(hdr); in tipc_recvstream()
2049 if (unlikely(!dlen && !err)) { in tipc_recvstream()
2066 copy = min_t(int, dlen - offset, buflen - copied); in tipc_recvstream()
2072 if (unlikely(offset < dlen)) { in tipc_recvstream()
2091 tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen); in tipc_recvstream()