Lines Matching defs:dlen
838 * @dlen: length of data to send
845 struct msghdr *msg, size_t dlen, long timeout)
882 rc = tipc_msg_build(hdr, msg, 0, dlen, mtu, &pkts);
885 if (unlikely(rc == dlen)) {
894 return rc ? rc : dlen;
905 * @dlen: total length of message data
909 u32 dnode, u32 dport, int dlen)
913 int blks = tsk_blocks(GROUP_H_SIZE + dlen);
928 rc = tipc_msg_build(hdr, m, 0, dlen, mtu, &pkts);
929 if (unlikely(rc != dlen))
945 return dlen;
952 * @dlen: total length of message data
959 int dlen, long timeout)
963 int blks = tsk_blocks(GROUP_H_SIZE + dlen);
987 rc = tipc_send_group_msg(net, tsk, m, mb, node, port, dlen);
989 return rc ? rc : dlen;
996 * @dlen: total length of message data
1003 int dlen, long timeout)
1009 int blks = tsk_blocks(GROUP_H_SIZE + dlen);
1069 rc = tipc_send_group_msg(net, tsk, m, mbr, node, port, dlen);
1071 return rc ? rc : dlen;
1078 * @dlen: total length of message data
1085 int dlen, long timeout)
1094 int blks = tsk_blocks(MCAST_H_SIZE + dlen);
1129 rc = tipc_msg_build(hdr, m, 0, dlen, mtu, &pkts);
1130 if (unlikely(rc != dlen))
1145 return dlen;
1152 * @dlen: total length of message data
1159 int dlen, long timeout)
1180 return tipc_send_group_unicast(sock, m, dlen, timeout);
1184 return tipc_send_group_bcast(sock, m, dlen, timeout);
1410 static int __tipc_sendmsg(struct socket *sock, struct msghdr *m, size_t dlen)
1425 if (unlikely(dlen > TIPC_MAX_USER_MSG_SIZE))
1437 return tipc_send_group_bcast(sock, m, dlen, timeout);
1439 return tipc_send_group_anycast(sock, m, dlen, timeout);
1441 return tipc_send_group_unicast(sock, m, dlen, timeout);
1443 return tipc_send_group_mcast(sock, m, dlen, timeout);
1470 return tipc_sendmcast(sock, ua, m, dlen, timeout);
1506 rc = tipc_msg_build(hdr, m, 0, dlen, mtu, &pkts);
1507 if (unlikely(rc != dlen))
1525 if (dlen && timeout) {
1531 return rc ? rc : dlen;
1557 static int __tipc_sendstream(struct socket *sock, struct msghdr *m, size_t dlen)
1573 if (unlikely(dlen > INT_MAX))
1578 rc = __tipc_sendmsg(sock, m, dlen);
1579 if (dlen && dlen == rc) {
1581 tsk->snt_unacked = tsk_inc(tsk, dlen + msg_hdr_sz(hdr));
1593 send = min_t(size_t, dlen - sent, TIPC_MAX_USER_MSG_SIZE);
1637 } while (sent < dlen && !rc);
1743 int dlen, rc;
1749 dlen = msg_data_sz(hdr);
1757 data[1] = dlen;
1759 if (rc || !dlen)
1761 rc = put_cmsg(m, SOL_TIPC, TIPC_RETDATA, dlen, msg_data(hdr));
1892 int rc, err, hlen, dlen, copy;
1919 dlen = msg_data_sz(hdr);
1923 if (likely(dlen || err))
1939 copy = min_t(int, dlen - offset, buflen);
1943 if (unlikely(offset + copy < dlen)) {
1980 tipc_group_update_rcv_win(tsk->group, tsk_blocks(hlen + dlen),
1995 tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen);
2025 int hlen, dlen, err, rc;
2049 dlen = msg_data_sz(hdr);
2054 if (unlikely(!dlen && !err)) {
2071 copy = min_t(int, dlen - offset, buflen - copied);
2077 if (unlikely(offset < dlen)) {
2096 tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen);