| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_streaming_ping_pong.cc | 37 int msg_size = 0; in StreamingPingPongArgs() local
41 for (msg_size = 0; msg_size <= 128 * 1024 * 1024; in StreamingPingPongArgs()
42 msg_size == 0 ? msg_size++ : msg_size *= 8) { in StreamingPingPongArgs()
43 b->Args({msg_size, 1}); in StreamingPingPongArgs()
44 b->Args({msg_size, 2}); in StreamingPingPongArgs()
86 int msg_size = 0; in StreamingPingPongWithCoalescingApiArgs() local
93 for (msg_size = 0; msg_size <= 128 * 1024 * 1024; in StreamingPingPongWithCoalescingApiArgs()
94 msg_size == 0 ? msg_size++ : msg_size *= 8) { in StreamingPingPongWithCoalescingApiArgs()
95 b->Args({msg_size, 1, 0}); in StreamingPingPongWithCoalescingApiArgs()
96 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 …]
|
| /external/grpc-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 …]
|
| /external/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()
|
| /external/strace/tests-m32/ |
| D | mq_sendrecv.c | 131 do_send(int fd, char *msg, unsigned int msg_size, struct timespec *tmout, in do_send() argument
138 rc = syscall(__NR_mq_timedsend, fd, msg, msg_size, 42, in do_send()
142 printstr(MSG_START, msg_size > MSG_MAX_UNCUT ? MSG_MAX_UNCUT : in do_send()
143 msg_size); in do_send()
147 printf(", %u, 42, {tv_sec=%lld, tv_nsec=%llu}) = %s\n", msg_size, in do_send()
158 dumpstr(MSG_START, msg_size); in do_send()
164 do_recv(int fd, char *msg, unsigned int msg_size, struct timespec *tmout, in do_recv() argument
195 if ((rc >= 0) && ((unsigned long) rc != msg_size)) in do_recv()
198 msg_size, rc); in do_recv()
|
| /external/strace/tests/ |
| D | mq_sendrecv.c | 131 do_send(int fd, char *msg, unsigned int msg_size, struct timespec *tmout, in do_send() argument
138 rc = syscall(__NR_mq_timedsend, fd, msg, msg_size, 42, in do_send()
142 printstr(MSG_START, msg_size > MSG_MAX_UNCUT ? MSG_MAX_UNCUT : in do_send()
143 msg_size); in do_send()
147 printf(", %u, 42, {tv_sec=%lld, tv_nsec=%llu}) = %s\n", msg_size, in do_send()
158 dumpstr(MSG_START, msg_size); in do_send()
164 do_recv(int fd, char *msg, unsigned int msg_size, struct timespec *tmout, in do_recv() argument
195 if ((rc >= 0) && ((unsigned long) rc != msg_size)) in do_recv()
198 msg_size, rc); in do_recv()
|
| /external/strace/tests-mx32/ |
| D | mq_sendrecv.c | 131 do_send(int fd, char *msg, unsigned int msg_size, struct timespec *tmout, in do_send() argument
138 rc = syscall(__NR_mq_timedsend, fd, msg, msg_size, 42, in do_send()
142 printstr(MSG_START, msg_size > MSG_MAX_UNCUT ? MSG_MAX_UNCUT : in do_send()
143 msg_size); in do_send()
147 printf(", %u, 42, {tv_sec=%lld, tv_nsec=%llu}) = %s\n", msg_size, in do_send()
158 dumpstr(MSG_START, msg_size); in do_send()
164 do_recv(int fd, char *msg, unsigned int msg_size, struct timespec *tmout, in do_recv() argument
195 if ((rc >= 0) && ((unsigned long) rc != msg_size)) in do_recv()
198 msg_size, rc); in do_recv()
|
| /external/vixl/examples/aarch64/ |
| D | crc-checksums.cc | 83 size_t msg_size = strlen(msg); in RunExample() local
87 simulator.WriteXRegister(1, msg_size); in RunExample()
|
| /external/arm-trusted-firmware/plat/nvidia/tegra/drivers/bpmp_ipc/ |
| D | intf.c | 221 size_t msg_size; in tegra_bpmp_ipc_init() local
242 msg_size = tegra_ivc_align(IVC_CMD_SZ_BYTES); in tegra_bpmp_ipc_init()
243 frame_size = (uint32_t)tegra_ivc_total_queue_size(msg_size); in tegra_bpmp_ipc_init()
|
| /external/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()
|
| /external/curl/lib/ |
| D | smb.c | 293 size_t msg_size; in smb_recv_message() local
316 msg_size = sizeof(struct smb_header); in smb_recv_message()
317 if(nbt_size >= msg_size + 1) { in smb_recv_message()
319 msg_size += 1 + ((unsigned char) buf[msg_size]) * sizeof(unsigned short); in smb_recv_message()
320 if(nbt_size >= msg_size + sizeof(unsigned short)) { in smb_recv_message()
322 msg_size += sizeof(unsigned short) + in smb_recv_message()
323 Curl_read16_le((const unsigned char *)&buf[msg_size]); in smb_recv_message()
324 if(nbt_size < msg_size) in smb_recv_message()
|
| /external/perfetto/src/protozero/ |
| D | message_unittest.cc | 410 uint8_t msg_size[proto_utils::kMessageLengthFieldSize] = {}; in TEST_F() local
411 msg->set_size_field(&msg_size[0]); in TEST_F()
420 ASSERT_EQ(0u, msg_size[0]); in TEST_F()
422 ASSERT_EQ(0x83u, msg_size[0]); in TEST_F()
|
| /external/libhevc/encoder/ |
| D | osal_mbox.h | 72 UWORD32 msg_size; /* Size of the msg */ member
|
| D | osal.h | 154 UWORD32 msg_size; /* Length of each message. */ member
|
| /external/google-breakpad/src/client/linux/crash_generation/ |
| D | crash_generation_server.cc | 221 const ssize_t msg_size = HANDLE_EINTR(recvmsg(server_fd_, &msg, 0)); in ClientEvent() local
222 if (msg_size != expected_msg_size) in ClientEvent()
|
| /external/grpc-grpc/third_party/nanopb/tests/regression/issue_172/ |
| D | SConscript | 12 p = incpath.Program(["msg_size.c",
|
| /external/nanopb-c/tests/regression/issue_172/ |
| D | SConscript | 12 p = incpath.Program(["msg_size.c",
|
| /external/iproute2/bridge/ |
| D | fdb.c | 327 int msg_size = sizeof(struct ifinfomsg); in fdb_show() local
363 msg_size += RTA_LENGTH(4); in fdb_show()
377 if (rtnl_dump_request(&rth, RTM_GETNEIGH, &req.ifm, msg_size) < 0) { in fdb_show()
|
| /external/iproute2/tc/ |
| D | m_action.c | 580 int ret = 0, prio = 0, msg_size = 0; in tc_act_list_or_flush() local
642 msg_size = NLMSG_ALIGN(req.n.nlmsg_len) - NLMSG_ALIGN(sizeof(struct nlmsghdr)); in tc_act_list_or_flush()
645 if (rtnl_dump_request(&rth, event, (void *)&req.t, msg_size) < 0) { in tc_act_list_or_flush()
|
| /external/crosvm/src/plugin/ |
| D | process.rs | 516 let (msg_size, request_file) = self.request_sockets[index] in handle_socket()
520 if msg_size == 0 { in handle_socket()
524 let request = protobuf::parse_from_bytes::<MainRequest>(&self.request_buffer[..msg_size]) in handle_socket()
|
| /external/vm_tools/p9/src/protocol/ |
| D | messages.rs | 125 let msg_size = match self.msg { in byte_size() localVariable
157 (mem::size_of::<u32>() + mem::size_of::<u8>() + mem::size_of::<u16>()) as u32 + msg_size in byte_size()
539 let msg_size = match self.msg { in byte_size() localVariable
572 (mem::size_of::<u32>() + mem::size_of::<u8>() + mem::size_of::<u16>()) as u32 + msg_size in byte_size()
|
| /external/vixl/test/aarch64/examples/ |
| D | test-examples.cc | 457 size_t msg_size = strlen(msg); in TEST() local
460 simulator.WriteXRegister(1, msg_size); in TEST()
|
| /external/perfetto/test/ |
| D | end_to_end_integrationtest.cc | 750 size_t msg_size = packet.for_testing().str().size(); in TEST_F() local
751 ASSERT_EQ(kMsgSize, msg_size); in TEST_F()
752 for (size_t i = 0; i < msg_size; i++) in TEST_F()
753 ASSERT_EQ(i < msg_size - 1 ? '.' : 0, packet.for_testing().str()[i]); in TEST_F()
|
| /external/tcpdump/ |
| D | print-ppp.c | 835 int val_size, name_size, msg_size; in handle_chap() local
895 msg_size = len - (p - p0); in handle_chap()
897 for (i = 0; i< msg_size; i++) { in handle_chap()
|
| /external/libchrome/ipc/ |
| D | ipc_mojo_perftest.cc | 55 void SetTestParams(int msg_count, size_t msg_size, bool sync) { in SetTestParams() argument
58 msg_size_ = msg_size; in SetTestParams()
|