| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/foxxll/io/ |
| H A D | disk_queues.cpp | 60 void disk_queues::add_request(request_ptr& req, disk_id_type disk) in add_request()
87 bool disk_queues::cancel_request(request_ptr& req, disk_id_type disk) in cancel_request()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/services/device/usb/ |
| H A D | usb_device_handle_win.h | 176 Request* request_ptr,
183 Request* request_ptr,
188 Request* request_ptr,
|
| H A D | usb_device_handle_win.cc | 997 Request* request_ptr = request.get(); in MakeRequest() local
998 requests_[request_ptr] = std::move(request); in MakeRequest()
999 return request_ptr; in MakeRequest()
1003 UsbDeviceHandleWin::Request* request_ptr) { in UnlinkRequest() argument
1004 auto it = requests_.find(request_ptr); in UnlinkRequest()
1015 Request* request_ptr, in GotNodeConnectionInformation() argument
1021 std::unique_ptr<Request> request = UnlinkRequest(request_ptr); in GotNodeConnectionInformation()
1042 Request* request_ptr, in GotDescriptorFromNodeConnection() argument
1045 std::unique_ptr<Request> request = UnlinkRequest(request_ptr); in GotDescriptorFromNodeConnection()
1076 Request* request_ptr, in TransferComplete() argument
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgatherv/ |
| H A D | iallgatherv.c | 505 MPIR_Request *request_ptr = NULL; in MPI_Iallgatherv() local
587 displs, recvtype, comm_ptr, &request_ptr); in MPI_Iallgatherv()
591 if (!request_ptr) in MPI_Iallgatherv()
592 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__COLL); in MPI_Iallgatherv()
594 *request = request_ptr->handle; in MPI_Iallgatherv()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ialltoallv/ |
| H A D | ialltoallv.c | 427 MPIR_Request *request_ptr = NULL; in MPI_Ialltoallv() local
503 recvcounts, rdispls, recvtype, comm_ptr, &request_ptr); in MPI_Ialltoallv()
507 if (!request_ptr) in MPI_Ialltoallv()
508 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__COLL); in MPI_Ialltoallv()
510 *request = request_ptr->handle; in MPI_Ialltoallv()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallreduce/ |
| H A D | iallreduce.c | 536 MPIR_Request *request_ptr = NULL; in MPI_Iallreduce() local
609 mpi_errno = MPIR_Iallreduce(sendbuf, recvbuf, count, datatype, op, comm_ptr, &request_ptr); in MPI_Iallreduce()
613 if (!request_ptr) in MPI_Iallreduce()
614 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__COLL); in MPI_Iallreduce()
616 *request = request_ptr->handle; in MPI_Iallreduce()
|
| /dports/devel/stxxl/stxxl-1.4.1/include/stxxl/bits/algo/ |
| H A D | stable_ksort.h | 323 request_ptr req; in stable_ksort()
335 request_ptr* reqs1 = new request_ptr[max_bucket_size_bl]; in stable_ksort()
336 request_ptr* reqs2 = new request_ptr[max_bucket_size_bl]; in stable_ksort()
444 request_ptr req = block->read(*last.bid()); in stable_ksort()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/ios/chrome/browser/infobars/overlays/ |
| H A D | translate_infobar_placeholder_overlay_request_cancel_handler_unittest.mm | 86 OverlayRequest* request_ptr = request.get();
97 EXPECT_TRUE(queue->front_request() == request_ptr);
105 presentation_context_.GetPresentationState(request_ptr));
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/device/bluetooth/ |
| H A D | bluetooth_socket_mac.mm | 711 SendRequest* request_ptr = request.get();
734 if (request_ptr->status == kIOReturnSuccess)
735 request_ptr->status = status;
736 request_ptr->error_signaled = true;
741 if (request_ptr->active_async_writes == 0) {
747 request_ptr->active_async_writes++;
755 SendRequest* request_ptr = send_queue_.front().get();
763 if (request_ptr->status == kIOReturnSuccess)
764 request_ptr->status = status;
768 request_ptr->active_async_writes--;
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/device/bluetooth/ |
| H A D | bluetooth_socket_mac.mm | 707 SendRequest* request_ptr = request.get();
730 if (request_ptr->status == kIOReturnSuccess)
731 request_ptr->status = status;
732 request_ptr->error_signaled = true;
733 request_ptr->error_callback.Run(error.str());
737 if (request_ptr->active_async_writes == 0) {
743 request_ptr->active_async_writes++;
759 if (request_ptr->status == kIOReturnSuccess)
760 request_ptr->status = status;
764 request_ptr->active_async_writes--;
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/network_hints/browser/ |
| H A D | simple_network_hints_handler_impl.cc | 133 DnsLookupRequest* request_ptr = request.get(); in PrefetchDNS() local
134 request_ptr->Start(std::move(request)); in PrefetchDNS()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/network_hints/browser/ |
| H A D | simple_network_hints_handler_impl.cc | 133 DnsLookupRequest* request_ptr = request.get(); in PrefetchDNS() local
134 request_ptr->Start(std::move(request)); in PrefetchDNS()
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/data/ |
| H A D | block_pool.hpp | 103 foxxll::request_ptr GetAnyWriting();
107 foxxll::request_ptr EvictBlockLRU();
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/tools/ |
| H A D | benchmark_disks_random.cpp | 35 using foxxll::request_ptr;
76 request_ptr* reqs = new request_ptr[num_blocks_in_span]; in run_test()
|
| /dports/devel/stxxl/stxxl-1.4.1/tools/ |
| H A D | benchmark_files.cpp | 34 using stxxl::request_ptr;
55 void watch_times(request_ptr reqs[], unsigned n, double* out) in watch_times()
194 request_ptr* reqs = new request_ptr[nfiles * batch_size]; in benchmark_files()
|
| /dports/devel/stxxl/stxxl-1.4.1/include/stxxl/bits/mng/ |
| H A D | block_prefetcher.h | 76 request_ptr* read_reqs;
128 read_reqs = new request_ptr[nreadblocks]; in consume_seq_begin()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/media/router/discovery/dial/ |
| H A D | dial_app_discovery_service_unittest.cc | 91 auto* request_ptr = request.get(); in AddFetchRequest() local
93 return request_ptr; in AddFetchRequest()
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/foxxll/mng/ |
| H A D | block_prefetcher.hpp | 79 request_ptr* read_reqs;
131 read_reqs = new request_ptr[nreadblocks]; in block_prefetcher()
|
| /dports/devel/stxxl/stxxl-1.4.1/tests/containers/hash_map/ |
| H A D | test_hash_map_reader_writer.cpp | 61 stxxl::request_ptr req = block->read(bids[i_block]); in reader_writer_test()
128 stxxl::request_ptr req = block->read(bids[i_block]); in reader_writer_test()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/permissions/ |
| H A D | permission_context_base.cc | 356 std::unique_ptr<PermissionRequest> request_ptr = in DecidePermission() local
365 PermissionRequest* request = request_ptr.get(); in DecidePermission()
369 .insert(std::make_pair(id.ToString(), std::move(request_ptr))) in DecidePermission()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/cast_channel/ |
| H A D | cast_message_handler.cc | 547 [request_id](const auto& request_ptr) { in HandlePendingRequest() argument
548 return request_ptr->request_id == request_id; in HandlePendingRequest()
557 [&app_id, result](const auto& request_ptr) { in HandlePendingRequest() argument
558 if (request_ptr->app_id == app_id) { in HandlePendingRequest()
559 std::move(request_ptr->callback).Run(app_id, result); in HandlePendingRequest()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/p2p/ |
| H A D | socket_manager.cc | 286 DnsRequest* request_ptr = request.get(); in GetHostAddress() local
288 request_ptr->Resolve( in GetHostAddress()
291 base::Unretained(this), request_ptr, std::move(callback))); in GetHostAddress()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/permissions/ |
| H A D | permission_context_base.cc | 371 std::unique_ptr<PermissionRequest> request_ptr = in DecidePermission() local
379 PermissionRequest* request = request_ptr.get(); in DecidePermission()
383 .insert(std::make_pair(id.ToString(), std::move(request_ptr))) in DecidePermission()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/p2p/ |
| H A D | socket_manager.cc | 291 DnsRequest* request_ptr = request.get(); in GetHostAddress() local
293 request_ptr->Resolve( in GetHostAddress()
296 base::Unretained(this), request_ptr, std::move(callback))); in GetHostAddress()
|
| /dports/devel/stxxl/stxxl-1.4.1/include/stxxl/bits/containers/ |
| H A D | sequence.h | 411 request_ptr req = m_pool->read(m_front_block, m_bids.front()); in pop_front()
470 request_ptr req = m_pool->read(m_back_block, m_bids.back()); in pop_back()
659 request_ptr req = m_sequence.m_pool->read(m_current_block, *m_next_bid);
790 request_ptr req = m_sequence.m_pool->read(m_current_block, *m_next_bid);
|