Searched refs:msg_delivered (Results 1 – 11 of 11) sorted by relevance
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/renderer/ |
| H A D | frame_swap_message_queue_unittest.cc | 210 bool msg_delivered = reason != cc::SwapPromise::COMMIT_FAILS && in TestDidNotSwap() local
214 ASSERT_TRUE(msg_delivered == HasMessageForId(messages, rid[0])); in TestDidNotSwap()
215 ASSERT_TRUE(msg_delivered == HasMessageForId(messages, rid[1])); in TestDidNotSwap()
222 ASSERT_TRUE(msg_delivered == HasMessageForId(messages, rid[2])); in TestDidNotSwap()
228 ASSERT_TRUE(msg_delivered != HasMessageForId(messages, rid[0])); in TestDidNotSwap()
229 ASSERT_TRUE(msg_delivered != HasMessageForId(messages, rid[1])); in TestDidNotSwap()
230 ASSERT_TRUE(msg_delivered != HasMessageForId(messages, rid[2])); in TestDidNotSwap()
|
| H A D | queue_message_swap_promise_unittest.cc | 273 bool msg_delivered = reason != cc::SwapPromise::COMMIT_FAILS && in VisualStateSwapPromiseDidNotSwap() local
279 EXPECT_EQ(msg_delivered, ContainsMessage(DirectSendMessages(), messages_[0])); in VisualStateSwapPromiseDidNotSwap()
280 EXPECT_EQ(msg_delivered, ContainsMessage(DirectSendMessages(), messages_[1])); in VisualStateSwapPromiseDidNotSwap()
285 EXPECT_EQ(msg_delivered, ContainsMessage(DirectSendMessages(), messages_[2])); in VisualStateSwapPromiseDidNotSwap()
288 EXPECT_EQ(msg_delivered, frame_swap_message_queue_->Empty()); in VisualStateSwapPromiseDidNotSwap()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_zookeeper_example.c | 112 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
564 rd_kafka_conf_set_dr_cb(conf, msg_delivered); in main()
|
| H A D | rdkafka_example.c | 107 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
582 rd_kafka_conf_set_dr_msg_cb(conf, msg_delivered); in main()
|
| H A D | rdkafka_performance.c | 185 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
1335 rd_kafka_conf_set_dr_msg_cb(conf, msg_delivered); in main()
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_example.c | 107 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
596 rd_kafka_conf_set_dr_msg_cb(conf, msg_delivered); in main()
|
| H A D | rdkafka_performance.c | 185 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
1369 rd_kafka_conf_set_dr_msg_cb(conf, msg_delivered); in main()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_example.c | 107 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
596 rd_kafka_conf_set_dr_msg_cb(conf, msg_delivered); in main()
|
| H A D | rdkafka_performance.c | 185 static void msg_delivered (rd_kafka_t *rk, in msg_delivered() function
1369 rd_kafka_conf_set_dr_msg_cb(conf, msg_delivered); in main()
|
| /dports/mail/alpine/alpine-465e23b/pith/ |
| H A D | pattern.c | 8124 static int msg_delivered = 0; in set_some_flags() local
8128 if(msg_delivered++ < 2){ in set_some_flags()
|
| /dports/editors/pico-alpine/alpine-465e23b/pith/ |
| H A D | pattern.c | 8124 static int msg_delivered = 0; in set_some_flags() local
8128 if(msg_delivered++ < 2){ in set_some_flags()
|