| /src/sys/arm/broadcom/bcm2835/ |
| H A D | bcm2835_intr.c | 164 uint32_t pending, pending_gpu; in bcm2835_intc_active_intr() local
166 pending = intc_read_4(sc, INTC_PENDING_BASIC) & INTC_PENDING_BASIC_MASK; in bcm2835_intc_active_intr()
167 if (pending == 0) in bcm2835_intc_active_intr()
169 if (pending & INTC_PENDING_BASIC_ARM) in bcm2835_intc_active_intr()
170 return (ffs(pending) - 1); in bcm2835_intc_active_intr()
171 if (pending & INTC_PENDING_BASIC_GPU1_MASK) { in bcm2835_intc_active_intr()
172 if (pending & INTC_PENDING_BASIC_GPU1_7) in bcm2835_intc_active_intr()
174 if (pending & INTC_PENDING_BASIC_GPU1_9) in bcm2835_intc_active_intr()
176 if (pending & INTC_PENDING_BASIC_GPU1_10) in bcm2835_intc_active_intr()
178 if (pending & INTC_PENDING_BASIC_GPU1_18) in bcm2835_intc_active_intr()
[all …]
|
| /src/tests/sys/aio/ |
| H A D | aio_kqueue_test.c | 68 int failed = 0, fd, kq, pending, result, run; in main() local
111 pending = 0; in main()
113 pending++; in main()
142 pending--; in main()
148 cancel = max_queue_per_proc - pending; in main()
152 while (pending) { in main()
188 pending, max_queue_per_proc, cancel); in main()
199 j, result, pending); in main()
207 " (errno=%d) should be %zu\n", run, pending, in main()
212 pending - 1); in main()
[all …]
|
| /src/contrib/sendmail/contrib/ |
| H A D | cidrexpand | 106 my %pending;
156 if (%pending && m!^(.+?)${space_re}!)
158 delete $pending{$opts{f} ? $1 : lc($1)};
163 print foreach values %pending;
177 $pending{"$fp$nl"} = $val;
205 $pending{"$fp$nl"} = $val;
|
| /src/crypto/krb5/src/ccapi/server/ |
| H A D | ccs_callback.c | 29 cc_int32 pending; member
108 if (io_callback->pending) { in ccs_callback_release()
112 io_callback->pending = 0; in ccs_callback_release()
143 io_callback->pending = 0; /* client is dead, don't try to talk to it */ in ccs_callback_invalidate()
165 if (io_callback->pending) { in ccs_callback_reply_to_client()
175 io_callback->pending = 0; in ccs_callback_reply_to_client()
196 *out_pending = in_callback->pending; in ccs_callback_is_pending()
|
| /src/contrib/unbound/services/ |
| H A D | outside_network.h | 51 struct pending;
130 struct pending* udp_wait_first;
132 struct pending* udp_wait_last;
135 rbtree_type* pending; member
279 struct pending_tcp* pending; member
312 struct pending { struct
338 struct pending* next_waiting; argument
518 void* pending; member
597 struct pending* pending_udp_query(struct serviced_query* sq,
623 void pending_delete(struct outside_network* outnet, struct pending* p);
|
| H A D | outside_network.c | 86 static int randomize_and_send_udp(struct pending* pend, sldns_buffer* packet,
106 struct pending *p1 = (struct pending*)key1; in pending_cmp()
107 struct pending *p2 = (struct pending*)key2; in pending_cmp()
376 if(!reuse || !reuse->pending || !reuse->pending->c)
381 reuse->pending->c->fd);
500 pend_tcp->reuse.pending = pend_tcp;
546 key_p.reuse.pending = &key_p;
565 log_assert(&key_p != ((struct reuse_tcp*)result)->pending);
772 pend->reuse.pending = pend;
980 pend_tcp = reuse->pending;
[all …]
|
| /src/sys/dev/nvmf/host/ |
| H A D | nvmf_aer.c | 27 int pending; member
89 nvmf_finish_aer_page_task(void *arg, int pending) in nvmf_finish_aer_page_task() argument
115 aer->pending--; in nvmf_io_complete_aer_page()
116 if (aer->pending == 0) { in nvmf_io_complete_aer_page()
131 aer->pending--; in nvmf_complete_aer_page()
132 if (aer->pending == 0) { in nvmf_complete_aer_page()
188 nvmf_complete_aer_task(void *arg, int pending) in nvmf_complete_aer_task() argument
196 aer->pending = 2; in nvmf_complete_aer_task()
|
| /src/crypto/openssl/doc/man3/ |
| H A D | DTLSv1_handle_timeout.pod | 5 DTLSv1_handle_timeout - handle a pending timeout event for a DTLS or QUIC SSL
16 DTLSv1_handle_timeout() handles any timeout events which have become pending
30 Returns 1 if there was a pending timeout event and it was handled successfully.
32 Returns 0 if there was no pending timeout event, or if the SSL object is not a
35 Returns -1 if there was a pending timeout event but it could not be handled
|
| /src/sys/dev/cxgbe/ |
| H A D | t4_clip.c | 83 bool pending; /* in clip_pending list */ member
207 ce->pending = true; in lookup_clip_entry()
264 if (++ce->refcount == 1 && ce->pending && ce->clip_idx != -1) { in t4_get_clip_entry()
270 ce->pending = false; in t4_get_clip_entry()
312 MPASS(ce->pending); in release_clip_entry_locked()
326 MPASS(!ce->pending); in release_clip_entry_locked()
328 ce->pending = true; in release_clip_entry_locked()
510 ce->pending = false; in update_sw_clip_table()
513 MPASS(ce->pending); in update_sw_clip_table()
525 ce->pending = true; in update_sw_clip_table()
[all …]
|
| /src/sys/riscv/vmm/ |
| H A D | vmm_fence.c | 127 int pending; in vmm_fence_process() local
129 pending = atomic_readandclear_32(&hypctx->fence_req); in vmm_fence_process()
131 KASSERT((pending & ~(FENCE_REQ_I | FENCE_REQ_VMA)) == 0, in vmm_fence_process()
134 if (pending & FENCE_REQ_I) in vmm_fence_process()
137 if (pending & FENCE_REQ_VMA) in vmm_fence_process()
|
| /src/sys/contrib/zlib/ |
| H A D | deflate.c | 656 s->pending = 0; in deflateResetKeep()
722 int ZEXPORT deflatePending(z_streamp strm, unsigned *pending, int *bits) { in deflatePending() argument
726 if (pending != Z_NULL) { in deflatePending()
727 *pending = (unsigned)strm->state->pending; in deflatePending()
728 if (*pending != strm->state->pending) { in deflatePending()
729 *pending = (unsigned)-1; in deflatePending()
955 len = s->pending > strm->avail_out ? strm->avail_out : in flush_pending()
956 (unsigned)s->pending; in flush_pending()
964 s->pending -= len; in flush_pending()
965 if (s->pending == 0) { in flush_pending()
[all …]
|
| /src/sys/cam/ |
| H A D | cam_iosched.c | 261 int pending; /* I/Os pending in the hardware */ member
438 if (ios->current <= 0 || ios->pending < ios->current) in cam_iosched_qd_iop()
448 if (ios->current <= 0 || ios->pending < ios->current) in cam_iosched_qd_caniop()
458 if (ios->current <= 0 || ios->pending != ios->current) in cam_iosched_qd_iodone()
610 int pending; in cam_iosched_ticker() local
648 pending = isc->read_stats.pending + isc->write_stats.pending /* + isc->trim_stats.pending */; in cam_iosched_ticker()
649 pending += !!(isc->read_stats.state_flags & IOP_RATE_LIMITED) * isc->read_stats.queued + in cam_iosched_ticker()
652 pending <<= 16; in cam_iosched_ticker()
653 pending /= isc->periph->path->device->ccbq.total_openings; in cam_iosched_ticker()
655 …isc->load = (pending + (isc->load << 13) - isc->load) >> 13; /* see above: 13 -> 16139 / 200/s = ~… in cam_iosched_ticker()
[all …]
|
| /src/sys/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()
|
| /src/usr.sbin/bluetooth/btpand/ |
| H A D | event.c | 54 TAILQ_INSERT_TAIL(&pending, ev, next); \
66 static TAILQ_HEAD(, event) pending;
72 TAILQ_INIT(&pending); in event_init()
110 while (!TAILQ_EMPTY(&pending)) { in __event_dispatch()
111 ev = TAILQ_FIRST(&pending); in __event_dispatch()
245 TAILQ_REMOVE(&pending, ev, next); in __event_del()
|
| /src/sys/net/ |
| H A D | mp_ring.c | 96 int n, pending, total; in drain_ring_locked() local
105 pending = 0; in drain_ring_locked()
125 pending += n; in drain_ring_locked()
133 if (cidx != pidx && pending < 64 && total < budget) in drain_ring_locked()
158 pending = 0; in drain_ring_locked()
170 int n, pending, total; in drain_ring_lockless() local
179 pending = 0; in drain_ring_lockless()
204 pending += n; in drain_ring_lockless()
212 if (cidx != pidx && pending < 64 && total < budget) in drain_ring_lockless()
241 pending = 0; in drain_ring_lockless()
|
| /src/usr.sbin/ypserv/ |
| H A D | yp_dnslookup.c | 126 static int pending = 0; variable
328 pending--; in yp_prune_dnsq()
333 if (pending < 0) in yp_prune_dnsq()
334 pending = 0; in yp_prune_dnsq()
374 if (!pending || in yp_run_dnsq()
395 pending--; in yp_run_dnsq()
450 pending++; in yp_async_lookup_name()
538 pending++; in yp_async_lookup_addr()
|
| /src/sys/contrib/ncsw/Peripherals/FM/ |
| H A D | fm_ncsw.c | 537 static void GuestErrorIsr(t_Fm *p_Fm, uint32_t pending) in GuestErrorIsr() argument
549 if (pending & ERR_INTR_EN_1G_MAC0) in GuestErrorIsr()
551 if (pending & ERR_INTR_EN_1G_MAC1) in GuestErrorIsr()
553 if (pending & ERR_INTR_EN_1G_MAC2) in GuestErrorIsr()
555 if (pending & ERR_INTR_EN_1G_MAC3) in GuestErrorIsr()
557 if (pending & ERR_INTR_EN_1G_MAC4) in GuestErrorIsr()
559 if (pending & ERR_INTR_EN_1G_MAC5) in GuestErrorIsr()
561 if (pending & ERR_INTR_EN_1G_MAC6) in GuestErrorIsr()
563 if (pending & ERR_INTR_EN_1G_MAC7) in GuestErrorIsr()
565 if (pending & ERR_INTR_EN_10G_MAC0) in GuestErrorIsr()
[all …]
|
| /src/lib/libproc/ |
| H A D | proc_util.c | 64 int pending; in proc_continue() local
70 pending = WSTOPSIG(phdl->wstat); in proc_continue()
72 pending = 0; in proc_continue()
74 pending) != 0) in proc_continue()
|
| /src/sys/kern/ |
| H A D | vfs_inotify.c | 166 STAILQ_HEAD(, inotify_record) pending; /* events waiting to be read */
185 KASSERT(!STAILQ_EMPTY(&sc->pending), in inotify_dequeue()
188 rec = STAILQ_FIRST(&sc->pending); in inotify_dequeue()
189 STAILQ_REMOVE_HEAD(&sc->pending, link); in inotify_dequeue()
201 STAILQ_INSERT_HEAD(&sc->pending, rec, link); in inotify_enqueue()
203 STAILQ_INSERT_TAIL(&sc->pending, rec, link); in inotify_enqueue()
221 while (STAILQ_EMPTY(&sc->pending)) { in inotify_read()
226 error = msleep(&sc->pending, &sc->lock, PCATCH, "inotify", 0); in inotify_read()
232 for (first = true; !STAILQ_EMPTY(&sc->pending); first = false) { in inotify_read()
414 inotify_reap(void *arg, int pending) in inotify_reap() argument
[all …]
|
| /src/contrib/xz/src/liblzma/lz/ |
| H A D | lz_encoder.c | 137 if (coder->mf.pending > 0 in fill_window()
141 const uint32_t pending = coder->mf.pending; in fill_window() local
142 coder->mf.pending = 0; in fill_window()
146 assert(coder->mf.read_pos >= pending); in fill_window()
147 coder->mf.read_pos -= pending; in fill_window()
151 coder->mf.skip(&coder->mf, pending); in fill_window()
400 mf->pending = 0; in lz_encoder_init()
|
| /src/sys/dev/ena/ |
| H A D | ena_datapath.h | 35 void ena_cleanup(void *arg, int pending);
38 void ena_deferred_mq_start(void *arg, int pending);
|
| /src/sys/compat/linuxkpi/common/include/linux/ |
| H A D | kthread.h | 144 u_int pending = 0; in kthread_cancel_work_sync() local
147 taskqueue_cancel(work->tq, &work->task, &pending) != 0) in kthread_cancel_work_sync()
150 return (pending != 0); in kthread_cancel_work_sync()
|
| /src/sys/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()
|
| /src/sys/dev/bhnd/nvram/ |
| H A D | bhnd_nvram_store_subr.c | 86 path->pending = bhnd_nvram_plist_new(); in bhnd_nvstore_path_new()
87 if (path->pending == NULL) in bhnd_nvstore_path_new()
97 if (path->pending != NULL) in bhnd_nvstore_path_new()
98 bhnd_nvram_plist_release(path->pending); in bhnd_nvstore_path_new()
118 bhnd_nvram_plist_release(path->pending); in bhnd_nvstore_path_free()
305 return (bhnd_nvram_plist_get_prop(path->pending, name)); in bhnd_nvstore_path_get_update()
404 bhnd_nvram_plist_remove(path->pending, name); in bhnd_nvstore_path_register_update()
407 error = bhnd_nvram_plist_replace_val(path->pending, name, in bhnd_nvstore_path_register_update()
|
| /src/sys/arm64/spe/ |
| H A D | arm_spe_dev.c | 117 STAILQ_INIT(&sc->pending); in arm_spe_attach()
270 arm_spe_send_buffer(void *arg, int pending __unused) in arm_spe_send_buffer()
292 STAILQ_INSERT_TAIL(&info->sc->pending, queue, next); in arm_spe_send_buffer()
308 arm_spe_error(void *arg, int pending __unused) in arm_spe_error()
|