Home
last modified time | relevance | path

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

123456789

/freebsd-13-stable/sys/contrib/vchiq/interface/vchiq_arm/
HDvchiq_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()
/freebsd-13-stable/contrib/apr-util/misc/
HDapr_queue.c73 #define apr_queue_full(queue) ((queue)->nelts == (queue)->bounds) argument
79 #define apr_queue_empty(queue) ((queue)->nelts == 0) argument
87 apr_queue_t *queue = data; in queue_destroy() local
106 apr_queue_t *queue; in apr_queue_create() local
148 APU_DECLARE(apr_status_t) apr_queue_push(apr_queue_t *queue, void *data) in apr_queue_push()
211 APU_DECLARE(apr_status_t) apr_queue_trypush(apr_queue_t *queue, void *data) in apr_queue_trypush()
251 APU_DECLARE(unsigned int) apr_queue_size(apr_queue_t *queue) { in apr_queue_size()
261 APU_DECLARE(apr_status_t) apr_queue_pop(apr_queue_t *queue, void **data) in apr_queue_pop()
325 APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t *queue, void **data) in apr_queue_trypop()
362 APU_DECLARE(apr_status_t) apr_queue_interrupt_all(apr_queue_t *queue) in apr_queue_interrupt_all()
[all …]
/freebsd-13-stable/sys/kern/
HDsubr_taskqueue.c108 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init()
128 task_get_busy(struct taskqueue *queue, struct task *task) in task_get_busy()
145 struct taskqueue *queue; in _taskqueue_create() local
187 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
217 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
232 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task, int flags) in taskqueue_enqueue_locked()
305 taskqueue_enqueue_flags(struct taskqueue *queue, struct task *task, int flags) in taskqueue_enqueue_flags()
317 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue()
325 struct taskqueue *queue; in taskqueue_timeout_func() local
338 taskqueue_enqueue_timeout_sbt(struct taskqueue *queue, in taskqueue_enqueue_timeout_sbt()
[all …]
HDsubr_gtaskqueue.c128 struct gtaskqueue *queue; in _gtaskqueue_create() local
171 gtaskqueue_free(struct gtaskqueue *queue) in gtaskqueue_free()
191 struct gtaskqueue *queue = grouptask->gt_taskqueue; in grouptask_block() local
209 struct gtaskqueue *queue = grouptask->gt_taskqueue; in grouptask_unblock() local
224 grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *gtask) in grouptaskqueue_enqueue()
260 gtaskqueue_drain_tq_queue(struct gtaskqueue *queue) in gtaskqueue_drain_tq_queue()
293 gtaskqueue_drain_tq_active(struct gtaskqueue *queue) in gtaskqueue_drain_tq_active()
321 gtaskqueue_block(struct gtaskqueue *queue) in gtaskqueue_block()
330 gtaskqueue_unblock(struct gtaskqueue *queue) in gtaskqueue_unblock()
341 gtaskqueue_run_locked(struct gtaskqueue *queue) in gtaskqueue_run_locked()
[all …]
HDsubr_turnstile.c315 int queue; in turnstile_adjust_thread() local
738 turnstile_wait(struct turnstile *ts, struct thread *owner, int queue) in turnstile_wait()
827 turnstile_signal(struct turnstile *ts, int queue) in turnstile_signal()
878 turnstile_broadcast(struct turnstile *ts, int queue) in turnstile_broadcast()
1066 turnstile_head(struct turnstile *ts, int queue) in turnstile_head()
1081 turnstile_empty(struct turnstile *ts, int queue) in turnstile_empty()
1102 print_queue(struct threadqueue *queue, const char *header, const char *prefix) in print_queue()
/freebsd-13-stable/sys/contrib/ck/include/spinlock/
HDmcs.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()
HDclh.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()
/freebsd-13-stable/contrib/dma/
HDdma.c99 set_from(struct queue *queue, const char *osender) in set_from()
157 do_alias(struct queue *queue, const char *addr) in do_alias()
177 add_recp(struct queue *queue, const char *str, int expand) in add_recp()
244 go_background(struct queue *queue) in go_background()
376 run_queue(struct queue *queue) in run_queue()
389 show_queue(struct queue *queue) in show_queue()
426 struct queue queue; in main() local
HDspool.c75 newspoolf(struct queue *queue) in newspoolf()
157 readqueuef(struct queue *queue, char *queuefn) in readqueuef()
235 linkspool(struct queue *queue) in linkspool()
282 load_queue(struct queue *queue) in load_queue()
388 dropspool(struct queue *queue, struct qitem *keep) in dropspool()
HDdma.h122 struct queue { struct
123 struct queueh queue; member
124 char *id;
125 FILE *mailf;
126 char *tmpf;
127 const char *sender;
HDmail.c168 parse_addrs(struct parse_state *ps, char *s, struct queue *queue) in parse_addrs()
350 writeline(struct queue *queue, const char *line, ssize_t linelen) in writeline()
376 readmail(struct queue *queue, int nodot, int recp_from_header) in readmail()
/freebsd-13-stable/contrib/subversion/subversion/libsvn_subr/
HDsorts.c415 heap_is_less(svn_priority_queue__t *queue, in heap_is_less() argument
431 heap_swap(svn_priority_queue__t *queue, in heap_swap()
451 heap_bubble_down(svn_priority_queue__t *queue, in heap_bubble_down()
465 heap_bubble_up(svn_priority_queue__t *queue, in heap_bubble_up()
492 svn_priority_queue__t *queue = apr_pcalloc(elements->pool, sizeof(*queue)); in svn_priority_queue__create() local
503 svn_priority_queue__size(svn_priority_queue__t *queue) in svn_priority_queue__size()
509 svn_priority_queue__peek(svn_priority_queue__t *queue) in svn_priority_queue__peek()
515 svn_priority_queue__update(svn_priority_queue__t *queue) in svn_priority_queue__update()
521 svn_priority_queue__pop(svn_priority_queue__t *queue) in svn_priority_queue__pop()
535 svn_priority_queue__push(svn_priority_queue__t *queue, in svn_priority_queue__push()
/freebsd-13-stable/sys/netinet/
HDtcp_pcap.c262 tcp_pcap_add(struct tcphdr *th, struct mbuf *m, struct mbufq *queue) in tcp_pcap_add()
424 tcp_pcap_drain(struct mbufq *queue) in tcp_pcap_drain()
439 tcp_pcap_set_sock_max(struct mbufq *queue, int newval) in tcp_pcap_set_sock_max()
447 tcp_pcap_get_sock_max(struct mbufq *queue) in tcp_pcap_get_sock_max()
/freebsd-13-stable/sys/contrib/octeon-sdk/
HDcvmx-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()
HDcvmx-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()
/freebsd-13-stable/sys/dev/vmware/vmci/
HDvmci_kernel_if.c513 struct vmci_queue *queue; in vmci_alloc_queue() local
571 struct vmci_queue *queue = q; in vmci_free_queue() local
817 __vmci_memcpy_to_queue(struct vmci_queue *queue, uint64_t queue_offset, in __vmci_memcpy_to_queue()
874 __vmci_memcpy_from_queue(void *dest, const struct vmci_queue *queue, in __vmci_memcpy_from_queue()
931 vmci_memcpy_to_queue(struct vmci_queue *queue, uint64_t queue_offset, in vmci_memcpy_to_queue()
960 const struct vmci_queue *queue, uint64_t queue_offset, size_t size, in vmci_memcpy_from_queue()
988 vmci_memcpy_to_queue_local(struct vmci_queue *queue, uint64_t queue_offset, in vmci_memcpy_to_queue_local()
1017 const struct vmci_queue *queue, uint64_t queue_offset, size_t size, in vmci_memcpy_from_queue_local()
1043 vmci_memcpy_to_queue_v(struct vmci_queue *queue, uint64_t queue_offset, in vmci_memcpy_to_queue_v()
1076 const struct vmci_queue *queue, uint64_t queue_offset, size_t size, in vmci_memcpy_from_queue_v()
HDvmci_queue.h96 vmci_memcpy_to_queue_v_local(struct vmci_queue *queue, uint64_t queue_offset, in vmci_memcpy_to_queue_v_local()
107 const struct vmci_queue *queue, uint64_t queue_offset, size_t size, in vmci_memcpy_from_queue_v_local()
/freebsd-13-stable/sys/cam/
HDcam_queue.c83 camq_fini(struct camq *queue) in camq_fini()
96 camq_resize(struct camq *queue, int new_size) in camq_resize()
131 camq_insert(struct camq *queue, cam_pinfo *new_entry) in camq_insert()
151 camq_remove(struct camq *queue, int index) in camq_remove()
178 camq_change_priority(struct camq *queue, int index, u_int32_t new_priority) in camq_change_priority()
HDcam_queue.h61 struct camq queue; member
184 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
211 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
/freebsd-13-stable/sys/contrib/ck/src/
HDck_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
/freebsd-13-stable/tools/tools/net80211/w00t/expand/
HDexpand.c49 struct queue { struct
55 struct queue *next; argument
/freebsd-13-stable/sys/contrib/dev/iwlwifi/mvm/
HDrxmq.c18 int queue, struct ieee80211_sta *sta) in iwl_mvm_check_pn()
241 struct sk_buff *skb, int queue, in iwl_mvm_pass_packet_to_mac80211()
369 u32 pkt_flags, int queue, u8 *crypt_len) in iwl_mvm_rx_crypto()
506 static bool iwl_mvm_is_dup(struct ieee80211_sta *sta, int queue, in iwl_mvm_is_dup()
748 static void iwl_mvm_del_ba(struct iwl_mvm *mvm, int queue, in iwl_mvm_del_ba()
789 u8 baid, u16 nssn, int queue, in iwl_mvm_release_frames_from_notif()
831 struct napi_struct *napi, int queue, in iwl_mvm_nssn_sync()
840 struct iwl_rx_cmd_buffer *rxb, int queue) in iwl_mvm_rx_queue_notif()
897 u32 reorder, u32 gp2, int queue) in iwl_mvm_oldsn_workaround()
949 int queue, in iwl_mvm_reorder()
[all …]
HDsta.c306 static int iwl_mvm_invalidate_sta_queue(struct iwl_mvm *mvm, int queue, in iwl_mvm_invalidate_sta_queue()
357 int queue = *queueptr; in iwl_mvm_disable_txq() local
447 static int iwl_mvm_get_queue_agg_tids(struct iwl_mvm *mvm, int queue) in iwl_mvm_get_queue_agg_tids()
487 static int iwl_mvm_remove_sta_queue_marking(struct iwl_mvm *mvm, int queue) in iwl_mvm_remove_sta_queue_marking()
550 static int iwl_mvm_free_inactive_queue(struct iwl_mvm *mvm, int queue, in iwl_mvm_free_inactive_queue()
600 int queue = 0; in iwl_mvm_get_shared_queue() local
666 static int iwl_mvm_reconfig_scd(struct iwl_mvm *mvm, int queue, int fifo, in iwl_mvm_reconfig_scd()
704 static int iwl_mvm_redirect_queue(struct iwl_mvm *mvm, int queue, int tid, in iwl_mvm_redirect_queue()
852 int queue, size; in iwl_mvm_tvqm_enable_txq() local
921 int queue = -1; in iwl_mvm_sta_alloc_queue_tvqm() local
[all …]
/freebsd-13-stable/tools/tools/net80211/w00t/redir/
HDredir.c50 struct queue { struct
57 struct queue *next; argument
/freebsd-13-stable/sys/contrib/dev/iwlwifi/
HDiwl-op-mode.h145 unsigned int queue) in iwl_op_mode_rx_rss()
158 int queue) in iwl_op_mode_queue_full()
164 int queue) in iwl_op_mode_queue_not_full()

123456789