Searched refs:subscriptionStats (Results 1 – 3 of 3) sorted by relevance
355 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local357 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST_F()358 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST_F()462 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local463 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST_F()464 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST_F()495 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local496 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST_F()497 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST_F()522 auto subscriptionStats = getStatsdStatsReport().subscription_stats(); in TEST_F() local[all …]
930 auto subscriptionStats = report.subscription_stats(); in TEST() local931 EXPECT_EQ(subscriptionStats.pull_thread_wakeup_count(), 0); in TEST()932 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST()933 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST()949 auto subscriptionStats = report.subscription_stats(); in TEST() local950 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST()951 auto perSubscriptionStats = subscriptionStats.per_subscription_stats(0); in TEST()963 auto subscriptionStats = report.subscription_stats(); in TEST() local964 ASSERT_EQ(subscriptionStats.per_subscription_stats_size(), 1); in TEST()965 EXPECT_GT(subscriptionStats.per_subscription_stats(0).end_time_sec(), 0); in TEST()[all …]
1076 SubscriptionStats& subscriptionStats = mSubscriptionStats[subId]; in noteSubscriptionStarted() local1077 subscriptionStats.pushed_atom_count = pushedAtomCount; in noteSubscriptionStarted()1078 subscriptionStats.pulled_atom_count = pulledAtomCount; in noteSubscriptionStarted()1079 subscriptionStats.start_time_sec = nowTimeSec; in noteSubscriptionStarted()