| /third_party/mindspore/mindspore/ccsrc/ps/core/communicator/ |
| D | communicator_base.cc | 28 bool CommunicatorBase::SendResponse(const void *rsp_data, size_t rsp_len, in SendResponse() function in mindspore::ps::core::CommunicatorBase
35 return msg_handler->SendResponse(rsp_data, rsp_len); in SendResponse()
|
| D | message_handler.h | 36 virtual bool SendResponse(const void *data, const size_t &len) = 0;
|
| D | http_msg_handler.h | 35 bool SendResponse(const void *data, const size_t &len) override;
|
| D | http_msg_handler.cc | 37 bool HttpMsgHandler::SendResponse(const void *data, const size_t &len) { in SendResponse() function in mindspore::ps::core::HttpMsgHandler
|
| D | tcp_msg_handler.h | 37 bool SendResponse(const void *data, const size_t &len) override;
|
| D | tcp_msg_handler.cc | 38 bool TcpMsgHandler::SendResponse(const void *data, const size_t &len) { in SendResponse() function in mindspore::ps::core::TcpMsgHandler
|
| D | communicator_base.h | 83 …bool SendResponse(const void *rsp_data, size_t rsp_len, const std::shared_ptr<MessageHandler> &msg…
|
| D | http_message_handler.cc | 243 void HttpMessageHandler::SendResponse() { in SendResponse() function in mindspore::ps::core::HttpMessageHandler
272 SendResponse(); in ErrorResponse()
|
| D | http_message_handler.h | 93 void SendResponse();
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | distributed_count_service.cc | 206 …if (!communicator_->SendResponse(count_rsp.SerializeAsString().data(), count_rsp.SerializeAsString… in HandleCountRequest()
221 …if (!communicator_->SendResponse(count_rsp.SerializeAsString().data(), count_rsp.SerializeAsString… in HandleCountRequest()
240 …if (!communicator_->SendResponse(count_rsp.SerializeAsString().data(), count_rsp.SerializeAsString… in HandleCountRequest()
263 if (!communicator_->SendResponse(count_reach_threshold_rsp.SerializeAsString().data(), in HandleCountReachThresholdRequest()
276 …if (!communicator_->SendResponse(couter_event_rsp_msg.data(), couter_event_rsp_msg.size(), message… in HandleCounterEvent()
|
| D | round.cc | 135 if (!communicator_->SendResponse(reason.c_str(), reason.size(), message)) { in LaunchRoundKernel()
153 if (!communicator_->SendResponse(reason.c_str(), reason.size(), message)) { in LaunchRoundKernel()
159 if (!communicator_->SendResponse(output->addr, output->size, message)) { in LaunchRoundKernel()
|
| D | iteration.cc | 376 if (!communicator_->SendResponse(sync_iter_rsp_msg.data(), sync_iter_rsp_msg.size(), message)) { in HandleSyncIterationRequest()
413 if (!communicator_->SendResponse(notify_leader_to_next_iter_rsp.SerializeAsString().data(), in HandleNotifyLeaderMoveToNextIterRequest()
489 if (!communicator_->SendResponse(prepare_next_iter_rsp.SerializeAsString().data(), in HandlePrepareForNextIterRequest()
540 if (!communicator_->SendResponse(proceed_to_next_iter_rsp.SerializeAsString().data(), in HandleMoveToNextIterRequest()
598 if (!communicator_->SendResponse(end_last_iter_rsp.SerializeAsString().data(), in HandleEndLastIterRequest()
610 if (!communicator_->SendResponse(end_last_iter_rsp.SerializeAsString().data(), in HandleEndLastIterRequest()
|
| D | server.cc | 523 if (!tcp_comm->SendResponse(response.dump().c_str(), response.dump().size(), message)) { in HandleEnableServerRequest()
541 if (!tcp_comm->SendResponse(response.dump().c_str(), response.dump().size(), message)) { in HandleDisableServerRequest()
563 if (!tcp_comm->SendResponse(response.dump().c_str(), response.dump().size(), message)) { in HandleNewInstanceRequest()
573 if (!tcp_comm->SendResponse(response.dump().c_str(), response.dump().size(), message)) { in HandleNewInstanceRequest()
592 if (!tcp_comm->SendResponse(response.dump().c_str(), response.dump().size(), message)) { in HandleQueryInstanceRequest()
|
| D | distributed_metadata_store.cc | 197 …if (!communicator_->SendResponse(update_meta_rsp_msg.data(), update_meta_rsp_msg.size(), message))… in HandleUpdateMetadataRequest()
218 …if (!communicator_->SendResponse(getting_meta_rsp_msg.data(), getting_meta_rsp_msg.size(), message… in HandleGetMetadataRequest()
|
| /third_party/cef/tests/cefclient/browser/ |
| D | server_test.cc | 272 SendResponse(callback, true, result_dict); in HandleQueryAction()
323 SendResponse(callback, success, result_dict); in OnStartComplete()
333 SendResponse(callback, success, result_dict); in OnStopComplete()
337 static void SendResponse(CefRefPtr<Callback> callback, in SendResponse() function in client::server_test::__anone6b9c63a0111::Handler
|
| D | media_router_test.cc | 228 SendResponse("onRoutes", payload); in OnRoutes()
238 SendResponse("onRouteStateChanged", payload); in OnRouteStateChanged()
251 SendResponse("onRouteMessageReceived", payload); in OnRouteMessageReceived()
303 void SendResponse(const std::string& name, in SendResponse() function in client::media_router_test::__anon385130630111::MediaObserver
338 SendResponse("onSinks", payload); in SendSinksResponse()
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | scheduler_node.cc | 600 resp->SendResponse(); in ProcessScaleOut()
681 resp->SendResponse(); in ProcessScaleIn()
719 resp->SendResponse(); in ProcessGetNodesInfo()
740 resp->SendResponse(); in ProcessGetClusterState()
804 resp->SendResponse(); in ProcessNewInstance()
856 resp->SendResponse(); in ProcessQueryInstance()
912 resp->SendResponse(); in ProcessEnableFLS()
968 resp->SendResponse(); in ProcessDisableFLS()
|
| /third_party/cef/tests/ceftests/ |
| D | test_server.h | 80 void SendResponse(CefRefPtr<CefServer> server,
|
| D | test_server.cc | 467 void SendResponse(CefRefPtr<CefServer> server, in SendResponse() function
|
| D | urlrequest_unittest.cc | 1415 SendResponse(server, connection_id, response, std::string()); in HandleAuthRequest()
1435 SendResponse(server, connection_id, response, response_data); in HandleNormalRequest()
1458 SendResponse(server, connection_id, redirect_response, std::string()); in HandleRedirectRequest()
1461 static void SendResponse(CefRefPtr<CefServer> server, in SendResponse() function in __anon2283f3400111::RequestServerHandler
1469 base::BindOnce(RequestServerHandler::SendResponse, server, in SendResponse()
|
| D | cookie_unittest.cc | 1365 SendResponse(server, connection_id, it->second->response, in HandleRequest()
1376 static void SendResponse(CefRefPtr<CefServer> server, in SendResponse() function in __anon6ae417fe0411::CookieAccessServerHandler
1384 base::BindOnce(CookieAccessServerHandler::SendResponse, server, in SendResponse()
|
| D | cors_unittest.cc | 329 test_server::SendResponse(server, connection_id, resource->response, in OnHttpRequest()
|
| /third_party/cef/libcef/browser/ |
| D | server_impl.cc | 311 server_->SendResponse(connection_id, response, MISSING_TRAFFIC_ANNOTATION); in SendHttpResponse()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 263 SendResponse(stream, response_and_delay.first, in BalanceLoad()
373 void SendResponse(Stream* stream, const LoadBalanceResponse& response, in SendResponse() function in grpc::testing::__anon039512b90111::BalancerServiceImpl
|