reconnect_server_init(&tcp_server_);
}
- ~ReconnectServiceImpl() override {
+ ~ReconnectServiceImpl() {
if (server_started_) {
reconnect_server_destroy(&tcp_server_);
}
void Poll(int seconds) { reconnect_server_poll(&tcp_server_, seconds); }
Status Start(ServerContext* /*context*/, const ReconnectParams* request,
- Empty* /*response*/) override {
+ Empty* /*response*/) {
bool start_server = true;
std::unique_lock<std::mutex> lock(mu_);
while (serving_ && !shutdown_) {
}
Status Stop(ServerContext* /*context*/, const Empty* /*request*/,
- ReconnectInfo* response) override {
+ ReconnectInfo* response) {
// extract timestamps and set response
Verify(response);
reconnect_server_clear_timestamps(&tcp_server_);