| 1802 | } |
| 1803 | |
| 1804 | void Statestore::ShutdownForTesting() { |
| 1805 | CHECK(TestInfo::is_be_test()) << "Only valid to call in backend tests."; |
| 1806 | subscriber_topic_update_threadpool_.Shutdown(); |
| 1807 | subscriber_priority_topic_update_threadpool_.Shutdown(); |
| 1808 | subscriber_heartbeat_threadpool_.Shutdown(); |
| 1809 | subscriber_topic_update_threadpool_.Join(); |
| 1810 | subscriber_priority_topic_update_threadpool_.Join(); |
| 1811 | subscriber_heartbeat_threadpool_.Join(); |
| 1812 | } |
| 1813 | |
| 1814 | int64_t Statestore::FailedExecutorDetectionTimeMs() { |
| 1815 | return FLAGS_statestore_max_missed_heartbeats * FLAGS_statestore_heartbeat_frequency_ms; |
no test coverage detected