| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_server.cc | 153 response->mutable_payload()->set_body(timestamp.c_str(), timestamp.size()); in CacheableUnaryCall()
178 if (!SetPayload(request->response_size(), response->mutable_payload())) { in UnaryCall()
201 response.mutable_payload())) { in StreamingOutputCall()
268 response.mutable_payload()->set_type(request.payload().type()); in FullDuplexCall()
269 response.mutable_payload()->set_body( in FullDuplexCall()
302 response.mutable_payload()->set_type(requests[i].payload().type()); in HalfDuplexCall()
307 response.mutable_payload()->set_body( in HalfDuplexCall()
|
| D | interop_client.cc | 182 request->mutable_payload()->set_body(payload.c_str(), kLargeRequestSize); in PerformLargeUnary()
318 probe_req.mutable_payload()->set_body(grpc::string(kLargeRequestSize, '\0')); in DoClientCompressedUnary()
402 Payload* payload = request.mutable_payload(); in DoRequestStreaming()
468 probe_req.mutable_payload()->set_body(grpc::string(27182, '\0')); in DoClientCompressedStreaming()
497 request.mutable_payload()->set_body(grpc::string(27182, '\0')); in DoClientCompressedStreaming()
507 request.mutable_payload()->set_body(grpc::string(45904, '\0')); in DoClientCompressedStreaming()
685 Payload* payload = request.mutable_payload(); in DoPingPong()
753 request.mutable_payload()->set_body(grpc::string(27182, '\0')); in DoCancelAfterFirstResponse()
788 request.mutable_payload()->set_body(grpc::string(27182, '\0')); in DoTimeoutOnSleepingServer()
875 request.mutable_payload()->set_body(timestamp.c_str(), timestamp.size()); in DoCacheableUnary()
[all …]
|
| D | http2_client.cc | 76 request.mutable_payload()->set_body(payload.c_str(), kLargeRequestSize); in BuildDefaultRequest()
|
| /external/libchrome/mojo/core/ |
| D | broker_messages.h | 56 auto* header = static_cast<BrokerMessageHeader*>(message->mutable_payload()); in GetBrokerMessageData()
72 reinterpret_cast<BrokerMessageHeader*>(message->mutable_payload());
88 reinterpret_cast<BrokerMessageHeader*>(message->mutable_payload()); in CreateBrokerMessage()
|
| D | node_channel.cc | 138 Header* header = reinterpret_cast<Header*>(message->mutable_payload()); in CreateMessage()
189 *data = reinterpret_cast<Header*>(message->mutable_payload()) + 1; in GetEventMessageData()
557 memcpy(message->mutable_payload(), payload, payload_size); in OnChannelMessage()
667 memcpy(message->mutable_payload(), data + 1, num_bytes); in OnChannelMessage()
|
| D | user_message_impl.cc | 111 static_cast<char*>(original_message->mutable_payload())); in CreateOrExtendSerializedEventMessage()
500 header_ = static_cast<uint8_t*>(channel_message_->mutable_payload()) + in AppendData()
503 static_cast<uint8_t*>(channel_message_->mutable_payload()) + in AppendData()
|
| D | channel.h | 172 void* mutable_payload();
|
| D | channel_posix.cc | 533 memcpy(fds_message->mutable_payload(), fds.data(), in WriteNoLock()
627 memcpy(message->mutable_payload(), payload, payload_size); in OnControlMessage()
|
| D | channel.cc | 236 memcpy(message->mutable_payload(), payload, payload_size); in Deserialize()
320 void* Channel::Message::mutable_payload() { in mutable_payload() function in mojo::core::Channel::Message
|
| D | channel_unittest.cc | 82 char* payload = static_cast<char*>(message->mutable_payload()); in CreateDefaultMessage()
|
| /external/protobuf/src/google/protobuf/util/ |
| D | field_mask_util_test.cc | 412 nested_src.mutable_child()->mutable_payload()->set_optional_int32(1234); in TEST()
415 ->mutable_payload() in TEST()
443 nested_dst.mutable_child()->mutable_payload()->set_optional_int64(4321); in TEST()
458 nested_dst.mutable_payload(); in TEST()
466 nested_dst.mutable_payload(); in TEST()
471 nested_src.mutable_payload()->add_repeated_int32(1234); in TEST()
472 nested_dst.mutable_payload()->add_repeated_int32(5678); in TEST()
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | control_message_handler.cc | 100 message->mutable_payload()); in Run()
134 message->mutable_payload()); in RunOrClosePipe()
|
| D | pipe_control_message_handler.cc | 67 message->mutable_payload()); in RunOrClosePipe()
|
| D | control_message_proxy.cc | 62 message->mutable_payload()); in Accept()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_sync.cc | 124 response->mutable_payload())) { in ClientPull()
147 response->mutable_payload())) { in SetResponse()
|
| D | client.h | 75 req->mutable_payload()->set_type( in ClientRequestCreator()
79 req->mutable_payload()->set_body(body.get(), size); in ClientRequestCreator()
86 req->mutable_payload()->set_type( in ClientRequestCreator()
|
| D | server_async.cc | 548 response->mutable_payload())) { in ProcessSimpleRPC()
|
| /external/libchrome/mojo/public/tools/bindings/generators/cpp_templates/ |
| D | interface_definition.tmpl | 314 message->mutable_payload());
386 message->mutable_payload());
438 message->mutable_payload());
496 message->mutable_payload());
|
| /external/libchrome/base/ |
| D | pickle.h | 270 char* mutable_payload() { in mutable_payload() function
|
| D | pickle.cc | 420 char* write = mutable_payload() + write_offset_; in ClaimUninitializedBytesInternal()
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | message.h | 150 uint8_t* mutable_payload() { return const_cast<uint8_t*>(payload()); } in COMPONENT_EXPORT()
|
| /external/tensorflow/tensorflow/tools/proto_text/ |
| D | gen_proto_text_functions_lib_test.cc | 326 cur->mutable_payload()->set_optional_int32(1000 + depth); in TEST()
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | struct_unittest.cc | 86 reinterpret_cast<OutputDataType>(message.mutable_payload()); in SerializeAndDeserialize()
|