|
|
|
@ -221,16 +221,16 @@ ConnectionAttemptInjector::Hold::Hold(ConnectionAttemptInjector* injector, |
|
|
|
|
intercept_completion_(intercept_completion) {} |
|
|
|
|
|
|
|
|
|
void ConnectionAttemptInjector::Hold::Wait() { |
|
|
|
|
LOG(INFO) << "=== WAITING FOR CONNECTION ATTEMPT ON PORT " << port_ << "==="; |
|
|
|
|
LOG(INFO) << "=== WAITING FOR CONNECTION ATTEMPT ON PORT " << port_ << " ==="; |
|
|
|
|
grpc_core::MutexLock lock(&injector_->mu_); |
|
|
|
|
while (queued_attempt_ == nullptr) { |
|
|
|
|
start_cv_.Wait(&injector_->mu_); |
|
|
|
|
} |
|
|
|
|
LOG(INFO) << "=== CONNECTION ATTEMPT STARTED ON PORT " << port_ << "==="; |
|
|
|
|
LOG(INFO) << "=== CONNECTION ATTEMPT STARTED ON PORT " << port_ << " ==="; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void ConnectionAttemptInjector::Hold::Resume() { |
|
|
|
|
LOG(INFO) << "=== RESUMING CONNECTION ATTEMPT ON PORT " << port_ << "==="; |
|
|
|
|
LOG(INFO) << "=== RESUMING CONNECTION ATTEMPT ON PORT " << port_ << " ==="; |
|
|
|
|
grpc_core::ExecCtx exec_ctx; |
|
|
|
|
std::unique_ptr<QueuedAttempt> attempt; |
|
|
|
|
{ |
|
|
|
@ -241,7 +241,7 @@ void ConnectionAttemptInjector::Hold::Resume() { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void ConnectionAttemptInjector::Hold::Fail(grpc_error_handle error) { |
|
|
|
|
LOG(INFO) << "=== FAILING CONNECTION ATTEMPT ON PORT " << port_ << "==="; |
|
|
|
|
LOG(INFO) << "=== FAILING CONNECTION ATTEMPT ON PORT " << port_ << " ==="; |
|
|
|
|
grpc_core::ExecCtx exec_ctx; |
|
|
|
|
std::unique_ptr<QueuedAttempt> attempt; |
|
|
|
|
{ |
|
|
|
@ -252,7 +252,7 @@ void ConnectionAttemptInjector::Hold::Fail(grpc_error_handle error) { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void ConnectionAttemptInjector::Hold::WaitForCompletion() { |
|
|
|
|
LOG(INFO) << "=== WAITING FOR CONNECTION COMPLETION ON PORT " << port_ << "==="; |
|
|
|
|
LOG(INFO) << "=== WAITING FOR CONNECTION COMPLETION ON PORT " << port_ << " ==="; |
|
|
|
|
grpc_core::MutexLock lock(&injector_->mu_); |
|
|
|
|
while (original_on_complete_ != nullptr) { |
|
|
|
|
complete_cv_.Wait(&injector_->mu_); |
|
|
|
|