| /dports/net/oha/oha-0.4.7/cargo-crates/tokio-1.12.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/www/zola/zola-0.15.2/cargo-crates/tokio-1.14.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/textproc/mdbook-linkcheck/mdbook-linkcheck-0.7.6/cargo-crates/tokio-1.13.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/tokio-1.10.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/www/xh/xh-0.14.1/cargo-crates/tokio-1.11.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/tokio-1.11.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/tokio-1.12.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tokio/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/tokio-1.14.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/devel/sentry-cli/sentry-cli-1.71.0/cargo-crates/tokio-1.13.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/www/monolith/monolith-2.6.1/cargo-crates/tokio-1.8.0/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/devel/py-maturin/maturin-0.11.3/cargo-crates/tokio-1.10.1/tests/ |
| H A D | tcp_accept.rs | 52 npolls: Arc<AtomicUsize>, field
60 self.npolls.fetch_add(1, SeqCst); in poll_next()
75 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll() localVariable
88 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
94 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/tokio-1.16.1/tests/ |
| H A D | rt_basic.rs | 60 npolls: Arc<AtomicUsize>, in no_extra_poll()
73 this.npolls.fetch_add(1, SeqCst); in no_extra_poll()
80 npolls: Arc::new(AtomicUsize::new(0)), in no_extra_poll()
83 let npolls = Arc::clone(&rx.npolls); in no_extra_poll() localVariable
96 assert_eq!(npolls.load(SeqCst), 1); in no_extra_poll()
104 assert_eq!(npolls.load(SeqCst), 1 + 2); in no_extra_poll()
112 assert_eq!(npolls.load(SeqCst), 1 + 2 + 1); in no_extra_poll()
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/scif/ |
| H A D | scifsm.c | 157 static int npolls = 0; in MPID_nem_scif_connpoll() local
176 if (npolls >= NPOLLS) { in MPID_nem_scif_connpoll()
187 if (npolls++ >= NPOLLS) in MPID_nem_scif_connpoll()
188 npolls = 0; in MPID_nem_scif_connpoll()
|
| /dports/mail/isync/isync-1.4.4/src/ |
| H A D | util.c | 670 static uint npolls, rpolls; variable
681 uint idx = npolls++; in init_notifier()
682 if (rpolls < npolls) { in init_notifier()
683 rpolls = npolls; in init_notifier()
684 pollfds = nfrealloc( pollfds, npolls * sizeof(*pollfds) ); in init_notifier()
736 memmove( pollfds + idx, pollfds + idx + 1, (--npolls - idx) * sizeof(*pollfds) ); in wipe_notifier()
818 switch (poll( pollfds, npolls, timeout )) { in event_wait()
|
| /dports/net/rtpproxy/rtpproxy-2.1.1/pertools/udp_contention/ |
| H A D | udp_contention.c | 95 uint64_t npolls; member
378 rp->npolls++; in process_recvset()
509 poll_rate = ((double)rsp[i]->npolls) / tduration; in run_test()
|
| /dports/science/nwchem/nwchem-7b21660b82ebd85ef659f6fba7e1e73433b0bd0a/src/smd/smd-scheduler/ |
| H A D | sched_groups.c | 641 static int npolls=0, nwaits=0, npoll_loops=0; variable
645 int FATR sched_grp_npolls_() { return npolls; } in sched_grp_npolls_()
673 npolls = nwaits=npoll_loops=0; in sched_grp_reset_times_()
1810 npolls+=1; in full_poll_loop()
|
| /dports/science/nwchem/nwchem-7b21660b82ebd85ef659f6fba7e1e73433b0bd0a/src/smd/graveyard/smd-9-10-08/ |
| H A D | sched_groups.c | 641 static int npolls=0, nwaits=0, npoll_loops=0; variable
645 int FATR sched_grp_npolls_() { return npolls; } in sched_grp_npolls_()
673 npolls = nwaits=npoll_loops=0; in sched_grp_reset_times_()
1810 npolls+=1; in full_poll_loop()
|
| /dports/science/nwchem-data/nwchem-7.0.2-release/src/smd/graveyard/smd-9-10-08/ |
| H A D | sched_groups.c | 641 static int npolls=0, nwaits=0, npoll_loops=0; variable
645 int FATR sched_grp_npolls_() { return npolls; } in sched_grp_npolls_()
673 npolls = nwaits=npoll_loops=0; in sched_grp_reset_times_()
1810 npolls+=1; in full_poll_loop()
|
| /dports/science/nwchem-data/nwchem-7.0.2-release/src/smd/smd-scheduler/ |
| H A D | sched_groups.c | 641 static int npolls=0, nwaits=0, npoll_loops=0; variable
645 int FATR sched_grp_npolls_() { return npolls; } in sched_grp_npolls_()
673 npolls = nwaits=npoll_loops=0; in sched_grp_reset_times_()
1810 npolls+=1; in full_poll_loop()
|