| /f-stack/app/nginx-1.16.1/src/http/v2/ |
| H A D | ngx_http_v2_huff_encode.c | 203 pending = 0; in ngx_http_v2_huff_encode()
211 pending += next->len; in ngx_http_v2_huff_encode()
223 pending -= sizeof(buf) * 8; in ngx_http_v2_huff_encode()
225 buf |= code >> pending; in ngx_http_v2_huff_encode()
231 buf = pending ? code << (sizeof(buf) * 8 - pending) : 0; in ngx_http_v2_huff_encode()
234 if (pending == 0) { in ngx_http_v2_huff_encode()
238 buf |= (ngx_uint_t) -1 >> pending; in ngx_http_v2_huff_encode()
240 pending = ngx_align(pending, 8); in ngx_http_v2_huff_encode()
242 if (hlen + pending / 8 >= len) { in ngx_http_v2_huff_encode()
249 pending -= 8; in ngx_http_v2_huff_encode()
[all …]
|
| /f-stack/freebsd/arm/broadcom/bcm2835/ |
| H A D | bcm2835_intr.c | 166 uint32_t pending, pending_gpu; in bcm2835_intc_active_intr() local
169 if (pending == 0) in bcm2835_intc_active_intr()
171 if (pending & INTC_PENDING_BASIC_ARM) in bcm2835_intc_active_intr()
172 return (ffs(pending) - 1); in bcm2835_intc_active_intr()
174 if (pending & INTC_PENDING_BASIC_GPU1_7) in bcm2835_intc_active_intr()
176 if (pending & INTC_PENDING_BASIC_GPU1_9) in bcm2835_intc_active_intr()
178 if (pending & INTC_PENDING_BASIC_GPU1_10) in bcm2835_intc_active_intr()
180 if (pending & INTC_PENDING_BASIC_GPU1_18) in bcm2835_intc_active_intr()
182 if (pending & INTC_PENDING_BASIC_GPU1_19) in bcm2835_intc_active_intr()
186 if (pending & INTC_PENDING_BASIC_GPU2_21) in bcm2835_intc_active_intr()
[all …]
|
| /f-stack/dpdk/drivers/net/sfc/ |
| H A D | sfc_ef10_rx.c | 65 unsigned int pending; member
256 unsigned int pending = rxq->pending; in sfc_ef10_rx_process_event() local
274 rxq->pending = pending + ready; in sfc_ef10_rx_process_event()
283 } while (pending != rxq->pending); in sfc_ef10_rx_process_event()
284 rxq->completed = pending; in sfc_ef10_rx_process_event()
315 rxq->completed = pending; in sfc_ef10_rx_process_event()
357 rxq->completed = pending; in sfc_ef10_rx_process_event()
368 while (pending != rxq->pending) { in sfc_ef10_rx_process_event()
538 unsigned int pending = rxq->pending; in sfc_ef10_rx_qdesc_npending() local
547 pending) & in sfc_ef10_rx_qdesc_npending()
[all …]
|
| /f-stack/app/redis-5.0.5/tests/unit/type/ |
| H A D | stream-cgroups.tcl | 53 test {XPENDING is able to return pending items} {
54 set pending [r XPENDING mystream mygroup - + 10]
55 assert {[llength $pending] == 4}
57 set item [lindex $pending $j]
69 set pending [r XPENDING mystream mygroup - + 10 client-1]
70 assert {[llength $pending] == 2}
74 set pending [r XPENDING mystream mygroup - + 10 client-1]
75 set id1 [lindex $pending 0 0]
76 set id2 [lindex $pending 1 0]
79 assert {[llength $pending] == 1}
[all …]
|
| /f-stack/dpdk/kernel/linux/igb_uio/ |
| H A D | compat.h | 98 bool pending; in pci_check_and_mask_intx() local
105 pending = (((status >> 16) & PCI_STATUS_INTERRUPT) != 0); in pci_check_and_mask_intx()
106 if (pending) { in pci_check_and_mask_intx()
120 return pending; in pci_check_and_mask_intx()
|
| /f-stack/freebsd/contrib/ck/src/ |
| H A D | ck_hp.c | 126 ck_stack_init(&entry->pending); in ck_hp_unregister()
146 ck_stack_init(&entry->pending); in ck_hp_register()
239 CK_STACK_FOREACH_SAFE(&thread->pending, entry, next) { in ck_hp_reclaim()
260 CK_STACK_FIRST(&thread->pending) = CK_STACK_NEXT(entry); in ck_hp_reclaim()
279 ck_stack_push_spnc(&thread->pending, &hazard->pending_entry); in ck_hp_retire()
299 ck_stack_push_spnc(&thread->pending, &hazard->pending_entry); in ck_hp_free()
|
| /f-stack/freebsd/contrib/zlib/ |
| H A D | deflate.c | 484 s->pending = 0;
532 unsigned *pending; in deflatePending()
537 if (pending != Z_NULL)
538 *pending = strm->state->pending;
740 len = s->pending;
749 s->pending -= len;
750 if (s->pending == 0) {
789 if (s->pending != 0) {
846 if (s->pending != 0) {
924 s->pending += left;
[all …]
|
| /f-stack/freebsd/net/ |
| H A D | mp_ring.c | 99 int n, pending, total; in drain_ring_locked() local
108 pending = 0; in drain_ring_locked()
128 pending += n; in drain_ring_locked()
136 if (cidx != pidx && pending < 64 && total < budget) in drain_ring_locked()
161 pending = 0; in drain_ring_locked()
173 int n, pending, total; in drain_ring_lockless() local
182 pending = 0; in drain_ring_lockless()
207 pending += n; in drain_ring_lockless()
215 if (cidx != pidx && pending < 64 && total < budget) in drain_ring_lockless()
244 pending = 0; in drain_ring_lockless()
|
| /f-stack/app/redis-5.0.5/deps/jemalloc/src/ |
| H A D | tsd.c | 175 bool pending[MALLOC_TSD_CLEANUPS_MAX], again; in _malloc_thread_cleanup() local
179 pending[i] = true; in _malloc_thread_cleanup()
185 if (pending[i]) { in _malloc_thread_cleanup()
186 pending[i] = cleanups[i](); in _malloc_thread_cleanup()
187 if (pending[i]) { in _malloc_thread_cleanup()
|
| /f-stack/dpdk/drivers/regex/mlx5/ |
| H A D | mlx5_rxp.c | 613 unsigned int pending; in write_private_rules() local
654 pending = 0; in write_private_rules()
663 if (pending > 0) { in write_private_rules()
668 pending, id); in write_private_rules()
673 pending = 0; in write_private_rules()
677 pending++; in write_private_rules()
689 pending, id); in write_private_rules()
694 pending = 0; in write_private_rules()
707 if (pending) { in write_private_rules()
712 pending, id); in write_private_rules()
[all …]
|
| /f-stack/freebsd/contrib/ncsw/Peripherals/FM/ |
| H A D | fm_ncsw.c | 602 if (pending & INTR_EN_TMR) in GuestEventIsr()
4302 if (!pending) in FM_EventIsr()
4312 if (pending & INTR_EN_QMI) in FM_EventIsr()
4314 if (pending & INTR_EN_PRS) in FM_EventIsr()
4316 if (pending & INTR_EN_PLCR) in FM_EventIsr()
4318 if (pending & INTR_EN_TMR) in FM_EventIsr()
4344 if (pending & INTR_EN_REV0) in FM_EventIsr()
4355 if (pending & INTR_EN_REV1) in FM_EventIsr()
4365 if (pending & INTR_EN_REV2) in FM_EventIsr()
4375 if (pending & INTR_EN_REV3) in FM_EventIsr()
[all …]
|
| /f-stack/dpdk/lib/librte_rcu/ |
| H A D | rte_rcu_qsbr.c | 422 unsigned int *freed, unsigned int *pending, in rte_rcu_qsbr_dq_reclaim() argument
466 if (pending != NULL) in rte_rcu_qsbr_dq_reclaim()
467 *pending = rte_ring_count(dq->r); in rte_rcu_qsbr_dq_reclaim()
476 unsigned int pending; in rte_rcu_qsbr_dq_delete() local
486 rte_rcu_qsbr_dq_reclaim(dq, ~0, NULL, &pending, NULL); in rte_rcu_qsbr_dq_delete()
487 if (pending != 0) { in rte_rcu_qsbr_dq_delete()
|
| /f-stack/freebsd/contrib/octeon-sdk/ |
| H A D | cvmx-mdio.h | 363 } while (smi_rd.s.pending && (cvmx_get_cycle() < done)); in __cvmx_mdio_read_rd_dat()
466 cvmx_smix_wr_dat_t, pending, ==, 0, CVMX_MDIO_TIMEOUT)) in cvmx_mdio_write()
509 cvmx_smix_wr_dat_t, pending, ==, 0, CVMX_MDIO_TIMEOUT)) in cvmx_mdio_45_read()
522 if (smi_rd.s.pending) in cvmx_mdio_45_read()
573 cvmx_smix_wr_dat_t, pending, ==, 0, CVMX_MDIO_TIMEOUT)) in cvmx_mdio_45_write()
587 cvmx_smix_wr_dat_t, pending, ==, 0, CVMX_MDIO_TIMEOUT)) in cvmx_mdio_45_write()
|
| H A D | cvmx-smix-defs.h | 436 uint64_t pending : 1; /**< Read Xaction Pending */ member
442 uint64_t pending : 1;
482 uint64_t pending : 1; /**< Write Xaction Pending */ member
488 uint64_t pending : 1;
|
| /f-stack/freebsd/contrib/ck/include/ |
| H A D | ck_epoch.h | 98 ck_stack_t pending[CK_EPOCH_LENGTH]; member
206 ck_stack_push_spnc(&record->pending[offset], &entry->stack_entry); in ck_epoch_call()
226 ck_stack_push_upmc(&record->pending[offset], &entry->stack_entry); in ck_epoch_call_strict()
|
| /f-stack/dpdk/drivers/crypto/octeontx/ |
| H A D | otx_cryptodev_hw_access.c | 686 uint32_t pending, retries = 5; in otx_cpt_stop_device() local
690 pending = otx_cpt_read_vq_doorbell(cptvf); in otx_cpt_stop_device()
691 while (pending) { in otx_cpt_stop_device()
693 cptvf->dev_name, pending); in otx_cpt_stop_device()
695 pending = otx_cpt_read_vq_doorbell(cptvf); in otx_cpt_stop_device()
701 if (!retries && pending) { in otx_cpt_stop_device()
703 cptvf->dev_name, pending); in otx_cpt_stop_device()
|
| /f-stack/freebsd/mips/cavium/octe/ |
| H A D | ethernet-mdio.c | 77 } while (smi_rd.s.pending); in cvm_oct_mdio_read()
114 } while (smi_wr.s.pending); in cvm_oct_mdio_write()
|
| /f-stack/dpdk/drivers/net/ice/ |
| H A D | ice_dcf.c | 95 cmd->pending = 1; in ice_dcf_vc_cmd_set()
141 if (cmd->v_op == v_op && cmd->pending) { in ice_dcf_aq_cmd_handle()
151 cmd->pending = 0; in ice_dcf_aq_cmd_handle()
163 uint16_t pending = 1; in ice_dcf_handle_virtchnl_msg() local
169 while (pending) { in ice_dcf_handle_virtchnl_msg()
170 ret = iavf_clean_arq_element(&hw->avf, &info, &pending); in ice_dcf_handle_virtchnl_msg()
446 if (!cmd->pending) in ice_dcf_execute_virtchnl_cmd()
507 if ((!desc_cmd.pending && !buff_cmd.pending) || in ice_dcf_send_aq_cmd()
509 (!buff_cmd.pending && buff_cmd.v_ret != IAVF_SUCCESS)) in ice_dcf_send_aq_cmd()
736 args.pending = 0; in ice_dcf_configure_rss_key()
[all …]
|
| /f-stack/freebsd/netgraph/bluetooth/l2cap/ |
| H A D | ng_l2cap_main.c | 312 ep->con_handle, con->pending, in ng_l2cap_lower_rcvmsg()
315 con->pending -= ep->completed; in ng_l2cap_lower_rcvmsg()
316 if (con->pending < 0) { in ng_l2cap_lower_rcvmsg()
321 con->con_handle, con->pending, in ng_l2cap_lower_rcvmsg()
324 con->pending = 0; in ng_l2cap_lower_rcvmsg()
585 e2->pending = con->pending; in ng_l2cap_default_rcvmsg()
|
| /f-stack/dpdk/lib/librte_mbuf/ |
| H A D | rte_mbuf.c | 468 struct rte_mbuf ** const pending, unsigned int * const nb_pending, in __rte_pktmbuf_free_seg_via_array() argument
474 (*nb_pending > 0 && m->pool != pending[0]->pool)) { in __rte_pktmbuf_free_seg_via_array()
475 rte_mempool_put_bulk(pending[0]->pool, in __rte_pktmbuf_free_seg_via_array()
476 (void **)pending, *nb_pending); in __rte_pktmbuf_free_seg_via_array()
480 pending[(*nb_pending)++] = m; in __rte_pktmbuf_free_seg_via_array()
493 struct rte_mbuf *m, *m_next, *pending[RTE_PKTMBUF_FREE_PENDING_SZ]; in rte_pktmbuf_free_bulk() local
506 pending, &nb_pending, in rte_pktmbuf_free_bulk()
513 rte_mempool_put_bulk(pending[0]->pool, (void **)pending, nb_pending); in rte_pktmbuf_free_bulk()
|
| /f-stack/dpdk/drivers/net/dpaa2/ |
| H A D | dpaa2_rxtx.c | 607 pending = 1; in dpaa2_dev_prefetch_rx()
620 pending = 0; in dpaa2_dev_prefetch_rx()
652 } while (pending); in dpaa2_dev_prefetch_rx()
814 pending = 1; in dpaa2_dev_rx()
826 pending = 0; in dpaa2_dev_rx()
864 } while (pending); in dpaa2_dev_rx()
929 pending = 1; in dpaa2_dev_tx_conf()
941 pending = 0; in dpaa2_dev_tx_conf()
1594 pending = 1; in dpaa2_dev_loopback_rx()
1607 pending = 0; in dpaa2_dev_loopback_rx()
[all …]
|
| /f-stack/dpdk/lib/librte_timer/ |
| H A D | rte_timer.c | 515 __TIMER_STAT_ADD(priv_timer, pending, -1); in __rte_timer_reset()
530 __TIMER_STAT_ADD(priv_timer, pending, 1); in __rte_timer_reset()
613 __TIMER_STAT_ADD(priv_timer, pending, -1); in __rte_timer_stop()
749 __TIMER_STAT_ADD(priv_timer, pending, -1); in __rte_timer_manage()
770 __TIMER_STAT_ADD(priv_timer, pending, 1); in __rte_timer_manage()
935 __TIMER_STAT_ADD(data->priv_timer, pending, -1); in rte_timer_alt_manage()
958 __TIMER_STAT_ADD(data->priv_timer, pending, 1); in rte_timer_alt_manage()
1058 sum.pending += priv_timer[lcore_id].stats.pending; in __rte_timer_dump_stats()
1064 fprintf(f, " pending = %"PRIu64"\n", sum.pending); in __rte_timer_dump_stats()
|
| /f-stack/freebsd/crypto/ccp/ |
| H A D | ccp.c | 523 if (s->pending != 0) in ccp_freesession()
526 s->pending); in ccp_freesession()
568 if (s->pending != 0) { in ccp_process()
575 if (s->pending != 0) { in ccp_process()
582 if (s->pending != 0) { in ccp_process()
589 if (s->pending != 0) { in ccp_process()
598 s->pending++; in ccp_process()
|
| /f-stack/freebsd/arm/freescale/imx/ |
| H A D | tzic.c | 111 uint32_t pending; in tzic_intr() local
115 pending = tzic_read_4(sc, TZIC_PND(i)); in tzic_intr()
116 if ((b = 31 - __builtin_clz(pending)) < 0) in tzic_intr()
|
| /f-stack/freebsd/kern/ |
| H A D | subr_taskqueue.c | 354 taskqueue_task_nop_fn(void *context, int pending) in taskqueue_task_nop_fn() argument
454 int pending; in taskqueue_run_locked() local
466 pending = task->ta_pending; in taskqueue_run_locked()
480 task->ta_func(task->ta_context, pending); in taskqueue_run_locked()
561 u_int pending, pending1; in taskqueue_cancel_timeout() local
565 pending = !!(callout_stop(&timeout_task->c) > 0); in taskqueue_cancel_timeout()
574 *pendp = pending + pending1; in taskqueue_cancel_timeout()
|