Home
last modified time | relevance | path

Searched refs:pending_requests (Results 1 – 25 of 229) sorted by relevance

12345678910

/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/sender/
H A Dcast_platform_client.cc72 pending_requests.availability.push_back(AvailabilityRequest{ in RequestAppAvailability()
109 auto& pending_requests = entry->second; in CancelRequest() local
115 if (it != pending_requests.availability.end()) { in CancelRequest()
116 pending_requests.availability.erase(it); in CancelRequest()
160 PendingRequests& pending_requests = entry->second; in HandleResponse() local
162 pending_requests.availability.end(), in HandleResponse()
166 if (it != pending_requests.availability.end()) { in HandleResponse()
188 pending_requests.availability.erase(it); in HandleResponse()
194 PendingRequests& pending_requests = entry.second; in CancelAppAvailabilityRequest() local
200 if (it != pending_requests.availability.end()) { in CancelAppAvailabilityRequest()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/sender/
H A Dcast_platform_client.cc81 pending_requests.availability.push_back(AvailabilityRequest{ in RequestAppAvailability()
118 auto& pending_requests = entry->second; in CancelRequest() local
124 if (it != pending_requests.availability.end()) { in CancelRequest()
125 pending_requests.availability.erase(it); in CancelRequest()
168 PendingRequests& pending_requests = entry->second; in HandleResponse() local
170 pending_requests.availability.end(), in HandleResponse()
174 if (it != pending_requests.availability.end()) { in HandleResponse()
196 pending_requests.availability.erase(it); in HandleResponse()
202 PendingRequests& pending_requests = entry.second; in CancelAppAvailabilityRequest() local
208 if (it != pending_requests.availability.end()) { in CancelAppAvailabilityRequest()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/ui/views/
H A Darc_app_dialog_view_browsertest.cc271 const auto& pending_requests = in IN_PROC_BROWSER_TEST_F() local
273 EXPECT_EQ(3u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
284 EXPECT_EQ(2u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
295 EXPECT_EQ(0u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
338 const auto& pending_requests = in IN_PROC_BROWSER_TEST_F() local
340 EXPECT_EQ(2u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
347 EXPECT_EQ(1u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
356 EXPECT_EQ(0u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
389 const auto& pending_requests = in IN_PROC_BROWSER_TEST_F() local
391 EXPECT_EQ(1u, pending_requests.size()); in IN_PROC_BROWSER_TEST_F()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/web_applications/components/
H A Dweb_app_icon_downloader_unittest.cc127 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
130 EXPECT_EQ(1u, downloader.pending_requests()); in TEST_F()
134 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
151 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
154 EXPECT_EQ(1u, downloader.pending_requests()); in TEST_F()
159 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
176 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
180 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
183 EXPECT_EQ(1u, downloader.pending_requests()); in TEST_F()
187 EXPECT_EQ(0u, downloader.pending_requests()); in TEST_F()
[all …]
/dports/mail/dovecot/dovecot-2.3.17/src/lib-imap-urlauth/
H A Dimap-urlauth-fetch.c35 unsigned int pending_requests; member
61 ufetch->pending_requests--; in imap_urlauth_fetch_abort_local()
75 ufetch->pending_requests--; in imap_urlauth_fetch_abort_local()
150 ufetch->pending_requests--; in imap_urlauth_fetch_error()
165 ufetch->pending_requests++; in imap_urlauth_fetch_error()
255 ufetch->pending_requests--; in imap_urlauth_fetch_local()
281 ufetch->pending_requests++; in imap_urlauth_fetch_local()
318 ufetch->pending_requests--; in imap_urlauth_fetch_request_callback()
334 ufetch->pending_requests++; in imap_urlauth_fetch_request_callback()
376 ufetch->pending_requests++; in imap_urlauth_fetch_url_parsed()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/base/
H A Dprotobuf_http_test_responder.cc102 test_url_loader_factory_.pending_requests()->rbegin(), in GetRequestMessage()
103 test_url_loader_factory_.pending_requests()->rend(), in GetRequestMessage()
108 test_url_loader_factory_.pending_requests()->rend()) { in GetRequestMessage()
122 return test_url_loader_factory_.pending_requests()->size(); in GetNumPending()
128 DCHECK_LT(index, test_url_loader_factory_.pending_requests()->size()); in GetPendingRequest()
129 return (*test_url_loader_factory_.pending_requests())[index]; in GetPendingRequest()
135 DCHECK(!test_url_loader_factory_.pending_requests()->empty()); in GetMostRecentPendingRequest()
136 return test_url_loader_factory_.pending_requests()->back(); in GetMostRecentPendingRequest()
/dports/devel/p5-AnyEvent-Task/AnyEvent-Task-0.801/lib/AnyEvent/Task/Client/
H A DCheckout.pm30 $self->{pending_requests} = [];
78 push @{$self->{pending_requests}}, $request;
114 } elsif (@{$self->{pending_requests}}) {
115 $current_cb = $self->{pending_requests}->[0]->[-1];
120 $self->{pending_requests} = undef;
142 return unless @{$self->{pending_requests}};
144 my $request = shift @{$self->{pending_requests}};
222 …$self->{pending_requests} = $self->{current_cb} = $self->{timeout_timer} = $self->{cmd_handler} = …
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/proxy_resolution/
H A Dconfigured_proxy_resolution_service_unittest.cc404 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
601 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
722 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
911 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
1275 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
1298 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
1305 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
1353 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
2337 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
2447 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/proxy_resolution/
H A Dconfigured_proxy_resolution_service_unittest.cc368 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
568 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
691 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
884 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
1251 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
1274 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
1281 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
1330 ASSERT_EQ(1u, factory->pending_requests().size()); in TEST_F()
2336 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
2447 EXPECT_TRUE(factory->pending_requests().empty()); in TEST_F()
[all …]
/dports/www/p5-Gungho/Gungho-0.09008/lib/Gungho/Component/Throttle/
H A DProvider.pm19 $c->pending_requests( {} );
40 if (! $c->pending_requests->{ $request->id }) {
41 $c->pending_requests->{ $request->id } = $request;
54 if (delete $c->pending_requests->{ $request->id }) {
65 if (delete $c->pending_requests->{ $request->id }) {
/dports/www/p5-POE-Component-Client-HTTP/POE-Component-Client-HTTP-0.949/t/
H A D60_rt50231_pending.t59 pending_requests => 0,
87 $_[HEAP]->{pending_requests}++;
114 $heap->{pending_requests}--;
122 my $actual_pending = $heap->{pending_requests};
136 if ( $heap->{pending_requests} == 0 ) {
H A D60_rt50231_pending_many.t59 pending_requests => 0,
87 $_[HEAP]->{pending_requests}++;
114 $heap->{pending_requests}--;
122 my $actual_pending = $heap->{pending_requests};
141 if ( $heap->{pending_requests} == 0 ) {
/dports/net/rtpproxy/rtpproxy-2.1.1/python/sippy_lite/sippy/
H A DRtp_proxy_client_udp.py48 pending_requests = None variable in Rtp_proxy_client_udp
67 self.pending_requests = {}
95 …self.pending_requests[cookie] = (next_retr, nretr, timer, command, result_callback, stime, callbac…
98 …esleft, timer, command, result_callback, stime, callback_parameters = self.pending_requests[cookie]
101 del self.pending_requests[cookie]
111 …self.pending_requests[cookie] = (next_retr, triesleft, timer, command, result_callback, stime, cal…
119 parameters = self.pending_requests.pop(cookie, None)
/dports/net-im/pidgin-sipe/pidgin-sipe-1.24.0/src/core/
H A Dsipe-http-request.c112 struct sipe_http_request *req = conn_public->pending_requests->data; in sipe_http_request_send()
159 return(conn_public->pending_requests != NULL); in sipe_http_request_pending()
181 conn_public->pending_requests = g_slist_append(conn_public->pending_requests, in sipe_http_request_enqueue()
253 conn_public->pending_requests = g_slist_remove(conn_public->pending_requests, in sipe_http_request_response_redirection()
475 struct sipe_http_request *req = conn_public->pending_requests->data; in sipe_http_request_response()
524 if (conn_public->pending_requests) { in sipe_http_request_shutdown()
525 GSList *entry = conn_public->pending_requests; in sipe_http_request_shutdown()
550 g_slist_free(conn_public->pending_requests); in sipe_http_request_shutdown()
551 conn_public->pending_requests = NULL; in sipe_http_request_shutdown()
641 conn_public->pending_requests = g_slist_remove(conn_public->pending_requests, in sipe_http_request_cancel()
H A Dsipe-lync-autodiscover.c61 GSList *pending_requests; member
67 GSList *entry = sipe_private->lync_autodiscover->pending_requests; \
82 sla->pending_requests = g_slist_remove(sla->pending_requests, request); in sipe_lync_autodiscover_request_free()
464 sla->pending_requests = g_slist_prepend(sla->pending_requests, in sipe_lync_autodiscover_create()
499 while (sla->pending_requests) in sipe_lync_autodiscover_free()
501 sla->pending_requests->data); in sipe_lync_autodiscover_free()
H A Dsipe-svc.c64 GSList *pending_requests; member
93 if (svc->pending_requests) { in sipe_svc_free()
94 GSList *entry = svc->pending_requests; in sipe_svc_free()
99 g_slist_free(svc->pending_requests); in sipe_svc_free()
154 svc->pending_requests = g_slist_remove(svc->pending_requests, in sipe_svc_https_response()
221 svc->pending_requests = g_slist_prepend(svc->pending_requests, in sipe_svc_https_request()
/dports/net/py-pysmb/pysmb-1.1.27/python3/smb/
H A Dbase.py65 self.pending_requests = { } #: MID mapped to _PendingRequest instance
322 req = self.pending_requests.pop(message.mid, None)
331 req = self.pending_requests.pop(message.mid, None)
934 self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, infoCB, errback,
1655 … self.pending_requests[m.mid] = _PendingRequest(m.mid, int(time.time()) + timeout, echoCB, errback)
1778 req = self.pending_requests[message.mid]
1785 req = self.pending_requests.pop(message.mid, None)
1895 … self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, connectSrvSvcCB, errback)
2085 self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, findFirstCB, errback)
2238 … self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, dfsReferralCB, errback)
[all …]
/dports/net/py-pysmb/pysmb-1.1.27/python2/smb/
H A Dbase.py71 self.pending_requests = { } #: MID mapped to _PendingRequest instance
328 req = self.pending_requests.pop(message.mid, None)
337 req = self.pending_requests.pop(message.mid, None)
630 … self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, createCB, errback, tid = tid)
940 self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, infoCB, errback,
1659 … self.pending_requests[m.mid] = _PendingRequest(m.mid, int(time.time()) + timeout, echoCB, errback)
1782 req = self.pending_requests[message.mid]
1789 req = self.pending_requests.pop(message.mid, None)
1899 … self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, connectSrvSvcCB, errback)
2242 … self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, dfsReferralCB, errback)
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/media/kaleidoscope/
H A Dkaleidoscope_service_unittest.cc114 return url_loader_factory()->pending_requests()->front().request; in GetCurrentRequest()
158 EXPECT_TRUE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
171 EXPECT_FALSE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
201 EXPECT_TRUE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
230 EXPECT_FALSE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
259 EXPECT_FALSE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
309 EXPECT_TRUE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
340 EXPECT_TRUE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
367 EXPECT_TRUE(url_loader_factory()->pending_requests()->empty()); in TEST_F()
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/certificate_provider/
H A Dsign_requests.cc41 state.pending_requests.emplace( in AddRequest()
54 for (const auto& entry : extension_requests.pending_requests) { in FindRequestsForAuthenticatingUser()
72 std::map<int, Request>& pending = state.pending_requests; in RemoveRequest()
87 for (auto& entry : extension_to_requests_[extension_id].pending_requests) { in RemoveAllRequests()
/dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-client-transports/src/transports/
H A Dduplex.rs53 pending_requests: HashMap<Id, PendingRequest>, field
73 pending_requests: Default::default(), in new()
125 .pending_requests in poll()
144 .pending_requests in poll()
193 match self.pending_requests.remove(&id) { in poll()
304 && self.pending_requests.is_empty() in poll()
321 writeln!(f, "pending_requests: {}", self.pending_requests.len())?; in fmt()
/dports/net/belle-sip/belle-sip-1.6.3-0/src/
H A Dhttp-provider.c33 belle_sip_list_t *pending_requests; member
131 …belle_http_request_t *req=ctx->pending_requests ? (belle_http_request_t*) ctx->pending_requests->d… in http_channel_context_handle_response_headers()
159 ctx->pending_requests=belle_sip_list_pop_front(ctx->pending_requests,(void**)&req); in http_channel_context_handle_response()
197 if (ctx->pending_requests==NULL) elem=chan->outgoing_messages; in http_channel_context_handle_io_error()
198 else elem=ctx->pending_requests; in http_channel_context_handle_io_error()
256 ctx->pending_requests=belle_sip_list_append(ctx->pending_requests,belle_sip_object_ref(msg)); in channel_on_sending()
279 belle_sip_list_free_with_data(obj->pending_requests,belle_sip_object_unref); in belle_http_channel_context_uninit()
308 return obj->pending_requests != NULL; in belle_http_channel_is_busy()
/dports/net/pyrad/pyrad-2.4/pyrad/
H A Dclient_async.py29 self.pending_requests = {}
47 for id, req in self.pending_requests.items():
69 del self.pending_requests[id]
77 if packet.id in self.pending_requests:
81 self.pending_requests[packet.id] = {
124 if reply and reply.id in self.pending_requests:
125 req = self.pending_requests[reply.id]
134 del self.pending_requests[reply.id]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/nearby_sharing/local_device_data/
H A Dnearby_share_local_device_data_manager_impl_unittest.cc131 EXPECT_TRUE(updater()->pending_requests().empty()); in DownloadDeviceData()
133 EXPECT_FALSE(updater()->pending_requests().empty()); in DownloadDeviceData()
135 EXPECT_FALSE(updater()->pending_requests().front().contacts); in DownloadDeviceData()
136 EXPECT_FALSE(updater()->pending_requests().front().certificates); in DownloadDeviceData()
157 EXPECT_FALSE(updater()->pending_requests().front().certificates); in UploadContacts()
163 ->pending_requests() in UploadContacts()
184 EXPECT_FALSE(updater()->pending_requests().front().contacts); in UploadCertificates()
190 ->pending_requests() in UploadCertificates()
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/enterprise/reporting/
H A Dprofile_report_generator_desktop.cc87 const base::DictionaryValue* pending_requests = in GetExtensionRequest() local
91 if (!pending_requests) in GetExtensionRequest()
100 for (const auto& it : *pending_requests) { in GetExtensionRequest()

12345678910