Home
last modified time | relevance | path

Searched refs:message_size (Results 1 – 25 of 28) sorted by relevance

12

/external/libmojo/mojo/edk/test/
Dmojo_test_base.cc130 uint32_t message_size = 0; in ReadMessageWithHandles() local
132 CHECK_EQ(MojoReadMessage(mp, nullptr, &message_size, nullptr, &num_handles, in ReadMessageWithHandles()
137 std::string message(message_size, 'x'); in ReadMessageWithHandles()
138 CHECK_EQ(MojoReadMessage(mp, &message[0], &message_size, handles, in ReadMessageWithHandles()
141 CHECK_EQ(message_size, message.size()); in ReadMessageWithHandles()
154 uint32_t message_size = 0; in ReadMessageWithOptionalHandle() local
156 CHECK_EQ(MojoReadMessage(mp, nullptr, &message_size, nullptr, &num_handles, in ReadMessageWithOptionalHandle()
163 std::string message(message_size, 'x'); in ReadMessageWithOptionalHandle()
164 CHECK_EQ(MojoReadMessage(mp, &message[0], &message_size, handle, in ReadMessageWithOptionalHandle()
167 CHECK_EQ(message_size, message.size()); in ReadMessageWithOptionalHandle()
[all …]
/external/curl/tests/libtest/
Dlib571.c56 int message_size; in rtp_write() local
62 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
64 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
65 if(message_size != coded_size) { in rtp_write()
67 coded_size, message_size); in rtp_write()
72 for(i = 0; i < message_size; i+= RTP_DATA_SIZE) { in rtp_write()
73 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
80 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
82 message_size - i, data + i); in rtp_write()
/external/libmojo/mojo/public/cpp/bindings/tests/
De2e_perftest.cc56 void RunTest(int iterations, int batch_size, int message_size);
80 void PingPongTest::RunTest(int iterations, int batch_size, int message_size) { in RunTest() argument
83 message_ = std::string(message_size, 'a'); in RunTest()
150 for (int message_size : kMessageSizes) { in RunTests() local
152 if (message_size == 65536) in RunTests()
156 batch_size, message_size); in RunTests()
158 test.RunTest(num_messages / batch_size, batch_size, message_size); in RunTests()
/external/libmojo/mojo/edk/system/
Dmessage_pipe_perftest.cc36 void SetUpMeasurement(int message_count, size_t message_size) { in SetUpMeasurement() argument
38 message_size_ = message_size; in SetUpMeasurement()
39 payload_ = std::string(message_size, '*'); in SetUpMeasurement()
40 read_buffer_.resize(message_size * 2); in SetUpMeasurement()
Dbroker_messages.h39 const size_t message_size = sizeof(BrokerMessageHeader) + sizeof(T); in CreateBrokerMessage() local
40 Channel::MessagePtr message(new Channel::Message(message_size, num_handles)); in CreateBrokerMessage()
Dmessage_pipe_dispatcher.cc533 size_t message_size = 0; in OnPortStatusChanged() local
535 port_, [&message_size](const ports::Message& message) { in OnPortStatusChanged()
536 message_size = message.num_payload_bytes(); in OnPortStatusChanged()
541 << "; size=" << message_size << "]"; in OnPortStatusChanged()
/external/libcxx/test/std/diagnostics/syserr/syserr.errcondition/syserr.errcondition.nonmembers/
Dmake_error_condition.pass.cpp22 const std::error_condition ec1 = std::make_error_condition(std::errc::message_size); in main()
23 assert(ec1.value() == static_cast<int>(std::errc::message_size)); in main()
/external/fmtlib/test/
Dformat-impl-test.cc79 std::size_t message_size = std::strlen(message); in TEST() local
80 EXPECT_GE(BUFFER_SIZE - 1u, message_size); in TEST()
85 result = fmt::safe_strerror(error_code, message = buffer, message_size); in TEST()
/external/protobuf/python/google/protobuf/internal/
Dwire_format.py214 message_size = msg.ByteSize()
217 total_size += _VarUInt64ByteSizeNoTag(message_size)
220 total_size += message_size
/external/nanopb-c/generator/google/protobuf/internal/
Dwire_format.py214 message_size = msg.ByteSize()
217 total_size += _VarUInt64ByteSizeNoTag(message_size)
220 total_size += message_size
/external/libmojo/ipc/
Dipc_message.cc145 : message_size(0), message_found(false), pickle_end(nullptr), in NextMessageInfo()
175 info->message_size = 0; in FindNext()
220 info->message_size = info->message_end - range_start; in FindNext()
222 info->message_size = pickle_size; in FindNext()
Dipc_message.h182 size_t message_size; member
/external/google-tv-pairing-protocol/cpp/tests/polo/wire/protobuf/
Dprotobufwireadaptertest.cc78 void ExpectReadPreamble(uint32_t message_size) { in ExpectReadPreamble() argument
82 util::PoloUtil::IntToBigEndianBytes(message_size, size_bytes); in ExpectReadPreamble()
83 EXPECT_CALL(interface_, Receive(message_size)); in ExpectReadPreamble()
/external/protobuf/src/google/protobuf/
Dextension_set_heavy.cc720 int message_size = 0; in MessageSetItemByteSize() local
722 message_size = lazymessage_value->ByteSize(); in MessageSetItemByteSize()
724 message_size = message_value->ByteSize(); in MessageSetItemByteSize()
727 our_size += io::CodedOutputStream::VarintSize32(message_size); in MessageSetItemByteSize()
728 our_size += message_size; in MessageSetItemByteSize()
Dwire_format.cc1123 int message_size = sub_message.ByteSize(); in MessageSetItemByteSize() local
1125 our_size += io::CodedOutputStream::VarintSize32(message_size); in MessageSetItemByteSize()
1126 our_size += message_size; in MessageSetItemByteSize()
/external/netperf/src/
Dnettest_unix.c1660 dg_stream_request->message_size = send_size; in send_dg_stream()
1940 int message_size; in recv_dg_stream() local
1996 dg_stream_request->message_size, in recv_dg_stream()
2079 message_size = dg_stream_request->message_size; in recv_dg_stream()
2108 message_size, in recv_dg_stream()
2109 0)) != message_size) { in recv_dg_stream()
2146 bytes_received = (messages_recvd * message_size) + len; in recv_dg_stream()
Dnettest_unix.h105 int message_size; member
Dnettest_dlpi.h111 int message_size; member
Dnettest_xti.h152 int message_size; member
Dnettest_dlpi.c1997 dlpi_cl_stream_request->message_size = send_size; in send_dlpi_cl_stream()
2319 int message_size; in recv_dlpi_cl_stream() local
2379 if (dlpi_cl_stream_request->message_size > 0) { in recv_dlpi_cl_stream()
2380 recv_message.maxlen = dlpi_cl_stream_request->message_size; in recv_dlpi_cl_stream()
2487 message_size = dlpi_cl_stream_request->message_size; in recv_dlpi_cl_stream()
2555 bytes_received = (messages_recvd * message_size) + len; in recv_dlpi_cl_stream()
Dnettest_xti.c2631 xti_udp_stream_request->message_size = send_size; in send_xti_udp_stream()
3077 unsigned int message_size; in recv_xti_udp_stream() local
3133 xti_udp_stream_request->message_size, in recv_xti_udp_stream()
3256 message_size = xti_udp_stream_request->message_size; in recv_xti_udp_stream()
3277 unitdata.udata.maxlen = xti_udp_stream_request->message_size; in recv_xti_udp_stream()
3278 unitdata.udata.len = xti_udp_stream_request->message_size; in recv_xti_udp_stream()
3362 bytes_received = (messages_recvd * message_size); in recv_xti_udp_stream()
Dnettest_bsd.h435 int message_size; member
/external/parameter-framework/asio-1.10.6/include/asio/
Derror.hpp82 message_size = ASIO_SOCKET_ERROR(EMSGSIZE), enumerator
/external/libcxx/test/std/diagnostics/syserr/
Derrc.pass.cpp50 static_assert(static_cast<int>(std::errc::message_size) == EMSGSIZE, ""); in main()
/external/swiftshader/third_party/LLVM/lib/Support/Windows/
Dsystem_error.inc126 MAP_ERR_TO_COND(WSAEMSGSIZE, message_size);

12