Home
last modified time | relevance | path

Searched refs:message_counter (Results 1 – 25 of 56) sorted by relevance

123

/dports/www/chromium-legacy/chromium-88.0.4324.182/chromeos/services/secure_channel/
H A Dsingle_client_message_proxy_impl_unittest.cc72 int message_counter = next_message_counter_++; in SendMessageAndVerifyState() local
80 base::Unretained(this), message_counter)); in SendMessageAndVerifyState()
87 EXPECT_FALSE(WasMessageSent(message_counter)); in SendMessageAndVerifyState()
92 EXPECT_TRUE(WasMessageSent(message_counter)); in SendMessageAndVerifyState()
95 return message_counter; in SendMessageAndVerifyState()
127 bool WasMessageSent(int message_counter) { in WasMessageSent() argument
128 return base::Contains(sent_message_counters_, message_counter); in WasMessageSent()
173 void OnMessageSent(int message_counter) { in OnMessageSent() argument
174 sent_message_counters_.insert(message_counter); in OnMessageSent()
H A Dmultiplexed_channel_impl_unittest.cc143 int message_counter = next_send_message_counter_++; in SendMessageAndVerifyState() local
147 base::Unretained(this), message_counter)); in SendMessageAndVerifyState()
154 EXPECT_FALSE(HasMessageBeenSent(message_counter)); in SendMessageAndVerifyState()
156 EXPECT_TRUE(HasMessageBeenSent(message_counter)); in SendMessageAndVerifyState()
159 return message_counter; in SendMessageAndVerifyState()
184 bool HasMessageBeenSent(int message_counter) { in HasMessageBeenSent() argument
185 return base::Contains(sent_message_counters_, message_counter); in HasMessageBeenSent()
294 void OnMessageSent(int message_counter) { in OnMessageSent() argument
295 sent_message_counters_.insert(message_counter); in OnMessageSent()
/dports/games/edge/Edge-1.35-source/src/
H A Dhu_stuff.cc68 static int message_counter; variable
144 message_counter = HU_MSGTIMEOUT; in HU_StartMessage()
153 if (message_counter && !--message_counter) in HU_Ticker()
215 message_counter = HU_MSGTIMEOUT; in HU_Responder()
/dports/comms/xastir/Xastir-Release-2.1.8/src/
H A Dmessages.c77 char message_counter[5+1]; variable
667 message_counter[1]++; in bump_message_counter()
670 if (message_counter[1] == ':') in bump_message_counter()
672 message_counter[1] = 'A'; in bump_message_counter()
675 if (message_counter[1] == '[') in bump_message_counter()
677 message_counter[1] = 'a'; in bump_message_counter()
680 if (message_counter[1] == '{') in bump_message_counter()
682 message_counter[1] = '0'; in bump_message_counter()
689 message_counter[0] = 'A'; in bump_message_counter()
694 message_counter[0] = 'a'; in bump_message_counter()
[all …]
H A Dxa_config.c2511 if (!get_string ("MESSAGE_COUNTER", message_counter, sizeof(message_counter)) in load_data_or_default()
2512 || message_counter[0] == '\0') in load_data_or_default()
2514 xastir_snprintf(message_counter, in load_data_or_default()
2521 if ( (message_counter[0] < '0') in load_data_or_default()
2522 || (message_counter[1] < '0') in load_data_or_default()
2523 || ( (message_counter[0] > '9') && (message_counter[0] < 'A') ) in load_data_or_default()
2524 || ( (message_counter[1] > '9') && (message_counter[1] < 'A') ) in load_data_or_default()
2525 || ( (message_counter[0] > 'Z') && (message_counter[0] < 'a') ) in load_data_or_default()
2526 || ( (message_counter[1] > 'Z') && (message_counter[1] < 'a') ) in load_data_or_default()
2530 message_counter[0] = '0'; in load_data_or_default()
[all …]
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/python_functional/functional_tests/destination_drivers/snmp_destination/general/
H A Dtest_snmp_destination_reload_statistics.py30 message_counter = 1
31 expected_message_counter = message_counter
33 generator_source = config.create_example_msg_generator_source(num=message_counter)
51 …expected_message_counter += message_counter # example_msg_generator source generates a new messag…
/dports/mail/p5-Email-Sender/Email-Sender-1.300031/t/
H A Dsmtp-via-rig.t40 my $message_counter = 0;
62 $message_counter++;
64 $message_counter, $rig->client_id,
67 $message_counter, $rig->client_id,
/dports/devel/py-pyro/Pyro4-4.77/examples/messagebus/
H A Dmanytopics_subscriber.py19 self.message_counter = {}
22 self.message_counter[t] = 0
26 self.message_counter[topic] += 1
52 for topic, count in sorted(subber.message_counter.items(), key=itemgetter(1), reverse=True):
/dports/audio/ardour6/Ardour-6.8.0/libs/midi++2/
H A Dparser.cc107 memset (message_counter, 0, sizeof (message_counter[0]) * 256); in Parser()
338 message_counter[inbyte]++; in scanner()
348 message_counter[inbyte]++; in scanner()
510 message_counter[msgbuf[0] & 0xF0]++; in scanner()
544 message_counter[inbyte]++; in realtime_msg()
627 message_counter[inbyte]++; in system_msg()
/dports/www/chromium-legacy/chromium-88.0.4324.182/chromeos/services/secure_channel/public/cpp/client/
H A Dclient_channel_impl_unittest.cc67 static int message_counter = 0; in CallSendMessage() local
68 int counter_for_this_message = message_counter++; in CallSendMessage()
119 void OnMessageSent(int message_counter) { in OnMessageSent() argument
120 message_counters_received_.insert(message_counter); in OnMessageSent()
/dports/games/crispy-doom/crispy-doom-crispy-doom-5.10.3/src/strife/
H A Dhu_stuff.c92 static int message_counter; variable
396 if (message_counter && !--message_counter) in HU_Ticker()
413 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
445 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
563 message_counter = HU_MSGTIMEOUT; in HU_Responder()
/dports/games/chocolate-doom/chocolate-doom-3.0.1/src/doom/
H A Dhu_stuff.c102 static int message_counter; variable
461 if (message_counter && !--message_counter) in HU_Ticker()
477 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
511 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
614 message_counter = HU_MSGTIMEOUT; in HU_Responder()
/dports/games/chocolate-doom/chocolate-doom-3.0.1/src/strife/
H A Dhu_stuff.c104 static int message_counter; variable
408 if (message_counter && !--message_counter) in HU_Ticker()
425 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
457 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
575 message_counter = HU_MSGTIMEOUT; in HU_Responder()
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/internal/
H A Dsubscription_concurrency_control_test.cc339 int message_counter = 0; in TEST_F() local
342 if (++message_counter >= kTestDoneThreshold) { in TEST_F()
346 if (message_counter >= kNackThreshold) return; in TEST_F()
368 handler_cv.wait(lk, [&] { return message_counter >= kTestDoneThreshold; }); in TEST_F()
403 int message_counter = 0; in TEST_F() local
409 if (++message_counter >= kTestDoneThreshold) handler_cv.notify_one(); in TEST_F()
431 handler_cv.wait(lk, [&] { return message_counter >= kTestDoneThreshold; }); in TEST_F()
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/timer_thread/single_timer_zero_delay/
H A Dmain.cpp27 int & message_counter ) in a_test_t() argument
29 , m_message_counter( message_counter ) in a_test_t()
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/timer_thread/timers_cancelation/
H A Dmain.cpp35 int & message_counter ) in a_test_t() argument
37 , m_message_counter( message_counter ) in a_test_t()
/dports/audio/ardour6/Ardour-6.8.0/libs/midi++2/midi++/
H A Dparser.h115 size_t *message_counts() { return message_counter; } in message_counts()
156 size_t message_counter[256]; variable
/dports/japanese/today/ja-today-2.12_2/
H A Devent.c45 static int message_counter; variable
123 message_counter = 0; in event()
1305 if (message_counter > 0) { in output_eventlist()
1307 pager_output("--- %d�� ---", message_counter); in output_eventlist()
1309 pager_output("--- %2d�� ---", message_counter); in output_eventlist()
1334 if (message_counter == 0) { in output_eventlist()
1338 message_counter++; in output_eventlist()
/dports/comms/smstools3/smstools3/src/
H A Dstats.c82 statistics[i]->message_counter = 0; in initstats()
349 STATISTICS->message_counter = counter; in update_message_counter()
441 …fprintf(fp, "\t%i,\t%i,\t%i", statistics[i]->message_counter, statistics[i]->failed_counter, stati… in write_status()
H A Dstats.h29 int message_counter; // This is a number of sent messages, stored in GSM1.counter file. member
/dports/mail/dbmail/dbmail-3.2.5/src/
H A Dpop3.c102 volatile int message_counter = 0; in db_createsession() local
134 message_counter = 1; in db_createsession()
155 tmpmessage->messageid = (uint64_t) message_counter; in db_createsession()
159 message_counter++; in db_createsession()
169 if (message_counter == 1) { in db_createsession()
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/cisco/ios/tests/integration/targets/ios_logging_global/tests/cli/
H A D_populate_config.yaml26 message_counter:
/dports/games/crispy-doom/crispy-doom-crispy-doom-5.10.3/src/doom/
H A Dhu_stuff.c111 static int message_counter; variable
937 if (message_counter && !--message_counter) in HU_Ticker()
971 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
1006 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
1210 message_counter = HU_MSGTIMEOUT; in HU_Responder()
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/
H A Dsubscription_concurrency_control_test.cc338 int message_counter = 0; in TEST_F() local
341 if (++message_counter >= kTestDoneThreshold) { in TEST_F()
345 if (message_counter >= kNackThreshold) return; in TEST_F()
365 handler_cv.wait(lk, [&] { return message_counter >= kTestDoneThreshold; }); in TEST_F()
/dports/games/libretro-prboom/libretro-prboom-cc80175/src/
H A Dhu_stuff.c194 static int message_counter; variable
1312 if (message_counter && !--message_counter) in HU_Ticker()
1340 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
1377 message_counter = HU_MSGTIMEOUT; in HU_Ticker()
1497 message_counter = HU_MSGTIMEOUT; in HU_Responder()

123