| /dports/sysutils/tracker/tracker-2.3.4/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/devel/rudiments/rudiments-1.2.2/test/ |
| H A D | gssclient.cpp | 357 uint64_t msgsize; in main() local
358 ssize_t sizeread=fd.read(&msgsize); in main()
386 unsigned char *msg=new unsigned char[msgsize]; in main()
387 sizeread=fd.read(msg,msgsize); in main()
410 } else if (sizeread!=(ssize_t)msgsize) { in main()
|
| /dports/net/openradius/openradius-0.9.12c/common/ |
| H A D | md5.h | 71 void md5(P3(char *digest, const char *message, int msgsize));
73 void md5(char *digest, const char *message, int msgsize);
|
| /dports/games/minetest/minetest-5.4.1/src/network/ |
| H A D | networkpacket.cpp | 126 u16 msgsize = src.size(); in operator <<() local
128 *this << msgsize; in operator <<()
130 putRawString(src.c_str(), (u32)msgsize); in operator <<()
141 u32 msgsize = src.size(); in putLongString() local
143 *this << msgsize; in putLongString()
145 putRawString(src.c_str(), msgsize); in putLongString()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0077-compaction.c | 100 int msgcnt, size_t msgsize) { in produce_compactable_msgs() argument
114 val = calloc(1, msgsize); in produce_compactable_msgs()
117 "compactable messages\n", msgcnt, (size_t)msgcnt*msgsize); in produce_compactable_msgs()
132 RD_KAFKA_V_VALUE(val, msgsize), in produce_compactable_msgs()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0077-compaction.c | 100 int msgcnt, size_t msgsize) { in produce_compactable_msgs() argument
114 val = calloc(1, msgsize); in produce_compactable_msgs()
117 "compactable messages\n", msgcnt, (size_t)msgcnt*msgsize); in produce_compactable_msgs()
132 RD_KAFKA_V_VALUE(val, msgsize), in produce_compactable_msgs()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/redislog/ |
| H A D | redislog_plugin.c | 12 char msgsize[11]; member
141 uredislog->iovec[2].iov_base = uredislog->msgsize; in uwsgi_redis_logger()
193 uwsgi_num2str2(len + uredislog->iovec[4].iov_len, uredislog->msgsize); in uwsgi_redis_logger()
194 uredislog->iovec[2].iov_len = strlen(uredislog->msgsize); in uwsgi_redis_logger()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0077-compaction.c | 100 int msgcnt, size_t msgsize) {
114 val = calloc(1, msgsize);
117 "compactable messages\n", msgcnt, (size_t)msgcnt*msgsize);
132 RD_KAFKA_V_VALUE(val, msgsize),
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/src/ |
| H A D | csel.c | 858 MPI_Aint msgsize = 0; in get_avg_msgsize() local
863 msgsize *= coll_info.u.allreduce.count; in get_avg_msgsize()
868 msgsize *= coll_info.u.iallreduce.count; in get_avg_msgsize()
872 MPIR_Datatype_get_size_macro(coll_info.u.bcast.datatype, msgsize); in get_avg_msgsize()
873 msgsize *= coll_info.u.bcast.count; in get_avg_msgsize()
878 msgsize *= coll_info.u.ibcast.count; in get_avg_msgsize()
883 msgsize *= coll_info.u.reduce.count; in get_avg_msgsize()
888 msgsize *= coll_info.u.ireduce.count; in get_avg_msgsize()
893 msgsize *= coll_info.u.alltoall.sendcount; in get_avg_msgsize()
898 msgsize *= coll_info.u.ialltoall.sendcount; in get_avg_msgsize()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/gpu/drm/i915/gt/uc/ |
| H A D | intel_guc_ct.c | 677 u32 msgsize = (len + 1) * sizeof(u32); /* msg size in bytes w/header */ in ct_handle_response() local
689 CT_ERROR(ct, "Corrupted response %*ph\n", msgsize, msg); in ct_handle_response()
699 CT_ERROR(ct, "Corrupted response %*ph\n", msgsize, msg); in ct_handle_response()
714 req->fence, msgsize, msg); in ct_handle_response()
727 CT_ERROR(ct, "Unsolicited response %*ph\n", msgsize, msg); in ct_handle_response()
817 u32 msgsize = (len + 1) * sizeof(u32); /* msg size in bytes w/header */ in ct_handle_request() local
823 request = kmalloc(sizeof(*request) + msgsize, GFP_ATOMIC); in ct_handle_request()
825 CT_ERROR(ct, "Dropping request %*ph\n", msgsize, msg); in ct_handle_request()
828 memcpy(request->msg, msg, msgsize); in ct_handle_request()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/gpu/drm/i915/gt/uc/ |
| H A D | intel_guc_ct.c | 677 u32 msgsize = (len + 1) * sizeof(u32); /* msg size in bytes w/header */ in ct_handle_response() local
689 CT_ERROR(ct, "Corrupted response %*ph\n", msgsize, msg); in ct_handle_response()
699 CT_ERROR(ct, "Corrupted response %*ph\n", msgsize, msg); in ct_handle_response()
714 req->fence, msgsize, msg); in ct_handle_response()
727 CT_ERROR(ct, "Unsolicited response %*ph\n", msgsize, msg); in ct_handle_response()
817 u32 msgsize = (len + 1) * sizeof(u32); /* msg size in bytes w/header */ in ct_handle_request() local
823 request = kmalloc(sizeof(*request) + msgsize, GFP_ATOMIC); in ct_handle_request()
825 CT_ERROR(ct, "Dropping request %*ph\n", msgsize, msg); in ct_handle_request()
828 memcpy(request->msg, msg, msgsize); in ct_handle_request()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/gpu/drm/i915/gt/uc/ |
| H A D | intel_guc_ct.c | 677 u32 msgsize = (len + 1) * sizeof(u32); /* msg size in bytes w/header */ in ct_handle_response() local
689 CT_ERROR(ct, "Corrupted response %*ph\n", msgsize, msg); in ct_handle_response()
699 CT_ERROR(ct, "Corrupted response %*ph\n", msgsize, msg); in ct_handle_response()
714 req->fence, msgsize, msg); in ct_handle_response()
727 CT_ERROR(ct, "Unsolicited response %*ph\n", msgsize, msg); in ct_handle_response()
817 u32 msgsize = (len + 1) * sizeof(u32); /* msg size in bytes w/header */ in ct_handle_request() local
823 request = kmalloc(sizeof(*request) + msgsize, GFP_ATOMIC); in ct_handle_request()
825 CT_ERROR(ct, "Dropping request %*ph\n", msgsize, msg); in ct_handle_request()
828 memcpy(request->msg, msg, msgsize); in ct_handle_request()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_msg.c | 1801 if (msgsize) { in ut_rd_kafka_msg_new()
1804 rkm->rkm_len = msgsize; in ut_rd_kafka_msg_new()
1874 const size_t msgsize = 100; in unittest_msgq_order() local
1994 rkm = ut_rd_kafka_msg_new(msgsize); in unittest_msgq_order()
2073 size_t msgsize) { in ut_msgq_populate() argument
2103 const size_t msgsize = 100; in unittest_msgq_insert_all_sort() local
2117 msgsize); in unittest_msgq_insert_all_sort()
2131 msgsize); in unittest_msgq_insert_all_sort()
2199 const size_t msgsize = 100; in unittest_msgq_insert_each_sort() local
2212 msgsize); in unittest_msgq_insert_each_sort()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_msg.c | 1801 if (msgsize) { in ut_rd_kafka_msg_new()
1804 rkm->rkm_len = msgsize; in ut_rd_kafka_msg_new()
1874 const size_t msgsize = 100; in unittest_msgq_order() local
1994 rkm = ut_rd_kafka_msg_new(msgsize); in unittest_msgq_order()
2073 size_t msgsize) { in ut_msgq_populate() argument
2103 const size_t msgsize = 100; in unittest_msgq_insert_all_sort() local
2117 msgsize); in unittest_msgq_insert_all_sort()
2131 msgsize); in unittest_msgq_insert_all_sort()
2199 const size_t msgsize = 100; in unittest_msgq_insert_each_sort() local
2212 msgsize); in unittest_msgq_insert_each_sort()
[all …]
|
| /dports/audio/schismtracker/schismtracker-20211116/fmt/ |
| H A D | generic.c | 226 int msgsize = 0, linesize; in read_lined_message() local
230 if (msgsize + linesize + 1 >= MAX_MESSAGE) { in read_lined_message()
241 msgsize += linesize + 1; in read_lined_message()
|
| /dports/devel/cxxtools/cxxtools-2.2.1/include/cxxtools/net/ |
| H A D | udpstream.h | 42 unsigned msgsize; variable
51 msgsize(msgsize_), in message()
|
| /dports/mail/cone/cone-1.1/libs/maildir/ |
| H A D | maildirquota.c | 858 int64_t msgsize, int nmsgs, in maildir_quota_add_start() argument
895 rc=maildir_checkquota(info, msgsize, nmsgs); in maildir_quota_add_start()
913 int64_t msgsize, int nmsgs) in maildir_quota_add_end() argument
915 maildir_addquota(info, msgsize, nmsgs); in maildir_quota_add_end()
947 int64_t msgsize, int nmsgs) in maildir_quota_delundel_start() argument
954 maildir_quota_deleted(maildir, msgsize, nmsgs); in maildir_quota_delundel_start()
958 return maildir_quota_add_start(maildir, info, msgsize, nmsgs, NULL); in maildir_quota_delundel_start()
963 int64_t msgsize, int nmsgs) in maildir_quota_delundel_end() argument
971 maildir_quota_add_end(info, msgsize, nmsgs); in maildir_quota_delundel_end()
1069 createInfo.msgsize=msg_len; in do_deliver_warning()
|
| /dports/mail/sqwebmail/sqwebmail-6.0.6/libs/maildir/ |
| H A D | maildirquota.c | 858 int64_t msgsize, int nmsgs, in maildir_quota_add_start() argument
895 rc=maildir_checkquota(info, msgsize, nmsgs); in maildir_quota_add_start()
913 int64_t msgsize, int nmsgs) in maildir_quota_add_end() argument
915 maildir_addquota(info, msgsize, nmsgs); in maildir_quota_add_end()
947 int64_t msgsize, int nmsgs) in maildir_quota_delundel_start() argument
954 maildir_quota_deleted(maildir, msgsize, nmsgs); in maildir_quota_delundel_start()
958 return maildir_quota_add_start(maildir, info, msgsize, nmsgs, NULL); in maildir_quota_delundel_start()
963 int64_t msgsize, int nmsgs) in maildir_quota_delundel_end() argument
971 maildir_quota_add_end(info, msgsize, nmsgs); in maildir_quota_delundel_end()
1069 createInfo.msgsize=msg_len; in do_deliver_warning()
|
| /dports/mail/courier/courier-0.65.3/maildir/ |
| H A D | maildirquota.c | 853 int64_t msgsize, int nmsgs, in maildir_quota_add_start() argument
890 rc=maildir_checkquota(info, msgsize, nmsgs); in maildir_quota_add_start()
908 int64_t msgsize, int nmsgs) in maildir_quota_add_end() argument
910 maildir_addquota(info, msgsize, nmsgs); in maildir_quota_add_end()
942 int64_t msgsize, int nmsgs) in maildir_quota_delundel_start() argument
949 maildir_quota_deleted(maildir, msgsize, nmsgs); in maildir_quota_delundel_start()
953 return maildir_quota_add_start(maildir, info, msgsize, nmsgs, NULL); in maildir_quota_delundel_start()
958 int64_t msgsize, int nmsgs) in maildir_quota_delundel_end() argument
966 maildir_quota_add_end(info, msgsize, nmsgs); in maildir_quota_delundel_end()
1064 createInfo.msgsize=msg_len; in do_deliver_warning()
|
| /dports/mail/courier-imap/courier-imap-5.1.4/libs/maildir/ |
| H A D | maildirquota.c | 858 int64_t msgsize, int nmsgs, in maildir_quota_add_start() argument
895 rc=maildir_checkquota(info, msgsize, nmsgs); in maildir_quota_add_start()
913 int64_t msgsize, int nmsgs) in maildir_quota_add_end() argument
915 maildir_addquota(info, msgsize, nmsgs); in maildir_quota_add_end()
947 int64_t msgsize, int nmsgs) in maildir_quota_delundel_start() argument
954 maildir_quota_deleted(maildir, msgsize, nmsgs); in maildir_quota_delundel_start()
958 return maildir_quota_add_start(maildir, info, msgsize, nmsgs, NULL); in maildir_quota_delundel_start()
963 int64_t msgsize, int nmsgs) in maildir_quota_delundel_end() argument
971 maildir_quota_add_end(info, msgsize, nmsgs); in maildir_quota_delundel_end()
1069 createInfo.msgsize=msg_len; in do_deliver_warning()
|
| /dports/mail/maildrop/maildrop-3.0.3/libs/maildir/ |
| H A D | maildirquota.c | 858 int64_t msgsize, int nmsgs, in maildir_quota_add_start() argument
895 rc=maildir_checkquota(info, msgsize, nmsgs); in maildir_quota_add_start()
913 int64_t msgsize, int nmsgs) in maildir_quota_add_end() argument
915 maildir_addquota(info, msgsize, nmsgs); in maildir_quota_add_end()
947 int64_t msgsize, int nmsgs) in maildir_quota_delundel_start() argument
954 maildir_quota_deleted(maildir, msgsize, nmsgs); in maildir_quota_delundel_start()
958 return maildir_quota_add_start(maildir, info, msgsize, nmsgs, NULL); in maildir_quota_delundel_start()
963 int64_t msgsize, int nmsgs) in maildir_quota_delundel_end() argument
971 maildir_quota_add_end(info, msgsize, nmsgs); in maildir_quota_delundel_end()
1069 createInfo.msgsize=msg_len; in do_deliver_warning()
|
| /dports/lang/fpc/fpc-3.2.2/compiler/utils/ |
| H A D | msg2inc.pp | 52 msgsize : longint;
96 msgsize:=0;
146 inc(msgsize,j-i);
150 inc(msgsize,length(s)-i+1);
173 getmem(msgtxt,msgsize);
175 dec(msgsize);
286 writeln(t,' MsgTxtSize = ',msgsize,';');
352 for i:=1 to msgsize do
464 for i:=1to msgsize do
487 s:=l0(msgsize);
[all …]
|
| /dports/lang/fpc-source/fpc-3.2.2/compiler/utils/ |
| H A D | msg2inc.pp | 52 msgsize : longint;
96 msgsize:=0;
146 inc(msgsize,j-i);
150 inc(msgsize,length(s)-i+1);
173 getmem(msgtxt,msgsize);
175 dec(msgsize);
286 writeln(t,' MsgTxtSize = ',msgsize,';');
352 for i:=1 to msgsize do
464 for i:=1to msgsize do
487 s:=l0(msgsize);
[all …]
|
| /dports/editors/fpc-ide/fpc-3.2.2/compiler/utils/ |
| H A D | msg2inc.pp | 52 msgsize : longint;
96 msgsize:=0;
146 inc(msgsize,j-i);
150 inc(msgsize,length(s)-i+1);
173 getmem(msgtxt,msgsize);
175 dec(msgsize);
286 writeln(t,' MsgTxtSize = ',msgsize,';');
352 for i:=1 to msgsize do
464 for i:=1to msgsize do
487 s:=l0(msgsize);
[all …]
|
| /dports/databases/twemproxy/twemproxy-0.5.0/src/ |
| H A D | nc_response.c | 225 rsp_forward_stats(struct context *ctx, struct server *server, struct msg *msg, uint32_t msgsize) in rsp_forward_stats() argument
230 stats_server_incr_by(ctx, server, response_bytes, msgsize); in rsp_forward_stats()
239 uint32_t msgsize; in rsp_forward() local
242 msgsize = msg->mlen; in rsp_forward()
271 rsp_forward_stats(ctx, s_conn->owner, msg, msgsize); in rsp_forward()
|