Home
last modified time | relevance | path

Searched refs:active_requests (Results 1 – 25 of 131) sorted by relevance

123456

/dports/devel/boost-docs/boost_1_72_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/devel/boost-python-libs/boost_1_72_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/databases/percona57-server/boost_1_59_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/databases/xtrabackup/boost_1_59_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/databases/percona57-client/boost_1_59_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/devel/boost-libs/boost_1_72_0/libs/mpi/test/python/
H A Dnonblocking_test.py34 self.active_requests = {}
38 if tag not in self.active_requests:
39 self.active_requests[tag] = self.comm.irecv(tag=tag)
40 requests = mpi.RequestList(self.active_requests.values())
42 del self.active_requests[status.tag]
46 for r in self.active_requests.itervalues():
49 self.active_requests = {}
/dports/devel/hyperscan/boost_1_75_0/libs/mpi/test/python/
H A Dnonblocking_test.py32 self.active_requests = {}
36 if tag not in self.active_requests:
37 self.active_requests[tag] = self.comm.irecv(tag=tag)
38 requests = mpi.RequestList(self.active_requests.values())
40 del self.active_requests[status.tag]
44 for r in self.active_requests.itervalues():
47 self.active_requests = {}
/dports/net-mgmt/phpipam/phpipam-a14bc06/app/admin/requests/
H A Dindex.php11 $active_requests = $Tools->fetch_multiple_objects ("requests", "processed", 0, "id", false); variable
20 if($active_requests===false) { print "<div class='alert alert-info'>"._('No IP address requests ava…
41 foreach($active_requests as $k=>$request) {
48 unset($active_requests[$k]);
/dports/www/p5-Gungho/Gungho-0.09008/t/plugin/statistics/
H A D02_parts.t21 $storage->incr("active_requests");
24 is($storage->get("active_requests"), 10);
27 $storage->decr("active_requests");
31 is($storage->get("active_requests"), 5);
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/trust-dns-proto-0.20.3/src/xfer/
H A Ddns_multiplexer.rs127 active_requests: HashMap<u16, ActiveRequest>, field
188 for (&id, ref mut active_req) in &mut self.active_requests { in drop_cancelled()
205 if let Some(active_request) = self.active_requests.remove(&id) { in drop_cancelled()
224 if !self.active_requests.contains_key(&id) { in next_random_query_id()
236 if !self.active_requests.is_empty() { in stream_closed_close_all()
242 for (_, active_request) in self.active_requests.drain() { in stream_closed_close_all()
286 active_requests: HashMap::new(), in poll()
313 if self.active_requests.len() > CHANNEL_BUFFER_SIZE { in send_message()
361 .active_requests in send_message()
400 if self.is_shutdown && self.active_requests.is_empty() { in poll_next()
[all …]
/dports/net/oha/oha-0.4.7/cargo-crates/trust-dns-proto-0.20.3/src/xfer/
H A Ddns_multiplexer.rs127 active_requests: HashMap<u16, ActiveRequest>, field
188 for (&id, ref mut active_req) in &mut self.active_requests { in drop_cancelled()
205 if let Some(active_request) = self.active_requests.remove(&id) { in drop_cancelled()
224 if !self.active_requests.contains_key(&id) { in next_random_query_id()
236 if !self.active_requests.is_empty() { in stream_closed_close_all()
242 for (_, active_request) in self.active_requests.drain() { in stream_closed_close_all()
286 active_requests: HashMap::new(), in poll()
313 if self.active_requests.len() > CHANNEL_BUFFER_SIZE { in send_message()
361 .active_requests in send_message()
400 if self.is_shutdown && self.active_requests.is_empty() { in poll_next()
[all …]
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/trust-dns-proto-0.19.5/src/xfer/
H A Ddns_multiplexer.rs127 active_requests: HashMap<u16, ActiveRequest>, field
188 for (&id, ref mut active_req) in &mut self.active_requests { in drop_cancelled()
205 if let Some(active_request) = self.active_requests.remove(&id) { in drop_cancelled()
224 if !self.active_requests.contains_key(&id) { in next_random_query_id()
235 if !self.active_requests.is_empty() { in stream_closed_close_all()
244 for (_, active_request) in self.active_requests.drain() { in stream_closed_close_all()
288 active_requests: HashMap::new(), in poll()
375 .active_requests in send_message()
418 if self.is_shutdown && self.active_requests.is_empty() { in poll_next()
434 Ok(message) => match self.active_requests.entry(message.id()) { in poll_next()
/dports/net/proby/proby-1.0.2/cargo-crates/trust-dns-proto-0.18.0-alpha.2/src/xfer/
H A Ddns_multiplexer.rs126 active_requests: HashMap<u16, ActiveRequest>, field
187 for (&id, ref mut active_req) in &mut self.active_requests { in drop_cancelled()
204 if let Some(active_request) = self.active_requests.remove(&id) { in drop_cancelled()
223 if !self.active_requests.contains_key(&id) { in next_random_query_id()
234 if !self.active_requests.is_empty() { in stream_closed_close_all()
243 for (_, active_request) in self.active_requests.drain() { in stream_closed_close_all()
287 active_requests: HashMap::new(), in poll()
369 .active_requests in send_message()
412 if self.is_shutdown && self.active_requests.is_empty() { in poll_next()
428 Ok(message) => match self.active_requests.entry(message.id()) { in poll_next()
/dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/peermanager/nat/
H A DPeerNATTraverser.java97 private List active_requests = new ArrayList(); field in PeerNATTraverser
155 "NAT traversal stats: active=" + active_requests.size() + in PeerNATTraverser()
169 for (int i=0;i<active_requests.size();i++){ in PeerNATTraverser()
171 used += ((PeerNATTraversal)active_requests.get(i)).getTimeUsed(); in PeerNATTraverser()
188 active_requests.size() >= MAX_ACTIVE_REQUESTS ){ in PeerNATTraverser()
197 active_requests.add( traversal ); in PeerNATTraverser()
393 if ( active_requests.remove( request )){ in removeRequest()
/dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/applications/mod_hiredis/
H A Dhiredis_pipeline.c47 while ( profile->pipeline_running || switch_queue_size(profile->active_requests) > 0 ) { in pipeline_thread()
49 …if ( switch_queue_pop_timeout(profile->active_requests, &val, 500 * 1000) == SWITCH_STATUS_SUCCESS… in pipeline_thread()
56 if ( switch_queue_trypop(profile->active_requests, &val) == SWITCH_STATUS_SUCCESS && val ) { in pipeline_thread()
114 switch_queue_interrupt_all(profile->active_requests); in hiredis_pipeline_threads_stop()
131 …if ( profile->pipeline_running && switch_queue_trypush(profile->active_requests, request) == SWITC… in hiredis_profile_execute_pipeline_request()
/dports/devel/py-celery/celery-4.4.7/t/unit/worker/
H A Dtest_state.py19 state.active_requests.clear()
179 assert req in state.active_requests
188 assert len(state.active_requests) == 2
191 assert len(state.active_requests) == 0
/dports/security/snort3/snort3-3.1.19.0/src/service_inspectors/dce_rpc/
H A Ddce_smb2_tree.cc83 auto request_it = active_requests.find(message_key); in find_request()
84 return (request_it == active_requests.end()) ? nullptr : request_it->second; in find_request()
92 auto request_it = active_requests.find(message_key); in remove_request()
93 if (request_it != active_requests.end()) in remove_request()
96 return active_requests.erase(message_key); in remove_request()
444 size_t pending_requests = active_requests.size(); in process()
547 if (active_requests.size()) in ~Dce2Smb2TreeTracker()
554 for (auto it_request : active_requests) in ~Dce2Smb2TreeTracker()
/dports/devel/py-celery/celery-4.4.7/celery/worker/
H A Dstate.py51 active_requests = weakref.WeakSet() variable
69 active_requests.clear()
93 add_active_request=active_requests.add,
105 discard_active_request=active_requests.discard,
H A Dheartbeat.py12 from .state import SOFTWARE_INFO, active_requests, all_total_count
46 active=len(active_requests),
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/libnbc/
H A Dcoll_libnbc_component.c94 OBJ_CONSTRUCT(&mca_coll_libnbc_component.active_requests, opal_list_t); in libnbc_open()
117 OBJ_DESTRUCT(&mca_coll_libnbc_component.active_requests); in libnbc_close()
272 OPAL_LIST_FOREACH_SAFE(request, next, &mca_coll_libnbc_component.active_requests, in ompi_coll_libnbc_progress()
279 opal_list_remove_item(&mca_coll_libnbc_component.active_requests, in ompi_coll_libnbc_progress()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/py3lite/test/
H A Dserver.py148 active_requests = server.get_active_requests()
149 self.assertGreaterEqual(active_requests, 0)
150 self.assertLess(active_requests, 10)
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/py3/test/
H A Dserver.py166 active_requests = server.get_active_requests()
167 self.assertGreaterEqual(active_requests, 0)
168 self.assertLess(active_requests, 10)
/dports/games/augustus/augustus-3.1.0/src/widget/sidebar/
H A Dextra.c108 int active_requests; member
318 int new_requests = update_extra_info_value(count_active_requests(), &data.active_requests); in update_extra_info()
328 int other_requests = data.active_requests - troop_requests; in update_extra_info()
404 if (data.visible_requests < data.active_requests && i == data.visible_requests - 1) { in draw_request_buttons()
586 if (data.active_requests == 0) { in draw_extra_info_panel()
622 if (data.info_to_display & SIDEBAR_EXTRA_DISPLAY_REQUESTS && data.active_requests) { in draw_extra_info_buttons()
682 if (data.active_requests > data.visible_requests && index == data.visible_requests - 1) { in button_handle_request()

123456