| /third_party/skia/third_party/externals/microhttpd/src/microhttpd/ |
| D | response.c | 51 add_response_entry (struct MHD_Response *response, in add_response_entry() argument
58 if ( (NULL == response) || in add_response_entry()
84 hdr->next = response->first_header; in add_response_entry()
85 response->first_header = hdr; in add_response_entry()
100 MHD_add_response_header (struct MHD_Response *response, in MHD_add_response_header() argument
103 return add_response_entry (response, in MHD_add_response_header()
120 MHD_add_response_footer (struct MHD_Response *response, in MHD_add_response_footer() argument
123 return add_response_entry (response, in MHD_add_response_footer()
140 MHD_del_response_header (struct MHD_Response *response, in MHD_del_response_header() argument
150 pos = response->first_header; in MHD_del_response_header()
[all …]
|
| /third_party/libcoap/tests/ |
| D | test_error_response.c | 34 coap_pdu_t *response; in t_error_response1() local
42 response = coap_new_error_response(pdu, COAP_RESPONSE_CODE(400), &opts); in t_error_response1()
44 CU_ASSERT_PTR_NOT_NULL(response); in t_error_response1()
46 CU_ASSERT(response->used_size == sizeof(teststr) - 4); in t_error_response1()
47 CU_ASSERT(response->type == COAP_MESSAGE_ACK); in t_error_response1()
48 CU_ASSERT(response->token_length == 0); in t_error_response1()
49 CU_ASSERT(response->code == 0x80); in t_error_response1()
50 CU_ASSERT(response->mid == 0x1234); in t_error_response1()
51 CU_ASSERT(coap_pdu_encode_header(response, COAP_PROTO_UDP) == 4); in t_error_response1()
52 CU_ASSERT(memcmp(response->token - 4, teststr, sizeof(teststr)) == 0); in t_error_response1()
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-http2-compat-serverresponse-headers.js | 14 server.once('request', common.mustCall(function(request, response) { argument
20 response.setHeader(real, expectedValue);
22 assert.strictEqual(response.hasHeader(real), true);
23 assert.strictEqual(response.hasHeader(fake), false);
24 assert.strictEqual(response.hasHeader(denormalised), true);
25 assert.strictEqual(response.getHeader(real), expectedValue);
26 assert.strictEqual(response.getHeader(denormalised), expectedValue);
27 assert.strictEqual(response.getHeader(fake), undefined);
29 response.removeHeader(fake);
30 assert.strictEqual(response.hasHeader(fake), false);
[all …]
|
| D | test-http2-compat-serverresponse-end.js | 26 const server = createServer(mustCall((request, response) => {
27 response.end('end', 'utf8', mustCall(() => {
28 response.end(mustCall());
30 response.end(mustCall());
34 response.on('finish', mustCall(() => {
35 response.end(mustCall());
37 response.end(mustCall());
65 const server = createServer(mustCall((request, response) => {
66 strictEqual(response, response.end());
67 strictEqual(response, response.end());
[all …]
|
| D | test-http2-compat-serverresponse-finished.js | 14 server.once('request', common.mustCall((request, response) => {
15 assert.ok(response.socket instanceof net.Socket);
16 assert.ok(response.connection instanceof net.Socket);
17 assert.strictEqual(response.socket, response.connection);
19 response.on('finish', common.mustCall(() => {
20 assert.strictEqual(response.socket, undefined);
21 assert.strictEqual(response.connection, undefined);
23 assert.ok(response.stream);
27 assert.strictEqual(response.finished, false);
28 assert.strictEqual(response.writableEnded, false);
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/common/ |
| D | gas_server.c | 55 static void gas_server_free_response(struct gas_server_response *response);
60 struct gas_server_response *response = eloop_ctx; in gas_server_response_timeout() local
64 response, MAC2STR(response->dst), response->dialog_token, in gas_server_response_timeout()
65 response->freq, response->frag_id, in gas_server_response_timeout()
66 (unsigned long) response->offset, in gas_server_response_timeout()
67 (unsigned long) (response->resp ? in gas_server_response_timeout()
68 wpabuf_len(response->resp) : 0)); in gas_server_response_timeout()
69 response->handler->status_cb(response->handler->ctx, in gas_server_response_timeout()
70 response->resp, 0); in gas_server_response_timeout()
71 response->resp = NULL; in gas_server_response_timeout()
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/common/ |
| D | gas_server.c | 52 static void gas_server_free_response(struct gas_server_response *response);
57 struct gas_server_response *response = eloop_ctx; in gas_server_response_timeout() local
61 response, MAC2STR(response->dst), response->dialog_token, in gas_server_response_timeout()
62 response->freq, response->frag_id, in gas_server_response_timeout()
63 (unsigned long) response->offset, in gas_server_response_timeout()
64 (unsigned long) wpabuf_len(response->resp)); in gas_server_response_timeout()
65 response->handler->status_cb(response->handler->ctx, in gas_server_response_timeout()
66 response->resp, 0); in gas_server_response_timeout()
67 response->resp = NULL; in gas_server_response_timeout()
68 dl_list_del(&response->list); in gas_server_response_timeout()
[all …]
|
| /third_party/gptfdisk/ |
| D | support.cc | 80 uint64_t response, num; in GetNumber() local
89 num = sscanf(line, "%" PRIu64, &response); in GetNumber()
91 if ((response < low) || (response > high)) in GetNumber()
94 response = def; in GetNumber()
96 } while ((response < low) || (response > high)); in GetNumber()
99 response = low; in GetNumber()
101 return (response); in GetNumber()
106 char response; in GetYN() local
115 response = toupper(line[0]); in GetYN()
116 } while ((response != 'Y') && (response != 'N')); in GetYN()
[all …]
|
| /third_party/protobuf/js/experimental/runtime/kernel/conformance/ |
| D | conformance_testee.js | 17 const response = ConformanceResponse.createEmpty();
20 response.setSkipped('Json is not supported as input format.');
21 return response;
25 response.setSkipped('Text format is not supported as input format.');
26 return response;
30 response.setRuntimeError('Request didn\'t have payload.');
31 return response;
39 response.setSkipped('Json is not supported as output format.');
40 return response;
44 response.setSkipped('Text format is not supported as output format.');
[all …]
|
| /third_party/grpc/test/cpp/util/ |
| D | proto_reflection_descriptor_database.cc | 74 ServerReflectionResponse response; in FindFileByName() local
76 if (!DoOneRequest(request, response)) { in FindFileByName()
80 if (response.message_response_case() == in FindFileByName()
82 AddFileFromResponse(response.file_descriptor_response()); in FindFileByName()
83 } else if (response.message_response_case() == in FindFileByName()
85 const ErrorResponse& error = response.error_response(); in FindFileByName()
103 response.message_response_case()); in FindFileByName()
121 ServerReflectionResponse response; in FindFileContainingSymbol() local
123 if (!DoOneRequest(request, response)) { in FindFileContainingSymbol()
127 if (response.message_response_case() == in FindFileContainingSymbol()
[all …]
|
| /third_party/protobuf/conformance/ |
| D | conformance_nodejs.js | 44 var response = new conformance.ConformanceResponse();
48 response.setSkipped("JSON not supported.");
49 return response;
59 response.setParseError(err.toString());
60 return response;
67 response.setParseError(err.toString());
68 return response;
76 response.setSkipped("JSON not supported.");
77 return response;
80 response.setSkipped("Text format not supported.");
[all …]
|
| D | conformance_ruby.rb | 41 response = Conformance::ConformanceResponse.new
51 response.parse_error = err.message.encode('utf-8')
52 return response
55 response.skipped = "Ruby doesn't support proto2"
56 return response
66 response.parse_error = err.message.encode('utf-8')
67 return response
72 response.skipped = "Ruby doesn't support proto2"
73 return response
85 response.protobuf_payload = test_message.to_proto
[all …]
|
| D | conformance_php.php | 31 $response = new \Conformance\ConformanceResponse();
34 $response->setProtobufPayload("");
35 return $response;
40 $response->setParseError($e->getMessage());
41 return $response;
44 $response->setSkipped("PHP doesn't support proto2");
45 return $response;
57 $response->setParseError($e->getMessage());
58 return $response;
61 $response->setSkipped("PHP doesn't support text format yet");
[all …]
|
| /third_party/grpc/test/core/tsi/alts/fake_handshaker/ |
| D | fake_handshaker_server.cc | 68 HandshakerResp response; in DoHandshake() local
71 status = ProcessRequest(&context, request, &response); in DoHandshake()
73 stream->Write(response); in DoHandshake()
96 HandshakerResp* response) { in ProcessRequest() argument
97 GPR_ASSERT(context != nullptr && response != nullptr); in ProcessRequest()
98 response->Clear(); in ProcessRequest()
101 return ProcessClientStart(context, request.client_start(), response); in ProcessRequest()
104 return ProcessServerStart(context, request.server_start(), response); in ProcessRequest()
107 return ProcessNext(context, request.next(), response); in ProcessRequest()
114 HandshakerResp* response) { in ProcessClientStart() argument
[all …]
|
| /third_party/cef/tests/ceftests/ |
| D | response_unittest.cc | 10 CefRefPtr<CefResponse> response(CefResponse::Create()); in TEST() local
11 EXPECT_TRUE(response.get() != nullptr); in TEST()
15 response->SetHeaderByName("HeaderA", "ValueA", false); in TEST()
16 response->SetHeaderByName("HeaderB", "ValueB", false); in TEST()
23 response->GetHeaderByName("headera").ToString().c_str()); in TEST()
25 response->GetHeaderByName("headerb").ToString().c_str()); in TEST()
26 EXPECT_STREQ("", response->GetHeaderByName("noexist").ToString().c_str()); in TEST()
28 response->GetHeaderMap(headers); in TEST()
32 response->SetHeaderByName("HeaderA", "ValueANew", true); in TEST()
40 response->GetHeaderByName("headerA").ToString().c_str()); in TEST()
[all …]
|
| /third_party/nghttp2/src/ |
| D | asio_server_response.cc | 37 response::response() : impl_(std::make_unique<response_impl>()) {} in response() function in nghttp2::asio_http2::server::response
39 response::~response() {} in ~response()
41 void response::write_head(unsigned int status_code, header_map h) const { in write_head()
45 void response::end(std::string data) const { impl_->end(std::move(data)); } in end()
47 void response::end(generator_cb cb) const { impl_->end(std::move(cb)); } in end()
49 void response::write_trailer(header_map h) const { in write_trailer()
53 void response::on_close(close_cb cb) const { impl_->on_close(std::move(cb)); } in on_close()
55 void response::cancel(uint32_t error_code) const { impl_->cancel(error_code); } in cancel()
57 const response *response::push(boost::system::error_code &ec, in push()
63 void response::resume() const { impl_->resume(); } in resume()
[all …]
|
| /third_party/skia/tools/skiaserve/ |
| D | Response.cpp | 47 MHD_Response* response = MHD_create_response_from_buffer(strlen(data), in SendOK() local
50 int ret = MHD_queue_response(connection, 200, response); in SendOK()
51 MHD_destroy_response(response); in SendOK()
56 MHD_Response* response = MHD_create_response_from_buffer(strlen(msg), in SendError() local
59 int ret = MHD_queue_response(connection, 500, response); in SendError()
60 MHD_destroy_response(response); in SendError()
66 MHD_Response* response = MHD_create_response_from_buffer(data->size(), in SendData() local
69 MHD_add_response_header(response, "Content-Type", type); in SendData()
72 MHD_add_response_header(response, "Content-Disposition", dispositionString); in SendData()
75 int ret = MHD_queue_response(connection, MHD_HTTP_OK, response); in SendData()
[all …]
|
| /third_party/flutter/skia/tools/skiaserve/ |
| D | Response.cpp | 47 MHD_Response* response = MHD_create_response_from_buffer(strlen(data), in SendOK() local
50 int ret = MHD_queue_response(connection, 200, response); in SendOK()
51 MHD_destroy_response(response); in SendOK()
56 MHD_Response* response = MHD_create_response_from_buffer(strlen(msg), in SendError() local
59 int ret = MHD_queue_response(connection, 500, response); in SendError()
60 MHD_destroy_response(response); in SendError()
66 MHD_Response* response = MHD_create_response_from_buffer(data->size(), in SendData() local
69 MHD_add_response_header(response, "Content-Type", type); in SendData()
72 MHD_add_response_header(response, "Content-Disposition", dispositionString); in SendData()
75 int ret = MHD_queue_response(connection, MHD_HTTP_OK, response); in SendData()
[all …]
|
| /third_party/grpc/test/cpp/interop/ |
| D | http2_client.cc | 67 Status Http2Client::SendUnaryCall(SimpleResponse* response) { in SendUnaryCall() argument
69 return serviceStub_.Get()->UnaryCall(&context, defaultRequest_, response); in SendUnaryCall()
83 SimpleResponse response; in DoRstAfterHeader() local
84 AssertStatusCode(SendUnaryCall(&response), grpc::StatusCode::INTERNAL); in DoRstAfterHeader()
85 GPR_ASSERT(!response.has_payload()); // no data should be received in DoRstAfterHeader()
94 SimpleResponse response; in DoRstAfterData() local
95 AssertStatusCode(SendUnaryCall(&response), grpc::StatusCode::INTERNAL); in DoRstAfterData()
105 SimpleResponse response; in DoRstDuringData() local
106 AssertStatusCode(SendUnaryCall(&response), grpc::StatusCode::INTERNAL); in DoRstDuringData()
107 GPR_ASSERT(!response.has_payload()); // no data should be received in DoRstDuringData()
[all …]
|
| /third_party/grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 253 EchoResponse* response) override { in Echo() argument
256 return stub_->Echo(client_context.get(), *request, response); in Echo()
267 EchoResponse* response) override { in Echo() argument
268 response->set_message("no package"); in Echo()
472 EchoResponse response; in SendRpc() local
483 Status s = stub->Echo(&context, request, &response); in SendRpc()
484 EXPECT_EQ(response.message(), request.message()); in SendRpc()
511 EchoResponse response; in TestRequestStreamServerCancel() local
518 auto stream = stub_->RequestStream(&context, &response); in TestRequestStreamServerCancel()
589 EchoResponse response; in TestResponseStreamServerCancel() local
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | graph_data_service_impl.cc | 46 Status GraphDataServiceImpl::FillDefaultFeature(GnnClientRegisterResponsePb *response) { in FillDefaultFeature() argument
49 GnnFeatureInfoPb *feature_info = response->add_default_node_feature(); in FillDefaultFeature()
55 GnnFeatureInfoPb *feature_info = response->add_default_edge_feature(); in FillDefaultFeature()
64 GnnClientRegisterResponsePb *response) { in ClientRegister() argument
70 response->set_error_msg("Initializing"); in ClientRegister()
73 response->set_error_msg("Success"); in ClientRegister()
74 response->set_data_schema(graph_data_impl_->GetDataSchema()); in ClientRegister()
75 response->set_shared_memory_key(graph_data_impl_->GetSharedMemoryKey()); in ClientRegister()
76 response->set_shared_memory_size(graph_data_impl_->GetSharedMemorySize()); in ClientRegister()
77 s = FillDefaultFeature(response); in ClientRegister()
[all …]
|
| D | graph_data_service_impl.h | 39 GnnClientRegisterResponsePb *response);
42 GnnClientUnRegisterResponsePb *response);
45 GnnGraphDataResponsePb *response);
48 GnnMetaInfoResponsePb *response);
50 Status GetAllNodes(const GnnGraphDataRequestPb *request, GnnGraphDataResponsePb *response);
51 Status GetAllEdges(const GnnGraphDataRequestPb *request, GnnGraphDataResponsePb *response);
52 Status GetNodesFromEdges(const GnnGraphDataRequestPb *request, GnnGraphDataResponsePb *response);
53 Status GetEdgesFromNodes(const GnnGraphDataRequestPb *request, GnnGraphDataResponsePb *response);
54 Status GetAllNeighbors(const GnnGraphDataRequestPb *request, GnnGraphDataResponsePb *response);
55 …Status GetSampledNeighbors(const GnnGraphDataRequestPb *request, GnnGraphDataResponsePb *response);
[all …]
|
| /third_party/skia/third_party/externals/microhttpd/src/microspdy/ |
| D | applicationlayer.c | 36 struct SPDY_Response *response, in spdy_callback_response_done() argument
46 SPDY_destroy_response(response); in spdy_callback_response_done()
227 …response_queue->rrcb(response_queue->rrcb_cls, response_queue->response, request, status, streamop… in spdy_handler_response_queue_result()
398 struct SPDY_Response *response = NULL; in SPDY_build_response() local
410 if(NULL == (response = malloc(sizeof(struct SPDY_Response)))) in SPDY_build_response()
412 memset(response, 0, sizeof(struct SPDY_Response)); in SPDY_build_response()
443 if(0 >= (response->headers_size = SPDYF_name_value_to_stream(all_headers, in SPDY_build_response()
445 &(response->headers)))) in SPDY_build_response()
455 if(NULL == (response->data = malloc(size))) in SPDY_build_response()
457 free(response->headers); in SPDY_build_response()
[all …]
|
| /third_party/flutter/flutter/packages/flutter/test/foundation/ |
| D | consolidate_response_test.dart | 20 MockHttpClientResponse response;
23 response = MockHttpClientResponse();
24 when(response.compressionState).thenReturn(HttpClientResponseCompressionState.notCompressed);
25 when(response.listen(
47 when(response.contentLength)
50 await consolidateHttpClientResponseBytes(response);
56 when(response.contentLength).thenReturn(chunkOne.length);
58 await consolidateHttpClientResponseBytes(response);
64 when(response.contentLength).thenReturn(-1);
66 await consolidateHttpClientResponseBytes(response);
[all …]
|
| /third_party/grpc/src/cpp/ext/ |
| D | proto_server_reflection.cc | 51 ServerReflectionResponse response; in ServerReflectionInfo() local
56 status = GetFileByName(context, request.file_by_filename(), &response); in ServerReflectionInfo()
60 context, request.file_containing_symbol(), &response); in ServerReflectionInfo()
65 context, &request.file_containing_extension(), &response); in ServerReflectionInfo()
71 response.mutable_all_extension_numbers_response()); in ServerReflectionInfo()
75 ListService(context, response.mutable_list_services_response()); in ServerReflectionInfo()
82 FillErrorResponse(status, response.mutable_error_response()); in ServerReflectionInfo()
84 response.set_valid_host(request.host()); in ServerReflectionInfo()
85 response.set_allocated_original_request( in ServerReflectionInfo()
87 stream->Write(response); in ServerReflectionInfo()
[all …]
|