Searched refs:msg_rate (Results 1 – 7 of 7) sorted by relevance
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0107-topic_recreate.c | 49 static const int msg_rate = 10; /**< Messages produced per second */ variable
108 rd_usleep(1000000 / msg_rate, NULL); in run_producer()
210 expect_messages(consumer, msg_rate * 5, value); in do_test_create_delete_create()
228 expect_messages(consumer, msg_rate * 5, value); in do_test_create_delete_create()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0107-topic_recreate.c | 49 static const int msg_rate = 10; /**< Messages produced per second */ variable
108 rd_usleep(1000000 / msg_rate, NULL); in run_producer()
210 expect_messages(consumer, msg_rate * 5, value); in do_test_create_delete_create()
228 expect_messages(consumer, msg_rate * 5, value); in do_test_create_delete_create()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0107-topic_recreate.c | 49 static const int msg_rate = 10; /**< Messages produced per second */ variable
108 rd_usleep(1000000 / msg_rate, NULL); in run_producer()
210 expect_messages(consumer, msg_rate * 5, value); in do_test_create_delete_create()
228 expect_messages(consumer, msg_rate * 5, value); in do_test_create_delete_create()
|
| /dports/net/tcpkali/tcpkali-1.1.1/src/ |
| H A D | tcpkali_engine.h | 98 void engine_update_message_send_rate(struct engine *, double msg_rate);
|
| H A D | tcpkali_engine.c | 521 engine_update_message_send_rate(struct engine *eng, double msg_rate) { in engine_update_message_send_rate() argument
525 eng->params.channel_send_rate = RATE_MPS(msg_rate); in engine_update_message_send_rate()
|
| /dports/www/py-notebook/notebook-6.4.5/notebook/services/kernels/ |
| H A D | handlers.py | 499 msg_rate = float(self._iopub_window_msg_count) / self.rate_limit_window
503 if self.iopub_msg_rate_limit > 0 and msg_rate > self.iopub_msg_rate_limit:
519 if self._iopub_msgs_exceeded and msg_rate < (0.8 * self.iopub_msg_rate_limit):
|
| /dports/devel/py-jupyter-server/jupyter_server-1.12.1/jupyter_server/services/kernels/ |
| H A D | handlers.py | 520 msg_rate = float(self._iopub_window_msg_count) / self.rate_limit_window
524 if self.iopub_msg_rate_limit > 0 and msg_rate > self.iopub_msg_rate_limit:
546 if self._iopub_msgs_exceeded and msg_rate < (0.8 * self.iopub_msg_rate_limit):
|