Home
last modified time | relevance | path

Searched refs:num_messages (Results 1 – 25 of 712) sorted by relevance

12345678910>>...29

/dports/net/astron/Astron-c8ba982/src/tests/
H A DMDPerformanceTest.cpp20 MDPerformanceParticipant() : MDParticipantInterface(), num_messages(0) in MDPerformanceParticipant()
36 num_messages++; in spam()
42 num_messages++; in spam()
45 uint32_t num_messages; member in MDPerformanceParticipant
99 double num_messages = 0; in speed_test() local
101 … num_messages += double(m_participants[i]->num_messages) / double(MD_PERF_NUM_PARTICIPANTS); in speed_test()
104 mdperf_log.info() << "An average of " << num_messages << " messages were processed. " in speed_test()
105 … "this comes out to be " << num_messages / MD_PERF_TIME << " messages/second" << std::endl; in speed_test()
120 double num_messages = 0; in speed_test_no_memcpy() local
122 … num_messages += double(m_participants[i]->num_messages) / double(MD_PERF_NUM_PARTICIPANTS); in speed_test_no_memcpy()
[all …]
/dports/net/dgd-lpmud/mud/2.4.5/obj/
H A Dbull_board.c2 int num_messages; variable
13 if (num_messages == 0) {
17 write("The bulletine board contains " + num_messages);
18 if (num_messages == 1)
72 if (num_messages == 10) { in new()
93 num_messages += 1; in get_body()
113 if (i < 1 || i > num_messages) { in read()
143 if (i < 1 || i > num_messages) { in remove()
161 num_messages -= 1; in remove()
H A Dorg.w_bb2 int num_messages;
13 if (num_messages == 0) {
17 write("The bulletin board contains " + num_messages);
18 if (num_messages == 1)
72 if (num_messages == 30) {
103 num_messages += 1;
123 if (i < 1 || i > num_messages) {
158 if (i < 1 || i > num_messages) {
177 num_messages -= 1;
/dports/games/ldmud/ldmud-3.3.720/mud/lp-245/obj/
H A Dbull_board.c2 int num_messages; variable
15 if (num_messages == 0) {
19 write("The bulletine board contains " + num_messages);
20 if (num_messages == 1)
74 if (num_messages == 10) { in new()
95 num_messages += 1; in get_body()
115 if (i < 1 || i > num_messages) { in read()
146 if (i < 1 || i > num_messages) { in remove()
164 num_messages -= 1; in remove()
/dports/net/libzmq4/zeromq-4.3.4/tests/
H A Dtest_iov.cpp56 const int num_messages = 10; in do_check() local
59 send_count = recv_count = num_messages; in do_check()
66 struct iovec send_iov[num_messages]; in do_check()
67 char *buf = static_cast<char *> (malloc (msg_size_ * num_messages)); in do_check()
69 for (int i = 0; i < num_messages; i++) { in do_check()
98 struct iovec recv_iov[num_messages]; in do_check()
113 num_messages, in do_check()
116 for (int i = 0; i < num_messages; i++) { in do_check()
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/tests/integration/consumer_producer/
H A Dconsumer.rs56 let mut num_messages = 0; in test_consumer_commit_messageset() localVariable
61 num_messages += messages.len(); in test_consumer_commit_messageset()
67 if num_messages >= (NUM_MESSAGES as usize) { in test_consumer_commit_messageset()
72 assert_eq!(NUM_MESSAGES as usize, num_messages, "wrong number of messages"); in test_consumer_commit_messageset()
116 let mut num_messages = 0; in test_consumer_commit_messageset_no_consumes() localVariable
121 num_messages += messages.len(); in test_consumer_commit_messageset_no_consumes()
129 if num_messages >= (NUM_MESSAGES as usize) { in test_consumer_commit_messageset_no_consumes()
134 assert_eq!(NUM_MESSAGES as usize, num_messages, "wrong number of messages"); in test_consumer_commit_messageset_no_consumes()
/dports/science/eccodes/eccodes-2.23.0-Source/tests/
H A Dbufr_extract_headers.c20 int num_messages = 0, i =0;
29 …err = codes_extract_offsets_malloc(c, filename, PRODUCT_GRIB, &offsets, &num_messages, strict_mode…
32 for (i = 0; i < num_messages; ++i) {
44 int num_messages = 0; in main() local
57 err = codes_bufr_extract_headers_malloc(c, filename, &header_array, &num_messages, strict_mode); in main()
67 for (i = 0; i < num_messages; ++i) { in main()
H A Dextract_offsets.c18 int num_messages = 0, i =0; in main() local
27 …err = codes_extract_offsets_malloc(c, filename, PRODUCT_ANY, &offsets, &num_messages, strict_mode); in main()
30 for (i = 0; i < num_messages; ++i) { in main()
/dports/devel/glib20/glib-2.70.4/gio/
H A Dgdatagrambased.c170 guint num_messages, in g_datagram_based_receive_messages() argument
181 g_return_val_if_fail (num_messages == 0 || messages != NULL, -1); in g_datagram_based_receive_messages()
189 retval = iface->receive_messages (datagram_based, messages, num_messages, in g_datagram_based_receive_messages()
200 g_return_val_if_fail (retval < 0 || (guint) retval <= num_messages, -1); in g_datagram_based_receive_messages()
271 guint num_messages, in g_datagram_based_send_messages() argument
282 g_return_val_if_fail (num_messages == 0 || messages != NULL, -1); in g_datagram_based_send_messages()
290 retval = iface->send_messages (datagram_based, messages, num_messages, flags, in g_datagram_based_send_messages()
301 g_return_val_if_fail (retval < 0 || (guint) retval <= num_messages, -1); in g_datagram_based_send_messages()
302 g_return_val_if_fail (!(timeout < 0 && num_messages > 0) || retval != 0, -1); in g_datagram_based_send_messages()
/dports/sysutils/busybox/busybox-1.26.2/applets/
H A Dusage_pod.c52 int num_messages = sizeof(usage_array) / sizeof(usage_array[0]); in main() local
54 if (num_messages == 0) in main()
58 num_messages, sizeof(usage_array[0]), in main()
62 for (i = 0; i < num_messages; i++) { in main()
82 for (i = 0; i < num_messages; i++) { in main()
H A Dusage.c43 int num_messages = sizeof(usage_array) / sizeof(usage_array[0]); in main() local
45 if (num_messages == 0) in main()
49 num_messages, sizeof(usage_array[0]), in main()
51 for (i = 0; i < num_messages; i++) in main()
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/template/
H A Deval.c32 log_template_append_format_with_context(LogTemplate *self, LogMessage **messages, gint num_messages, in log_template_append_format_with_context() argument
57 if (e->msg_ref > num_messages) in log_template_append_format_with_context()
59 msg_ndx = num_messages - e->msg_ref; in log_template_append_format_with_context()
98 e->msg_ref ? 1 : num_messages, in log_template_append_format_with_context()
122 log_template_format_with_context(LogTemplate *self, LogMessage **messages, gint num_messages, in log_template_format_with_context() argument
126 log_template_append_format_with_context(self, messages, num_messages, options, result); in log_template_format_with_context()
/dports/net/openmpi/openmpi-4.1.1/examples/
H A Dspc_example.c18 void message_exchange(int num_messages, int message_size) in message_exchange() argument
28 for(i = 0; i < num_messages; i++) in message_exchange()
31 for(i = 0; i < num_messages; i++) in message_exchange()
40 int num_messages, message_size, rc; in main() local
46 num_messages = atoi(argv[1]); in main()
102 message_exchange(num_messages, message_size); in main()
/dports/mail/pear-Net_IMAP/Net_IMAP-1.1.3/docs/
H A Dtest_IMAP.php206 if ( !PEAR::isError( $num_messages = $imap->getNumberOfMessages( $mailbox ) ) ){ variable
210 for($i=1; $i<=$num_messages;$i++) {
435 if ( PEAR::isError( $num_messages = $imap->getNumberOfMessages( $mailbox ) ) ){
437 $num_messages="[ERROR]";
454 for($i=strlen($num_messages) ; $i< 13 ; $i++) echo ' ';
455 echo $num_messages;
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/quartc/
H A Dquartc_multiplexer_test.cc262 int num_messages = 10; in TEST_F() local
264 messages_1.reserve(num_messages); in TEST_F()
266 messages_2.reserve(num_messages); in TEST_F()
323 int num_messages = 10; in TEST_F() local
325 messages_1.reserve(num_messages); in TEST_F()
327 messages_2.reserve(num_messages); in TEST_F()
383 int num_messages = 10; in TEST_F() local
385 messages_1.reserve(num_messages); in TEST_F()
387 messages_2.reserve(num_messages); in TEST_F()
449 int num_messages = 10; in TEST_F() local
[all …]
/dports/net-mgmt/pandorafms_console/pandorafms_console-6.0SP2/operation/messages/
H A Dmessage_list.php78 $num_messages = messages_get_count_sent($config['id_user']); variable
79 if ($num_messages > 0 && !is_ajax()) {
80 echo '<p>'.__('You have').' <b>'.$num_messages.'</b> '.' '.__('sent message(s)').'.</p>';
85 $num_messages = messages_get_count ($config["id_user"]); variable
86 if ($num_messages > 0 && !is_ajax()) {
87 echo '<p>'.__('You have').' <b>'.$num_messages.'</b> '.' '.__('unread message(s)').'.</p>';
/dports/misc/urh/urh-2.9.2/src/urh/ui/actions/
H A DInsertBitsAndPauses.py19 self.num_messages = 0
23 self.num_messages += len(self.proto_analyzer.messages)
26 for i in reversed(range(self.index, self.index+self.num_messages)):
28 self.num_messages = 0
/dports/games/vultures-eye/vulture-2.3.67/vulture/winclass/
H A Dmessagewin.cpp64 int age, textlen, num_messages; in draw() local
91 num_messages = 0; in draw()
96 while(!(message = get_message(num_messages, &age)).empty() && in draw()
97 (time_cur-age) < V_MAX_MESSAGE_COLORS && num_messages < vulture_opts.messagelines) in draw()
102 num_messages++; in draw()
135 for (i = 0; i < num_messages; i++) { in draw()
136 message = get_message(num_messages - i - 1, &age); in draw()
/dports/www/nginx-full/nchan-1.2.12/src/store/redis/redis-lua-scripts/
H A Ddelete.lua14 local num_messages = 0
20 num_messages = num_messages + 1
64 tonumber(num_messages)
/dports/net/storj/storj-1.45.3/vendor/github.com/zeebo/admission/v3/
H A Ddispatch.go50 num_messages := d.NumMessages
51 if num_messages == 0 {
52 num_messages = DefaultMessages
60 msgs := make([]*Message, num_messages)
/dports/net/libngtcp2/ngtcp2-224bd62/third-party/http-parser/
H A Dtest.c89 static int num_messages; variable
2069 strlncat(messages[num_messages].body, in body_cb()
2123 if (messages[num_messages].body_size && in message_complete_cb()
2138 num_messages++; in message_complete_cb()
2161 messages[num_messages].num_chunks++; in chunk_header_cb()
2449 num_messages = 0; in parser_init()
3436 if (num_messages != 1) { in test_message()
3473 if (num_messages != 1) { in test_message_count_body()
3832 if (message_count != num_messages) {
4039 if (num_messages != 1) {
[all …]
/dports/multimedia/gmerlin/gmerlin-1.2.0/tests/
H A Dmsgtest.c81 int num_messages; in read_message() local
91 num_messages = 1; in read_message()
102 num_messages = 10; in read_message()
114 for(i = 0; i < num_messages; i++) in read_message()
/dports/devel/fstrm/fstrm-0.6.1/t/
H A Dtest_fstrm_io_file.c63 unsigned num_messages; member
82 for (unsigned i = 0; i < p->num_messages; i++) { in thr_producer()
197 unsigned num_messages; in main() local
213 num_messages = atoi(argv[4]); in main()
218 if (num_messages < 1) { in main()
236 file_path, queue_model_str, num_threads, num_messages); in main()
266 test_producers[i].num_messages = num_messages; in main()
/dports/net/py-pynsq/pynsq-0.9.0b1/tests/
H A Dtest_reader.py179 num_messages = 500
182 self._send_messages(topic, num_messages, b'sup')
187 if self.msg_count >= num_messages:
252 num_messages = 300
254 self._send_messages(topic, num_messages, b'sup')
259 if self.msg_count >= num_messages:
284 num_messages = 1
287 self._send_messages(topic, num_messages, b'sup')
292 if self.msg_count >= num_messages:
/dports/net-im/psi/psi-1.5/3rdparty/http-parser/
H A Dtest.c88 static int num_messages; variable
1907 strlncat(messages[num_messages].body, in body_cb()
1961 if (messages[num_messages].body_size && in message_complete_cb()
1976 num_messages++; in message_complete_cb()
1996 messages[num_messages].num_chunks++; in chunk_header_cb()
2284 num_messages = 0; in parser_init()
3268 if (num_messages != 1) { in test_message()
3305 if (num_messages != 1) { in test_message_count_body()
3664 if (message_count != num_messages) {
3871 if (num_messages != 1) {
[all …]

12345678910>>...29