Home
last modified time | relevance | path

Searched refs:sent (Results 1 – 25 of 175) sorted by relevance

1234567

/f-stack/app/nginx-1.16.1/src/os/unix/
H A Dngx_darwin_sendfile_chain.c34 off_t send, prev_send, sent; in ngx_darwin_sendfile_chain() local
129 sent = header.size + file_size; in ngx_darwin_sendfile_chain()
133 file->file_pos, sent, header.size); in ngx_darwin_sendfile_chain()
136 &sent, &hdtr, 0); in ngx_darwin_sendfile_chain()
156 "sendfile() sent only %O bytes", sent); in ngx_darwin_sendfile_chain()
159 if (rc == 0 && sent == 0) { in ngx_darwin_sendfile_chain()
185 sent = (n == NGX_AGAIN) ? 0 : n; in ngx_darwin_sendfile_chain()
188 c->sent += sent; in ngx_darwin_sendfile_chain()
190 in = ngx_chain_update_sent(in, sent); in ngx_darwin_sendfile_chain()
193 send = prev_send + sent; in ngx_darwin_sendfile_chain()
[all …]
H A Dngx_freebsd_sendfile_chain.c36 off_t send, prev_send, sent; in ngx_freebsd_sendfile_chain() local
180 sent = 0; in ngx_freebsd_sendfile_chain()
222 } else if (rc >= 0 && sent == 0) { in ngx_freebsd_sendfile_chain()
248 sent = (n == NGX_AGAIN) ? 0 : n; in ngx_freebsd_sendfile_chain()
251 c->sent += sent; in ngx_freebsd_sendfile_chain()
253 in = ngx_chain_update_sent(in, sent); in ngx_freebsd_sendfile_chain()
264 if (sent) { in ngx_freebsd_sendfile_chain()
271 if (sent == 0) { in ngx_freebsd_sendfile_chain()
293 send = prev_send + sent; in ngx_freebsd_sendfile_chain()
320 send = prev_send + sent; in ngx_freebsd_sendfile_chain()
[all …]
H A Dngx_solaris_sendfilev_chain.c47 size_t sent; in ngx_solaris_sendfilev_chain() local
84 sent = 0; in ngx_solaris_sendfilev_chain()
164 n = sendfilev(c->fd, sfvs, nsfv, &sent); in ngx_solaris_sendfilev_chain()
184 "sendfilev() sent only %uz bytes", sent); in ngx_solaris_sendfilev_chain()
186 } else if (n == 0 && sent == 0) { in ngx_solaris_sendfilev_chain()
208 "sendfilev: %z %z", n, sent); in ngx_solaris_sendfilev_chain()
210 c->sent += sent; in ngx_solaris_sendfilev_chain()
212 in = ngx_chain_update_sent(in, sent); in ngx_solaris_sendfilev_chain()
215 send = prev_send + sent; in ngx_solaris_sendfilev_chain()
219 if (send - prev_send != (off_t) sent) { in ngx_solaris_sendfilev_chain()
H A Dngx_linux_sendfile_chain.c51 size_t file_size, sent; in ngx_linux_sendfile_chain() local
185 sent = (n == NGX_AGAIN) ? 0 : n; in ngx_linux_sendfile_chain()
194 sent = (n == NGX_AGAIN) ? 0 : n; in ngx_linux_sendfile_chain()
197 c->sent += sent; in ngx_linux_sendfile_chain()
199 in = ngx_chain_update_sent(in, sent); in ngx_linux_sendfile_chain()
206 if ((size_t) (send - prev_send) != sent) { in ngx_linux_sendfile_chain()
218 send = prev_send + sent; in ngx_linux_sendfile_chain()
309 size_t sent; member
364 if (ctx->sent == 0) { in ngx_linux_sendfile_thread()
377 return ctx->sent; in ngx_linux_sendfile_thread()
[all …]
H A Dngx_writev_chain.c16 ssize_t n, sent; in ngx_writev_chain() local
89 sent = (n == NGX_AGAIN) ? 0 : n; in ngx_writev_chain()
91 c->sent += sent; in ngx_writev_chain()
93 in = ngx_chain_update_sent(in, sent); in ngx_writev_chain()
95 if (send - prev_send != sent) { in ngx_writev_chain()
/f-stack/dpdk/examples/l2fwd-event/
H A Dl2fwd_poll.c13 int sent; in l2fwd_poll_simple_forward() local
22 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_poll_simple_forward()
23 if (sent) in l2fwd_poll_simple_forward()
24 rsrc->port_stats[dst_port].tx += sent; in l2fwd_poll_simple_forward()
39 int32_t sent; in l2fwd_poll_main_loop() local
75 sent = rte_eth_tx_buffer_flush(port_id, 0, buf); in l2fwd_poll_main_loop()
76 if (sent) in l2fwd_poll_main_loop()
77 rsrc->port_stats[port_id].tx += sent; in l2fwd_poll_main_loop()
/f-stack/app/nginx-1.16.1/src/http/
H A Dngx_http_write_filter_module.c50 off_t size, sent, nsent, limit; in ngx_http_write_filter() local
259 - (c->sent - r->limit_rate_after); in ngx_http_write_filter()
281 sent = c->sent; in ngx_http_write_filter()
298 nsent = c->sent; in ngx_http_write_filter()
302 sent -= r->limit_rate_after; in ngx_http_write_filter()
303 if (sent < 0) { in ngx_http_write_filter()
304 sent = 0; in ngx_http_write_filter()
313 delay = (ngx_msec_t) ((nsent - sent) * 1000 / r->limit_rate); in ngx_http_write_filter()
324 && c->sent - sent >= limit - (off_t) (2 * ngx_pagesize)) in ngx_http_write_filter()
/f-stack/dpdk/examples/multi_process/client_server_mp/mp_client/
H A Dclient.c188 int sent; in handle_packet() local
193 sent = rte_eth_tx_buffer(out_port, client_id, buffer, buf); in handle_packet()
194 if (sent) in handle_packet()
195 tx_stats->tx[out_port] += sent; in handle_packet()
213 uint16_t sent; in main() local
257 sent = rte_eth_tx_buffer_flush(port, in main()
260 tx_stats->tx[port] += sent; in main()
/f-stack/dpdk/examples/server_node_efd/node/
H A Dnode.c255 int sent; in transmit_packet() local
260 sent = rte_eth_tx_buffer(out_port, node_id, buffer, buf); in transmit_packet()
261 if (sent) in transmit_packet()
262 tx_stats->tx[out_port] += sent; in transmit_packet()
312 uint16_t sent; in main() local
371 sent = rte_eth_tx_buffer_flush( in main()
375 if (unlikely(sent)) in main()
376 tx_stats->tx[port] += sent; in main()
/f-stack/freebsd/netinet/
H A Dsctp_timer.c69 if (chk->sent == SCTP_DATAGRAM_RESEND) { in sctp_audit_retranmission_queue()
75 if (chk->sent == SCTP_DATAGRAM_RESEND) { in sctp_audit_retranmission_queue()
80 if (chk->sent == SCTP_DATAGRAM_RESEND) { in sctp_audit_retranmission_queue()
683 chk->sent = SCTP_DATAGRAM_RESEND; in sctp_mark_all_for_resend()
758 chk->sent = SCTP_DATAGRAM_RESEND; in sctp_mark_all_for_resend()
1107 cookie->sent = SCTP_DATAGRAM_RESEND; in sctp_cookie_timer()
1152 chk->sent = SCTP_DATAGRAM_RESEND; in sctp_strreset_timer()
1172 strrst->sent = SCTP_DATAGRAM_RESEND; in sctp_strreset_timer()
1238 chk->sent = SCTP_DATAGRAM_RESEND; in sctp_asconf_timer()
1251 if (asconf->sent != SCTP_DATAGRAM_RESEND && chk->sent != SCTP_DATAGRAM_UNSENT) in sctp_asconf_timer()
[all …]
H A Dsctp_indata.c3345 tp1->sent, in sctp_strike_gap_ack_chunks()
3424 tp1->sent, in sctp_strike_gap_ack_chunks()
3428 tp1->sent++; in sctp_strike_gap_ack_chunks()
3449 tp1->sent, in sctp_strike_gap_ack_chunks()
3452 tp1->sent++; in sctp_strike_gap_ack_chunks()
3486 tp1->sent, in sctp_strike_gap_ack_chunks()
3490 tp1->sent++; in sctp_strike_gap_ack_chunks()
3525 tp1->sent++; in sctp_strike_gap_ack_chunks()
3548 tp1->sent, in sctp_strike_gap_ack_chunks()
3552 tp1->sent++; in sctp_strike_gap_ack_chunks()
[all …]
/f-stack/app/nginx-1.16.1/src/core/
H A Dngx_buf.c272 ngx_chain_update_sent(ngx_chain_t *in, off_t sent) in ngx_chain_update_sent() argument
282 if (sent == 0) { in ngx_chain_update_sent()
288 if (sent >= size) { in ngx_chain_update_sent()
289 sent -= size; in ngx_chain_update_sent()
303 in->buf->pos += (size_t) sent; in ngx_chain_update_sent()
307 in->buf->file_pos += sent; in ngx_chain_update_sent()
/f-stack/dpdk/examples/distributor/
H A Dmain.c280 uint16_t sent = rte_ring_enqueue_burst(tx_ring, in lcore_rx()
295 app_stats.rx.enqueued_pkts += sent; in lcore_rx()
296 if (unlikely(sent < nb_ret)) { in lcore_rx()
297 app_stats.rx.enqdrop_pkts += nb_ret - sent; in lcore_rx()
300 while (sent < nb_ret) in lcore_rx()
301 rte_pktmbuf_free(bufs[sent++]); in lcore_rx()
375 uint16_t sent = rte_ring_enqueue_burst(out_r, in lcore_distributor() local
377 app_stats.dist.sent_pkts += sent; in lcore_distributor()
378 if (unlikely(sent < nb_ret)) { in lcore_distributor()
383 while (sent < nb_ret) in lcore_distributor()
[all …]
/f-stack/dpdk/examples/link_status_interrupt/
H A Dmain.c175 int sent; in lsi_simple_forward() local
188 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in lsi_simple_forward()
189 if (sent) in lsi_simple_forward()
190 port_statistics[dst_port].tx += sent; in lsi_simple_forward()
200 unsigned sent; in lsi_main_loop() local
243 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in lsi_main_loop()
244 if (sent) in lsi_main_loop()
245 port_statistics[portid].tx += sent; in lsi_main_loop()
/f-stack/dpdk/doc/guides/platform/
H A Docteontx2.rst355 Total octets sent on the interface: 0
356 Total frames sent on the interface: 0
357 Packets sent with an octet count < 64: 0
358 Packets sent with an octet count == 64: 0
359 Packets sent with an octet count of 65127: 0
360 Packets sent with an octet count of 128-255: 0
361 Packets sent with an octet count of 256-511: 0
364 Packets sent with an octet count of > 1518: 0
365 Packets sent to a broadcast DMAC: 0
366 Packets sent to the multicast DMAC: 0
[all …]
/f-stack/dpdk/examples/l2fwd-keepalive/
H A Dmain.c172 int sent; in l2fwd_simple_forward() local
187 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_simple_forward()
188 if (sent) in l2fwd_simple_forward()
189 port_statistics[dst_port].tx += sent; in l2fwd_simple_forward()
198 int sent; in l2fwd_main_loop() local
253 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in l2fwd_main_loop()
254 if (sent) in l2fwd_main_loop()
255 port_statistics[portid].tx += sent; in l2fwd_main_loop()
/f-stack/dpdk/examples/l2fwd/
H A Dmain.c183 int sent; in l2fwd_simple_forward() local
192 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_simple_forward()
193 if (sent) in l2fwd_simple_forward()
194 port_statistics[dst_port].tx += sent; in l2fwd_simple_forward()
203 int sent; in l2fwd_main_loop() local
248 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in l2fwd_main_loop()
249 if (sent) in l2fwd_main_loop()
250 port_statistics[portid].tx += sent; in l2fwd_main_loop()
/f-stack/dpdk/examples/packet_ordering/
H A Dmain.c533 unsigned sent; in send_thread() local
598 sent = rte_eth_tx_buffer(outp1, 0, outbuf, rombufs[i]); in send_thread()
599 if (sent) in send_thread()
600 app_stats.tx.ro_tx_pkts += sent; in send_thread()
617 unsigned sent; in tx_thread() local
647 sent = rte_eth_tx_buffer(outp, 0, outbuf, mbufs[i]); in tx_thread()
648 if (sent) in tx_thread()
649 app_stats.tx.ro_tx_pkts += sent; in tx_thread()
/f-stack/dpdk/app/test-pmd/
H A Dnoisy_vnf.c210 unsigned int sent; in pkt_burst_noisy_vnf() local
213 sent = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_noisy_vnf()
215 if (unlikely(sent < nb_deqd) && fs->retry_enabled) in pkt_burst_noisy_vnf()
218 fs->fwd_dropped += drop_pkts(tmp_pkts, nb_deqd, sent); in pkt_burst_noisy_vnf()
/f-stack/freebsd/arm/freescale/vybrid/
H A Dvf_i2c.c571 i2c_write(device_t dev, const char *buf, int len, int *sent, int timeout) in i2c_write() argument
580 *sent = 0; in i2c_write()
583 while (*sent < len) { in i2c_write()
592 if (!tx_acked(sc) && (*sent = (len - 2)) ){ in i2c_write()
594 vf_i2c_dbg(sc, "no ACK on %d write\n", *sent); in i2c_write()
598 (*sent)++; in i2c_write()
/f-stack/freebsd/contrib/openzfs/cmd/zed/zed.d/
H A Dzed.rc15 # Email will only be sent if ZED_EMAIL_ADDR is defined.
23 # Email will only be sent if ZED_EMAIL_ADDR is defined.
32 # Email will only be sent if ZED_EMAIL_ADDR is defined.
71 # If not defined, push notifications will instead be sent to all devices
/f-stack/app/nginx-1.16.1/auto/os/
H A Dsolaris37 size_t sent; ssize_t n;
38 n = sendfilev(fd, vec, 1, &sent);
/f-stack/app/redis-5.0.5/src/
H A Dslowlog.c161 long count = 10, sent = 0; in slowlogCommand() local
186 sent++; in slowlogCommand()
188 setDeferredMultiBulkLength(c,totentries,sent); in slowlogCommand()
/f-stack/freebsd/arm/mv/
H A Da37x0_iic.c406 a37x0_iic_write(device_t dev, const char *buf, int len, int *sent, int timeout) in a37x0_iic_write() argument
421 *sent = 0; in a37x0_iic_write()
422 while (*sent < len) { in a37x0_iic_write()
426 if (*sent == len - 1) in a37x0_iic_write()
433 (*sent)++; in a37x0_iic_write()
/f-stack/dpdk/doc/guides/howto/
H A Drte_flow.rst281 received packet with src ip = 176.80.50.4 sent to queue 2
282 received packet with src ip = 176.80.50.5 sent to queue 1
283 received packet with src ip = 176.80.50.6 sent to queue 0
303 received packet with src ip = 176.80.50.4 sent to queue 3
304 received packet with src ip = 176.80.50.5 sent to queue 1
305 received packet with src ip = 176.80.50.6 sent to queue 3

1234567