| /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/epid-sdk/tools/revokesig/src/ |
| D | main.c | 83 size_t sig_size, char const* msg_str, size_t msg_size,
105 char const* msg_str, size_t msg_size, bool verbose);
114 size_t msg_size = 0; in main() local
205 msg_size = strlen(msg_str); in main()
207 msg_buf = NewBufferFromFile(msg_file->filename[0], &msg_size); in main()
214 msg_size = 0; in main()
229 msg_str, msg_size, verbose_flag); in main()
259 size_t sig_size, char const* msg_str, size_t msg_size, in FillRequest() argument
263 size_t req_mid_size = sizeof(((SigRlRequestMid*)0)->be_msg_size) + msg_size; in FillRequest()
267 if (!pubkey || !sig || !req_buf || !req_top || (!msg_str && 0 != msg_size)) { in FillRequest()
[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/perfetto/src/protozero/test/ |
| D | protozero_conformance_unittest.cc | 101 size_t msg_size = GetNumSerializedBytes(); in TEST_F() local
103 std::unique_ptr<uint8_t[]> msg_binary(new uint8_t[msg_size]); in TEST_F()
104 GetSerializedBytes(0, msg_size, msg_binary.get()); in TEST_F()
107 gold_msg.ParseFromArray(msg_binary.get(), static_cast<int>(msg_size)); in TEST_F()
132 EXPECT_EQ(msg_size, static_cast<size_t>(gold_msg.ByteSize())); in TEST_F()
146 size_t msg_size = GetNumSerializedBytes(); in TEST_F() local
147 EXPECT_EQ(26u, msg_size); in TEST_F()
149 std::unique_ptr<uint8_t[]> msg_binary(new uint8_t[msg_size]); in TEST_F()
150 GetSerializedBytes(0, msg_size, msg_binary.get()); in TEST_F()
153 gold_msg_a.ParseFromArray(msg_binary.get(), static_cast<int>(msg_size)); in TEST_F()
|
| /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-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-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/epid-sdk/example/signmsg/src/ |
| D | main.c | 62 size_t msg_size = 0; in main() local
202 msg_size = strlen(msg_str); in main()
204 msg_buf = NewBufferFromFile(msg_file->filename[0], &msg_size); in main()
211 msg_size = 0; in main()
339 log_msg(" [in] Message Len: %d", (int)msg_size); in main()
341 PrintBuffer(msg_str, msg_size); in main()
370 result = SignMsg(msg_str, msg_size, basename_str, basename_size, in main()
|
| /external/epid-sdk/example/verifysig/src/ |
| D | main.c | 70 size_t msg_size = 0; in main() local
231 msg_size = strlen(msg_str); in main()
233 msg_buf = NewBufferFromFile(msg_file->filename[0], &msg_size); in main()
240 msg_size = 0; in main()
399 log_msg(" [in] Message Len: %d", (int)msg_size); in main()
401 PrintBuffer(msg_str, msg_size); in main()
449 Verify(sig, sig_size, msg_str, msg_size, basename_str, basename_size, in main()
461 result = Verify11(sig, sig_size, msg_str, msg_size, basename_str, in main()
|
| /external/tensorflow/tensorflow/contrib/mpi/ |
| D | mpi_rendezvous_mgr.h | 234 int flag = 0, msg_size = 0; in ProbeForData() local
240 MPI_CHECK(MPI_Get_count(status, MPI_CHAR, &msg_size)); in ProbeForData()
242 std::vector<char> request_buffer_(msg_size); in ProbeForData()
243 MPI_Mrecv(&request_buffer_[0], msg_size, MPI_CHAR, &msg, &stat2); in ProbeForData()
244 bool res = obj->ParseFromArray(&request_buffer_[0], msg_size); in ProbeForData()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/definitions/mqueue_h/ |
| D | 6-1-buildonly.c | 13 ssize_t msg_size; in test_mq_receive_prototype() local
18 msg_size = mq_receive(mqdes, msgp, msg_len, &msg_prio); in test_mq_receive_prototype()
|
| /external/vixl/examples/aarch64/ |
| D | crc-checksums.cc | 80 size_t msg_size = strlen(msg); in runExample() local
84 simulator.WriteXRegister(1, msg_size); in runExample()
|
| /external/flatbuffers/include/flatbuffers/ |
| D | grpc.h | 238 auto msg_size = buf_.size(); // size of msg in GetMessage() local
241 FLATBUFFERS_ASSERT(msg_size); in GetMessage()
243 FLATBUFFERS_ASSERT(msg_data + msg_size <= buf_data + buf_size); in GetMessage()
246 auto end = begin + msg_size; in GetMessage()
|
| /external/nos/test/system-test-harness/src/ |
| D | util.cc | 253 int msg_size = message.ByteSize(); in SendOneofProto() local
254 if (msg_size + 2 > (int) PROTO_BUFFER_MAX_LEN) { in SendOneofProto()
260 msg.data_len = (uint16_t) (msg_size + 2); in SendOneofProto()
261 if (!message.SerializeToArray(msg.data + 2, msg_size)) { in SendOneofProto()
273 int msg_size = message.ByteSize(); in SendProto() local
274 if (msg_size > (int) (PROTO_BUFFER_MAX_LEN - 2)) { in SendProto()
277 msg.data_len = (uint16_t) msg_size; in SendProto()
|
| /external/curl/lib/ |
| D | smb.c | 294 size_t msg_size; in smb_recv_message() local
317 msg_size = sizeof(struct smb_header); in smb_recv_message()
318 if(nbt_size >= msg_size + 1) { in smb_recv_message()
320 msg_size += 1 + ((unsigned char) buf[msg_size]) * sizeof(unsigned short); in smb_recv_message()
321 if(nbt_size >= msg_size + sizeof(unsigned short)) { in smb_recv_message()
323 msg_size += sizeof(unsigned short) + in smb_recv_message()
324 Curl_read16_le((const unsigned char *)&buf[msg_size]); in smb_recv_message()
325 if(nbt_size < msg_size) in smb_recv_message()
|
| /external/perfetto/src/protozero/ |
| D | message_unittest.cc | 393 uint8_t msg_size[proto_utils::kMessageLengthFieldSize] = {}; in TEST_F() local
394 msg->set_size_field(&msg_size[0]); in TEST_F()
403 ASSERT_EQ(0u, msg_size[0]); in TEST_F()
405 ASSERT_EQ(0x83u, msg_size[0]); in TEST_F()
|
| /external/google-breakpad/src/client/linux/crash_generation/ |
| D | crash_generation_server.cc | 218 const ssize_t msg_size = HANDLE_EINTR(recvmsg(server_fd_, &msg, 0)); in ClientEvent() local
219 if (msg_size != expected_msg_size) in ClientEvent()
|
| /external/libhevc/encoder/ |
| D | osal_mbox.h | 72 UWORD32 msg_size; /* Size of the msg */ member
|
| /external/nanopb-c/tests/regression/issue_172/ |
| D | SConscript | 12 p = incpath.Program(["msg_size.c",
|
| /external/grpc-grpc/third_party/nanopb/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/perfetto/test/ |
| D | end_to_end_integrationtest.cc | 468 size_t msg_size = packet.for_testing().str().size(); in TEST_F() local
469 ASSERT_EQ(kMsgSize, msg_size); in TEST_F()
470 for (size_t i = 0; i < msg_size; i++) in TEST_F()
471 ASSERT_EQ(i < msg_size - 1 ? '.' : 0, packet.for_testing().str()[i]); in TEST_F()
|
| /external/vixl/test/aarch64/examples/ |
| D | test-examples.cc | 463 size_t msg_size = strlen(msg); in TEST() local
466 simulator.WriteXRegister(1, msg_size); in TEST()
|