Home
last modified time | relevance | path

Searched refs:message_string (Results 1 – 10 of 10) sorted by relevance

/aosp_15_r20/system/core/init/
H A Dproto_utils.h44 std::string message_string; in SendMessage() local
45 if (!message.SerializeToString(&message_string)) { in SendMessage()
49 if (message_string.size() > kBufferSize) { in SendMessage()
54 TEMP_FAILURE_RETRY(send(socket, message_string.c_str(), message_string.size(), 0)); in SendMessage()
55 result != static_cast<long>(message_string.size())) { in SendMessage()
/aosp_15_r20/system/server_configurable_flags/aconfigd/
H A Daconfigd_socket_test.cpp71 auto message_string = std::string(); in send_message() local
72 if (!messages.SerializeToString(&message_string)) { in send_message()
77 uint32_t msg_size = message_string.size(); in send_message()
89 send(*sock_fd, message_string.c_str(), message_string.size(), 0)); in send_message()
90 if (num_bytes != static_cast<long>(message_string.size())) { in send_message()
H A Dlib.rs100 fn handle_socket_request(&self, message_string: &CxxString) -> CppStringResult; in handle_socket_request()
/aosp_15_r20/device/google/cuttlefish/host/commands/kernel_log_monitor/
Dutils.cc52 std::string message_string = Json::writeString(factory, event_message); in WriteEvent() local
53 size_t length = message_string.length(); in WriteEvent()
59 retval = WriteAll(fd, message_string); in WriteEvent()
/aosp_15_r20/device/google/cuttlefish/host/frontend/webrtc/libdevice/
Ddata_channels.cpp406 std::string message_string = Json::writeString(factory, message); in Send() local
407 return Send(reinterpret_cast<const uint8_t *>(message_string.c_str()), in Send()
408 message_string.size(), /*binary=*/false); in Send()
/aosp_15_r20/out/soong/.intermediates/system/server_configurable_flags/aconfigd/libcxx_aconfigd_bridge_code/gen/
Dlibcxx_aconfigd_cxx_generated.cc166 …est(::aconfigdwrapper::CppAconfigd const &self, ::std::string const &message_string, ::aconfigdwra… in aconfigdwrapper$cxxbridge1$CppAconfigd$handle_socket_request() argument
168 new (return$) ::aconfigdwrapper::CppStringResult((self.*handle_socket_request$)(message_string)); in aconfigdwrapper$cxxbridge1$CppAconfigd$handle_socket_request()
/aosp_15_r20/external/rust/android-crates-io/crates/rayon/src/iter/collect/
Dtest.rs356 let message_string = error.downcast_ref::<String>().map(String::as_str); in assert_is_panic_with_message() localVariable
357 if let Some(message) = message_str.or(message_string) { in assert_is_panic_with_message()
/aosp_15_r20/external/cronet/net/http/
H A Dhttp_auth_gssapi_posix.cc169 std::string_view message_string{ in GetGssStatusCodeValue() local
174 if (!base::IsStringUTF8(message_string)) in GetGssStatusCodeValue()
177 messages.Append(message_string); in GetGssStatusCodeValue()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcall.cc3012 absl::string_view message_string; in StartRecvStatusOnClient() local
3015 message_string = message->as_string_view(); in StartRecvStatusOnClient()
3020 if (message_string.empty()) { in StartRecvStatusOnClient()
3023 std::string error_string(message_string); in StartRecvStatusOnClient()
3248 absl::string_view message_string; in Finish() local
3250 message_string = message->as_string_view(); in Finish()
3253 if (message_string.empty()) { in Finish()
3256 std::string error_string(message_string); in Finish()
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
H A Dend_to_end_test.cc5151 std::string message_string(kMaxOutgoingPacketSize, 'a'); in TEST_P() local
5159 message_string.data(), in TEST_P()
5170 absl::string_view(message_string.data(), message_length))); in TEST_P()
5183 message_string.data(), in TEST_P()