Searched refs:subscriptionStats (Results 1 – 3 of 3) sorted by relevance
349 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local351 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST_F()352 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST_F()456 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local457 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST_F()458 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST_F()489 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local490 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST_F()491 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST_F()516 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local[all …]
918 auto subscriptionStats = report.subscription_stats(); in TEST() local919 EXPECT_EQ(subscriptionStats.pull_thread_wakeup_count(), 0); in TEST()920 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST()921 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST()937 auto subscriptionStats = report.subscription_stats(); in TEST() local938 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST()939 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST()951 auto subscriptionStats = report.subscription_stats(); in TEST() local952 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST()953 EXPECT_GT(subscriptionStats.per_subscription_stats(0).end_time_sec(), 0); in TEST()[all …]
1050 SubscriptionStats& subscriptionStats = mSubscriptionStats[subId]; in noteSubscriptionStarted() local1051 subscriptionStats.pushed_atom_count = pushedAtomCount; in noteSubscriptionStarted()1052 subscriptionStats.pulled_atom_count = pulledAtomCount; in noteSubscriptionStarted()1053 subscriptionStats.start_time_sec = nowTimeSec; in noteSubscriptionStarted()