| /net/bluetooth/ |
| D | hci_event.c | 163 void *sent; in hci_cc_write_link_policy() local
170 sent = hci_sent_cmd_data(hdev, HCI_OP_WRITE_LINK_POLICY); in hci_cc_write_link_policy()
171 if (!sent) in hci_cc_write_link_policy()
178 conn->link_policy = get_unaligned_le16(sent + 2); in hci_cc_write_link_policy()
200 void *sent; in hci_cc_write_def_link_policy() local
207 sent = hci_sent_cmd_data(hdev, HCI_OP_WRITE_DEF_LINK_POLICY); in hci_cc_write_def_link_policy()
208 if (!sent) in hci_cc_write_def_link_policy()
211 hdev->link_policy = get_unaligned_le16(sent); in hci_cc_write_def_link_policy()
251 struct hci_cp_read_stored_link_key *sent; in hci_cc_read_stored_link_key() local
255 sent = hci_sent_cmd_data(hdev, HCI_OP_READ_STORED_LINK_KEY); in hci_cc_read_stored_link_key()
[all …]
|
| D | hci_core.c | 2775 struct hci_command_hdr *sent = (void *) hdev->sent_cmd->data; in hci_cmd_timeout() local
2776 u16 opcode = __le16_to_cpu(sent->opcode); in hci_cmd_timeout()
4480 if (c->sent < min) { in hci_low_sent()
4481 min = c->sent; in hci_low_sent()
4530 if (c->type == type && c->sent) { in hci_link_tx_to()
4582 if (conn->sent < min) { in hci_chan_sent()
4583 min = conn->sent; in hci_chan_sent()
4646 if (chan->sent) { in hci_prio_recalculate()
4647 chan->sent = 0; in hci_prio_recalculate()
4718 conn->sent++; in hci_sched_sco()
[all …]
|
| D | hci_conn.c | 652 hdev->acl_cnt += conn->sent; in hci_conn_del()
657 hdev->le_cnt += conn->sent; in hci_conn_del()
659 hdev->acl_cnt += conn->sent; in hci_conn_del()
|
| /net/x25/ |
| D | x25_out.c | 52 int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT; in x25_output() local
73 return sent; in x25_output()
77 "sent\n", err, sent); in x25_output()
101 sent += len; in x25_output()
107 sent = skb->len - header_len; in x25_output()
109 return sent; in x25_output()
|
| /net/smc/ |
| D | smc_tx.h | 23 union smc_host_cursor sent, prep; in smc_tx_prepared_sends() local
25 smc_curs_copy(&sent, &conn->tx_curs_sent, conn); in smc_tx_prepared_sends()
27 return smc_curs_diff(conn->sndbuf_desc->len, &sent, &prep); in smc_tx_prepared_sends()
|
| D | smc_tx.c | 306 union smc_host_cursor *sent, in smc_tx_advance_cursors() argument
316 smc_curs_add(conn->sndbuf_desc->len, sent, len); in smc_tx_advance_cursors()
419 union smc_host_cursor sent, prep, prod, cons; in smc_tx_rdma_writes() local
425 smc_curs_copy(&sent, &conn->tx_curs_sent, conn); in smc_tx_rdma_writes()
428 to_send = smc_curs_diff(conn->sndbuf_desc->len, &sent, &prep); in smc_tx_rdma_writes()
468 if (sent.count + dst_len <= conn->sndbuf_desc->len) { in smc_tx_rdma_writes()
473 src_len = conn->sndbuf_desc->len - sent.count; in smc_tx_rdma_writes()
477 rc = smcd_tx_rdma_writes(conn, len, sent.count, src_len, in smc_tx_rdma_writes()
480 rc = smcr_tx_rdma_writes(conn, len, sent.count, src_len, in smc_tx_rdma_writes()
487 smc_tx_advance_cursors(conn, &prod, &sent, len); in smc_tx_rdma_writes()
[all …]
|
| /net/vmw_vsock/ |
| D | vmci_transport_notify.c | 121 bool sent; in vmci_transport_handle_waiting_read() local
124 sent = vmci_transport_send_wrote_bh(dst, src) > 0; in vmci_transport_handle_waiting_read()
126 sent = vmci_transport_send_wrote(sk) > 0; in vmci_transport_handle_waiting_read()
128 if (sent) in vmci_transport_handle_waiting_read()
151 bool sent; in vmci_transport_handle_waiting_write() local
154 sent = vmci_transport_send_read_bh(dst, src) > 0; in vmci_transport_handle_waiting_write()
156 sent = vmci_transport_send_read(sk) > 0; in vmci_transport_handle_waiting_write()
158 if (sent) in vmci_transport_handle_waiting_write()
|
| /net/hsr/ |
| D | Kconfig | 18 with other HSR capable nodes. All Ethernet frames sent over the HSR
19 device will be sent in both directions on the ring (over both slave
26 frames sent over the PRP device will be sent to both networks giving
|
| D | hsr_forward.c | 373 bool sent = false; in hsr_forward_do() local
392 if ((port->dev->features & NETIF_F_HW_HSR_DUP) && sent) in hsr_forward_do()
430 sent = true; in hsr_forward_do()
|
| /net/sctp/ |
| D | chunk.c | 78 int error, sent; in sctp_datamsg_destroy() local
92 sent = chunk->has_tsn ? SCTP_DATA_SENT : SCTP_DATA_UNSENT; in sctp_datamsg_destroy()
96 ev = sctp_ulpevent_make_send_failed(asoc, chunk, sent, in sctp_datamsg_destroy()
105 sent, error, in sctp_datamsg_destroy()
|
| /net/sunrpc/ |
| D | svcsock.c | 559 unsigned int sent; in svc_udp_sendto() local
572 err = xprt_sock_sendmsg(svsk->sk_sock, &msg, xdr, 0, 0, &sent); in svc_udp_sendto()
576 err = xprt_sock_sendmsg(svsk->sk_sock, &msg, xdr, 0, 0, &sent); in svc_udp_sendto()
584 return sent; in svc_udp_sendto()
1156 unsigned int sent; in svc_tcp_sendto() local
1167 err = svc_tcp_sendmsg(svsk->sk_sock, xdr, marker, &sent); in svc_tcp_sendto()
1169 trace_svcsock_tcp_send(xprt, err < 0 ? (long)err : sent); in svc_tcp_sendto()
1170 if (err < 0 || sent != (xdr->len + sizeof(marker))) in svc_tcp_sendto()
1175 return sent; in svc_tcp_sendto()
1185 (err < 0) ? err : sent, xdr->len); in svc_tcp_sendto()
|
| D | xprtsock.c | 878 unsigned int sent; in xs_local_send_request() local
892 transport->xmit.offset, rm, &sent); in xs_local_send_request()
899 if (likely(sent > 0) || status == 0) { in xs_local_send_request()
900 transport->xmit.offset += sent; in xs_local_send_request()
949 unsigned int sent; in xs_udp_send_request() local
963 status = xprt_sock_sendmsg(transport->sock, &msg, xdr, 0, 0, &sent); in xs_udp_send_request()
975 if (sent > 0 || status == 0) { in xs_udp_send_request()
976 req->rq_xmit_bytes_sent += sent; in xs_udp_send_request()
977 if (sent >= req->rq_slen) in xs_udp_send_request()
1033 unsigned int sent; in xs_tcp_send_request() local
[all …]
|
| /net/bluetooth/rfcomm/ |
| D | sock.c | 567 int sent; in rfcomm_sock_sendmsg() local
582 sent = bt_sock_wait_ready(sk, msg->msg_flags); in rfcomm_sock_sendmsg()
586 if (sent) in rfcomm_sock_sendmsg()
587 return sent; in rfcomm_sock_sendmsg()
594 sent = rfcomm_dlc_send(d, skb); in rfcomm_sock_sendmsg()
595 if (sent < 0) in rfcomm_sock_sendmsg()
598 return sent; in rfcomm_sock_sendmsg()
|
| D | tty.c | 788 int sent = 0, size; in rfcomm_tty_write() local
801 skb_put_data(skb, buf + sent, size); in rfcomm_tty_write()
805 sent += size; in rfcomm_tty_write()
809 return sent; in rfcomm_tty_write()
|
| /net/kcm/ |
| D | kcmsock.c | 585 unsigned int sent, total_sent = 0; in kcm_write_msgs() local
599 kcm_tx_msg(skb_peek(&sk->sk_write_queue))->sent = 0; in kcm_write_msgs()
608 if (txm->sent) { in kcm_write_msgs()
614 sent = txm->sent; in kcm_write_msgs()
630 sent = 0; in kcm_write_msgs()
660 txm->sent = sent; in kcm_write_msgs()
678 txm->sent = 0; in kcm_write_msgs()
685 sent += ret; in kcm_write_msgs()
707 sk->sk_wmem_queued -= sent; in kcm_write_msgs()
708 total_sent += sent; in kcm_write_msgs()
|
| /net/caif/ |
| D | caif_socket.c | 601 int sent = 0; in caif_stream_sendmsg() local
617 while (sent < len) { in caif_stream_sendmsg()
619 size = len-sent; in caif_stream_sendmsg()
660 sent += size; in caif_stream_sendmsg()
663 return sent; in caif_stream_sendmsg()
666 if (sent == 0 && !(msg->msg_flags&MSG_NOSIGNAL)) in caif_stream_sendmsg()
670 return sent ? : err; in caif_stream_sendmsg()
|
| /net/mptcp/ |
| D | protocol.c | 1183 u16 sent; member
1280 u64 data_seq = dfrag->data_seq + info->sent; in mptcp_sendmsg_frag()
1281 int offset = dfrag->offset + info->sent; in mptcp_sendmsg_frag()
1292 msk, ssk, dfrag->data_seq, dfrag->data_len, info->sent); in mptcp_sendmsg_frag()
1294 if (WARN_ON_ONCE(info->sent > info->limit || in mptcp_sendmsg_frag()
1350 copy = min_t(size_t, copy, info->limit - info->sent); in mptcp_sendmsg_frag()
1522 u32 sent) in mptcp_update_post_push() argument
1526 dfrag->already_sent += sent; in mptcp_update_post_push()
1528 msk->snd_burst -= sent; in mptcp_update_post_push()
1529 msk->tx_pending_data -= sent; in mptcp_update_post_push()
[all …]
|
| /net/ceph/ |
| D | messenger_v2.c | 3137 int sent; in prepare_zero_front() local
3140 sent = front_len(con->out_msg) - resid; in prepare_zero_front()
3141 dout("%s con %p sent %d resid %d\n", __func__, con, sent, resid); in prepare_zero_front()
3143 if (sent) { in prepare_zero_front()
3145 crc32c(-1, con->out_msg->front.iov_base, sent); in prepare_zero_front()
3158 int sent; in prepare_zero_middle() local
3161 sent = middle_len(con->out_msg) - resid; in prepare_zero_middle()
3162 dout("%s con %p sent %d resid %d\n", __func__, con, sent, resid); in prepare_zero_middle()
3164 if (sent) { in prepare_zero_middle()
3166 crc32c(-1, con->out_msg->middle->vec.iov_base, sent); in prepare_zero_middle()
[all …]
|
| /net/appletalk/ |
| D | aarp.c | 609 goto sent; in aarp_send_ddp()
619 goto sent; in aarp_send_ddp()
663 goto sent; in aarp_send_ddp()
670 sent: in aarp_send_ddp()
|
| /net/netfilter/ipvs/ |
| D | Kconfig | 243 destinations changes, a connection will likely be sent to the same
255 sent to the ith server, in which Ci is the number of connections
266 When there is an idle server available, the job will be sent to
268 is no idle server available, the job will be sent to the server
329 the IP address and port number of real servers cannot be sent to
|
| /net/ipv4/ |
| D | tcp_bpf.c | 292 u32 tosend, origsize, sent, delta = 0; in tcp_bpf_send_verdict() local
353 sent = origsize - msg->sg.size; in tcp_bpf_send_verdict()
392 sk_mem_charge(sk, tosend - sent); in tcp_bpf_send_verdict()
|
| /net/rds/ |
| D | ib_send.c | 867 int sent; in rds_ib_xmit_rdma() local
914 sent = 0; in rds_ib_xmit_rdma()
954 sent += len; in rds_ib_xmit_rdma()
955 rdsdebug("ic %p sent %d remote_addr %llu\n", ic, sent, remote_addr); in rds_ib_xmit_rdma()
|
| /net/unix/ |
| D | af_unix.c | 2030 int sent = 0; in unix_stream_sendmsg() local
2063 while (sent < len) { in unix_stream_sendmsg()
2064 size = len - sent; in unix_stream_sendmsg()
2110 sent += size; in unix_stream_sendmsg()
2118 sent++; in unix_stream_sendmsg()
2124 return sent; in unix_stream_sendmsg()
2130 if (sent == 0 && !(msg->msg_flags&MSG_NOSIGNAL)) in unix_stream_sendmsg()
2135 return sent ? : err; in unix_stream_sendmsg()
|
| /net/atm/ |
| D | Kconfig | 35 Normally, an "ICMP host unreachable" message is sent if a neighbour
|
| /net/tipc/ |
| D | socket.c | 1569 int send, sent = 0; in __tipc_sendstream() local
1592 send = min_t(size_t, dlen - sent, TIPC_MAX_USER_MSG_SIZE); in __tipc_sendstream()
1603 sent += send; in __tipc_sendstream()
1619 rc = tipc_msg_build(hdr, m, sent, send, maxpkt, txq); in __tipc_sendstream()
1634 sent += send; in __tipc_sendstream()
1636 } while (sent < dlen && !rc); in __tipc_sendstream()
1638 return sent ? sent : rc; in __tipc_sendstream()
|