| /dports/net/ortp/ortp-1.0.2-0/src/ |
| H A D | rtpparse.c | 133 int msgsize; in rtp_session_rtp_parse() local
137 msgsize=(int)(mp->b_wptr-mp->b_rptr); in rtp_session_rtp_parse()
139 if (msgsize<RTP_FIXED_HEADER_SIZE){ in rtp_session_rtp_parse()
140 ortp_warning("Packet too small to be a rtp packet (%i)!",msgsize); in rtp_session_rtp_parse()
177 ortp_global_stats.hw_recv+=msgsize; in rtp_session_rtp_parse()
178 stats->hw_recv+=msgsize; in rtp_session_rtp_parse()
187 if (rtp->cc*sizeof(uint32_t) > (uint32_t) (msgsize-RTP_FIXED_HEADER_SIZE)){ in rtp_session_rtp_parse()
290 …_packet(session->rtp.video_bw_estimator, rtp->timestamp, &mp->timestamp, msgsize + overhead, rtp->… in rtp_session_rtp_parse()
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_performance.c | 824 int msgsize = -1; in main() local
913 msgsize = atoi(optarg); in main()
1298 if (msgsize == -1) in main()
1341 msgsize = RD_MAX(minlen, msgsize); in main()
1352 sbuf = malloc(msgsize); in main()
1355 while (rof < msgsize) { in main()
1363 msgsize); in main()
1366 msgcnt, msgsize); in main()
1418 pbuf = malloc(msgsize); in main()
1419 memcpy(pbuf, sbuf, msgsize); in main()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_performance.c | 799 int msgsize = -1; in main() local
894 msgsize = atoi(optarg); in main()
1282 if (msgsize == -1) in main()
1307 msgsize = RD_MAX(minlen, msgsize); in main()
1318 sbuf = malloc(msgsize); in main()
1321 while (rof < msgsize) { in main()
1329 msgsize); in main()
1332 msgcnt, msgsize); in main()
1390 pbuf = malloc(msgsize); in main()
1391 memcpy(pbuf, sbuf, msgsize); in main()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_performance.c | 824 int msgsize = -1; in main() local
913 msgsize = atoi(optarg); in main()
1298 if (msgsize == -1) in main()
1341 msgsize = RD_MAX(minlen, msgsize); in main()
1352 sbuf = malloc(msgsize); in main()
1355 while (rof < msgsize) { in main()
1363 msgsize); in main()
1366 msgcnt, msgsize); in main()
1418 pbuf = malloc(msgsize); in main()
1419 memcpy(pbuf, sbuf, msgsize); in main()
[all …]
|
| /dports/lang/fpc-utils/fpc-3.2.2/utils/ |
| H A D | data2inc.pp | 258 for i:=0 to msgsize-1 do
315 for i:=0 to msgsize-1 do
378 for i:=1 to msgsize do
529 inc(msgsize);
550 INC(msgsize,I1);
603 inc(msgsize,i4);
636 msgsize:=0;
657 msgsize:=0;
758 inc(msgsize,i1);
792 Getmem(msgtxt,msgsize);
[all …]
|
| /dports/lang/fpc-source/fpc-3.2.2/utils/ |
| H A D | data2inc.pp | 258 for i:=0 to msgsize-1 do
315 for i:=0 to msgsize-1 do
378 for i:=1 to msgsize do
529 inc(msgsize);
550 INC(msgsize,I1);
603 inc(msgsize,i4);
636 msgsize:=0;
657 msgsize:=0;
758 inc(msgsize,i1);
792 Getmem(msgtxt,msgsize);
[all …]
|
| /dports/ftp/bbftp-client/bbftp-client-3.2.1/bbftpc/ |
| H A D | readmessage.c | 71 int msgsize ; in readmessage() local
82 msgsize = msglen ; in readmessage()
86 while ( nbget < msgsize ) { in readmessage()
104 msgget = read(sock,&buffer[nbget],msgsize-nbget) ; in readmessage()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/unittest/gunit/libmysqlgcs/xcom/ |
| H A D | gcs_xcom_xcom_transport-t.cc | 210 uint32_t msgsize = 0; in TEST_F() local
213 get_header_1_0(buf, &msgsize, &x_type, &tag); in TEST_F()
214 ASSERT_EQ(msgsize + MSG_HDR_SIZE, buflen); in TEST_F()
219 deserialize_msg(p_received, x_1_6, (char *)buf + MSG_HDR_SIZE, msgsize); in TEST_F()
|
| /dports/devel/log4c/log4c-1.2.4/tests/log4c/ |
| H A D | bench_fwrite.c | 77 static char *make_msgbuf(long msgsize);
138 static char *make_msgbuf(long msgsize){ in make_msgbuf() argument
140 char *s = (char *)calloc(msgsize, sizeof(char)); in make_msgbuf()
143 while(i < msgsize-1) { in make_msgbuf()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/hv/ |
| H A D | channel.c | 318 u32 msgsize; in create_gpadl_header() local
333 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
336 msgheader = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
341 msgheader->msgsize = msgsize; in create_gpadl_header()
370 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
373 msgbody = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
392 msgbody->msgsize = msgsize; in create_gpadl_header()
414 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
417 msgheader = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
422 msgheader->msgsize = msgsize; in create_gpadl_header()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/hv/ |
| H A D | channel.c | 318 u32 msgsize; in create_gpadl_header() local
333 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
336 msgheader = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
341 msgheader->msgsize = msgsize; in create_gpadl_header()
370 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
373 msgbody = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
392 msgbody->msgsize = msgsize; in create_gpadl_header()
414 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
417 msgheader = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
422 msgheader->msgsize = msgsize; in create_gpadl_header()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/hv/ |
| H A D | channel.c | 318 u32 msgsize; in create_gpadl_header() local
333 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
336 msgheader = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
341 msgheader->msgsize = msgsize; in create_gpadl_header()
370 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
373 msgbody = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
392 msgbody->msgsize = msgsize; in create_gpadl_header()
414 msgsize = sizeof(struct vmbus_channel_msginfo) + in create_gpadl_header()
417 msgheader = kzalloc(msgsize, GFP_KERNEL); in create_gpadl_header()
422 msgheader->msgsize = msgsize; in create_gpadl_header()
[all …]
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0053-stats_cb.cpp | 229 int msgsize; /**< Expected per message size. member
372 const int msgsize = 6*1024; in test_stats() local
421 exp_parts[part].msgsize = msgsize; in test_stats()
431 char *buf = (char *)malloc(msgsize); in test_stats()
435 test_prepare_msg(testid, part, i, buf, msgsize, key, sizeof(key)); in test_stats()
438 buf, msgsize, key, sizeof(key), in test_stats()
442 exp_parts[part].totsize += msgsize + sizeof(key); in test_stats()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0053-stats_cb.cpp | 229 int msgsize; /**< Expected per message size. member
372 const int msgsize = 6*1024; in test_stats() local
421 exp_parts[part].msgsize = msgsize; in test_stats()
431 char *buf = (char *)malloc(msgsize); in test_stats()
435 test_prepare_msg(testid, part, i, buf, msgsize, key, sizeof(key)); in test_stats()
438 buf, msgsize, key, sizeof(key), in test_stats()
442 exp_parts[part].totsize += msgsize + sizeof(key); in test_stats()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0053-stats_cb.cpp | 229 int msgsize; /**< Expected per message size.
372 const int msgsize = 6*1024;
421 exp_parts[part].msgsize = msgsize;
431 char *buf = (char *)malloc(msgsize);
435 test_prepare_msg(testid, part, i, buf, msgsize, key, sizeof(key));
438 buf, msgsize, key, sizeof(key),
442 exp_parts[part].totsize += msgsize + sizeof(key);
|
| /dports/devel/rudiments/rudiments-1.2.2/test/ |
| H A D | tlsclient.cpp | 275 uint64_t msgsize; in main() local
276 ssize_t sizeread=fd.read(&msgsize); in main()
304 unsigned char *msg=new unsigned char[msgsize]; in main()
305 sizeread=fd.read(msg,msgsize); in main()
328 } else if (sizeread!=(ssize_t)msgsize) { in main()
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/include/ |
| H A D | mpid_nem_inline.h | 32 intptr_t *msg_offset, intptr_t msgsize,
466 intptr_t *msg_offset, intptr_t msgsize, in MPID_nem_mpich_send_seg_header() argument
487 if (sizeof(MPIDI_CH3_Pkt_t) + msgsize <= MPID_NEM_FBOX_DATALEN) in MPID_nem_mpich_send_seg_header()
507 cell_ptr->header.datalen = sizeof(MPIDI_CH3_Pkt_t) + msgsize; in MPID_nem_mpich_send_seg_header()
518 msgsize - *msg_offset, &actual_pack_bytes); in MPID_nem_mpich_send_seg_header()
519 MPIR_Assert(actual_pack_bytes == msgsize - *msg_offset); in MPID_nem_mpich_send_seg_header()
566 if (msgsize - *msg_offset <= MPID_NEM_MPICH_DATA_LEN - buf_offset) in MPID_nem_mpich_send_seg_header()
567 max_pack_bytes = msgsize - *msg_offset; in MPID_nem_mpich_send_seg_header()
611 intptr_t *msg_offset, intptr_t msgsize, MPIDI_VC_t *vc, int *again) in MPID_nem_mpich_send_seg() argument
652 if (msgsize - *msg_offset <= MPID_NEM_MPICH_DATA_LEN) in MPID_nem_mpich_send_seg()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_msg.c | 1542 if (msgsize) { in ut_rd_kafka_msg_new()
1545 rkm->rkm_len = msgsize; in ut_rd_kafka_msg_new()
1615 const size_t msgsize = 100; in unittest_msgq_order() local
1735 rkm = ut_rd_kafka_msg_new(msgsize); in unittest_msgq_order()
1814 size_t msgsize) { in ut_msgq_populate() argument
1844 const size_t msgsize = 100; in unittest_msgq_insert_all_sort() local
1858 msgsize); in unittest_msgq_insert_all_sort()
1872 msgsize); in unittest_msgq_insert_all_sort()
1940 const size_t msgsize = 100; in unittest_msgq_insert_each_sort() local
1953 msgsize); in unittest_msgq_insert_each_sort()
[all …]
|
| /dports/mail/opendkim/opendkim-2.10.3/libopendkim/tests/ |
| H A D | t-signperf.c | 184 size_t msgsize = DEFMSGSIZE; in main() local
228 msgsize = strtoul(optarg, &p, 10); in main()
289 (unsigned int) msgsize, (long) testint); in main()
334 msgrem = msgsize; in main()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/arch/powerpc/platforms/ps3/ |
| H A D | gelic_udbg.c | 192 static void gelic_sendbuf(int msgsize) in gelic_sendbuf() argument
198 dbg.descr.buf_size = header_size + msgsize; in gelic_sendbuf()
199 h_ip->tot_len = msgsize + sizeof(struct udphdr) + in gelic_sendbuf()
201 h_udp->len = msgsize + sizeof(struct udphdr); in gelic_sendbuf()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/arch/powerpc/platforms/ps3/ |
| H A D | gelic_udbg.c | 192 static void gelic_sendbuf(int msgsize) in gelic_sendbuf() argument
198 dbg.descr.buf_size = header_size + msgsize; in gelic_sendbuf()
199 h_ip->tot_len = msgsize + sizeof(struct udphdr) + in gelic_sendbuf()
201 h_udp->len = msgsize + sizeof(struct udphdr); in gelic_sendbuf()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/arch/powerpc/platforms/ps3/ |
| H A D | gelic_udbg.c | 192 static void gelic_sendbuf(int msgsize) in gelic_sendbuf() argument
198 dbg.descr.buf_size = header_size + msgsize; in gelic_sendbuf()
199 h_ip->tot_len = msgsize + sizeof(struct udphdr) + in gelic_sendbuf()
201 h_udp->len = msgsize + sizeof(struct udphdr); in gelic_sendbuf()
|
| /dports/devel/cxxtools/cxxtools-2.2.1/src/ |
| H A D | udpstream.cpp | 51 setp(message, message + msgsize); in overflow()
69 setp(message, message + msgsize); in sync()
|
| /dports/sysutils/tracker-miners/tracker-miners-2.3.5/tests/estress/ |
| H A D | options.py | 39 def parse_options (graphic_mode=False, period=1, msgsize=1, timeout=0): argument
52 "msgsize" : msgsize,
|
| /dports/sysutils/tracker3/tracker-3.1.2/tests/estress/ |
| H A D | options.py | 39 def parse_options (graphic_mode=False, period=1, msgsize=1, timeout=0): argument
52 "msgsize" : msgsize,
|