/external/tensorflow/tensorflow/compiler/xla/rpc/ |
D | grpc_stub.cc | 31 TransferToClientResponse* response) { in TransferToClient() 38 TransferToServerResponse* response) { in TransferToServer() 45 TransferToInfeedResponse* response) { in TransferToInfeed() 52 TransferFromOutfeedResponse* response) { in TransferFromOutfeed() 59 ResetDeviceResponse* response) { in ResetDevice() 66 CompileResponse* response) { in Compile() 73 ExecuteResponse* response) { in Execute() 81 ExecuteParallelResponse* response) { in ExecuteGraphParallel() 88 WaitForExecutionResponse* response) { in WaitForExecution() 95 DeconstructTupleResponse* response) { in DeconstructTuple() [all …]
|
/external/okhttp/okhttp-logging-interceptor/src/test/java/com/squareup/okhttp/logging/ |
D | HttpLoggingInterceptorTest.java | 147 Response response = client.newCall(request().build()).execute(); in basicResponseBody() local 165 Response response = client.newCall(request().build()).execute(); in headersGet() local 198 Response response = client.newCall(request).execute(); in headersPost() local 235 Response response = client.newCall(request).execute(); in headersPostNoContentType() local 278 Response response = client.newCall(request().post(body).build()).execute(); in headersPostNoLength() local 315 Response response = client.newCall(request().build()).execute(); in headersResponseBody() local 349 Response response = client.newCall(request().build()).execute(); in bodyGet() local 390 Response response = client.newCall(request().build()).execute(); in bodyGetNoBody() local 423 Response response = client.newCall(request).execute(); in bodyPost() local 465 Response response = client.newCall(request().build()).execute(); in bodyResponseBody() local [all …]
|
/external/libbrillo/brillo/http/ |
D | http_utils_test.cc | 28 fake::ServerResponse* response) { in EchoDataHandler() 36 fake::ServerResponse* response) { in EchoMethodHandler() 49 auto response = in TEST() local 73 std::unique_ptr<http::Response> response) { in TEST() 101 auto response = in TEST() local 119 auto response = http::SendRequestAndBlock(request_type::kGet, in TEST() local 136 auto response = http::SendRequestAndBlock(request_type::kPut, in TEST() local 152 auto response = http::SendRequestWithNoDataAndBlock( in TEST() local 162 [](RequestID /* request_id */, std::unique_ptr<http::Response> response) { in TEST() 183 [](const fake::ServerRequest& request, fake::ServerResponse* response) { in TEST() [all …]
|
/external/nanohttpd/core/src/test/java/fi/iki/elonen/integration/ |
D | GZipIntegrationTest.java | 60 public Response response; field in GZipIntegrationTest.TestServer 87 HttpResponse response = httpclient.execute(request); in contentEncodingShouldBeAddedToFixedLengthResponses() local 99 HttpResponse response = httpclient.execute(request); in contentEncodingShouldBeAddedToChunkedResponses() local 110 HttpResponse response = httpclient.execute(request); in shouldFindCorrectAcceptEncodingAmongMany() local 121 HttpResponse response = httpclient.execute(request); in contentLengthShouldBeRemovedFromZippedResponses() local 131 HttpResponse response = new DecompressingHttpClient(httpclient).execute(request); in fixedLengthContentIsEncodedProperly() local 141 HttpResponse response = new DecompressingHttpClient(httpclient).execute(request); in chunkedContentIsEncodedProperly() local 149 HttpResponse response = httpclient.execute(request); in noGzipWithoutAcceptEncoding() local 161 HttpResponse response = httpclient.execute(request); in contentShouldNotBeGzippedIfContentLengthIsAddedManually() local
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
D | worker_interface.h | 65 RunGraphResponse* response, StatusCallback done) { in RunGraphAsync() 133 GetStatusResponse* response) { in GetStatus() 146 CreateWorkerSessionResponse* response) { in CreateWorkerSession() 151 DeleteWorkerSessionResponse* response) { in DeleteWorkerSession() 157 RegisterGraphResponse* response) { in RegisterGraph() 162 DeregisterGraphResponse* response) { in DeregisterGraph() 167 CleanupGraphResponse* response) { in CleanupGraph() 172 CleanupAllResponse* response) { in CleanupAll() 176 Status Logging(const LoggingRequest* request, LoggingResponse* response) { in Logging() 180 Status Tracing(const TracingRequest* request, TracingResponse* response) { in Tracing() [all …]
|
D | test_utils.h | 34 GetStatusResponse* response, bool fail_fast, in GetStatusAsync() 40 CreateWorkerSessionResponse* response, in CreateWorkerSessionAsync() 47 DeleteWorkerSessionResponse* response, in DeleteWorkerSessionAsync() 53 RegisterGraphResponse* response, in RegisterGraphAsync() 59 DeregisterGraphResponse* response, in DeregisterGraphAsync() 65 MutableRunGraphResponseWrapper* response, in RunGraphAsync() 71 CleanupGraphResponse* response, in CleanupGraphAsync() 77 CleanupAllResponse* response, in CleanupAllAsync() 83 TensorResponse* response, StatusCallback done) override { in RecvTensorAsync() 87 void LoggingAsync(const LoggingRequest* request, LoggingResponse* response, in LoggingAsync() [all …]
|
D | message_wrappers_test.cc | 114 void CheckRunGraphResponse(MutableRunGraphResponseWrapper* response) { in CheckRunGraphResponse() 149 void CheckRunStepResponse(const MutableRunStepResponseWrapper& response) { in CheckRunStepResponse() 259 InMemoryRunStepResponse response; in TEST() local 268 OwnedProtoRunStepResponse response; in TEST() local 278 NonOwnedProtoRunStepResponse response(&response_proto); in TEST() local 287 InMemoryRunStepResponse response; in TEST() local 296 OwnedProtoRunStepResponse response; in TEST() local 306 NonOwnedProtoRunStepResponse response(&response_proto); in TEST() local 316 InMemoryRunStepResponse response; in TEST() local 326 OwnedProtoRunStepResponse response; in TEST() local [all …]
|
D | worker.cc | 39 GetStatusResponse* response, bool fail_fast, in GetStatusAsync() 52 CreateWorkerSessionResponse* response, in CreateWorkerSessionAsync() 63 DeleteWorkerSessionResponse* response, in DeleteWorkerSessionAsync() 70 RegisterGraphResponse* response, in RegisterGraphAsync() 91 DeregisterGraphResponse* response, in DeregisterGraphAsync() 138 MutableRunGraphResponseWrapper* response, in RunGraphAsync() 162 MutableRunGraphResponseWrapper* response, in DoRunGraph() 263 MutableRunGraphResponseWrapper* response, in DoPartialRunGraph() 352 CleanupGraphResponse* response, in CleanupGraphAsync() 369 CleanupAllResponse* response, in CleanupAllAsync() [all …]
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | grpc_master_service_impl.cc | 81 CreateSessionResponse* response) { in CreateSession() 88 ExtendSessionResponse* response) { in ExtendSession() 95 PartialRunSetupResponse* response) { in PartialRunSetup() 102 RunStepResponse* response) { in RunStep() 109 CloseSessionResponse* response) { in CloseSession() 116 ListDevicesResponse* response) { in ListDevices() 123 ResetResponse* response) { in Reset() 130 MakeCallableResponse* response) { in MakeCallable() 137 RunCallableResponse* response) { in RunCallable() 144 ReleaseCallableResponse* response) { in ReleaseCallable()
|
D | grpc_remote_master.cc | 49 CreateSessionResponse* response) override { in CreateSession() 56 ExtendSessionResponse* response) override { in ExtendSession() 63 PartialRunSetupResponse* response) override { in PartialRunSetup() 69 MutableRunStepResponseWrapper* response) override { in RunStep() 77 CloseSessionResponse* response) override { in CloseSession() 84 ListDevicesResponse* response) override { in ListDevices() 90 ResetResponse* response) override { in Reset() 97 MakeCallableResponse* response) override { in MakeCallable() 103 RunCallableResponse* response) override { in RunCallable() 109 ReleaseCallableResponse* response) override { in ReleaseCallable() [all …]
|
D | grpc_remote_worker.cc | 75 GetStatusResponse* response, bool fail_fast, in GetStatusAsync() 82 CreateWorkerSessionResponse* response, in CreateWorkerSessionAsync() 89 DeleteWorkerSessionResponse* response, in DeleteWorkerSessionAsync() 96 RegisterGraphResponse* response, in RegisterGraphAsync() 102 DeregisterGraphResponse* response, in DeregisterGraphAsync() 108 RunGraphResponse* response, StatusCallback done) override { in RunGraphAsync() 112 MutableRunGraphResponseWrapper* response, in RunGraphAsync() 119 CleanupGraphResponse* response, in CleanupGraphAsync() 125 CleanupAllResponse* response, in CleanupAllAsync() 131 RecvBufResponse* response, StatusCallback done) override { in RecvBufAsync() [all …]
|
D | grpc_master_service_impl.h | 133 ::grpc::ServerAsyncResponseWriter<CreateSessionResponse>* response, in RequestCreateSession() 141 ::grpc::ServerAsyncResponseWriter<ExtendSessionResponse>* response, in RequestExtendSession() 149 ::grpc::ServerAsyncResponseWriter<PartialRunSetupResponse>* response, in RequestPartialRunSetup() 157 ::grpc::ServerAsyncResponseWriter<RunStepResponse>* response, in RequestRunStep() 165 ::grpc::ServerAsyncResponseWriter<CloseSessionResponse>* response, in RequestCloseSession() 173 ::grpc::ServerAsyncResponseWriter<ListDevicesResponse>* response, in RequestListDevices() 181 ::grpc::ServerAsyncResponseWriter<ResetResponse>* response, in RequestReset() 189 ::grpc::ServerAsyncResponseWriter<MakeCallableResponse>* response, in RequestMakeCallable() 197 ::grpc::ServerAsyncResponseWriter<RunCallableResponse>* response, in RequestRunCallable() 205 ::grpc::ServerAsyncResponseWriter<ReleaseCallableResponse>* response, in RequestReleaseCallable()
|
/external/robolectric-shadows/shadows/httpclient/src/test/java/org/robolectric/shadows/httpclient/ |
D | ShadowDefaultRequestDirectorTest.java | 84 HttpResponse response = requestDirector.execute(null, new HttpGet("http://example.com"), null); in shouldGetHttpResponseFromExecute() local 98 HttpResponse response = requestDirector.execute(null, new HttpGet("http://some.uri"), null); in shouldPreferPendingResponses() local 110 HttpResponse response = requestDirector.execute(null, new HttpGet("http://some.uri"), null); in shouldReturnRequestsByRule() local 123 HttpResponse response = requestDirector.execute(null, new HttpGet("http://some.uri"), null); in shouldReturnRequestsByRule_MatchingMethod() local 177 HttpResponse response = requestDirector.execute(null, new HttpGet("http://some.uri"), null); in shouldReturnRequestsByRule_WithTextResponse() local 190 HttpResponse response = requestDirector.execute(null, new HttpGet("http://some.uri"), null); in clearHttpResponseRules_shouldRemoveAllRules() local 203 HttpResponse response = requestDirector.execute(null, new HttpGet("http://some.uri"), null); in clearPendingHttpResponses() local 221 HttpResponse response = requestDirector.execute(null, new HttpGet("http://matching.uri"), null); in shouldReturnRequestsByRule_WithCustomRequestMatcher() local 235 HttpResponse response = requestDirector.execute(null, new HttpGet("http://example.com"), null); in shouldGetHttpResponseFromExecuteSimpleApi() local 324 HttpResponse response = client.execute(new HttpGet("http://www.nowhere.org")); in shouldSupportBasicResponseHandlerHandleResponse() local [all …]
|
/external/llvm-project/lldb/source/Plugins/Process/gdb-remote/ |
D | GDBRemoteCommunicationClient.cpp | 124 StringExtractorGDBRemote response; in HandshakeWithServer() local 220 StringExtractorGDBRemote response; in QueryNoAckModeSupported() local 237 StringExtractorGDBRemote response; in GetListThreadsInStopReplySupported() local 250 StringExtractorGDBRemote response; in GetVAttachOrWaitSupported() local 264 StringExtractorGDBRemote response; in GetSyncThreadStateSupported() local 357 StringExtractorGDBRemote response; in GetRemoteQSupported() local 454 StringExtractorGDBRemote response; in GetThreadSuffixSupported() local 466 StringExtractorGDBRemote response; in GetVContSupported() local 525 lldb::tid_t tid, StreamString &&payload, StringExtractorGDBRemote &response, in SendThreadSpecificPacketAndWaitForResponse() 562 StringExtractorGDBRemote response; in GetThreadPacketSupported() local [all …]
|
D | GDBRemoteCommunicationServerCommon.cpp | 183 StreamString response; in Handle_qHostInfo() local 325 StreamString response; in Handle_qProcessInfoPID() local 420 StreamString response; in Handle_qsProcessInfo() local 441 StreamString response; in Handle_qUserName() local 461 StreamString response; in Handle_qGroupName() local 483 StreamString response; in Handle_qSpeedTest() local 533 StreamString response; in Handle_vFile_Open() local 560 StreamString response; in Handle_vFile_Close() local 571 StreamGDBRemote response; in Handle_vFile_pRead() local 607 StreamGDBRemote response; in Handle_vFile_pWrite() local [all …]
|
/external/perfetto/src/tracing/ipc/consumer/ |
D | consumer_ipc_client_impl.cc | 92 ipc::AsyncResult<protos::gen::EnableTracingResponse> response) { in EnableTracing() 111 [](ipc::AsyncResult<protos::gen::ChangeTraceConfigResponse> response) { in ChangeTraceConfig() 128 [](ipc::AsyncResult<protos::gen::StartTracingResponse> response) { in StartTracing() 144 [](ipc::AsyncResult<protos::gen::DisableTracingResponse> response) { in DisableTracing() 165 [this](ipc::AsyncResult<protos::gen::ReadBuffersResponse> response) { in ReadBuffers() 173 ipc::AsyncResult<protos::gen::ReadBuffersResponse> response) { in OnReadBuffersResponse() 192 ipc::AsyncResult<protos::gen::EnableTracingResponse> response) { in OnEnableTracingResponse() 216 [](ipc::AsyncResult<protos::gen::FreeBuffersResponse> response) { in FreeBuffers() 233 [callback](ipc::AsyncResult<protos::gen::FlushResponse> response) { in Flush() 251 [weak_this](ipc::AsyncResult<protos::gen::DetachResponse> response) { in Detach() [all …]
|
/external/grpc-grpc/test/cpp/interop/ |
D | http2_client.cc | 67 Status Http2Client::SendUnaryCall(SimpleResponse* response) { in SendUnaryCall() 83 SimpleResponse response; in DoRstAfterHeader() local 94 SimpleResponse response; in DoRstAfterData() local 105 SimpleResponse response; in DoRstDuringData() local 115 SimpleResponse response; in DoGoaway() local 135 SimpleResponse response; in DoPing() local 145 SimpleResponse response; in MaxStreamsWorker() local 156 SimpleResponse response; in DoMaxStreams() local
|
D | interop_client.cc | 54 const SimpleRequest* request, const SimpleResponse* response) {} in NoopChecks() 58 const SimpleResponse* response) { in UnaryCompressionChecks() 157 Empty response; in DoEmpty() local 171 SimpleResponse* response) { in PerformLargeUnary() 176 SimpleResponse* response, in PerformLargeUnary() 210 SimpleResponse response; in DoComputeEngineCreds() local 234 SimpleResponse response; in DoOauth2AuthToken() local 258 SimpleResponse response; in DoPerRpcCreds() local 284 SimpleResponse response; in DoJwtTokenCreds() local 300 SimpleResponse response; in DoLargeUnary() local [all …]
|
/external/openscreen/osp/impl/presentation/ |
D | presentation_receiver.cc | 67 const msgs::PresentationStartResponse& response, in WritePresentationInitiationResponse() 74 const msgs::PresentationConnectionOpenResponse& response, in WritePresentationConnectionOpenResponse() 88 const msgs::PresentationTerminationResponse& response, in WritePresentationTerminationResponse() 95 const msgs::PresentationUrlAvailabilityResponse& response, in WritePresentationUrlAvailabilityResponse() 125 msgs::PresentationUrlAvailabilityResponse response; in OnStreamMessage() local 154 msgs::PresentationStartResponse response; in OnStreamMessage() local 185 msgs::PresentationStartResponse response; in OnStreamMessage() local 220 msgs::PresentationConnectionOpenResponse response; in OnStreamMessage() local 252 msgs::PresentationConnectionOpenResponse response; in OnStreamMessage() local 294 msgs::PresentationTerminationResponse response; in OnStreamMessage() local [all …]
|
/external/tensorflow/tensorflow/compiler/xla/client/ |
D | client.cc | 48 TransferToClientResponse response; in Transfer() local 75 TransferToServerResponse response; in TransferToServer() local 104 TransferToInfeedResponse response; in TransferToInfeed() local 129 TransferFromOutfeedResponse response; in TransferFromOutfeed() local 152 ResetDeviceResponse response; in ResetDevice() local 192 ComputeConstantResponse response; in ComputeConstant() local 239 CompileResponse response; in Compile() local 261 ExecuteResponse response; in Execute() local 342 ExecuteParallelResponse response; in ExecuteParallel() local 373 GetDeviceHandlesResponse response; in GetDeviceHandles() local [all …]
|
/external/libbrillo/brillo/dbus/ |
D | dbus_object_test.cc | 87 std::unique_ptr<DBusMethodResponse<std::string>> response, in TestWithMessageAsync() 147 void ExpectError(dbus::Response* response, const std::string& expected_code) { in ExpectError() 164 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 177 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 190 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 203 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 213 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 228 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 241 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local 254 auto response = testing::CallMethod(*dbus_object_, &method_call); in TEST_F() local [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/channelz/ |
D | channelz_service.cc | 42 channelz::v1::GetTopChannelsResponse* response) { in GetTopChannels() 58 channelz::v1::GetServersResponse* response) { in GetServers() 74 channelz::v1::GetServerResponse* response) { in GetServer() 91 channelz::v1::GetServerSocketsResponse* response) { in GetServerSockets() 108 channelz::v1::GetChannelResponse* response) { in GetChannel() 124 channelz::v1::GetSubchannelResponse* response) { in GetSubchannel() 140 channelz::v1::GetSocketResponse* response) { in GetSocket()
|
/external/rust/crates/grpcio-sys/grpc/src/cpp/ext/ |
D | proto_server_reflection.cc | 51 ServerReflectionResponse response; in ServerReflectionInfo() local 100 ListServiceResponse* response) { in ListService() 113 ServerReflectionResponse* response) { in GetFileByName() 130 ServerReflectionResponse* response) { in GetFileContainingSymbol() 147 ServerReflectionResponse* response) { in GetFileContainingExtension() 171 ExtensionNumberResponse* response) { in GetAllExtensionNumbers() 193 ServerReflectionResponse* response, in FillFileDescriptorResponse()
|
/external/nanohttpd/nanolets/src/test/java/fi/iki/elonen/router/ |
D | TestNanolets.java | 111 CloseableHttpResponse response = httpclient.execute(httpget); in doSomeBasicMethodTest() local 148 CloseableHttpResponse response = httpclient.execute(httpget); in doNonRouterRequest() local 160 CloseableHttpResponse response = httpclient.execute(httpget); in doExceptionRequest() local 172 CloseableHttpResponse response = httpclient.execute(httpget); in doDeletedRoute() local 184 CloseableHttpResponse response = httpclient.execute(httpget); in doUriSelection1() local 196 CloseableHttpResponse response = httpclient.execute(httpget); in doStreamOfData() local 241 CloseableHttpResponse response = httpclient.execute(httpget); in doGeneralParams() local 253 CloseableHttpResponse response = httpclient.execute(httpget); in doIndexHandler() local 265 CloseableHttpResponse response = httpclient.execute(httpget); in doMissingHandler() local 284 CloseableHttpResponse response = httpclient.execute(httphead); in doOtherMethod() local [all …]
|
/external/vboot_reference/firmware/lib/tpm_lite/ |
D | tlcl.c | 64 uint8_t* response, int max_length) { in TlclSendReceiveNoRetry() 108 uint32_t TlclSendReceive(const uint8_t* request, uint8_t* response, in TlclSendReceive() 141 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in Send() local 176 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in TlclContinueSelfTest() local 195 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in TlclWrite() local 213 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in TlclRead() local 235 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in TlclPCRRead() local 280 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in TlclAssertPhysicalPresenceResult() local 295 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE + TPM_PUBEK_SIZE]; in TlclIsOwned() local 326 uint8_t response[TPM_LARGE_ENOUGH_COMMAND_SIZE]; in TlclGetPermanentFlags() local [all …]
|