| /dports/www/aria2/aria2-1.36.0/src/ |
| H A D | AbstractCommand.cc | 84 req_(req), in AbstractCommand()
190 if (req_ && req_->removalRequested()) { in execute()
215 if (req_ && req_->isPipeliningEnabled()) { in execute()
258 if (!req_ || req_->getMaxPipelinedRequest() == 1 || in execute()
309 req_->getHost(), req_->getProtocol()); in execute()
319 req_->getHost(), req_->getProtocol()); in execute()
348 if (req_) { in execute()
400 if (req_) { in execute()
443 if (req_) { in prepareForRetry()
474 if (req_) { in onAbort()
[all …]
|
| H A D | NameResolveCommand.cc | 63 req_(req) in NameResolveCommand()
90 const std::string& hostname = req_->remoteAddr; in execute()
130 req_->state = UDPT_STA_COMPLETE; in onShutdown()
131 req_->error = UDPT_ERR_SHUTDOWN; in onShutdown()
136 req_->state = UDPT_STA_COMPLETE; in onFailure()
137 req_->error = UDPT_ERR_NETWORK; in onFailure()
143 req_->remoteAddr = addrs[0]; in onSuccess()
144 e->getBtRegistry()->getUDPTrackerClient()->addRequest(req_); in onSuccess()
|
| /dports/cad/cascade-compiler/cascade-f4f7ae8bd1dd379790c0e58c286df90b8d1cdcde/share/cascade/verilator/ |
| H A D | harness_32.cpp | 19 Request req_; variable
27 req_ = READY; in verilator_init()
32 switch (req_) { in verilator_start()
38 req_ = WAIT; in verilator_start()
44 req_ = WAIT; in verilator_start()
50 req_ = DONE_1; in verilator_start()
54 req_ = DONE_2; in verilator_start()
57 req_ = READY; in verilator_start()
74 for (req_ = WRITE; req_ != READY;); in verilator_write()
79 for (req_ = READ; req_ != READY;); in verilator_read()
|
| H A D | harness_64.cpp | 19 Request req_; variable
27 req_ = READY; in verilator_init()
32 switch (req_) { in verilator_start()
38 req_ = WAIT; in verilator_start()
44 req_ = WAIT; in verilator_start()
50 req_ = DONE_1; in verilator_start()
54 req_ = DONE_2; in verilator_start()
57 req_ = READY; in verilator_start()
74 for (req_ = WRITE; req_ != READY;); in verilator_write()
79 for (req_ = READ; req_ != READY;); in verilator_read()
|
| /dports/devel/grpc/grpc-1.42.0/test/cpp/end2end/ |
| H A D | test_service_impl.cc | 160 if (req_->has_param() && req_->param().server_sleep_us() > 0) { in Echo()
183 if (req_->has_param() && req_->param().echo_metadata_initially()) { in Echo()
188 if (req_->has_param() && req_->param().has_expected_error()) { in Echo()
208 if (req_->has_param() && req_->param().server_die()) { in Echo()
212 if (req_->has_param() && req_->param().has_expected_error()) { in Echo()
236 if (req_->has_param() && req_->param().client_cancel_after_us()) { in Echo()
243 } else if (req_->has_param() && req_->param().server_cancel_after_us()) { in Echo()
254 if (req_->has_param() && req_->param().echo_metadata_initially()) { in Echo()
264 if (req_->has_param() && req_->param().echo_metadata()) { in Echo()
289 if (req_->has_param() && req_->param().response_message_length() > 0) { in Echo()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/test/cpp/end2end/ |
| H A D | test_service_impl.cc | 160 if (req_->has_param() && req_->param().server_sleep_us() > 0) { in Echo()
183 if (req_->has_param() && req_->param().echo_metadata_initially()) { in Echo()
188 if (req_->has_param() && req_->param().has_expected_error()) { in Echo()
208 if (req_->has_param() && req_->param().server_die()) { in Echo()
212 if (req_->has_param() && req_->param().has_expected_error()) { in Echo()
236 if (req_->has_param() && req_->param().client_cancel_after_us()) { in Echo()
243 } else if (req_->has_param() && req_->param().server_cancel_after_us()) { in Echo()
255 if (req_->has_param() && req_->param().echo_metadata_initially()) { in Echo()
265 if (req_->has_param() && req_->param().echo_metadata()) { in Echo()
290 if (req_->has_param() && req_->param().response_message_length() > 0) { in Echo()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/test/cpp/end2end/ |
| H A D | test_service_impl.cc | 161 if (req_->has_param() && req_->param().server_sleep_us() > 0) { in Echo()
184 if (req_->has_param() && req_->param().echo_metadata_initially()) { in Echo()
205 if (req_->has_param() && req_->param().server_die()) { in Echo()
209 if (req_->has_param() && req_->param().has_expected_error()) { in Echo()
233 if (req_->has_param() && req_->param().client_cancel_after_us()) { in Echo()
240 } else if (req_->has_param() && req_->param().server_cancel_after_us()) { in Echo()
248 } else if (!req_->has_param() || !req_->param().skip_cancelled_check()) { in Echo()
252 if (req_->has_param() && req_->param().echo_metadata_initially()) { in Echo()
262 if (req_->has_param() && req_->param().echo_metadata()) { in Echo()
287 if (req_->has_param() && req_->param().response_message_length() > 0) { in Echo()
[all …]
|
| /dports/math/dune-common/dune-common-df65b1282ea89ad40d2cb6565983f7e633ccce31/dune/common/parallel/ |
| H A D | mpifuture.hh | 84 mutable MPI_Request req_; member in Dune::MPIFuture
91 : req_(MPI_REQUEST_NULL) in MPIFuture()
98 req_(MPI_REQUEST_NULL) in MPIFuture()
106 : req_(MPI_REQUEST_NULL) in MPIFuture()
111 if(req_ != MPI_REQUEST_NULL){ in ~MPIFuture()
113 MPI_Cancel(&req_); in ~MPIFuture()
114 MPI_Request_free(&req_); in ~MPIFuture()
121 : req_(MPI_REQUEST_NULL) in MPIFuture()
125 std::swap(req_, f.req_); in MPIFuture()
130 std::swap(req_, f.req_); in operator =()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/cpp/server/ |
| H A D | server_cc.cc | 607 : req_(req) { in CallbackCallTag()
639 delete req_; in Run()
649 req_->server_, req_->method_index_, req_->method_, in Run()
662 req_->ctx_.set_call(req_->call_); in Run()
663 req_->ctx_.cq_ = req_->cq_; in Run()
664 req_->ctx_.BindDeadlineAndMetadata(req_->deadline_, in Run()
672 req_->call_, req_->server_, req_->cq_, in Run()
692 req_->request_ = req_->method_->handler()->Deserialize( in Run()
693 req_->call_, req_->request_payload_, &req_->request_status_, in Run()
698 req_->interceptor_methods_.SetRecvMessage(req_->request_, nullptr); in Run()
[all …]
|
| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | socks.cpp | 149 const socks_basic_auth_request_t &req_) in encode() argument
154 memcpy (ptr, req_.username.c_str (), req_.username.size ()); in encode()
155 ptr += req_.username.size (); in encode()
157 memcpy (ptr, req_.password.c_str (), req_.password.size ()); in encode()
158 ptr += req_.password.size (); in encode()
241 zmq_assert (req_.hostname.size () <= UINT8_MAX); in encode()
245 *ptr++ = req_.command; in encode()
275 memcpy (ptr, req_.hostname.c_str (), req_.hostname.size ()); in encode()
276 ptr += req_.hostname.size (); in encode()
282 *ptr++ = req_.port / 256; in encode()
[all …]
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | socks.cpp | 149 const socks_basic_auth_request_t &req_) in encode() argument
154 memcpy (ptr, req_.username.c_str (), req_.username.size ()); in encode()
155 ptr += req_.username.size (); in encode()
157 memcpy (ptr, req_.password.c_str (), req_.password.size ()); in encode()
158 ptr += req_.password.size (); in encode()
241 zmq_assert (req_.hostname.size () <= UINT8_MAX); in encode()
245 *ptr++ = req_.command; in encode()
275 memcpy (ptr, req_.hostname.c_str (), req_.hostname.size ()); in encode()
276 ptr += req_.hostname.size (); in encode()
282 *ptr++ = req_.port / 256; in encode()
[all …]
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/ |
| H A D | ReplyInfo.h | 30 : req_(std::move(req)), message_(std::move(message)) {} in AppOverloadExceptionInfo()
41 send(std::move(req_), message_); in operator()
44 ResponseChannelRequest::UniquePtr req_; variable
57 req_->sendReply(std::move(response_), nullptr, crc32c_); in operator()
60 ResponseChannelRequest::UniquePtr req_; variable
72 : req_(std::move(req)), in StreamReplyInfo()
78 req_->sendStreamReply(std::move(response_), std::move(stream_), crc32c_); in operator()
81 ResponseChannelRequest::UniquePtr req_; variable
94 : req_(std::move(req)), in SinkConsumerReplyInfo()
101 req_->sendSinkReply( in operator()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/include/ |
| H A D | mpidpost.h | 182 #define MPIDI_CH3U_Request_decrement_cc(req_, incomplete_) \ argument
183 MPID_cc_decr((req_)->cc_ptr, incomplete_)
184 #define MPIDI_CH3U_Request_increment_cc(req_, was_incomplete_) \ argument
185 MPID_cc_incr((req_)->cc_ptr, was_incomplete_)
195 #define MPID_Request_release(req_) \ argument
199 MPIR_Request_release_ref((req_), &inuse_); \
202 MPIDI_CH3_Request_destroy(req_); \
239 #define MPID_REQUEST_SET_COMPLETED(req_) \ argument
241 MPID_cc_set((req_)->cc_ptr, 0); \
|
| /dports/devel/grpc/grpc-1.42.0/src/cpp/server/ |
| H A D | server_cc.cc | 581 : req_(req) { in CallbackCallTag()
613 delete req_; in Run()
618 req_->ctx_->set_call(req_->call_); in Run()
619 req_->ctx_->cq_ = req_->cq_; in Run()
620 req_->ctx_->BindDeadlineAndMetadata(req_->deadline_, in Run()
628 req_->call_, req_->server_, req_->cq_, in Run()
648 req_->request_ = req_->method_->handler()->Deserialize( in Run()
649 req_->call_, req_->request_payload_, &req_->request_status_, in Run()
657 req_->interceptor_methods_.SetRecvMessage(req_->request_, nullptr); in Run()
673 call_, req_->ctx_, req_->request_, req_->request_status_, in ContinueRunAfterInterception()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/src/cpp/server/ |
| H A D | server_cc.cc | 605 : req_(req) { in CallbackCallTag()
638 delete req_; in Run()
643 req_->ctx_.set_call(req_->call_); in Run()
644 req_->ctx_.cq_ = req_->cq_; in Run()
645 req_->ctx_.BindDeadlineAndMetadata(req_->deadline_, in Run()
653 req_->call_, req_->server_, req_->cq_, in Run()
673 req_->request_ = req_->method_->handler()->Deserialize( in Run()
674 req_->call_, req_->request_payload_, &req_->request_status_, in Run()
679 req_->interceptor_methods_.SetRecvMessage(req_->request_, nullptr); in Run()
695 call_, &req_->ctx_, req_->request_, req_->request_status_, in ContinueRunAfterInterception()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/src/cpp/server/ |
| H A D | server_cc.cc | 596 : req_(req) { in CallbackCallTag()
629 delete req_; in Run()
634 req_->ctx_.set_call(req_->call_); in Run()
635 req_->ctx_.cq_ = req_->cq_; in Run()
636 req_->ctx_.BindDeadlineAndMetadata(req_->deadline_, in Run()
644 req_->call_, req_->server_, req_->cq_, in Run()
664 req_->request_ = req_->method_->handler()->Deserialize( in Run()
665 req_->call_, req_->request_payload_, &req_->request_status_, in Run()
670 req_->interceptor_methods_.SetRecvMessage(req_->request_, nullptr); in Run()
686 call_, &req_->ctx_, req_->request_, req_->request_status_, in ContinueRunAfterInterception()
[all …]
|
| /dports/net-mgmt/seafile-gui/seafile-client-7.0.9/src/ |
| H A D | repo-service-helper.cpp | 40 …t), repo_(repo), path_(path), file_name_(QFileInfo(path).fileName()), parent_(parent), req_(NULL) { in FileDownloadHelper()
46 if (req_) in ~FileDownloadHelper()
47 req_->deleteLater(); in ~FileDownloadHelper()
52 if (req_) in start()
56 req_ = new GetDirentsRequest(account_, repo_.id, dirent_path); in start()
57 connect(req_, SIGNAL(success(bool, const QList<SeafDirent> &, const QString&)), in start()
59 connect(req_, SIGNAL(failed(const ApiError &)), in start()
61 req_->send(); in start()
66 if (req_) in onCancel()
67 disconnect(req_, 0, this, 0); in onCancel()
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 121 req_(balloc_), in Downstream()
664 req_.recv_body_length += datalen; in push_upload_data_chunk()
766 if (req_.fs.content_length != req_.recv_body_length) { in validate_request_recv_body_length()
804 if (req_.method == HTTP_CONNECT) { in check_upgrade_fulfilled_http1()
838 req_.upgrade_request = true; in inspect_http2_request()
844 req_.upgrade_request = true; in inspect_http1_request()
845 } else if (req_.http_minor > 0) { in inspect_http1_request()
866 req_.fs.content_length = -1; in inspect_http1_request()
899 return req_.http_major == 3 || req_.http_major == 2 || in supports_non_final_response()
900 (req_.http_major == 1 && req_.http_minor == 1); in supports_non_final_response()
[all …]
|
| /dports/www/libnghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_downstream.cc | 121 req_(balloc_), in Downstream()
664 req_.recv_body_length += datalen; in push_upload_data_chunk()
766 if (req_.fs.content_length != req_.recv_body_length) { in validate_request_recv_body_length()
804 if (req_.method == HTTP_CONNECT) { in check_upgrade_fulfilled_http1()
838 req_.upgrade_request = true; in inspect_http2_request()
844 req_.upgrade_request = true; in inspect_http1_request()
845 } else if (req_.http_minor > 0) { in inspect_http1_request()
866 req_.fs.content_length = -1; in inspect_http1_request()
899 return req_.http_major == 3 || req_.http_major == 2 || in supports_non_final_response()
900 (req_.http_major == 1 && req_.http_minor == 1); in supports_non_final_response()
[all …]
|
| /dports/www/nghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_downstream.cc | 121 req_(balloc_), in Downstream()
664 req_.recv_body_length += datalen; in push_upload_data_chunk()
766 if (req_.fs.content_length != req_.recv_body_length) { in validate_request_recv_body_length()
804 if (req_.method == HTTP_CONNECT) { in check_upgrade_fulfilled_http1()
838 req_.upgrade_request = true; in inspect_http2_request()
844 req_.upgrade_request = true; in inspect_http1_request()
845 } else if (req_.http_minor > 0) { in inspect_http1_request()
866 req_.fs.content_length = -1; in inspect_http1_request()
899 return req_.http_major == 3 || req_.http_major == 2 || in supports_non_final_response()
900 (req_.http_major == 1 && req_.http_minor == 1); in supports_non_final_response()
[all …]
|
| /dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 121 req_(balloc_), in Downstream()
654 req_.recv_body_length += datalen; in push_upload_data_chunk()
756 if (req_.fs.content_length != req_.recv_body_length) { in validate_request_recv_body_length()
794 if (req_.method == HTTP_CONNECT) { in check_upgrade_fulfilled_http1()
827 if (req_.method == HTTP_CONNECT) { in inspect_http2_request()
828 req_.upgrade_request = true; in inspect_http2_request()
834 req_.upgrade_request = true; in inspect_http1_request()
835 } else if (req_.http_minor > 0) { in inspect_http1_request()
856 req_.fs.content_length = -1; in inspect_http1_request()
889 return req_.http_major == 2 || (req_.http_major == 1 && req_.http_minor == 1); in supports_non_final_response()
[all …]
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 121 req_(balloc_), in Downstream()
654 req_.recv_body_length += datalen; in push_upload_data_chunk()
756 if (req_.fs.content_length != req_.recv_body_length) { in validate_request_recv_body_length()
794 if (req_.method == HTTP_CONNECT) { in check_upgrade_fulfilled_http1()
827 if (req_.method == HTTP_CONNECT) { in inspect_http2_request()
828 req_.upgrade_request = true; in inspect_http2_request()
834 req_.upgrade_request = true; in inspect_http1_request()
835 } else if (req_.http_minor > 0) { in inspect_http1_request()
856 req_.fs.content_length = -1; in inspect_http1_request()
889 return req_.http_major == 2 || (req_.http_major == 1 && req_.http_minor == 1); in supports_non_final_response()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 121 req_(balloc_), in Downstream()
654 req_.recv_body_length += datalen; in push_upload_data_chunk()
756 if (req_.fs.content_length != req_.recv_body_length) { in validate_request_recv_body_length()
794 if (req_.method == HTTP_CONNECT) { in check_upgrade_fulfilled_http1()
827 if (req_.method == HTTP_CONNECT) { in inspect_http2_request()
828 req_.upgrade_request = true; in inspect_http2_request()
834 req_.upgrade_request = true; in inspect_http1_request()
835 } else if (req_.http_minor > 0) { in inspect_http1_request()
856 req_.fs.content_length = -1; in inspect_http1_request()
889 return req_.http_major == 2 || (req_.http_major == 1 && req_.http_minor == 1); in supports_non_final_response()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/ |
| H A D | mpidimpl.h | 297 #define MPIDI_Request_get_msg_type(req_) \ argument
309 #define MPIDI_Request_get_srbuf_flag(req_) \ argument
351 #define MPIDI_Request_get_type(req_) \ argument
354 #define MPIDI_Request_set_type(req_, type_) \ argument
364 *(flag_) = (req_)->dev.cancel_pending; \
365 (req_)->dev.cancel_pending = TRUE; \
375 #define MPIDI_Request_decr_pending(req_) \ argument
377 --(req_)->dev.recv_pending_count; \
398 (req_)->dev.seqnum = (seqnum_); \
818 if ((req_)->dev.tmpbuf != NULL) \
[all …]
|
| /dports/net/wangle/wangle-2021.12.27.00/wangle/channel/ |
| H A D | FileRegion.cpp | 178 : req_(req), pipe_in_(pipe_in), bytesToRead_(bytesToRead) { in FileReadHandler()
179 CHECK(req_->readBase_->isInEventBaseThread()); in FileReadHandler()
180 initHandler(req_->readBase_, folly::NetworkSocket::fromFd(pipe_in)); in FileReadHandler()
182 req_->fail( in FileReadHandler()
190 CHECK(req_->readBase_->isInEventBaseThread()); in ~FileReadHandler()
205 req_->readFd_, &req_->offset_, pipe_in_, nullptr, bytesToRead_, flags); in handlerReady()
210 req_->fail( in handlerReady()
221 req_->queue_.putMessage(static_cast<size_t>(spliced)); in handlerReady()
223 req_->fail( in handlerReady()
|