| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_streaming_ping_pong.cc | 35 int msg_size = 0; in StreamingPingPongArgs() local
39 for (msg_size = 0; msg_size <= 128 * 1024 * 1024; in StreamingPingPongArgs()
40 msg_size == 0 ? msg_size++ : msg_size *= 8) { in StreamingPingPongArgs()
41 b->Args({msg_size, 1}); in StreamingPingPongArgs()
42 b->Args({msg_size, 2}); in StreamingPingPongArgs()
84 int msg_size = 0; in StreamingPingPongWithCoalescingApiArgs() local
91 for (msg_size = 0; msg_size <= 128 * 1024 * 1024; in StreamingPingPongWithCoalescingApiArgs()
92 msg_size == 0 ? msg_size++ : msg_size *= 8) { in StreamingPingPongWithCoalescingApiArgs()
93 b->Args({msg_size, 1, 0}); in StreamingPingPongWithCoalescingApiArgs()
94 b->Args({msg_size, 2, 0}); in StreamingPingPongWithCoalescingApiArgs()
[all …]
|
| D | fullstack_streaming_ping_pong.h | 49 const int msg_size = state.range(0); in BM_StreamingPingPong() local
60 if (msg_size > 0) { in BM_StreamingPingPong()
61 send_request.set_message(std::string(msg_size, 'a')); in BM_StreamingPingPong()
62 send_response.set_message(std::string(msg_size, 'b')); in BM_StreamingPingPong()
136 state.SetBytesProcessed(msg_size * state.iterations() * max_ping_pongs * 2); in BM_StreamingPingPong()
143 const int msg_size = state.range(0); in BM_StreamingPingPongMsgs() local
153 if (msg_size > 0) { in BM_StreamingPingPongMsgs()
154 send_request.set_message(std::string(msg_size, 'a')); in BM_StreamingPingPongMsgs()
155 send_response.set_message(std::string(msg_size, 'b')); in BM_StreamingPingPongMsgs()
223 state.SetBytesProcessed(msg_size * state.iterations() * 2); in BM_StreamingPingPongMsgs()
[all …]
|
| D | bm_callback_streaming_ping_pong.cc | 37 for (int msg_size = 1; msg_size <= 128 * 1024 * 1024; msg_size *= 8) { in StreamingPingPongMsgSizeArgs() local
38 b->Args({msg_size, 1}); in StreamingPingPongMsgSizeArgs()
39 b->Args({msg_size, 2}); in StreamingPingPongMsgSizeArgs()
|
| /third_party/grpc/test/core/network_benchmarks/ |
| D | low_level_ping_pong.cc | 55 size_t msg_size; member
94 return read_bytes(args->fds.read_fd, buf, args->msg_size, 0); in blocking_read_bytes()
98 return read_bytes(args->fds.read_fd, buf, args->msg_size, 1); in spin_read_bytes()
136 return poll_read_bytes(args->fds.read_fd, buf, args->msg_size, 0); in poll_read_bytes_blocking()
140 return poll_read_bytes(args->fds.read_fd, buf, args->msg_size, 1); in poll_read_bytes_spin()
150 size_t read_size = args->msg_size; in epoll_read_bytes()
194 size_t write_size = args->msg_size; in blocking_write_bytes()
256 char* buf = static_cast<char*>(gpr_malloc(args->msg_size)); in server_thread()
295 char* buf = static_cast<char*>(gpr_malloc(args->msg_size * sizeof(char))); in client_thread()
296 memset(buf, 0, args->msg_size * sizeof(char)); in client_thread()
[all …]
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/definitions/mqueue_h/ |
| D | 6-1-buildonly.c | 14 ssize_t msg_size; in test_mq_receive_prototype() local
23 msg_size = mq_receive(mqdes, msgp, msg_len, &msg_prio); in test_mq_receive_prototype()
24 (void)msg_size; in test_mq_receive_prototype()
|
| /third_party/jerryscript/jerry-debugger/ |
| D | jerry_client_rawpacket.py | 56 msg_size = len(data)
58 while msg_size > 0:
60 if bytes_send < msg_size:
62 msg_size -= bytes_send
|
| /third_party/glib/fuzzing/ |
| D | fuzz_dbus_message.c | 11 gsize msg_size; in LLVMFuzzerTestOneInput() local
23 blob = g_dbus_message_to_blob (msg, &msg_size, flags, NULL); in LLVMFuzzerTestOneInput()
|
| /third_party/node/src/ |
| D | udp_wrap.cc | 54 size_t msg_size; member in node::SendWrap
547 size_t msg_size = 0; in Send() local
549 msg_size += bufs_ptr[i].len; in Send()
568 CHECK_EQ(static_cast<size_t>(err), msg_size); in Send()
571 return msg_size + 1; in Send()
578 ReqWrap<uv_udp_send_t>* req_wrap = listener()->CreateSendWrap(msg_size); in Send()
600 ReqWrap<uv_udp_send_t>* UDPWrap::CreateSendWrap(size_t msg_size) { in CreateSendWrap() argument
604 req_wrap->msg_size = msg_size; in CreateSendWrap()
665 Integer::New(env->isolate(), req_wrap->msg_size), in OnSendDone()
|
| D | udp_wrap.h | 59 virtual ReqWrap<uv_udp_send_t>* CreateSendWrap(size_t msg_size) = 0;
160 ReqWrap<uv_udp_send_t>* CreateSendWrap(size_t msg_size) override;
|
| /third_party/flatbuffers/include/flatbuffers/ |
| D | grpc.h | 240 auto msg_size = buf_.size(); // size of msg in GetMessage() local
243 FLATBUFFERS_ASSERT(msg_size); in GetMessage()
245 FLATBUFFERS_ASSERT(msg_data + msg_size <= buf_data + buf_size); in GetMessage()
248 auto end = begin + msg_size; in GetMessage()
|
| /third_party/curl/lib/ |
| D | smb.c | 304 size_t msg_size; in smb_recv_message() local
327 msg_size = sizeof(struct smb_header); in smb_recv_message()
328 if(nbt_size >= msg_size + 1) { in smb_recv_message()
330 msg_size += 1 + ((unsigned char) buf[msg_size]) * sizeof(unsigned short); in smb_recv_message()
331 if(nbt_size >= msg_size + sizeof(unsigned short)) { in smb_recv_message()
333 msg_size += sizeof(unsigned short) + in smb_recv_message()
334 Curl_read16_le((const unsigned char *)&buf[msg_size]); in smb_recv_message()
335 if(nbt_size < msg_size) in smb_recv_message()
|
| /third_party/gstreamer/gstplugins_good/gst/udp/ |
| D | gstmultiudpsink.c | 648 guint msg_size, skip, i; in gst_multiudpsink_send_messages() local
675 msg_size = gst_udp_calc_message_size (msg); in gst_multiudpsink_send_messages()
677 GST_LOG_OBJECT (sink, "error sending %u bytes to client %s: %s", msg_size, in gst_multiudpsink_send_messages()
682 if (msg_size > UDP_MAX_SIZE) { in gst_multiudpsink_send_messages()
686 "(%u > %d)", msg_size, UDP_MAX_SIZE), in gst_multiudpsink_send_messages()
|
| /third_party/cmsis/CMSIS/RTOS2/Include/ |
| D | cmsis_os2.h | 698 osMessageQueueId_t osMessageQueueNew (uint32_t msg_count, uint32_t msg_size, const osMessageQueueAt…
|
| /third_party/ffmpeg/libavcodec/ |
| D | videotoolboxenc.c | 1969 size_t msg_size = get_sei_msg_bytes(sei, in vtenc_cm_to_avpacket() local
1972 sei_nalu_size = sizeof(start_code) + 1 + msg_size + 1; in vtenc_cm_to_avpacket()
|