/external/pigweed/pw_tokenizer/ |
D | tokenize_test.cc | 158 size_t message_size = 14; in TEST_F() local 161 &message_size, in TEST_F() 169 ASSERT_EQ(expected.size(), message_size); in TEST_F() 174 size_t message_size; in TEST_F() local 177 message_size = size; in TEST_F() 181 &message_size, in TEST_F() 187 ASSERT_EQ(sizeof(uint32_t), message_size); in TEST_F() 206 ASSERT_EQ(expected.size(), message_size); in TEST_F() 213 size_t message_size = 9; in TEST_F() local 215 buffer_, &message_size, "%" PRId32, std::numeric_limits<int32_t>::min()); in TEST_F() [all …]
|
/external/openscreen/cast/common/channel/ |
D | message_framer.cc | 31 const size_t message_size = message.ByteSizeLong(); in Serialize() local 32 if (message_size > kMaxBodySize || message_size == 0) { in Serialize() 35 std::vector<uint8_t> out(message_size + kHeaderSize, 0); in Serialize() 36 WriteBigEndian<uint32_t>(message_size, out.data()); in Serialize() 37 if (!message.SerializeToArray(&out[kHeaderSize], message_size)) { in Serialize() 48 const uint32_t message_size = ReadBigEndian<uint32_t>(input.data()); in TryDeserialize() local 49 if (message_size > kMaxBodySize) { in TryDeserialize() 53 if (input.size() < (kHeaderSize + message_size)) { in TryDeserialize() 59 message_size)) { in TryDeserialize() 62 result.length = kHeaderSize + message_size; in TryDeserialize()
|
/external/curl/tests/libtest/ |
D | lib571.c | 57 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/ |
D | e2e_perftest.cc | 55 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/perfetto/src/trace_processor/importers/proto/ |
D | packet_sequence_state.cc | 28 auto message_size = message.length(); in InternMessage() local 29 protozero::ProtoDecoder decoder(message_start, message_size); in InternMessage() 49 (res.first->second.message().length() == message_size && in InternMessage() 51 message_size) == 0)); in InternMessage()
|
/external/libchrome/ipc/ |
D | ipc_message_unittest.cc | 141 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()
|
D | ipc_message.cc | 133 : 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()
|
D | ipc_cpu_perftest.cc | 34 : 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()
|
D | ipc_mojo_perftest.cc | 130 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()
|
/external/libchrome/mojo/core/ |
D | message_pipe_perftest.cc | 35 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()
|
D | broker_messages.h | 68 const size_t message_size = sizeof(BrokerMessageHeader) + variable 70 Channel::MessagePtr message(new Channel::Message(message_size, num_handles));
|
D | message_pipe_dispatcher.cc | 76 size_t message_size() const { return message_size_; } in message_size() function in mojo::core::PeekSizeMessageFilter 413 << "; size=" << filter.message_size() << "]"; in OnPortStatusChanged()
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
D | secure_endpoint.cc | 197 size_t message_size = GRPC_SLICE_LENGTH(encrypted); in on_read() local 199 while (message_size > 0 || keep_looping) { in on_read() 201 size_t processed_message_size = message_size; in on_read() 213 message_size -= processed_message_size; in on_read() 313 size_t message_size = GRPC_SLICE_LENGTH(plain); in endpoint_write() local 314 while (message_size > 0) { in endpoint_write() 316 size_t processed_message_size = message_size; in endpoint_write() 328 message_size -= processed_message_size; in endpoint_write()
|
/external/grpc-grpc/src/core/lib/security/transport/ |
D | secure_endpoint.cc | 170 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/llvm-project/libcxx/test/std/diagnostics/syserr/syserr.errcondition/syserr.errcondition.nonmembers/ |
D | make_error_condition.pass.cpp | 23 const std::error_condition ec1 = std::make_error_condition(std::errc::message_size); in main() 24 assert(ec1.value() == static_cast<int>(std::errc::message_size)); in main()
|
/external/libcxx/test/std/diagnostics/syserr/syserr.errcondition/syserr.errcondition.nonmembers/ |
D | make_error_condition.pass.cpp | 22 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/rust/crates/grpcio-sys/grpc/test/core/security/ |
D | secure_endpoint_test.cc | 82 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/grpc-grpc/test/core/security/ |
D | secure_endpoint_test.cc | 82 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/ |
D | wire_format.py | 214 message_size = msg.ByteSize() 217 total_size += _VarUInt64ByteSizeNoTag(message_size) 220 total_size += message_size
|
/external/webrtc/modules/audio_coding/audio_network_adaptor/ |
D | parse_ana_dump.py | 34 message_size = GetNextMessageSize(file_to_parse) 35 if message_size == 0: 39 event.ParseFromString(file_to_parse.read(message_size))
|
/external/pigweed/pw_tokenizer/public/pw_tokenizer/ |
D | base64.h | 81 constexpr size_t Base64EncodedBufferSize(size_t message_size) { in Base64EncodedBufferSize() argument 82 return sizeof(kBase64Prefix) + base64::EncodedSize(message_size) + in Base64EncodedBufferSize()
|
/external/grpc-grpc/test/core/tsi/ |
D | transport_security_test_lib.cc | 195 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/libcxx/include/ |
D | __errc | 54 message_size, // EMSGSIZE 151 message_size = EMSGSIZE,
|
/external/llvm-project/libcxx/include/ |
D | __errc | 53 message_size, // EMSGSIZE 150 message_size = EMSGSIZE,
|
/external/fmtlib/test/ |
D | format-impl-test.cc | 362 size_t message_size = std::strlen(message); in TEST() local 363 EXPECT_GE(BUFFER_SIZE - 1u, message_size); in TEST() 369 fmt::detail::safe_strerror(error_code, message = buffer, message_size); in TEST()
|