| /external/ltp/utils/sctp/func_tests/ |
| D | test_1_to_1_sendto.c | 64 int msg_count; in main() local
110 msg_count = strlen(message) + 1; in main()
113 count = sendto(sk, message, msg_count, flag, in main()
115 if (count != msg_count) in main()
121 test_recv(acpt_sk, message_rcv, msg_count, flag); in main()
126 count = sendto(acpt_sk, message, msg_count, flag, in main()
128 if (count != msg_count) in main()
134 test_recv(sk, message_rcv, msg_count, flag); in main()
143 count = sendto(sk1, message, msg_count, flag, in main()
145 if (count != msg_count) in main()
[all …]
|
| D | test_1_to_1_recvfrom.c | 67 int msg_count; in main() local
115 msg_count = (strlen(message) + 1); in main()
119 count = test_send(sk, message, msg_count, flag); in main()
122 count = recvfrom(-1, message_rcv, msg_count, flag, in main()
136 count = recvfrom(fd, message_rcv, msg_count, flag, in main()
149 count = recvfrom(acpt_sk, (char *)-1, msg_count, flag, in main()
158 count = recvfrom(lstn_sk, message_rcv, msg_count, flag, in main()
166 count = test_send(acpt_sk, message, msg_count, flag); in main()
171 count = recvfrom(acpt_sk, message_rcv, msg_count, flag, in main()
182 count = recvfrom(sk, message_rcv, msg_count, flag, in main()
[all …]
|
| D | test_1_to_1_send.c | 69 int msg_count; in main() local
204 msg_count = strlen(message) + 1; in main()
207 count = send(sk, message, msg_count, flag); in main()
208 if (count != msg_count) in main()
214 test_recv(acpt_sk, message_rcv, msg_count, flag); in main()
219 count = send(acpt_sk, message, msg_count, flag); in main()
220 if (count != msg_count) in main()
226 test_recv(sk, message_rcv, msg_count, flag); in main()
|
| D | test_1_to_1_sendmsg.c | 76 int msg_count; in main() local
318 msg_count = strlen(message) + 1; in main()
322 if (count != msg_count) in main()
329 test_check_msg_data(&inmessage, count, msg_count, MSG_EOR, 0, 0); in main()
335 if (count != msg_count) in main()
342 test_check_msg_data(&inmessage, count, msg_count, MSG_EOR, 0, 0); in main()
353 if (count != msg_count) in main()
362 test_check_msg_data(&inmessage, count, msg_count, MSG_EOR, 0, 0); in main()
368 if (count != msg_count) in main()
375 test_check_msg_data(&inmessage, count, msg_count, MSG_EOR, 0, 0); in main()
|
| D | test_1_to_1_nonblock.c | 67 int error,msg_count; in main() local
191 msg_count = strlen(message) + 1; in main()
201 test_sendmsg(acpt_sk, &outmessage, flag, msg_count); in main()
205 test_check_msg_data(&inmessage, error, msg_count, MSG_EOR, 0, 0); in main()
|
| D | test_1_to_1_addrs.c | 89 int msg_count; in main() local
149 msg_count = strlen(message) + 1; in main()
169 outmessage.msg_iov->iov_len = msg_count; in main()
171 test_sendmsg(clnt_sk, &outmessage, MSG_NOSIGNAL, msg_count); in main()
|
| /external/grpc-grpc/third_party/upb/upb/mini_descriptor/ |
| D | link.c | 77 uint32_t msg_count = 0; in upb_MiniTable_GetSubList() local
85 msg_count++; in upb_MiniTable_GetSubList()
98 return (msg_count << 16) | enum_count; in upb_MiniTable_GetSubList()
108 uint32_t msg_count = 0; in upb_MiniTable_Link() local
114 const upb_MiniTable* sub = sub_tables[msg_count++]; in upb_MiniTable_Link()
115 if (msg_count > sub_table_count) return false; in upb_MiniTable_Link()
|
| /external/grpc-grpc/third_party/upb/upb/mini_table/internal/ |
| D | file.h | 18 int UPB_PRIVATE(msg_count);
39 return f->UPB_PRIVATE(msg_count); in UPB_PRIVATE()
56 UPB_ASSERT(i < f->UPB_PRIVATE(msg_count)); in UPB_PRIVATE()
|
| /external/grpc-grpc/examples/ruby/pubsub/ |
| D | pubsub_demo.rb | 136 msg_count = rand(10..30)
137 msg_count.times do |x|
141 p "Sent #{msg_count} messages to #{topic_name}, checking for them now."
143 max_events: msg_count))
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/upb/upb/mini_table/ |
| D | file_internal.h | 40 int msg_count; member
|
| D | decode.c | 1070 uint32_t msg_count = 0; in upb_MiniTable_GetSubList() local
1078 msg_count++; in upb_MiniTable_GetSubList()
1091 return (msg_count << 16) | enum_count; in upb_MiniTable_GetSubList()
1101 uint32_t msg_count = 0; in upb_MiniTable_Link() local
1107 const upb_MiniTable* sub = sub_tables[msg_count++]; in upb_MiniTable_Link()
1108 if (msg_count > sub_table_count) return false; in upb_MiniTable_Link()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/upb/upbc/ |
| D | code_generator_request.c | 190 uint32_t msg_count = counts >> 16; in upbc_Scrape_MessageSubs() local
193 for (uint32_t i = 0; i < msg_count; i++) { in upbc_Scrape_MessageSubs()
205 upb_MessageDef_FindFieldByNumber(m, fields[msg_count + i]->number); in upbc_Scrape_MessageSubs()
|
| D | protoc-gen-upb.cc | 1558 int msg_count = WriteMessages(pools, file, options, output); in WriteMiniTableSource() local
1563 output(" $0,\n", msg_count ? kMessagesInit : "NULL"); in WriteMiniTableSource()
1566 output(" $0,\n", msg_count); in WriteMiniTableSource()
|
| /external/trace-cmd/lib/trace-cmd/ |
| D | trace-timesync-ptp.c | 537 int msg_count; in ptp_clock_server() local
581 msg_count = htonl(marker.data.count); in ptp_clock_server()
585 sizeof(msg_count), in ptp_clock_server()
586 (char *)&msg_count); in ptp_clock_server()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/upb/upb/reflection/ |
| D | def_builder_internal.h | 66 int msg_count; // Count of messages built so far. member
|
| D | message_def.c | 439 UPB_ASSERT(ctx->msg_count < ctx->layout->msg_count); in _upb_MessageDef_CreateMiniTable()
440 m->layout = ctx->layout->msgs[ctx->msg_count++]; in _upb_MessageDef_CreateMiniTable()
|
| D | def_pool.c | 336 .msg_count = 0, in _upb_DefPool_AddFile()
|
| /external/grpc-grpc/third_party/upb/upb/reflection/internal/ |
| D | def_builder.h | 50 int msg_count; // Count of messages built so far. member
|
| /external/pigweed/pw_rpc_transport/ |
| D | local_rpc_egress_test.cc | 43 uint32_t msg_count = 0; member in pw::rpc::__anone86fe72b0111::TestEchoService
|
| /external/crosvm/base/src/sys/windows/ |
| D | named_pipes.rs | 1533 fn send_receive_msgs(pipe: MultiPartMessagePipe, msg_count: u32) -> JoinHandle<()> { in send_receive_msgs()
1538 for _i in 0..msg_count { in send_receive_msgs()
1549 for _i in 0..msg_count { in send_receive_msgs()
|
| /external/libchrome/ipc/ |
| D | ipc_mojo_perftest.cc | 55 void SetTestParams(int msg_count, size_t msg_size, bool sync) { in SetTestParams() argument
57 msg_count_ = msg_count; in SetTestParams()
|
| /external/cronet/stable/ipc/ |
| D | ipc_mojo_perftest.cc | 66 void SetTestParams(int msg_count, size_t msg_size, bool sync) { in SetTestParams() argument
68 msg_count_ = msg_count; in SetTestParams()
|
| /external/cronet/tot/ipc/ |
| D | ipc_mojo_perftest.cc | 66 void SetTestParams(int msg_count, size_t msg_size, bool sync) { in SetTestParams() argument
68 msg_count_ = msg_count; in SetTestParams()
|
| /external/grpc-grpc/third_party/upb/upb/reflection/ |
| D | def_pool.c | 396 .msg_count = 0, in _upb_DefPool_AddFile()
|
| /external/perfetto/test/ |
| D | cmdline_integrationtest.cc | 78 uint32_t msg_count = 3, in CreateTraceConfigForBugreportTest() argument
99 ds_config->mutable_for_testing()->set_message_count(msg_count); in CreateTraceConfigForBugreportTest()
|