/dports/devel/boost-docs/boost_1_72_0/libs/mpi/test/python/ |
H A D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 34 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 D | nonblocking_test.py | 32 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 D | index.php | 11 $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 D | 02_parts.t | 21 $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 D | dns_multiplexer.rs | 127 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 D | dns_multiplexer.rs | 127 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 D | dns_multiplexer.rs | 127 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 D | dns_multiplexer.rs | 126 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 D | PeerNATTraverser.java | 97 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 D | hiredis_pipeline.c | 47 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 D | test_state.py | 19 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 D | dce_smb2_tree.cc | 83 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 D | state.py | 51 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 D | heartbeat.py | 12 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 D | coll_libnbc_component.c | 94 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 D | server.py | 148 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 D | server.py | 166 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 D | extra.c | 108 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()
|