@@ -144,17 +144,6 @@ static bool s_is_request_complete(void *context) {
144144 return record -> completed ;
145145}
146146
147- // static bool s_is_mqtt5_client_terminated(void *arg) {
148- // struct aws_mqtt5_client_mock_test_fixture *test_fixture = arg;
149- // return test_fixture->client_terminated;
150- // }
151-
152- // static void s_wait_for_mqtt5_client_terminated(struct aws_mqtt5_client_mock_test_fixture *test_context) {
153- // aws_mutex_lock(&test_context->lock);
154- // aws_condition_variable_wait_pred(&test_context->signal, &test_context->lock, s_is_mqtt5_client_terminated,
155- // test_context); aws_mutex_unlock(&test_context->lock);
156- // }
157-
158147static void s_rrc_wait_on_request_completion (
159148 struct aws_rr_client_test_fixture * fixture ,
160149 struct aws_byte_cursor record_key ) {
@@ -583,7 +572,7 @@ static void s_aws_rr_client_test_fixture_on_initialized(void *user_data) {
583572 aws_mutex_lock (& fixture -> lock );
584573 fixture -> client_initialized = true;
585574 aws_mutex_unlock (& fixture -> lock );
586- aws_condition_variable_notify_one (& fixture -> signal );
575+ aws_condition_variable_notify_all (& fixture -> signal );
587576}
588577
589578static bool s_rr_client_test_fixture_initialized (void * context ) {
@@ -603,9 +592,8 @@ static void s_aws_rr_client_test_fixture_on_terminated(void *user_data) {
603592
604593 aws_mutex_lock (& fixture -> lock );
605594 fixture -> client_destroyed = true;
606- AWS_LOGF_DEBUG (AWS_LS_MQTT_CLIENT , "id=%p: Request-response client destroyed." , & fixture -> rr_client );
607595 aws_mutex_unlock (& fixture -> lock );
608- aws_condition_variable_notify_one (& fixture -> signal );
596+ aws_condition_variable_notify_all (& fixture -> signal );
609597}
610598
611599static int s_aws_rr_client_test_fixture_init_from_mqtt5 (
0 commit comments