Home
last modified time | relevance | path

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

12

/external/curl/tests/libtest/
Dlib571.c57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
/external/libchrome/mojo/public/cpp/bindings/tests/
De2e_perftest.cc55 void RunTest(int iterations, int batch_size, int message_size);
79 void PingPongTest::RunTest(int iterations, int batch_size, int message_size) { in RunTest() argument
82 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/libchrome/ipc/
Dipc_message_unittest.cc141 EXPECT_EQ(next.message_size, message.size()); in TEST()
148 EXPECT_EQ(next.message_size, message.size()); in TEST()
156 EXPECT_EQ(next.message_size, message.size()); in TEST()
164 EXPECT_EQ(next.message_size, 0u); in TEST()
171 EXPECT_EQ(next.message_size, 0u); in TEST()
190 EXPECT_EQ(next.message_size, in TEST()
194 EXPECT_EQ(next.message_size, std::numeric_limits<size_t>::max()); in TEST()
202 EXPECT_EQ(next.message_size, in TEST()
Dipc_message.cc133 : message_size(0), message_found(false), pickle_end(nullptr), in NextMessageInfo()
143 info->message_size = 0; in FindNext()
153 info->message_size = pickle_size; in FindNext()
Dipc_cpu_perftest.cc34 : message_size(in_message_size), in TestParams()
39 size_t message_size; member
55 params.message_size, params.frames_per_second, params.messages_per_frame); in GetLogTitle()
113 payload_ = std::string(params.message_size, 'a'); in SetTestParams()
284 payload_ = std::string(params.message_size, 'a'); in RunPingPongServer()
Dipc_mojo_perftest.cc130 size_t message_size() const { return message_size_; } in message_size() function in IPC::__anon368bd5500111::PingPongTestParams
199 params[i].message_size(), false); in RunTestChannelProxyPingPong()
233 params[i].message_size(), true); in RunTestChannelProxySyncPing()
294 payload_ = std::string(params[i].message_size(), 'a'); in RunPingPongServer()
724 payload_ = std::string(params[i].message_size(), 'a'); in RunMultiThreadPingPongServer()
768 payload_ = std::string(params[i].message_size(), 'a'); in RunSingleThreadNoPostTaskPingPongServer()
800 payload_ = std::string(params[i].message_size(), 'a'); in RunSingleThreadPostTaskPingPongServer()
Dipc_channel_reader.cc130 next_message_size = info.message_size; in TranslateInputData()
Dipc_message.h184 size_t message_size; member
/external/libchrome/mojo/core/
Dmessage_pipe_perftest.cc35 void SetUpMeasurement(int message_count, size_t message_size) { in SetUpMeasurement() argument
37 message_size_ = message_size; in SetUpMeasurement()
38 payload_ = std::string(message_size, '*'); in SetUpMeasurement()
39 read_buffer_.resize(message_size * 2); in SetUpMeasurement()
Dbroker_messages.h68 const size_t message_size = sizeof(BrokerMessageHeader) + variable
70 Channel::MessagePtr message(new Channel::Message(message_size, num_handles));
Dmessage_pipe_dispatcher.cc76 size_t message_size() const { return message_size_; } in message_size() function in mojo::core::PeekSizeMessageFilter
413 << "; size=" << filter.message_size() << "]"; in OnPortStatusChanged()
/external/grpc-grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc170 size_t message_size = GRPC_SLICE_LENGTH(encrypted); in on_read() local
172 while (message_size > 0 || keep_looping) { in on_read()
174 size_t processed_message_size = message_size; in on_read()
186 message_size -= processed_message_size; in on_read()
286 size_t message_size = GRPC_SLICE_LENGTH(plain); in endpoint_write() local
287 while (message_size > 0) { in endpoint_write()
289 size_t processed_message_size = message_size; in endpoint_write()
301 message_size -= processed_message_size; in endpoint_write()
/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/grpc-grpc/test/core/security/
Dsecure_endpoint_test.cc82 size_t message_size = GRPC_SLICE_LENGTH(plain); in secure_endpoint_create_fixture_tcp_socketpair() local
83 while (message_size > 0) { in secure_endpoint_create_fixture_tcp_socketpair()
85 size_t processed_message_size = message_size; in secure_endpoint_create_fixture_tcp_socketpair()
91 message_size -= processed_message_size; in secure_endpoint_create_fixture_tcp_socketpair()
/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/perfetto/src/tracing/core/
Dtest_config.cc66 static_assert(sizeof(message_size_) == sizeof(proto.message_size()), in FromProto()
68 message_size_ = static_cast<decltype(message_size_)>(proto.message_size()); in FromProto()
98 static_assert(sizeof(message_size_) == sizeof(proto->message_size()), in ToProto()
101 static_cast<decltype(proto->message_size())>(message_size_)); in ToProto()
/external/perfetto/src/trace_processor/
Dproto_trace_tokenizer.cc58 auto message_size = message.length(); in InternMessage() local
59 protozero::ProtoDecoder decoder(message_start, message_size); in InternMessage()
77 (res.first->second.message.length() == message_size && in InternMessage()
79 message_size) == 0)); in InternMessage()
/external/grpc-grpc/test/core/tsi/
Dtransport_security_test_lib.cc195 size_t message_size = in tsi_test_frame_protector_send_message_to_peer() local
203 while (message_size > 0 && result == TSI_OK) { in tsi_test_frame_protector_send_message_to_peer()
205 size_t processed_message_size = message_size; in tsi_test_frame_protector_send_message_to_peer()
215 message_size -= processed_message_size; in tsi_test_frame_protector_send_message_to_peer()
217 if (message_size == 0) { in tsi_test_frame_protector_send_message_to_peer()
/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()
/external/libcxx/include/
D__errc54 message_size, // EMSGSIZE
151 message_size = EMSGSIZE,
/external/perfetto/test/
Dfake_producer.cc74 message_size_ = source_config.for_testing().message_size(); in StartDataSource()
/external/perfetto/protos/perfetto/config/
Dtest_config.proto60 optional uint32 message_size = 4; field
/external/perfetto/include/perfetto/tracing/core/
Dtest_config.h157 uint32_t message_size() const { return message_size_; } in message_size() function
/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()

12