diff --git a/source/mqtt.c b/source/mqtt.c index 0fbafdb5..2f8c8378 100644 --- a/source/mqtt.c +++ b/source/mqtt.c @@ -254,7 +254,7 @@ static struct aws_error_info_list s_error_list = { DEFINE_LOG_SUBJECT_INFO(AWS_LS_MQTT5_CLIENT, "mqtt5-client", "MQTT5 client and connections"), DEFINE_LOG_SUBJECT_INFO(AWS_LS_MQTT5_CANARY, "mqtt5-canary", "MQTT5 canary logging"), DEFINE_LOG_SUBJECT_INFO(AWS_LS_MQTT5_TO_MQTT3_ADAPTER, "mqtt5-to-mqtt3-adapter", "MQTT5-To-MQTT3 adapter logging"), - DEFINE_LOG_SUBJECT_INFO(AWS_LS_MQTT_REQUEST_RESPONSE, "mqtt-request-response-client", "MQTT request-response client logging"), + DEFINE_LOG_SUBJECT_INFO(AWS_LS_MQTT_REQUEST_RESPONSE, "mqtt-request-response-systems", "MQTT request-response systems logging"), }; /* clang-format on */ diff --git a/source/request-response/subscription_manager.c b/source/request-response/subscription_manager.c index 57694ddc..e93fbcf5 100644 --- a/source/request-response/subscription_manager.c +++ b/source/request-response/subscription_manager.c @@ -569,14 +569,13 @@ void aws_rr_subscription_manager_on_protocol_adapter_connection_event( struct aws_rr_subscription_manager *manager, const struct aws_protocol_adapter_connection_event *event) { - AWS_LOGF_DEBUG( - AWS_LS_MQTT_REQUEST_RESPONSE, - "request-response subscription manager - received a protocol adapter connection event, type %s, joined_session " - "%d", - aws_protocol_adapter_connection_event_type_to_c_str(event->event_type), - (int)(event->joined_session ? 1 : 0)); - if (event->event_type == AWS_PACET_CONNECTED) { + AWS_LOGF_DEBUG( + AWS_LS_MQTT_REQUEST_RESPONSE, + "request-response subscription manager - received a protocol adapter connection event, joined_session: " + "%d", + (int)(event->joined_session ? 1 : 0)); + manager->is_protocol_client_connected = true; if (!event->joined_session) { s_apply_session_lost(manager); @@ -585,6 +584,10 @@ void aws_rr_subscription_manager_on_protocol_adapter_connection_event( s_cull_unused_subscriptions(manager); s_activate_idle_subscriptions(manager); } else { + AWS_LOGF_DEBUG( + AWS_LS_MQTT_REQUEST_RESPONSE, + "request-response subscription manager - received a protocol adapter disconnection event"); + manager->is_protocol_client_connected = false; } }