HomeSort by relevance Sort by last modified time
    Searched defs:msg_size (Results 1 - 23 of 23) sorted by null

  /external/ltp/testcases/open_posix_testsuite/conformance/definitions/mqueue_h/
6-1-buildonly.c 13 ssize_t msg_size; local
18 msg_size = mq_receive(mqdes, msgp, msg_len, &msg_prio);
  /device/generic/goldfish/keymaster/trusty/
trusty_keymaster_ipc.cpp 53 size_t msg_size = in_size + sizeof(struct keymaster_message); local
54 ALOGE("calling %s insize %d msg size %d\n", __func__, (int)in_size, (int) msg_size);
55 struct keymaster_message* msg = reinterpret_cast<struct keymaster_message*>(malloc(msg_size));
59 int pipe_command_length = msg_size;
63 ALOGE("failed to send msg_size (%d) for cmd (%d) to %s: %s\n", (int)(sizeof(pipe_command_length)),
  /external/grpc-grpc/test/cpp/microbenchmarks/
bm_fullstack_streaming_ping_pong.cc 37 int msg_size = 0; local
39 b->Args({0, 0}); // spl case: 0 ping-pong msgs (msg_size doesn't matter here)
41 for (msg_size = 0; msg_size <= 128 * 1024 * 1024;
42 msg_size == 0 ? msg_size++ : msg_size *= 8) {
43 b->Args({msg_size, 1});
44 b->Args({msg_size, 2});
86 int msg_size = 0 local
    [all...]
fullstack_streaming_ping_pong.h 49 const int msg_size = state.range(0); local
60 if (msg_size > 0) {
61 send_request.set_message(std::string(msg_size, 'a'));
62 send_response.set_message(std::string(msg_size, 'b'));
136 state.SetBytesProcessed(msg_size * state.iterations() * max_ping_pongs * 2);
143 const int msg_size = state.range(0); local
153 if (msg_size > 0) {
154 send_request.set_message(std::string(msg_size, 'a'));
155 send_response.set_message(std::string(msg_size, 'b'));
223 state.SetBytesProcessed(msg_size * state.iterations() * 2)
241 const int msg_size = state.range(0); local
    [all...]
  /external/libhevc/encoder/
osal_mbox.h 72 UWORD32 msg_size; /* Size of the msg */ member in struct:__anon28775
osal.h 154 UWORD32 msg_size; /* Length of each message. */ member in struct:__anon28759
  /external/vixl/examples/aarch64/
crc-checksums.cc 80 size_t msg_size = strlen(msg); local
84 simulator.WriteXRegister(1, msg_size);
  /external/perfetto/src/protozero/test/
protozero_conformance_unittest.cc 101 size_t msg_size = GetNumSerializedBytes(); local
103 std::unique_ptr<uint8_t[]> msg_binary(new uint8_t[msg_size]);
104 GetSerializedBytes(0, msg_size, msg_binary.get());
107 gold_msg.ParseFromArray(msg_binary.get(), static_cast<int>(msg_size));
132 EXPECT_EQ(msg_size, static_cast<size_t>(gold_msg.ByteSize()));
146 size_t msg_size = GetNumSerializedBytes(); local
147 EXPECT_EQ(26u, msg_size);
149 std::unique_ptr<uint8_t[]> msg_binary(new uint8_t[msg_size]);
150 GetSerializedBytes(0, msg_size, msg_binary.get());
153 gold_msg_a.ParseFromArray(msg_binary.get(), static_cast<int>(msg_size));
    [all...]
  /external/google-breakpad/src/client/linux/crash_generation/
crash_generation_server.cc 218 const ssize_t msg_size = HANDLE_EINTR(recvmsg(server_fd_, &msg, 0)); local
219 if (msg_size != expected_msg_size)
  /external/epid-sdk/example/signmsg/src/
main.c 62 size_t msg_size = 0; local
202 msg_size = strlen(msg_str);
204 msg_buf = NewBufferFromFile(msg_file->filename[0], &msg_size);
211 msg_size = 0;
339 log_msg(" [in] Message Len: %d", (int)msg_size);
341 PrintBuffer(msg_str, msg_size);
370 result = SignMsg(msg_str, msg_size, basename_str, basename_size,
  /external/epid-sdk/example/verifysig/src/
main.c 70 size_t msg_size = 0; local
231 msg_size = strlen(msg_str);
233 msg_buf = NewBufferFromFile(msg_file->filename[0], &msg_size);
240 msg_size = 0;
399 log_msg(" [in] Message Len: %d", (int)msg_size);
401 PrintBuffer(msg_str, msg_size);
449 Verify(sig, sig_size, msg_str, msg_size, basename_str, basename_size,
461 result = Verify11(sig, sig_size, msg_str, msg_size, basename_str,
  /external/epid-sdk/tools/revokesig/src/
main.c 73 \param[in] msg_size
83 size_t sig_size, char const* msg_str, size_t msg_size,
98 \param[in] msg_size
105 char const* msg_str, size_t msg_size, bool verbose);
114 size_t msg_size = 0; local
205 msg_size = strlen(msg_str);
207 msg_buf = NewBufferFromFile(msg_file->filename[0], &msg_size);
214 msg_size = 0;
229 msg_str, msg_size, verbose_flag);
259 size_t sig_size, char const* msg_str, size_t msg_size,
    [all...]
  /external/flatbuffers/include/flatbuffers/
grpc.h 238 auto msg_size = buf_.size(); // size of msg local
241 FLATBUFFERS_ASSERT(msg_size);
243 FLATBUFFERS_ASSERT(msg_data + msg_size <= buf_data + buf_size);
246 auto end = begin + msg_size;
  /external/iproute2/bridge/
fdb.c 327 int msg_size = sizeof(struct ifinfomsg); local
363 msg_size += RTA_LENGTH(4);
377 if (rtnl_dump_request(&rth, RTM_GETNEIGH, &req.ifm, msg_size) < 0) {
  /external/iproute2/tc/
m_action.c 580 int ret = 0, prio = 0, msg_size = 0; local
642 msg_size = NLMSG_ALIGN(req.n.nlmsg_len) - NLMSG_ALIGN(sizeof(struct nlmsghdr));
645 if (rtnl_dump_request(&rth, event, (void *)&req.t, msg_size) < 0) {
  /external/nos/test/system-test-harness/src/
util.cc 253 int msg_size = message.ByteSize(); local
254 if (msg_size + 2 > (int) PROTO_BUFFER_MAX_LEN) {
260 msg.data_len = (uint16_t) (msg_size + 2);
261 if (!message.SerializeToArray(msg.data + 2, msg_size)) {
273 int msg_size = message.ByteSize(); local
274 if (msg_size > (int) (PROTO_BUFFER_MAX_LEN - 2)) {
277 msg.data_len = (uint16_t) msg_size;
  /external/perfetto/src/protozero/
message_unittest.cc 393 uint8_t msg_size[proto_utils::kMessageLengthFieldSize] = {}; local
394 msg->set_size_field(&msg_size[0]);
403 ASSERT_EQ(0u, msg_size[0]);
405 ASSERT_EQ(0x83u, msg_size[0]);
  /external/perfetto/test/
end_to_end_integrationtest.cc 468 size_t msg_size = packet.for_testing().str().size(); local
469 ASSERT_EQ(kMsgSize, msg_size);
470 for (size_t i = 0; i < msg_size; i++)
471 ASSERT_EQ(i < msg_size - 1 ? '.' : 0, packet.for_testing().str()[i]);
    [all...]
  /external/tensorflow/tensorflow/contrib/mpi/
mpi_rendezvous_mgr.h 234 int flag = 0, msg_size = 0; local
240 MPI_CHECK(MPI_Get_count(status, MPI_CHAR, &msg_size));
242 std::vector<char> request_buffer_(msg_size);
243 MPI_Mrecv(&request_buffer_[0], msg_size, MPI_CHAR, &msg, &stat2);
244 bool res = obj->ParseFromArray(&request_buffer_[0], msg_size);
  /external/grpc-grpc/test/core/network_benchmarks/
low_level_ping_pong.cc 55 size_t msg_size; member in struct:thread_args
94 return read_bytes(args->fds.read_fd, buf, args->msg_size, 0);
98 return read_bytes(args->fds.read_fd, buf, args->msg_size, 1);
136 return poll_read_bytes(args->fds.read_fd, buf, args->msg_size, 0);
140 return poll_read_bytes(args->fds.read_fd, buf, args->msg_size, 1);
150 size_t read_size = args->msg_size;
194 size_t write_size = args->msg_size;
256 char* buf = static_cast<char*>(gpr_malloc(args->msg_size));
295 char* buf = static_cast<char*>(gpr_malloc(args->msg_size * sizeof(char)));
296 memset(buf, 0, args->msg_size * sizeof(char))
633 int msg_size = -1; local
    [all...]
  /external/vixl/test/aarch64/examples/
test-examples.cc 463 size_t msg_size = strlen(msg); local
466 simulator.WriteXRegister(1, msg_size);
  /external/curl/lib/
smb.c 294 size_t msg_size; local
317 msg_size = sizeof(struct smb_header);
318 if(nbt_size >= msg_size + 1) {
320 msg_size += 1 + ((unsigned char) buf[msg_size]) * sizeof(unsigned short);
321 if(nbt_size >= msg_size + sizeof(unsigned short)) {
323 msg_size += sizeof(unsigned short) +
324 Curl_read16_le((const unsigned char *)&buf[msg_size]);
325 if(nbt_size < msg_size)
  /external/tcpdump/
print-ppp.c 835 int val_size, name_size, msg_size; local
895 msg_size = len - (p - p0);
897 for (i = 0; i< msg_size; i++) {
    [all...]

Completed in 1132 milliseconds