| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_request.cc | 32 Status remote_rc(static_cast<StatusCode>(reply_.rc()), reply_.msg()); in Wait()
109 if (!reply_.result().empty()) { in PostReply()
110 row_id_from_server_ = strtoll(reply_.result().data(), nullptr, kDecimal); in PostReply()
162 auto flag = reply_.flag(); in RestoreRows()
165 auto addr = strtoll(reply_.result().data(), nullptr, kDecimal); in RestoreRows()
170 ptr = reply_.result().data(); in RestoreRows()
175 …CHECK_FAIL_RETURN_UNEXPECTED(support_local_bypass_ || sz == reply_.result().length(), "Length mism… in RestoreRows()
232 auto p = flatbuffers::GetRoot<CreateCacheReplyMsg>(reply_.result().data()); in PostReply()
286 auto *map_msg = flatbuffers::GetRoot<SchemaMsg>(reply_.result().data()); in PostReply()
298 auto *msg = flatbuffers::GetRoot<ServiceStatMsg>(reply_.result().data()); in PostReply()
[all …]
|
| D | cache_grpc_client.cc | 102 ccReqTag->rpc_->Finish(&ccReqTag->base_rq_->reply_, &ccReqTag->rc_, ccReqTag); in HandleRequest()
128 Status2CacheReply(remote_rc, &rq->base_rq_->reply_); in WorkerEntry()
|
| /third_party/boost/libs/asio/example/cpp03/http/server4/ |
| D | server.cpp | 90 reply_.reset(new reply); in operator ()()
96 request_handler_(*request_, *reply_); in operator ()()
101 *reply_ = reply::stock_reply(reply::bad_request); in operator ()()
105 yield boost::asio::async_write(*socket_, reply_->to_buffers(), *this); in operator ()()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server4/ |
| D | server.cpp | 90 reply_.reset(new reply); in operator ()()
96 request_handler_(*request_, *reply_); in operator ()()
101 *reply_ = reply::stock_reply(reply::bad_request); in operator ()()
105 yield boost::asio::async_write(*socket_, reply_->to_buffers(), *this); in operator ()()
|
| D | server.hpp | 67 boost::shared_ptr<reply> reply_; member in http::server4::server
|
| /third_party/boost/libs/asio/example/cpp03/http/server2/ |
| D | connection.cpp | 50 request_handler_.handle_request(request_, reply_); in handle_read()
51 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
57 reply_ = reply::stock_reply(reply::bad_request); in handle_read()
58 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
|
| D | connection.hpp | 67 reply reply_; member in http::server2::connection
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server2/ |
| D | connection.cpp | 50 request_handler_.handle_request(request_, reply_); in handle_read()
51 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
57 reply_ = reply::stock_reply(reply::bad_request); in handle_read()
58 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
|
| D | connection.hpp | 67 reply reply_; member in http::server2::connection
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server3/ |
| D | connection.cpp | 51 request_handler_.handle_request(request_, reply_); in handle_read()
52 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
58 reply_ = reply::stock_reply(reply::bad_request); in handle_read()
59 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
|
| D | connection.hpp | 70 reply reply_; member in http::server3::connection
|
| /third_party/boost/libs/asio/example/cpp03/http/server3/ |
| D | connection.cpp | 51 request_handler_.handle_request(request_, reply_); in handle_read()
52 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
58 reply_ = reply::stock_reply(reply::bad_request); in handle_read()
59 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
|
| D | connection.hpp | 70 reply reply_; member in http::server3::connection
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server/ |
| D | connection.cpp | 57 request_handler_.handle_request(request_, reply_); in handle_read()
58 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
64 reply_ = reply::stock_reply(reply::bad_request); in handle_read()
65 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
|
| D | connection.hpp | 75 reply reply_; member in http::server::connection
|
| /third_party/boost/libs/asio/example/cpp03/http/server/ |
| D | connection.cpp | 57 request_handler_.handle_request(request_, reply_); in handle_read()
58 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
64 reply_ = reply::stock_reply(reply::bad_request); in handle_read()
65 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
|
| D | connection.hpp | 75 reply reply_; member in http::server::connection
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/http/server/ |
| D | connection.cpp | 52 request_handler_.handle_request(request_, reply_); in do_read()
57 reply_ = reply::stock_reply(reply::bad_request); in do_read()
75 boost::asio::async_write(socket_, reply_.to_buffers(), in do_write()
|
| /third_party/boost/libs/asio/example/cpp11/http/server/ |
| D | connection.cpp | 52 request_handler_.handle_request(request_, reply_); in do_read()
57 reply_ = reply::stock_reply(reply::bad_request); in do_read()
75 boost::asio::async_write(socket_, reply_.to_buffers(), in do_write()
|
| D | connection.hpp | 71 reply reply_; member in http::server::connection
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 105 reply_.set_message(prefix + request_.name()); in Proceed()
111 responder_.Finish(reply_, Status::OK, this); in Proceed()
133 HelloReply reply_; member in ServerImpl::CallData
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/ssl/ |
| D | client.cpp | 116 boost::asio::buffer(reply_, length), in receive_response()
122 std::cout.write(reply_, length); in receive_response()
134 char reply_[max_length]; member in client
|
| /third_party/boost/libs/asio/example/cpp11/ssl/ |
| D | client.cpp | 116 boost::asio::buffer(reply_, length), in receive_response()
122 std::cout.write(reply_, length); in receive_response()
134 char reply_[max_length]; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/ssl/ |
| D | client.cpp | 96 boost::asio::buffer(reply_, bytes_transferred), in handle_write()
113 std::cout.write(reply_, bytes_transferred); in handle_read()
125 char reply_[max_length]; member in client
|
| /third_party/boost/libs/asio/example/cpp03/ssl/ |
| D | client.cpp | 96 boost::asio::buffer(reply_, bytes_transferred), in handle_write()
113 std::cout.write(reply_, bytes_transferred); in handle_read()
125 char reply_[max_length]; member in client
|