How to check the connection status with aws (CA-268)

[arslan437]

here is my code snippet.

How can I check if the device is still connected to aws or not.

void aws_iot_main(void *pvParameters)
{
    int returnStatus = EXIT_SUCCESS;
    MQTTContext_t mqttContext = { 0 };
    NetworkContext_t xNetworkContext = { 0 };
    bool clientSessionPresent = false, brokerSessionPresent = false;
    struct timespec tp;

    /* Seed pseudo random number generator (provided by ISO C standard library) for
     * use by retry utils library when retrying failed network operations. */

    /* Get current time to seed pseudo random number generator. */
    ( void ) clock_gettime( CLOCK_REALTIME, &tp );
    /* Seed pseudo random number generator with nanoseconds. */
    srand( tp.tv_nsec );

    /* Initialize MQTT library. Initialization of the MQTT library needs to be
     * done only once in this demo. */
    returnStatus = initializeMqtt( &mqttContext, &xNetworkContext );

    if( returnStatus == EXIT_FAILURE )
    {
        LogError("Failed initialize MQTT");
        return;
    }

    /* Attempt to connect to the MQTT broker. If connection fails, retry after
    * a timeout. Timeout value will be exponentially increased till the maximum
    * attempts are reached or maximum timeout value is reached. The function
    * returns EXIT_FAILURE if the TCP connection cannot be established to
    * broker after configured number of attempts. */
    returnStatus = connectToServerWithBackoffRetries( &xNetworkContext, &mqttContext, &clientSessionPresent, &brokerSessionPresent );

    if( returnStatus == EXIT_FAILURE )
    {
        LogError("Failed to connect to MQTT broker");
        return;
    }

    clientSessionPresent = true;

    returnStatus = subscribeToTopic( &mqttContext );

    if( returnStatus == EXIT_FAILURE )
    {
        LogError("unable to subscribe to topics");
        return;
    }
    
    returnStatus = publishToTopic( &mqttContext, PUB_TOPIC_BOOT, "Booting up...", MQTTQoS0);

    if( returnStatus == EXIT_FAILURE )
    {
        LogError("unable to publish the boot message");
        return;
    }

    for ( ; ; )
    {
        if( brokerSessionPresent == true )
        {
            // LogInfo( ( "An MQTT session with broker is re-established. "
            //             "Resending unacked publishes." ) );

            /* Handle all the resend of publish messages. */
            returnStatus = handlePublishResend( &mqttContext );
        }
        else
        {
            // LogInfo( ( "A clean MQTT connection is established."
            //             " Cleaning up all the stored outgoing publishes.\n\n" ) );

            /* Clean up the outgoing publishes waiting for ack as this new
                * connection doesn't re-establish an existing session. */
            cleanupOutgoingPublishes();
        }
        MQTT_ProcessLoop( &mqttContext );
        // sleep( MQTT_SUBPUB_LOOP_DELAY_SECONDS );
        vTaskDelay(50 / portTICK_PERIOD_MS);
    }
}