| /dports/net/nanomsg/nanomsg-1.1.5/perf/ |
| H A D | inproc_lat.c | 39 static size_t message_size; variable
51 buf = malloc (message_size); in worker()
55 rc = nn_recv (s, buf, message_size, 0); in worker()
56 assert (rc == (int)message_size); in worker()
57 rc = nn_send (s, buf, message_size, 0); in worker()
58 assert (rc == (int)message_size); in worker()
81 message_size = atoi (argv [1]); in main()
94 buf = malloc (message_size); in main()
96 memset (buf, 111, message_size); in main()
106 assert (rc == (int)message_size); in main()
[all …]
|
| H A D | inproc_thr.c | 38 static size_t message_size; variable
50 buf = malloc (message_size); in worker()
52 memset (buf, 111, message_size); in worker()
58 rc = nn_send (s, buf, message_size, 0); in worker()
59 assert (rc == (int)message_size); in worker()
83 message_size = atoi (argv [1]); in main()
96 buf = malloc (message_size); in main()
102 rc = nn_recv (s, buf, message_size, 0); in main()
108 rc = nn_recv (s, buf, message_size, 0); in main()
109 assert (rc == (int)message_size); in main()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/common/channel/ |
| H A D | message_framer.cc | 31 const size_t message_size = message.ByteSizeLong(); in Serialize() local
32 if (message_size > kMaxBodySize || message_size == 0) { in Serialize()
35 std::vector<uint8_t> out(message_size + kHeaderSize, 0); in Serialize()
36 WriteBigEndian<uint32_t>(message_size, out.data()); in Serialize()
37 if (!message.SerializeToArray(&out[kHeaderSize], message_size)) { in Serialize()
48 const uint32_t message_size = ReadBigEndian<uint32_t>(input.data()); in TryDeserialize() local
49 if (message_size > kMaxBodySize) { in TryDeserialize()
53 if (input.size() < (kHeaderSize + message_size)) { in TryDeserialize()
59 message_size)) { in TryDeserialize()
62 result.length = kHeaderSize + message_size; in TryDeserialize()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/common/channel/ |
| H A D | message_framer.cc | 31 const size_t message_size = message.ByteSizeLong(); in Serialize() local
32 if (message_size > kMaxBodySize || message_size == 0) { in Serialize()
35 std::vector<uint8_t> out(message_size + kHeaderSize, 0); in Serialize()
36 WriteBigEndian<uint32_t>(message_size, out.data()); in Serialize()
37 if (!message.SerializeToArray(&out[kHeaderSize], message_size)) { in Serialize()
48 const uint32_t message_size = ReadBigEndian<uint32_t>(input.data()); in TryDeserialize() local
49 if (message_size > kMaxBodySize) { in TryDeserialize()
53 if (input.size() < (kHeaderSize + message_size)) { in TryDeserialize()
59 message_size)) { in TryDeserialize()
62 result.length = kHeaderSize + message_size; in TryDeserialize()
|
| /dports/emulators/tme/tme-0.8/libtme/ |
| H A D | log.c | 322 unsigned long message_size; local
348 memcpy(message + message_size,
400 memcpy(message + message_size,
403 message_size += string_length + 1;
415 message_size += sizeof(char);
434 memcpy(message + message_size,
438 message_size += sizeof(prf_value_d);
457 memcpy(message + message_size,
461 message_size += sizeof(prf_value_ld);
482 memcpy(message + message_size,
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/media/midi/ |
| H A D | usb_midi_output_stream.cc | 77 size_t message_size = 0; in PushSysExMessage() local
82 if (message_size == kMessageSizeMax) { in PushSysExMessage()
98 message[message_size] = byte; in PushSysExMessage()
99 ++message_size; in PushSysExMessage()
129 DCHECK_NE(0u, message_size); in PushSysCommonMessage()
130 DCHECK_LE(message_size, 3u); in PushSysCommonMessage()
138 message_size == 1 ? 0x5 : static_cast<uint8_t>(message_size); in PushSysCommonMessage()
142 *current += message_size; in PushSysCommonMessage()
179 DCHECK_NE(0u, message_size); in PushChannelMessage()
180 DCHECK_LE(message_size, 3u); in PushChannelMessage()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/media/midi/ |
| H A D | usb_midi_output_stream.cc | 77 size_t message_size = 0; in PushSysExMessage() local
82 if (message_size == kMessageSizeMax) { in PushSysExMessage()
98 message[message_size] = byte; in PushSysExMessage()
99 ++message_size; in PushSysExMessage()
129 DCHECK_NE(0u, message_size); in PushSysCommonMessage()
130 DCHECK_LE(message_size, 3u); in PushSysCommonMessage()
138 message_size == 1 ? 0x5 : static_cast<uint8_t>(message_size); in PushSysCommonMessage()
142 *current += message_size; in PushSysCommonMessage()
179 DCHECK_NE(0u, message_size); in PushChannelMessage()
180 DCHECK_LE(message_size, 3u); in PushChannelMessage()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/cast_channel/ |
| H A D | cast_framer.cc | 25 MessageFramer::MessageHeader::MessageHeader() : message_size(0) {} in MessageHeader()
30 message_size = size; in SetMessageSize()
37 output.message_size = base::HostToNet32(message_size); in PrependToString()
49 uint32_t message_size; in Deserialize() local
50 memcpy(&message_size, data, header_size()); in Deserialize()
51 header->message_size = in Deserialize()
52 base::checked_cast<size_t>(base::NetToHost32(message_size)); in Deserialize()
79 size_t message_size = message_data->size(); in Serialize() local
80 if (message_size > MessageHeader::max_body_size()) { in Serialize()
85 header.SetMessageSize(message_size); in Serialize()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/cast_channel/ |
| H A D | cast_framer.cc | 27 MessageFramer::MessageHeader::MessageHeader() : message_size(0) {} in MessageHeader()
32 message_size = size; in SetMessageSize()
39 output.message_size = base::HostToNet32(message_size); in PrependToString()
51 uint32_t message_size; in Deserialize() local
52 memcpy(&message_size, data, header_size()); in Deserialize()
53 header->message_size = in Deserialize()
54 base::checked_cast<size_t>(base::NetToHost32(message_size)); in Deserialize()
81 size_t message_size = message_data->size(); in Serialize() local
82 if (message_size > MessageHeader::max_body_size()) { in Serialize()
87 header.SetMessageSize(message_size); in Serialize()
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/tuned/ |
| H A D | coll_tuned_decision_fixed.c | 241 size_t message_size, dsize; in ompi_coll_tuned_bcast_intra_dec_fixed() local
313 if (message_size < 524288) segsize = 0; in ompi_coll_tuned_bcast_intra_dec_fixed()
317 if (communicator_size <= 8 && message_size < 4096) { in ompi_coll_tuned_bcast_intra_dec_fixed()
320 if (communicator_size > 8 && message_size >= 32768 && message_size < 524288) { in ompi_coll_tuned_bcast_intra_dec_fixed()
324 if (message_size >= 524288) { in ompi_coll_tuned_bcast_intra_dec_fixed()
350 size_t message_size, dsize; in ompi_coll_tuned_reduce_intra_dec_fixed() local
388 (message_size < 2048) || (count <= 1)) { in ompi_coll_tuned_reduce_intra_dec_fixed()
409 if (communicator_size > (a4 * message_size + b4)) { in ompi_coll_tuned_reduce_intra_dec_fixed()
421 if (message_size <= 4096) { in ompi_coll_tuned_reduce_intra_dec_fixed()
428 if (message_size < 524288) { in ompi_coll_tuned_reduce_intra_dec_fixed()
[all …]
|
| /dports/sysutils/fwup/fwup-1.9.0/src/3rdparty/monocypher-3.1.2/src/optional/ |
| H A D | monocypher-ed25519.c | 202 FOR (i, 0, message_size) {
227 if (message_size == 0) {
234 message_size -= aligned;
237 FOR (i, 0, message_size / 128) { // number of blocks
245 message_size &= 127;
248 sha512_update(ctx, message, message_size);
278 crypto_sha512_update(&ctx, message, message_size);
322 crypto_sha512_update(&ctx->ctx, message, message_size);
342 const u8 *message, size_t message_size)
346 crypto_hmac_sha512_update(&ctx, message, message_size);
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/src/protocol/ |
| H A D | x_protocol.cc | 81 const uint32_t message_size) { in message_valid() argument
116 uint32_t &message_size, in get_next_message() argument
152 &message_size); in get_next_message()
161 size_t size_needed = message_offset + 4 + message_size; in get_next_message()
164 message_size, static_cast<long unsigned>(buffer.size()), in get_next_message()
171 while (message_size + 4 > bytes_left) { in get_next_message()
174 message_size + 4 - bytes_left); in get_next_message()
224 uint32_t message_size = 0; in copy_packets() local
241 message_type, message_size - 1)) { in copy_packets()
243 message_type, message_size - 1); in copy_packets()
[all …]
|
| /dports/print/pnm2ppa/pnm2ppa-1.13/ |
| H A D | pnm2ppa.c | 57 snprintf(syslog_message,message_size,"%s", in print_pnm()
80 snprintf(syslog_message,message_size,"print_pnm(): %s", in print_pnm()
91 snprintf(syslog_message,message_size, "print_pnm(): %s", in print_pnm()
98 snprintf(syslog_message,message_size, "%s %d (%s)\n", in print_pnm()
111 snprintf(syslog_message,message_size, "%s %d\n", in print_pnm()
130 snprintf(syslog_message,message_size,"%s" , in print_pnm()
138 snprintf(syslog_message,message_size,"%s" , in print_pnm()
170 snprintf(syslog_message,message_size,"%s %d\n", in readPath()
934 snprintf(syslog_message,message_size,"main(): %s", in main()
952 snprintf(syslog_message,message_size,"main(): %s", in main()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/ngs/src/ |
| H A D | protocol_decoder.cc | 51 uint32_t *message_size, in read_header() argument
95 buffer, message_size); in read_header()
99 if (*message_size > 0) { in read_header()
132 uint32_t message_size; in read_and_decode_impl() local
137 if (!read_header(&message_type, &message_size, wait_for_io)) { in read_and_decode_impl()
145 if (0 == message_size) { in read_and_decode_impl()
150 if (m_config->m_global->max_message_size < message_size) { in read_and_decode_impl()
155 const auto protobuf_payload_size = message_size - 1; in read_and_decode_impl()
174 message_size + k_header - m_vio_input_stream.ByteCount(); in read_and_decode_impl()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-mail/ |
| H A D | message-size.h | 4 struct message_size { struct
12 int message_get_header_size(struct istream *input, struct message_size *hdr, argument
15 int message_get_body_size(struct istream *input, struct message_size *body,
19 void message_size_add(struct message_size *dest,
20 const struct message_size *src);
|
| /dports/audio/gsequencer/gsequencer-3.10.4/ags/audio/osc/controller/ |
| H A D | ags_osc_renew_controller.c | 1048 message, message_size, in ags_osc_renew_controller_set_data_audio()
1393 message, message_size, in ags_osc_renew_controller_set_data_audio()
1414 message, message_size, in ags_osc_renew_controller_set_data_audio()
1605 message, message_size, in ags_osc_renew_controller_set_data_audio()
2047 message, message_size, in ags_osc_renew_controller_set_data_channel()
2068 message, message_size, in ags_osc_renew_controller_set_data_channel()
2575 message, message_size, in ags_osc_renew_controller_set_data_recall()
2596 message, message_size, in ags_osc_renew_controller_set_data_recall()
2640 message, message_size, in ags_osc_renew_controller_set_data_recall()
2676 message, message_size, in ags_osc_renew_controller_set_data_recall()
[all …]
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/curl-sys-0.4.51+curl-7.80.0/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/devel/sentry-cli/sentry-cli-1.71.0/cargo-crates/curl-sys-0.4.48+curl-7.79.1/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/audio/lewton/lewton-0.10.2/cargo-crates/curl-sys-0.4.25/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/net/openmpi/openmpi-4.1.1/test/spc/ |
| H A D | spc_test.c | 19 static void message_exchange(int num_messages, int message_size) in message_exchange() argument
23 char *data = (char*)calloc(message_size, sizeof(char)); in message_exchange()
30 MPI_Send(data, message_size, MPI_BYTE, 1, 123, MPI_COMM_WORLD); in message_exchange()
33 MPI_Recv(data, message_size, MPI_BYTE, 0, 123, MPI_COMM_WORLD, &status); in message_exchange()
119 int message_size = 1, expected_bytes = 0; in main() local
120 while(message_size <= MAX_SIZE) { in main()
121 expected_bytes += message_size; in main()
122 message_exchange(1, message_size); in main()
123 message_size *= 10; in main()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/curl-sys-0.4.34+curl-7.71.1/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/curl-sys-0.4.41+curl-7.75.0/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/graphics/mupdf/mupdf-1.18.0-source/thirdparty/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/curl-sys/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|
| /dports/www/newsboat/newsboat-2.22.1/cargo-crates/curl-sys-0.4.39+curl-7.74.0/curl/tests/libtest/ |
| H A D | lib571.c | 57 int message_size; in rtp_write() local
63 message_size = curlx_uztosi(size * nmemb) - 4; in rtp_write()
65 printf("RTP: message size %d, channel %d\n", message_size, channel); in rtp_write()
66 if(message_size != coded_size) { in rtp_write()
68 coded_size, message_size); in rtp_write()
73 for(i = 0; i < message_size; i += RTP_DATA_SIZE) { in rtp_write()
74 if(message_size - i > RTP_DATA_SIZE) { in rtp_write()
81 if(memcmp(RTP_DATA, data + i, message_size - i) != 0) { in rtp_write()
83 message_size - i, data + i); in rtp_write()
|