We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
WaitForHandler
1 parent 7a7eeac commit ac2b7c5Copy full SHA for ac2b7c5
1 file changed
cpp-driver/src/wait_for_handler.cpp
@@ -99,8 +99,10 @@ void WaitForHandler::start(Connection* connection) {
99
}
100
101
void WaitForHandler::schedule() {
102
- retry_timer_.start(connection_->loop(), retry_wait_time_ms_,
103
- bind_callback(&WaitForHandler::on_retry_timeout, this));
+ if (!is_finished_) { // Don't schedule a retry if the handler is finished.
+ retry_timer_.start(connection_->loop(), retry_wait_time_ms_,
104
+ bind_callback(&WaitForHandler::on_retry_timeout, this));
105
+ }
106
107
108
void WaitForHandler::finish() {
0 commit comments