Home
last modified time | relevance | path

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

1234

/third_party/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()
/third_party/flutter/engine/flutter/shell/platform/common/cpp/client_wrapper/
Dplugin_registrar.cc46 message_handler(message->message, message->message_size, in ForwardToHandler()
68 const size_t message_size) const override;
73 const size_t message_size,
91 const size_t message_size) const { in Send()
93 message_size); in Send()
98 const size_t message_size, in Send() argument
118 messenger_, channel.c_str(), message, message_size, message_reply, in Send()
Djson_message_codec.cc44 const size_t message_size) const { in DecodeMessageInternal()
51 json_message->Parse(raw_message, message_size); in DecodeMessageInternal()
59 parsing_successful = parser->parse(raw_message, raw_message + message_size, in DecodeMessageInternal()
Dengine_method_result.cc39 size_t message_size = data ? data->size() : 0; in SendResponseData() local
40 reply_handler_(message, message_size); in SendResponseData()
Dplugin_registrar_unittests.cc22 const size_t message_size) override { in MessengerSend() argument
28 const size_t message_size, in MessengerSendWithReply() argument
/third_party/boost/boost/log/utility/ipc/
Dreliable_message_queue.hpp502 BOOST_LOG_API operation_result send(void const* message_data, size_type message_size);
526 BOOST_LOG_API bool try_send(void const* message_data, size_type message_size);
547 operation_result receive(void* buffer, size_type buffer_size, size_type& message_size) in receive() argument
551 message_size = buffer_size - state.size; in receive()
579 receive(ElementT (&buffer)[SizeV], size_type& message_size) in receive() argument
581 return receive(buffer, SizeV, message_size); in receive()
630 bool try_receive(void* buffer, size_type buffer_size, size_type& message_size) in try_receive() argument
634 message_size = buffer_size - state.size; in try_receive()
659 try_receive(ElementT (&buffer)[SizeV], size_type& message_size) in try_receive() argument
661 return try_receive(buffer, SizeV, message_size); in try_receive()
/third_party/boost/libs/log/test/run/
Dutil_ipc_reliable_mq.cpp171 size_type message_size = 0u; in BOOST_AUTO_TEST_CASE() local
172 BOOST_CHECK(queue_b.try_receive(buffer, sizeof(buffer), message_size)); in BOOST_AUTO_TEST_CASE()
173 BOOST_CHECK_EQUAL(message_size, sizeof(message1) - 1u); in BOOST_AUTO_TEST_CASE()
174 BOOST_CHECK(std::memcmp(buffer, message1, message_size) == 0); in BOOST_AUTO_TEST_CASE()
175 BOOST_CHECK(!queue_b.try_receive(buffer, sizeof(buffer), message_size)); in BOOST_AUTO_TEST_CASE()
196 size_type message_size = 0u; in BOOST_AUTO_TEST_CASE() local
197 BOOST_CHECK(queue_b.receive(buffer, sizeof(buffer), message_size) == queue_t::succeeded); in BOOST_AUTO_TEST_CASE()
198 BOOST_CHECK_EQUAL(message_size, sizeof(message1) - 1u); in BOOST_AUTO_TEST_CASE()
199 BOOST_CHECK(std::memcmp(buffer, message1, message_size) == 0); in BOOST_AUTO_TEST_CASE()
248 const size_type message_size = block_size * 3u / 2u; in BOOST_AUTO_TEST_CASE() local
[all …]
/third_party/flutter/engine/flutter/shell/platform/common/cpp/client_wrapper/testing/
Dstub_flutter_api.cc58 const size_t message_size) { in FlutterDesktopMessengerSend() argument
62 s_stub_implementation->MessengerSend(channel, message, message_size); in FlutterDesktopMessengerSend()
70 const size_t message_size, in FlutterDesktopMessengerSendWithReply() argument
76 channel, message, message_size, reply, user_data); in FlutterDesktopMessengerSendWithReply()
Dstub_flutter_api.h43 const size_t message_size) { in MessengerSend() argument
50 const size_t message_size, in MessengerSendWithReply() argument
/third_party/boost/libs/log/src/posix/
Dipc_reliable_message_queue.cpp296 operation_result send(void const* message_data, size_type message_size) in send()
298 const uint32_t block_count = estimate_block_count(message_size); in send()
328 enqueue_message(message_data, message_size, block_count); in send()
333 bool try_send(void const* message_data, size_type message_size) in try_send()
335 const uint32_t block_count = estimate_block_count(message_size); in try_send()
354 enqueue_message(message_data, message_size, block_count); in try_send()
610 void enqueue_message(void const* message_data, size_type message_size, uint32_t block_count) in enqueue_message()
619 block->m_size = message_size; in enqueue_message()
621 …t< size_type >((capacity - pos) * block_size - block_header::get_header_overhead()), message_size); in enqueue_message()
630 write_size = message_size - write_size; in enqueue_message()
[all …]
/third_party/boost/libs/log/src/windows/
Dipc_reliable_message_queue.cpp288 operation_result send(void const* message_data, size_type message_size) in send()
290 const uint32_t block_count = estimate_block_count(message_size); in send()
317 enqueue_message(message_data, message_size, block_count); in send()
322 bool try_send(void const* message_data, size_type message_size) in try_send()
324 const uint32_t block_count = estimate_block_count(message_size); in try_send()
339 enqueue_message(message_data, message_size, block_count); in try_send()
559 void enqueue_message(void const* message_data, size_type message_size, uint32_t block_count) in enqueue_message()
568 block->m_size = message_size; in enqueue_message()
570 …t< size_type >((capacity - pos) * block_size - block_header::get_header_overhead()), message_size); in enqueue_message()
579 write_size = message_size - write_size; in enqueue_message()
[all …]
/third_party/flutter/engine/flutter/shell/platform/common/cpp/client_wrapper/include/flutter/
Dbinary_messenger.h25 void(const uint8_t* message, const size_t message_size, BinaryReply reply)>
38 const size_t message_size) const = 0;
44 const size_t message_size,
Dmessage_codec.h30 const size_t message_size) const { in DecodeMessage() argument
31 return std::move(DecodeMessageInternal(binary_message, message_size)); in DecodeMessage()
53 const size_t message_size) const = 0;
Dmethod_codec.h33 const size_t message_size) const { in DecodeMethodCall() argument
34 return std::move(DecodeMethodCallInternal(message, message_size)); in DecodeMethodCall()
74 const size_t message_size) const = 0;
/third_party/flutter/engine/flutter/shell/platform/common/cpp/public/
Dflutter_messenger.h38 size_t message_size; member
58 const size_t message_size);
64 const size_t message_size,
/third_party/grpc/test/cpp/microbenchmarks/
Dcallback_streaming_ping_pong.h123 int message_size = state.range(0); in BM_CallbackBidiStreaming() local
132 if (message_size > 0) { in BM_CallbackBidiStreaming()
133 request.set_message(std::string(message_size, 'a')); in BM_CallbackBidiStreaming()
144 state.SetBytesProcessed(2 * message_size * max_ping_pongs * in BM_CallbackBidiStreaming()
/third_party/grpc/src/python/grpcio_tests/tests/stress/
Dunary_stream_benchmark.py76 def profile(message_size, response_count): argument
78 message_size=message_size, response_count=response_count)
/third_party/jerryscript/jerry-core/debugger/
Ddebugger.c206 size_t message_size = current_frame * sizeof (jerry_debugger_frame_t); in jerry_debugger_send_backtrace() local
210 jerry_debugger_send (sizeof (jerry_debugger_send_type_t) + message_size); in jerry_debugger_send_backtrace()
646 if (message_size != sizeof (type)) \
695 uint32_t message_size, /**< message size */ in jerry_debugger_process_message() argument
731 if (message_size < sizeof (jerry_debugger_receive_uint8_data_part_t) + 1) in jerry_debugger_process_message()
741 message_size -= (uint32_t) sizeof (jerry_debugger_receive_uint8_data_part_t); in jerry_debugger_process_message()
743 if (message_size > expected_data) in jerry_debugger_process_message()
754 message_size); in jerry_debugger_process_message()
756 if (message_size < expected_data) in jerry_debugger_process_message()
758 uint8_data_p->uint8_offset += message_size; in jerry_debugger_process_message()
[all …]
/third_party/grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc197 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()
/third_party/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()
/third_party/flutter/engine/flutter/shell/platform/windows/
Dflutter_windows.cc215 const size_t message_size, in FlutterDesktopMessengerSendWithReply() argument
232 message_size, in FlutterDesktopMessengerSendWithReply()
250 const size_t message_size) { in FlutterDesktopMessengerSend() argument
252 message_size, nullptr, nullptr); in FlutterDesktopMessengerSend()
/third_party/protobuf/python/google/protobuf/internal/
Dwire_format.py214 message_size = msg.ByteSize()
217 total_size += _VarUInt64ByteSizeNoTag(message_size)
220 total_size += message_size
/third_party/cef/libcef/browser/devtools/
Ddevtools_manager.cc143 size_t message_size) { in SendDevToolsMessage() argument
145 if (!message || message_size == 0) in SendDevToolsMessage()
152 base::StringPiece(static_cast<const char*>(message), message_size)); in SendDevToolsMessage()
/third_party/cef/libcef/browser/media_router/
Dmedia_route_impl.cc45 size_t message_size) { in SendRouteMessage() argument
46 std::string message_str(reinterpret_cast<const char*>(message), message_size); in SendRouteMessage()
/third_party/cef/libcef_dll/ctocpp/
Dmedia_route_ctocpp.cc76 size_t message_size) { in SendRouteMessage() argument
91 _struct->send_route_message(_struct, message, message_size); in SendRouteMessage()

1234