Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 211) sorted by relevance

123456789

/f-stack/freebsd/contrib/vchiq/interface/vchiq_arm/
H A Dvchiq_util.c41 int vchiu_queue_init(VCHIU_QUEUE_T *queue, int size) in vchiu_queue_init()
61 void vchiu_queue_delete(VCHIU_QUEUE_T *queue) in vchiu_queue_delete()
67 int vchiu_queue_is_empty(VCHIU_QUEUE_T *queue) in vchiu_queue_is_empty()
72 int vchiu_queue_is_full(VCHIU_QUEUE_T *queue) in vchiu_queue_is_full()
77 void vchiu_queue_push(VCHIU_QUEUE_T *queue, VCHIQ_HEADER_T *header) in vchiu_queue_push()
107 VCHIQ_HEADER_T *vchiu_queue_peek(VCHIU_QUEUE_T *queue) in vchiu_queue_peek()
126 VCHIQ_HEADER_T *vchiu_queue_pop(VCHIU_QUEUE_T *queue) in vchiu_queue_pop()
/f-stack/dpdk/drivers/net/ark/
H A Dark_ethdev_rx.c70 struct ark_rx_queue *queue, in eth_ark_rx_hw_setup()
127 struct ark_rx_queue *queue; in eth_ark_dev_rx_queue_setup() local
248 struct ark_rx_queue *queue; in eth_ark_recv_pkts() local
395 struct ark_rx_queue *queue; in eth_ark_dev_rx_queue_count() local
405 struct ark_rx_queue *queue; in eth_ark_rx_start_queue() local
428 struct ark_rx_queue *queue; in eth_ark_rx_stop_queue() local
541 struct ark_rx_queue *queue; in eth_ark_rx_dump_queue() local
553 struct ark_rx_queue *queue; in eth_ark_dev_rx_queue_release() local
578 struct ark_rx_queue *queue; in eth_rx_queue_stats_get() local
601 struct ark_rx_queue *queue; in eth_rx_queue_stats_reset() local
[all …]
H A Dark_ethdev_tx.c62 ark_tx_hw_queue_stop(struct ark_tx_queue *queue) in ark_tx_hw_queue_stop()
92 struct ark_tx_queue *queue; in eth_ark_xmit_pkts() local
177 eth_ark_tx_jumbo(struct ark_tx_queue *queue, struct rte_mbuf *mbuf) in eth_ark_tx_jumbo()
217 struct ark_tx_queue *queue; in eth_ark_tx_queue_setup() local
286 eth_ark_tx_hw_queue_config(struct ark_tx_queue *queue) in eth_ark_tx_hw_queue_config()
336 struct ark_tx_queue *queue; in eth_ark_tx_queue_release() local
354 struct ark_tx_queue *queue; in eth_ark_tx_queue_stop() local
377 struct ark_tx_queue *queue; in eth_ark_tx_queue_start() local
391 free_completed_tx(struct ark_tx_queue *queue) in free_completed_tx()
414 struct ark_tx_queue *queue; in eth_tx_queue_stats_get() local
[all …]
/f-stack/freebsd/kern/
H A Dsubr_taskqueue.c137 struct taskqueue *queue; in _taskqueue_create() local
179 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
209 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
295 struct taskqueue *queue; in taskqueue_timeout_func() local
428 taskqueue_block(struct taskqueue *queue) in taskqueue_block()
437 taskqueue_unblock(struct taskqueue *queue) in taskqueue_unblock()
448 taskqueue_run_locked(struct taskqueue *queue) in taskqueue_run_locked()
491 taskqueue_run(struct taskqueue *queue) in taskqueue_run()
592 taskqueue_drain_all(struct taskqueue *queue) in taskqueue_drain_all()
605 taskqueue_drain_timeout(struct taskqueue *queue, in taskqueue_drain_timeout()
[all …]
H A Dsubr_gtaskqueue.c130 struct gtaskqueue *queue; in _gtaskqueue_create() local
173 gtaskqueue_free(struct gtaskqueue *queue) in gtaskqueue_free()
193 struct gtaskqueue *queue = grouptask->gt_taskqueue; in grouptask_block() local
211 struct gtaskqueue *queue = grouptask->gt_taskqueue; in grouptask_unblock() local
262 gtaskqueue_drain_tq_queue(struct gtaskqueue *queue) in gtaskqueue_drain_tq_queue()
295 gtaskqueue_drain_tq_active(struct gtaskqueue *queue) in gtaskqueue_drain_tq_active()
323 gtaskqueue_block(struct gtaskqueue *queue) in gtaskqueue_block()
332 gtaskqueue_unblock(struct gtaskqueue *queue) in gtaskqueue_unblock()
343 gtaskqueue_run_locked(struct gtaskqueue *queue) in gtaskqueue_run_locked()
382 task_is_running(struct gtaskqueue *queue, struct gtask *gtask) in task_is_running()
[all …]
H A Dsubr_turnstile.c317 int queue; in turnstile_adjust_thread() local
740 turnstile_wait(struct turnstile *ts, struct thread *owner, int queue) in turnstile_wait()
829 turnstile_signal(struct turnstile *ts, int queue) in turnstile_signal()
880 turnstile_broadcast(struct turnstile *ts, int queue) in turnstile_broadcast()
1068 turnstile_head(struct turnstile *ts, int queue) in turnstile_head()
1083 turnstile_empty(struct turnstile *ts, int queue) in turnstile_empty()
1104 print_queue(struct threadqueue *queue, const char *header, const char *prefix) in print_queue()
/f-stack/freebsd/contrib/ck/include/spinlock/
H A Dmcs.h48 ck_spinlock_mcs_init(struct ck_spinlock_mcs **queue) in ck_spinlock_mcs_init()
57 ck_spinlock_mcs_trylock(struct ck_spinlock_mcs **queue, in ck_spinlock_mcs_trylock()
72 ck_spinlock_mcs_locked(struct ck_spinlock_mcs **queue) in ck_spinlock_mcs_locked()
82 ck_spinlock_mcs_lock(struct ck_spinlock_mcs **queue, in ck_spinlock_mcs_lock()
116 ck_spinlock_mcs_unlock(struct ck_spinlock_mcs **queue, in ck_spinlock_mcs_unlock()
H A Dclh.h57 ck_spinlock_clh_locked(struct ck_spinlock_clh **queue) in ck_spinlock_clh_locked()
69 ck_spinlock_clh_lock(struct ck_spinlock_clh **queue, struct ck_spinlock_clh *thread) in ck_spinlock_clh_lock()
/f-stack/dpdk/lib/librte_bpf/
H A Dbpf_pkt.c47 uint16_t queue; member
141 bpf_eth_cbh_find(struct bpf_eth_cbh *cbh, uint16_t port, uint16_t queue) in bpf_eth_cbh_find()
153 bpf_eth_cbh_add(struct bpf_eth_cbh *cbh, uint16_t port, uint16_t queue) in bpf_eth_cbh_add()
275 bpf_rx_callback_vm(__rte_unused uint16_t port, __rte_unused uint16_t queue, in bpf_rx_callback_vm()
310 bpf_tx_callback_vm(__rte_unused uint16_t port, __rte_unused uint16_t queue, in bpf_tx_callback_vm()
466 bpf_eth_unload(struct bpf_eth_cbh *cbh, uint16_t port, uint16_t queue) in bpf_eth_unload()
484 rte_bpf_eth_rx_unload(uint16_t port, uint16_t queue) in rte_bpf_eth_rx_unload()
495 rte_bpf_eth_tx_unload(uint16_t port, uint16_t queue) in rte_bpf_eth_tx_unload()
506 bpf_eth_elf_load(struct bpf_eth_cbh *cbh, uint16_t port, uint16_t queue, in bpf_eth_elf_load()
576 rte_bpf_eth_rx_elf_load(uint16_t port, uint16_t queue, in rte_bpf_eth_rx_elf_load()
[all …]
/f-stack/dpdk/app/test-pmd/
H A Dutil.c60 dump_pkt_burst(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_pkt_burst()
237 dump_rx_pkts(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_rx_pkts()
246 dump_tx_pkts(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_tx_pkts()
254 tx_pkt_set_md(uint16_t port_id, __rte_unused uint16_t queue, in tx_pkt_set_md()
277 uint16_t queue; in add_tx_md_callback() local
298 uint16_t queue; in remove_tx_md_callback() local
317 tx_pkt_set_dynf(uint16_t port_id, __rte_unused uint16_t queue, in tx_pkt_set_dynf()
333 uint16_t queue; in add_tx_dynf_callback() local
354 uint16_t queue; in remove_tx_dynf_callback() local
/f-stack/freebsd/netinet/
H A Dtcp_pcap.c264 tcp_pcap_add(struct tcphdr *th, struct mbuf *m, struct mbufq *queue) in tcp_pcap_add()
426 tcp_pcap_drain(struct mbufq *queue) in tcp_pcap_drain()
441 tcp_pcap_set_sock_max(struct mbufq *queue, int newval) in tcp_pcap_set_sock_max()
449 tcp_pcap_get_sock_max(struct mbufq *queue) in tcp_pcap_get_sock_max()
/f-stack/freebsd/contrib/octeon-sdk/
H A Dcvmx-zip.c96 int cvmx_zip_queue_initialize(int queue, int zcoremask) in cvmx_zip_queue_initialize()
183 int cvmx_zip_queue_shutdown(int queue) in cvmx_zip_queue_shutdown()
225 int cvmx_zip_queue_submit(cvmx_zip_command_t *command, int queue) in cvmx_zip_queue_submit()
H A Dcvmx-pko.h179 …uint64_t queue : 9; /**< The output queue to send the packet to (0-127 are leg… member
283 static inline void cvmx_pko_doorbell(uint64_t ipd_port, uint64_t queue, uint64_t len) in cvmx_pko_doorbell()
338 static inline void cvmx_pko_send_packet_prepare(uint64_t port, uint64_t queue, cvmx_pko_lock_t use_… in cvmx_pko_send_packet_prepare()
374 static inline cvmx_pko_status_t cvmx_pko_send_packet_finish(uint64_t ipd_port, uint64_t queue, in cvmx_pko_send_packet_finish()
422 static inline cvmx_pko_status_t cvmx_pko_send_packet_finish3(uint64_t ipd_port, uint64_t queue, in cvmx_pko_send_packet_finish3()
734 static inline void cvmx_pko_doorbell_pkoid(uint64_t pko_port, uint64_t queue, uint64_t len) in cvmx_pko_doorbell_pkoid()
763 static inline cvmx_pko_status_t cvmx_pko_send_packet_finish_pkoid(int pko_port, uint64_t queue, in cvmx_pko_send_packet_finish_pkoid()
805 …atic inline cvmx_pko_status_t cvmx_pko_send_packet_finish3_pkoid(uint64_t pko_port, uint64_t queue, in cvmx_pko_send_packet_finish3_pkoid()
/f-stack/dpdk/drivers/net/failsafe/
H A Dfailsafe_rxtx.c80 failsafe_rx_burst(void *queue, in failsafe_rx_burst()
112 failsafe_rx_burst_fast(void *queue, in failsafe_rx_burst_fast()
140 failsafe_tx_burst(void *queue, in failsafe_tx_burst()
161 failsafe_tx_burst_fast(void *queue, in failsafe_tx_burst_fast()
/f-stack/dpdk/drivers/net/pfe/
H A Dpfe_hif_lib.c140 struct hif_client_rx_queue *queue; in hif_lib_client_init_rx_buffers() local
182 hif_lib_client_cleanup_tx_queue(struct hif_client_tx_queue *queue) in hif_lib_client_cleanup_tx_queue()
210 struct hif_client_tx_queue *queue; in hif_lib_client_init_tx_buffers() local
345 struct hif_client_rx_queue *queue = &client->rx_q[qno]; in hif_lib_event_handler_start() local
391 hif_lib_receive_pkt(struct hif_client_rx_queue *queue, in hif_lib_receive_pkt()
496 struct hif_client_tx_queue *queue = &client->tx_q[qno]; in hif_lib_xmit_pkt() local
522 struct hif_client_tx_queue *queue = &client->tx_q[qno]; in hif_lib_tx_get_next_complete() local
/f-stack/dpdk/drivers/event/opdl/
H A Dopdl_evdev_init.c299 struct opdl_queue *queue = &device->queue[q_id]; in opdl_add_deps() local
415 struct opdl_queue *queue = &device->queue[i]; in build_all_dependencies() local
472 struct opdl_queue *queue = &device->queue[i]; in check_queues_linked() local
527 struct opdl_queue *queue = &device->queue[device->nb_queues]; in initialise_queue() local
709 struct opdl_queue *queue = &device->queue[port->queue_id]; in initialise_all_other_ports() local
837 struct opdl_queue *queue = in initialise_all_other_ports() local
875 struct opdl_queue *queue = NULL; in initialise_queue_zero_ports() local
932 struct opdl_queue *queue = in assign_internal_queue_ids() local
/f-stack/dpdk/lib/librte_pdump/
H A Drte_pdump.c43 uint16_t queue; member
50 uint16_t queue; member
123 pdump_register_rx_callbacks(uint16_t end_q, uint16_t port, uint16_t queue, in pdump_register_rx_callbacks()
177 pdump_register_tx_callbacks(uint16_t end_q, uint16_t port, uint16_t queue, in pdump_register_tx_callbacks()
234 uint16_t nb_rx_q = 0, nb_tx_q = 0, end_q, queue; in set_pdump_rxtx_cbs() local
431 pdump_prepare_client_request(char *device, uint16_t queue, in pdump_prepare_client_request()
483 rte_pdump_enable(uint16_t port, uint16_t queue, uint32_t flags, in rte_pdump_enable()
509 rte_pdump_enable_by_deviceid(char *device_id, uint16_t queue, in rte_pdump_enable_by_deviceid()
531 rte_pdump_disable(uint16_t port, uint16_t queue, uint32_t flags) in rte_pdump_disable()
550 rte_pdump_disable_by_deviceid(char *device_id, uint16_t queue, in rte_pdump_disable_by_deviceid()
/f-stack/freebsd/contrib/ck/src/
H A Dck_barrier_combining.c39 ck_barrier_combining_queue_dequeue(struct ck_barrier_combining_queue *queue) in ck_barrier_combining_queue_dequeue()
76 ck_barrier_combining_queue_enqueue(struct ck_barrier_combining_queue *queue, in ck_barrier_combining_queue_enqueue()
99 struct ck_barrier_combining_queue queue; in ck_barrier_combining_group_init() local
/f-stack/app/nginx-1.16.1/src/core/
H A Dngx_queue.c18 ngx_queue_middle(ngx_queue_t *queue) in ngx_queue_middle()
51 ngx_queue_sort(ngx_queue_t *queue, in ngx_queue_sort()
/f-stack/dpdk/drivers/event/dlb2/pf/base/
H A Ddlb2_resource.c646 struct dlb2_ldb_queue *queue; in dlb2_attach_ldb_queues() local
1271 struct dlb2_ldb_queue *queue; in dlb2_domain_mapped_queues_empty() local
1355 struct dlb2_ldb_queue *queue; in dlb2_get_ldb_queue_from_id() local
2045 struct dlb2_ldb_queue *queue; in dlb2_domain_finish_map_port() local
2232 struct dlb2_ldb_queue *queue; in dlb2_domain_finish_unmap_port_slot() local
2472 struct dlb2_ldb_queue *queue; in dlb2_domain_disable_ldb_queue_write_perms() local
2644 struct dlb2_ldb_queue *queue; in dlb2_domain_verify_reset_success() local
2995 struct dlb2_ldb_queue *queue; in dlb2_domain_reset_ldb_queue_registers() local
3345 struct dlb2_ldb_queue *queue; in dlb2_domain_drain_unmapped_queues() local
3848 struct dlb2_ldb_queue *queue; in dlb2_hw_create_ldb_queue() local
[all …]
/f-stack/dpdk/drivers/common/qat/
H A Dqat_qp.c349 static void qat_queue_delete(struct qat_queue *queue) in qat_queue_delete()
376 qat_queue_create(struct qat_pci_device *qat_dev, struct qat_queue *queue, in qat_queue_create()
522 struct qat_queue *queue = &qp->tx_q; in adf_configure_queues() local
581 register struct qat_queue *queue; in qat_enqueue_op_burst() local
678 register struct qat_queue *queue; in qat_enqueue_comp_op_burst() local
922 struct qat_queue *queue = &(qp->rx_q); in qat_cq_dequeue_response() local
963 struct qat_queue *queue = &(qp->tx_q); in qat_cq_get_fw_version() local
/f-stack/dpdk/drivers/event/dlb/pf/base/
H A Ddlb_resource.c238 struct dlb_ldb_queue *queue; in dlb_attach_ldb_queues() local
265 struct dlb_ldb_queue *queue; in dlb_attach_ldb_queues() local
2255 struct dlb_ldb_queue *queue; in dlb_domain_disable_ldb_queue_write_perms() local
2466 struct dlb_ldb_queue *queue; in dlb_domain_finish_map_port() local
2580 struct dlb_ldb_queue *queue; in dlb_domain_finish_unmap_port_slot() local
2729 struct dlb_ldb_queue *queue; in dlb_domain_mapped_queues_empty() local
2824 struct dlb_ldb_queue *queue; in dlb_domain_drain_unmapped_queues() local
3222 struct dlb_ldb_queue *queue; in dlb_domain_verify_reset_success() local
3616 struct dlb_ldb_queue *queue; in dlb_domain_reset_ldb_queue_registers() local
4546 struct dlb_ldb_queue *queue; in dlb_hw_create_ldb_queue() local
[all …]
/f-stack/dpdk/lib/librte_node/
H A Dethdev_rx.c22 uint16_t port, queue; in ethdev_rx_node_process_inline() local
68 eth_pkt_parse_cb(uint16_t port, uint16_t queue, struct rte_mbuf **mbufs, in eth_pkt_parse_cb()
146 ethdev_ptype_setup(uint16_t port, uint16_t queue) in ethdev_ptype_setup()
/f-stack/dpdk/drivers/net/nfb/
H A Dnfb_tx.h19 struct ndp_queue *queue; /* tx queue */ member
121 nfb_eth_ndp_tx(void *queue, in nfb_eth_ndp_tx()
/f-stack/dpdk/examples/vhost/
H A Dvirtio_net.c25 struct vhost_queue *queue; in vs_vhost_net_setup() local
184 struct vhost_queue *queue; in vs_enqueue_pkts() local
366 struct vhost_queue *queue; in vs_dequeue_pkts() local

123456789