OTA_AgentShutdown issue

I have code where i am calling OTA_AgentShutdown in loop as long as wont get status != eOTA_AgentState_NotReady.
With long timeout like 10000ms (1000 ticks) or so im getting always status 2 (eOTA_AgentState_Active):
E (146226) _disconnectCallback: OTA shutdown                 // before calling OTA_AgentShutdown
E (176226) _disconnectCallback: OTA shutdown => 2        // after return from OTA_AgentShutdown
E (176226) _disconnectCallback: OTA shutdown
E (206226) _disconnectCallback: OTA shutdown => 2
E (206226) _disconnectCallback: OTA shutdown
E (236226) _disconnectCallback: OTA shutdown => 2
E (236226) _disconnectCallback: OTA shutdown
E (266226) _disconnectCallback: OTA shutdown => 2

and exactly the same code but with short timeout (let say about 300 ticks):
E (124076) _disconnectCallback: OTA shutdown
E (124076) _disconnectCallback: OTA shutdown => 3
E (124076) _disconnectCallback: OTA shutdown
E (124076) _disconnectCallback: OTA shutdown => 3

I am working with branch release-1.5, commit e88e2ce08b6e52c89b93a38f72511c5cfc0dbffc

After further investigation i found that code cant pass this line:
https://github.com/aws/amazon-freertos/blob/master/libraries/freertos_plus/aws/ota/src/aws_iot_ota_agent.c#L792
It can be issue in my code, which is a bit changed aws_iot_otaupdate_demo, or it can be problem with that code.
It does not happen always, when esp32 disconnect from wifi then everything works good, but when is still connected to wifi, but disconnects from mqtt because of:
198 8012 [iot_thread] [ERROR][MQTT][80120] (MQTT connection 0x3ffbf7dc) Failed to send PINGREQ.
199 8012 [iot_thread] [WARN ][NET][80120] Failed to close connection.
200 8012 [iot_thread] [INFO ][MQTT][80120] (MQTT connection 0x3ffbf7dc) Network connection closed.

then this issue occurs.

Its better logging for comparison.
wifi connection lost:
I (54317) WIFI: SYSTEM_EVENT_STA_DISCONNECTED: 3
I (54327) my_disconnectedCallback: Disconnected callback
E (54327) _disconnectCallback: mqtt disconnect callback
E (54337) _disconnectCallback: OTA shutdown
64 5407 [iot_thread] [INFO ][MQTT][54070] (MQTT connection 0x3ffbfecc) Disconnecting connection.
65 5407 [iot_thread] [INFO ][MQTT][54070] (MQTT connection 0x3ffbfecc) Network connection closed.
66 5408 [iot_thread] [INFO ][Shadow][54080] Shadow library cleanup done.
67 5408 [iot_thread] [OTA_AgentShutdown] Start: 500 ticks
68 5409 [OTA Task] [prvOTAUpdateTask] Received shutdown event.
E (54347) prvAgentShutdownCleanup: before prvUnSubscribeFromJobNotificationTopic
E (54377) prvAgentShutdownCleanup: after prvUnSubscribeFromJobNotificationTopic
69 5412 [OTA Task] [WARN ][MQTT][54120] (MQTT connection 0x3ffbfecc) Attempt to use closed connection.
70 5412 [OTA Task] [ERROR][MQTT][54120] (MQTT connection 0x3ffbfecc) New operation record cannot be created for a closed connection
71 5412 [OTA Task] [prvUnSubscribeFromJobNotificationTopic] FAIL: $aws/things/alexa-iot-test/jobs/notify-next
72 5412 [OTA Task] [WARN ][MQTT][54120] (MQTT connection 0x3ffbfecc) Attempt to use closed connection.
73 5412 [OTA Task] [ERROR][MQTT][54120] (MQTT connection 0x3ffbfecc) New operation record cannot be created for a closed connection
74 5412 [OTA Task] [prvUnSubscribeFromJobNotificationTopic] FAIL: $aws/things/alexa-iot-test/jobs/$next/get/accepted
75 5413 [OTA Task] [prvOTA_Close] Context->0x3ffc6740
76 5414 [iot_thread] [OTA_AgentShutdown] End: 494 ticks
E (54397) _disconnectCallback: OTA shutdown => 0

mqtt disconnect because of PING timeout:
E (168057) _disconnectCallback: mqtt disconnect callback
E (168057) _disconnectCallback: OTA shutdown
151 16780 [iot_thread] [ERROR][MQTT][167800] (MQTT connection 0x3ffbe300) Failed to receive PINGRESP within 10000 ms.
152 16780 [iot_thread] [WARN ][NET][167800] Failed to close connection.
153 16780 [iot_thread] [INFO ][MQTT][167800] (MQTT connection 0x3ffbe300) Network connection closed.
154 16780 [iot_thread] [INFO ][Shadow][167800] Shadow library cleanup done.
155 16780 [iot_thread] [OTA_AgentShutdown] Start: 500 ticks
156 16781 [OTA Task] [prvOTAUpdateTask] Received shutdown event.
E (168067) prvAgentShutdownCleanup: before
E (173057) _disconnectCallback: OTA shutdown => 3
E (173057) _disconnectCallback: OTA shutdown
E (173057) _disconnectCallback: OTA shutdown => 3

Hi chegewara,
I have code where i am calling OTA_AgentShutdown in loop as long as wont get status != eOTA_AgentState_NotReady(0).
The OTA_AgentShutdown sends an event OTA_EVT_MASK_SHUTDOWN to the OTA update task and waits for it to complete the shutdown and the OTA agent state to be set to eOTA_AgentState_NotReady(0).
Once the OTA update task receives this event it sets the agent state to eOTA_AgentState_ShuttingDown(3) and the performs number of cleanup steps on setup that was performed when OTA_AgentInit was called  -

Stop and delete timers.
Unsubscribe to OTA job notification topic
Close OTA file
Delete any shared memory , queue used etc.

From the log it seems the unsubscribe is failing as connection is closed before that. Can you share more information on your changes in OTA demo. You can also call OTA_AgentShutdown followed by OTA_GetAgentState to confirm that state is changed eOTA_AgentState_NotReady(0).

Hi @pvyawaha
ive been reading thru aws_iot_ota_agent code and i think i understand it now (at least more than yesterday). OTA_AgentShutdown works good most of the time (no matter if its called before or after ``), the only issue i have in one particular situation, when wifi is still connected, but there is no access to internet. To simulate this situation i have esp32 connected to smartphone router and after normal start when all is up and running i just disconnect smartphone from internet but esp32 is still connected to smartphone router. This is leading to PINGRESP timeout and mqtt connection is closed.
I will try the same situation with original OTA example (maybe this weekend), but here you can see my changes:
/*
 * Amazon FreeRTOS V201906.00 Major
 * Copyright (C) 2019 Amazon.com, Inc. or its affiliates.  All Rights Reserved.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of
 * this software and associated documentation files (the "Software"), to deal in
 * the Software without restriction, including without limitation the rights to
 * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
 * the Software, and to permit persons to whom the Software is furnished to do so,
 * subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
 * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
 * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
 * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 *
 * http://aws.amazon.com/freertos
 * http://www.FreeRTOS.org
 */

/**
 * @file aws_ota_update_demo.c
 * @brief A simple OTA update example.
 *
 * This example initializes the OTA agent to enable OTA updates via the
 * MQTT broker. It simply connects to the MQTT broker with the users
 * credentials and spins in an indefinite loop to allow MQTT messages to be
 * forwarded to the OTA agent for possible processing. The OTA agent does all
 * of the real work; checking to see if the message topic is one destined for
 * the OTA agent. If not, it is simply ignored.
 */
/* The config header is always included first. */
#include "iot_config.h"

/* MQTT include. */
#include "iot_mqtt.h"
/* Standard includes. */
#include <stdio.h>
#include <string.h>

/* FreeRTOS includes. */
#include "FreeRTOS.h"
#include "task.h"
#include "semphr.h"

/* Demo network handling */
#include "aws_iot_demo_network.h"

/* Required to get the broker address and port. */
#include "aws_clientcredential.h"

/* Amazon FreeRTOS OTA agent includes. */
#include "aws_ota_agent.h"

#include "iot_network_manager_private.h"

/* Required for demo task stack and priority */
#include "aws_demo_config.h"
#include "aws_application_version.h"

xTaskHandle OTAhandle; // ota task handle used in main.c to delete task on wifi disconnect

static void App_OTACompleteCallback(OTA_JobEvent_t eEvent );

static BaseType_t prxCreateNetworkConnection( void );
static IotNetworkError_t prvNetworkDisconnectCallback( void* pvContext );
static void prvNetworkStateChangeCallback( uint32_t ulNetworkType, AwsIotNetworkState_t xNetworkState, void* pvContext );

/*-----------------------------------------------------------*/

#define otaDemoCONN_TIMEOUT_MS              ( 2000UL )

#define otaDemoCONN_RETRY_INTERVAL_MS       ( 5000 )

#define otaDemoCONN_RETRY_LIMIT             ( 100 )

#define otaDemoKEEPALIVE_SECONDS            ( 1200 )

#define myappONE_SECOND_DELAY_IN_TICKS  pdMS_TO_TICKS( 1000UL )

#define otaDemoNETWORK_TYPES               ( AWSIOT_NETWORK_TYPE_ALL )

/**
 * @brief Structure which holds the context for an MQTT connection within Demo.
 */
static MqttConnectionContext_t xConnection =
{
     .pvNetworkConnection = NULL,
     .ulNetworkType       = AWSIOT_NETWORK_TYPE_NONE,
     .xNetworkInfo        = IOT_MQTT_NETWORK_INFO_INITIALIZER,
     .xMqttConnection     = IOT_MQTT_CONNECTION_INITIALIZER,
     .xDisconnectCallback = prvNetworkDisconnectCallback
};

/**
 * @brief Network manager subscription callback.
 */

static IotNetworkManagerSubscription_t xSubscriptionHandle = IOT_NETWORK_MANAGER_SUBSCRIPTION_INITIALIZER;

/**
 * @brief Semaphore to indicate a new network is available.
 */
static SemaphoreHandle_t xNetworkAvailableLock = NULL;

/**
 * @brief Flag used to unset, during disconnection of currently connected network. This will
 * trigger a reconnection from the main MQTT task.
 */
static BaseType_t xNetworkConnected = pdFALSE;

static void prvNetworkStateChangeCallback( uint32_t ulNetworkType, AwsIotNetworkState_t xNetworkState, void* pvContext )
{
    ( void ) pvContext;

    if( xNetworkState == eNetworkStateEnabled )
    {
        /* Release the semaphore, to indicate other tasks that a network is available */
        if( xNetworkConnected == pdFALSE )
        {
            xSemaphoreGive( xNetworkAvailableLock );
        }
    }
    else if ( xNetworkState == eNetworkStateDisabled )
    {
        /* If the publish task is already connected to this network, set connected network flag to none,
         * to trigger a reconnect.
         */
        if( ( xNetworkConnected == pdTRUE ) && ( xConnection.ulNetworkType == ulNetworkType ) )
        {
            xNetworkConnected = pdFALSE;
        }
    }
}

#include "esp_log.h"
static IotNetworkError_t prvNetworkDisconnectCallback( void* pvContext )
{
    ( void ) pvContext;
    xNetworkConnected = pdFALSE;

    return IOT_NETWORK_SUCCESS;
}

static BaseType_t prxCreateNetworkConnection( void )
{
    BaseType_t xRet = pdTRUE;
    uint32_t ulRetriesLeft     = otaDemoCONN_RETRY_LIMIT;
    uint32_t ulRetryIntervalMS = otaDemoCONN_RETRY_INTERVAL_MS;

    do
    {
         /* No networks are available, block for a physical network connection. */
        if( ( AwsIotNetworkManager_GetConnectedNetworks() & otaDemoNETWORK_TYPES ) == AWSIOT_NETWORK_TYPE_NONE )
        {
            /* Block for a Network Connection. */
            configPRINTF(( "Waiting for a network connection.\r\n" ));
            ( void ) xSemaphoreTake( xNetworkAvailableLock, portMAX_DELAY );
        }

        if( xRet == pdTRUE )
        {
        	break;
        }else
        {
            /* Connection failed. Retry for a configured number of retries. */
            if( ulRetriesLeft > 0 )
            {
                configPRINTF(( "Network Connection failed, retry delay %lu ms, retries left %lu\r\n", ulRetryIntervalMS, ulRetriesLeft ));
                vTaskDelay( pdMS_TO_TICKS( ulRetryIntervalMS ));
            }
        }

    } while ( ulRetriesLeft-- > 0 );

    return xRet;
}

static const char *pcStateStr[eOTA_NumAgentStates] =
{
     "Not Ready",
     "Ready",
     "Active",
     "Shutting down"
};

void vRunOTAUpdateDemo( void* param)
{
    IotMqttConnectInfo_t xConnectInfo = IOT_MQTT_CONNECT_INFO_INITIALIZER;
    OTA_State_t eState;

	configPRINTF ( ("OTA demo version %u.%u.%u\r\n",
		xAppFirmwareVersion.u.x.ucMajor,
		xAppFirmwareVersion.u.x.ucMinor,
		xAppFirmwareVersion.u.x.usBuild ) );

    for ( ; ; )
    {
        // TODO we are handling mqtt connection in main.c, so maybe we should remove this code???
        xNetworkConnected = prxCreateNetworkConnection();
		if( xNetworkConnected  )
		{
            eState = OTA_AgentInit( xConnection.xMqttConnection, ( const uint8_t * ) ( clientcredentialIOT_THING_NAME ), App_OTACompleteCallback, ( TickType_t ) ~0 );
            configPRINTF( ( "State: %s\n", pcStateStr[eState]));
            while( ( eState = OTA_GetAgentState() ) != eOTA_AgentState_NotReady )
            {
                /* Wait forever for OTA traffic but allow other tasks to run and output statistics only once per second. */
                vTaskDelay( myappONE_SECOND_DELAY_IN_TICKS );
                OTA_GetPacketsReceived();
                OTA_GetPacketsQueued();
                OTA_GetPacketsProcessed();
                OTA_GetPacketsDropped();
            }

            /* After failure to connect or a disconnect, wait an arbitrary one second before retry. */
            vTaskDelay( myappONE_SECOND_DELAY_IN_TICKS );
        }else
        {
            configPRINTF( ( "Failed to create MQTT client.\r\n" ) );
        }
    }
}

/* The OTA agent has completed the update job or determined that we're in
 * self test mode. If it was accepted, we want to activate the new image.
 * This typically means we should reset the device to run the new firmware.
 * If now is not a good time to reset the device, it may be activated later
 * by your user code. If the update was rejected, just return without doing
 * anything and we'll wait for another job. If it reported that we should
 * start test mode, normally we would perform some kind of system checks to
 * make sure our new firmware does the basic things we think it should do
 * but we'll just go ahead and set the image as accepted for demo purposes.
 * The accept function varies depending on your platform. Refer to the OTA
 * PAL implementation for your platform in aws_ota_pal.c to see what it
 * does for you.
 */

static void App_OTACompleteCallback( OTA_JobEvent_t eEvent )
{
	OTA_Err_t xErr = kOTA_Err_Uninitialized;

    /* OTA job is completed. so delete the MQTT and network connection. */
    if ( eEvent == eOTA_JobEvent_Activate )
    {
        // TODO make sure valve is closed before
        configPRINTF( ( "Received eOTA_JobEvent_Activate callback from OTA Agent.\r\n" ) );
        IotMqtt_Disconnect( xConnection.xMqttConnection, 0 );

        OTA_ActivateNewImage();
    }
    else if (eEvent == eOTA_JobEvent_Fail)
    {
        configPRINTF( ( "Received eOTA_JobEvent_Fail callback from OTA Agent.\r\n" ) );
        /* Nothing special to do. The OTA agent handles it. */
    }
	else if (eEvent == eOTA_JobEvent_StartTest)
	{
		/* This demo just accepts the image since it was a good OTA update and networking
		 * and services are all working (or we wouldn't have made it this far). If this
		 * were some custom device that wants to test other things before calling it OK,
		 * this would be the place to kick off those tests before calling OTA_SetImageState()
		 * with the final result of either accepted or rejected. */
        configPRINTF( ( "Received eOTA_JobEvent_StartTest callback from OTA Agent.\r\n" ) );
	    xErr = OTA_SetImageState (eOTA_ImageState_Accepted);
        if( xErr != kOTA_Err_None )
        {
            OTA_LOG_L1( " Error! Failed to set image state as accepted.\r\n" );
        }
	}
}

/*-----------------------------------------------------------*/

int vStartOTAUpdateTask(IotMqttNetworkInfo_t networkInfo, IotMqttConnection_t mqttConnection)
{
    int xRet = EXIT_SUCCESS;
    IotMqttError_t xMqttInitStatus;
    bool bMqttInitialized  = false;

    xConnection.xNetworkInfo = networkInfo;
    xConnection.xMqttConnection = mqttConnection;

    if( otaDemoNETWORK_TYPES == AWSIOT_NETWORK_TYPE_NONE )
    {
        configPRINTF(( "There are no networks configured for the demo.\r\n" ));
        xRet = EXIT_FAILURE;
    }

    /* Create semaphore to notify network available */
    if( xRet == EXIT_SUCCESS )
    {
        xNetworkAvailableLock = xSemaphoreCreateBinary();
        if( xNetworkAvailableLock == NULL )
        {
            configPRINTF(( "Failed to create semaphore.\r\n" ));
            xRet = EXIT_FAILURE;
        }
    }

    /**
     * Create a Network Manager Subscription for all the network types supported.
     */
    if( xRet == EXIT_SUCCESS )
    {
        if( AwsIotNetworkManager_SubscribeForStateChange( otaDemoNETWORK_TYPES,
                                                          prvNetworkStateChangeCallback,
                                                          NULL,
                                                          &xSubscriptionHandle ) != pdTRUE )
        {
            configPRINTF(( "Failed to create Network Manager subscription.\r\n" ));
            xRet = EXIT_FAILURE;
        }
    }

    if( xRet == EXIT_SUCCESS )
    {
        xTaskCreate(vRunOTAUpdateDemo, "otaT", 4*1024, NULL, 1, &OTAhandle);
    }
    else
    {
        if( xSubscriptionHandle != IOT_NETWORK_MANAGER_SUBSCRIPTION_INITIALIZER )
        {
            AwsIotNetworkManager_RemoveSubscription( xSubscriptionHandle );
        }

        if( xNetworkAvailableLock != NULL )
        {
            vSemaphoreDelete( xNetworkAvailableLock );
        }

        if( bMqttInitialized == true )
        {
            IotMqtt_Cleanup();
        }
    }

    return xRet;
}

Most important change is that i am establishing connection and connecting mqtt outside OTA task, i am passing mqttConnection, look at vRunOTAUpdateDemo.
Then i have this callback to control wifi disconnected event:
void my_disconnectedCallback( const IotNetworkInterface_t * pNetworkInteface )
{
    ESP_LOGI(__func__, "Disconnected callback");
    /**
     * disconnect from mqtt, so we could make clean start when internet is restored
     */
    IotMqtt_Disconnect( mqttConnection, IOT_MQTT_FLAG_CLEANUP_ONLY);

    if(OTAhandle != NULL)
    {
        vTaskDelete(OTAhandle);
        OTAhandle = NULL;
    }
}

and this callback to control mqtt disconnect event (either called from my_disconnectedCallback or when PINGRESP timeout occurs):
static void _disconnectCallback( void * pCallbackContext, IotMqttCallbackParam_t * pCallbackParam )
{
    ESP_LOGE(__func__, "mqtt disconnect callback");
    tasksStatus();
    int status = 0;
    /**
     * Deinit shadow and OTA task
     */
    AwsIotShadow_Cleanup();
    do{
        ESP_LOGE(__func__, "OTA shutdown");
        status = OTA_AgentShutdown(500);
        ESP_LOGE(__func__, "OTA shutdown => %d", status);
    }while(status != eOTA_AgentState_NotReady);

    if(OTAhandle != NULL)
    {
        vTaskDelete(OTAhandle);
        OTAhandle = NULL;
    }
}

Much appreciated help and great work on library.

Hi,
i cant reproduce it with OTA example, because DEMO_networkDisconnectedCallback is never called, even if i disconnect smartphone from internet OTA stays in loop:
668 65145 [iot_thread] State: Ready  Received: 1   Queued: 1   Processed: 1   Dropped: 0.

Ok, i found a way to reproduce it on OTA example.
I changed 2 things in code.

change otaDemoKEEPALIVE_SECONDS to 12 seconds (waiting 20 minutes is too long for test),
this disconnect callback:
https://github.com/aws/amazon-freertos/blob/master/demos/ota/aws_iot_ota_update_demo.c#L142

static IotNetworkError_t prvNetworkDisconnectCallback( void* pvContext )
{
    ( void ) pvContext;
    xNetworkConnected = pdFALSE;
    int status = 0;
    do{
        printf("OTA_AgentShutdown\n");
        status = OTA_AgentShutdown(500);
        vTaskDelay(100); // delay to let logs prints out
    }while(status != eOTA_AgentState_NotReady);
    return IOT_NETWORK_SUCCESS;
}

When device is still connected to wifi, but no access to internet im getting this logs:
88 6247 [iot_thread] State: Ready  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
89 6314 [iot_thread] [ERROR][MQTT][63140] (MQTT connection 0x3ffd3b94) Failed to receive PINGRESP within 10000 ms.
90 6314 [OTA Task] [prvOTAUpdateTask] Received shutdown event.
91 6347 [iot_thread] State: Ready  Received: 1   Queued: 1   Processed: 1   Dropped: 0
92 6447 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
93 6547 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
94 6647 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
95 6747 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
96 6847 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
97 6914 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
98 6947 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
99 7014 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
100 7047 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
101 7114 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
102 7147 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
103 7214 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
104 7247 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
105 7314 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
106 7347 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
107 7414 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
108 7447 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
109 7514 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
110 7547 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
111 7614 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
112 7647 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
113 7714 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
114 7747 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
115 7814 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
116 7847 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0
OTA_AgentShutdown
117 7914 [iot_thread] [OTA_AgentShutdown] Nothing to do: Already in state 3
118 7947 [iot_thread] State: Shutting down  Received: 1   Queued: 1   Processed: 1   Dropped: 0

Hi Chegewara,
Thank you for sharing the logs. The call to the OTA_AgentShutdown seems to be faster than the wait times for the unsubscribe operations in the shutdown process.  The OTA agent is subscribe to two job notification topics so during shutdown it unsubscribes from these topics. The wait time for the unsubscribe operation is defined in OTA agent as
#define OTA_UNSUBSCRIBE_WAIT_MS            1000UL
It basically calls IotMqtt_Wait with this timeout for  both unsubscribe operations.

Hi, thanks for response.
I changed OTA_AgentShutdown timeout to 5000 ticks, still the same. ( i tried portMAX_DELAY with same result)
    do{
        ESP_LOGE(__func__, "OTA shutdown");
        status = OTA_AgentShutdown(5000);
        IotClock_SleepMs(1000);
        status = OTA_GetAgentState();
        ESP_LOGE(__func__, "OTA shutdown => %d", status);
    }while(status != eOTA_AgentState_NotReady);

logs:
67 8239 [iot_thread] [OTA_AgentShutdown] Start: 5000 ticks
68 8240 [OTA Task] [prvOTAUpdateTask] Received shutdown event.
E (82667) prvAgentShutdownCleanup: before
E (82697) prvUnSubscribeFromJobNotificationTopic: 1. inside prvUnSubscribeFromJobNotificationTopic
E (82707) prvUnSubscribeFromJobNotificationTopic: 2. inside prvUnSubscribeFromJobNotificationTopic
69 13239 [iot_thread] [OTA_AgentShutdown] End: 0 ticks
E (133657) _disconnectCallback: OTA shutdown => 3

Like i said, code does stuck on this function:
   if( ( stUnSub.topicFilterLength > 0U ) && ( stUnSub.topicFilterLength < sizeof( pcJobTopic ) ) )
    {
ESP_LOGE(__func__, "2. inside prvUnSubscribeFromJobNotificationTopic");
        if( IotMqtt_Unsubscribe( xOTA_Agent.pvPubSubClient,
                                 &stUnSub,
                                 1, /* Subscriptions count */
                                 IOT_MQTT_FLAG_WAITABLE, /* flags */
								 NULL,
                                 &( unsubscribeOperation[ 0]) ) != IOT_MQTT_STATUS_PENDING )
        {
            OTA_LOG_L1( "[%s] FAIL: %s\n\r", OTA_METHOD_NAME, stUnSub.pTopicFilter );
        }
        else
        {
            OTA_LOG_L1( "[%s] OK: %s\n\r", OTA_METHOD_NAME, stUnSub.pTopicFilter );
        }

https://github.com/aws/amazon-freertos/blob/master/libraries/freertos_plus/aws/ota/src/aws_iot_ota_agent.c#L2938

I know OTA is working fine, because i tested it few times already with OTA example, but now i am trying with all changes i posted here and this is result after downloading new image with OTA Job:
I (95732) ota_pal: No such certificate file: xxx. Using aws_ota_codesigner_certificate.h.

2612 9542 [OTA Task] [prvIngestDataBlock] Received file block 1133, size 1024
2613 9542 [OTA Task] [prvIngestDataBlock] Received final expected block of file.
2614 9542 [OTA Task] [prvStopRequestTimer] Stopping file request timer.
2615 9542 [OTA Task] ERROR: Object with label xxx not found.
2616 9793 [OTA Task] [prvIngestDataBlock] File receive complete and signature is valid.
2617 9793 [OTA Task] [prvUpdateJobStatus] Msg: {"status":"IN_PROGRESS","statusDetails":{"self_test":"ready","updatedBy":"0x30001"}}
2618 9834 [OTA Task] [prvUpdateJobStatus] 'IN_PROGRESS' to $aws/things/alexa-iot-test/jobs/AFR_OTA-chaya_ota_v032_1/update
2619 9834 [OTA Task] [prvOTA_Close] Context->0x3ffcc720
2620 9841 [OTA Task] [prvUnSubscribeFromDataStream] OK: $aws/things/alexa-iot-test/streams/AFR_OTA-d9c4b79b-f9ea-4c98-aeaf-c042e7e9b083/data/cbor
2621 9841 [OTA Task] Received eOTA_JobEvent_Activate callback from OTA Agent.
E (98732) _disconnectCallback: mqtt disconnect callback
E (98742) _disconnectCallback: OTA shutdown
2622 9843 [OTA Task] [OTA_AgentShutdown] Start: 5000 ticks
2623 14926 [OTA Task] [OTA_AgentShutdown] End: 0 ticks
E (150572) _disconnectCallback: OTA shutdown => 2

I will close this issue for now, until i understand better whats going on.

Hi i am working to setup OTA demo for ESP32 using Amazon FreeRTOS i have followed all the steps as said but at the output I am getting the my files are being received but not processed
rst:0x1 (POWERON_RESET),boot:0x13 (SPI_FAST_FLASH_BOOT)
configsip: 0, SPIWP:0xee
clk_drv:0x00,q_drv:0x00,d_drv:0x00,cs0_drv:0x00,hd_drv:0x00,wp_drv:0x00
mode:DIO, clock div:2
load:0x3fff0018,len:4
load:0x3fff001c,len:7312
ho 0 tail 12 room 4
load:0x40078000,len:12620
load:0x40080400,len:6708
entry 0x40080778
I (75) boot: Chip Revision: 1
I (75) boot_comm: chip revision: 1, min. bootloader chip revision: 0
I (41) boot: ESP-IDF v3.3-163-g601a03e 2nd stage bootloader
I (41) boot: compile time 15:11:39
I (41) boot: Enabling RNG early entropy source...
I (46) boot: SPI Speed      : 40MHz
I (50) boot: SPI Mode       : DIO
I (54) boot: SPI Flash Size : 4MB
I (58) boot: Partition Table:
I (62) boot: ## Label            Usage          Type ST Offset   Length
I (69) boot:  0 nvs              WiFi data        01 02 00010000 00006000
I (77) boot:  1 otadata          OTA data         01 00 00016000 00002000
I (84) boot:  2 phy_init         RF data          01 01 00018000 00001000
I (92) boot:  3 ota_0            OTA app          00 10 00020000 00177000
I (99) boot:  4 ota_1            OTA app          00 11 001a0000 00177000
I (107) boot:  5 storage          WiFi data        01 02 00317000 00010000
I (114) boot: End of partition table
I (118) boot: ota rollback check done
I (123) boot_comm: chip revision: 1, min. application chip revision: 0
I (130) esp_image: segment 0: paddr=0x00020020 vaddr=0x3f400020 size=0x253dc (152540) map
I (192) esp_image: segment 1: paddr=0x00045404 vaddr=0x3ffbdb60 size=0x0336c ( 13164) load
I (198) esp_image: segment 2: paddr=0x00048778 vaddr=0x40080000 size=0x00400 (  1024) load
0x40080000: _WindowOverflow4 at C:\aws-freertos-backup\ahtasham_ota\freertos-1578549574684\AmazonFreeRTOS\build/../freertos_kernel/portable/ThirdParty/GCC/Xtensa_ESP32/xtensa_vectors.S:1685
I (200) esp_image: segment 3: paddr=0x00048b80 vaddr=0x40080400 size=0x07490 ( 29840) load
I (221) esp_image: segment 4: paddr=0x00050018 vaddr=0x400d0018 size=0xab74c (702284) map
0x400d0018: _flash_cache_start at ??:?
I (467) esp_image: segment 5: paddr=0x000fb76c vaddr=0x40087890 size=0x0f1e4 ( 61924) load
0x40087890: ld_inq_frm_isr_wrapper at ??:?
I (506) boot: Loaded app from partition at offset 0x20000
I (507) boot: Disabling RNG early entropy source...
I (507) cpu_start: Pro cpu up.
I (511) cpu_start: Application information:
I (515) cpu_start: Project name:     esp-idf
I (520) cpu_start: App version:      1
I (525) cpu_start: Compile time:     Jan  9 2020 15:11:14
I (531) cpu_start: ELF file SHA256:  c02c40b55ad5a2c1...
I (537) cpu_start: ESP-IDF:          v3.3-163-g601a03e
I (543) cpu_start: Single core mode
I (547) heap_init: Initializing. RAM available for dynamic allocation:
I (554) heap_init: At 3FFAFF10 len 000000F0 (0 KiB): DRAM
I (560) heap_init: At 3FFB6388 len 00001C78 (7 KiB): DRAM
I (566) heap_init: At 3FFB9A20 len 00004108 (16 KiB): DRAM
I (572) heap_init: At 3FFBDB5C len 00000004 (0 KiB): DRAM
I (578) heap_init: At 3FFCFCB0 len 00010350 (64 KiB): DRAM
I (585) heap_init: At 3FFE0440 len 0001FBC0 (126 KiB): D/IRAM
I (591) heap_init: At 40078000 len 00008000 (32 KiB): IRAM
I (597) heap_init: At 40096A74 len 0000958C (37 KiB): IRAM
I (603) cpu_start: Pro cpu start user code
I (286) cpu_start: Starting scheduler on PRO CPU.
I (308) uart: queue free spaces: 10
0 1 [main] Initializing FreeRTOS TCP stack
I (308) PKCS11: Initializing NVS partition: "storage"
E (308) PKCS11: failed nvs get file size 4354 0
1 1 [main] Write certificate...
2 16 [iot_thread] [INFO ][DEMO][160] ---------STARTING DEMO---------
I (458) BTDM_INIT: BT controller compile version [9891bc6]
3 16 [iot_thread] [INFO ][INIT][160] SDK successfully initialized.
I (458) system_api: Base MAC address is not set, read default base MAC address from BLK0 of EFUSE
I (628) phy: phy_version: 4102, 2fa7a43, Jul 15 2019, 13:06:06, 0, 2
W (628) phy_init: saving new calibration data because of checksum failure, mode(0)
GAP procedure initiated: stop advertising.
GAP procedure initiated: advertise; disc_mode=2 adv_channel_map=0 own_addr_type=0 adv_filter_policy=0 adv_itvl_min=480 adv_itvl_max=960
I (928) wifi: wifi driver task: 3ffd4718, prio:23, stack:3584, core=0
I (928) system_api: Base MAC address is not set, read default base MAC address from BLK0 of EFUSE
I (928) system_api: Base MAC address is not set, read default base MAC address from BLK0 of EFUSE
I (948) wifi: wifi firmware version: c94f3e6
I (948) wifi: config NVS flash: enabled
I (948) wifi: config nano formating: disabled
I (948) wifi: Init dynamic tx buffer num: 32
I (958) wifi: Init data frame dynamic rx buffer num: 32
I (958) wifi: Init management frame dynamic rx buffer num: 32
I (968) wifi: Init management short buffer num: 32
I (968) wifi: Init static rx buffer size: 1600
I (968) wifi: Init static rx buffer num: 10
I (978) wifi: Init dynamic rx buffer num: 32
I (988) wifi: mode : sta (3c:71:bf:b3:60:e4)
I (988) WIFI: SYSTEM_EVENT_STA_START
I (1108) wifi: new:<1,0>, old:<1,0>, ap:<255,255>, sta:<1,0>, prof:1
I (2098) wifi: state: init -> auth (b0)
I (2108) wifi: state: auth -> assoc (0)
I (2108) wifi: state: assoc -> run (10)
I (2128) wifi: connected with AnchorRecovery, channel 1, BW20, bssid = c2:71:54:43:1b:e4
I (2128) wifi: pm start, type: 1
I (2128) WIFI: SYSTEM_EVENT_STA_CONNECTED
4 304 [IP-task] vDHCPProcess: offer c0a81066ip
I (3378) event: sta ip: <IP_ADDRESS>, mask: <IP_ADDRESS>, gw: <IP_ADDRESS>
I (3378) WIFI: SYSTEM_EVENT_STA_GOT_IP
5 308 [IP-task] vDHCPProcess: offer c0a81066ip
6 308 [iot_thread] [INFO ][DEMO][3080] Successfully initialized the demo. Network type for the demo: 1
7 308 [iot_thread] [INFO ][MQTT][3080] MQTT library successfully initialized.
8 308 [iot_thread] OTA demo version 0.9.5
9 308 [iot_thread] Creating MQTT Client...
10 322 [iot_thread] DNS[0x67A1]: The answer to 'akp17u3blui5g-ats.iot.us-west-2.amazonaws.com' (34597d0bip) will be stored
E (3988) PKCS11: failed nvs get file size 4354 0
11 948 [iot_thread] Connecting to broker...
12 948 [iot_thread] [INFO ][MQTT][9480] Establishing new MQTT connection.
13 948 [iot_thread] [INFO ][MQTT][9480] Anonymous metrics (SDK language, SDK version) will be provided to AWS IoT. Recompile with AWS_IOT_MQTT_ENABLE_METRICS set to 0 to disable.
14 948 [iot_thread] [INFO ][MQTT][9480] (MQTT connection 0x3fff0b00, CONNECT operation 0x3ffe18f4) Waiting for operation completion.
15 988 [iot_thread] [INFO ][MQTT][9880] (MQTT connection 0x3fff0b00, CONNECT operation 0x3ffe18f4) Wait complete with result SUCCESS.
16 988 [iot_thread] [INFO ][MQTT][9880] New MQTT connection 0x3ffbdc68 established.
17 988 [iot_thread] Connected to broker.
18 989 [iot_thread] [OTA_AgentInit_internal] OTA Task is Ready.
19 990 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [Ready] Event [Start] New state [RequestingJob]
20 990 [OTA Agent Task] [INFO ][MQTT][9900] (MQTT connection 0x3fff0b00) SUBSCRIBE operation scheduled.
21 990 [OTA Agent Task] [INFO ][MQTT][9900] (MQTT connection 0x3fff0b00, SUBSCRIBE operation 0x3fff2c2c) Waiting for operation completion.
22 1030 [OTA Agent Task] [INFO ][MQTT][10300] (MQTT connection 0x3fff0b00, SUBSCRIBE operation 0x3fff2c2c) Wait complete with result SUCCESS.
23 1030 [OTA Agent Task] [prvSubscribeToJobNotificationTopics] OK: $aws/things/quickconnect_esp32/jobs/$next/get/accepted
24 1030 [OTA Agent Task] [INFO ][MQTT][10300] (MQTT connection 0x3fff0b00) SUBSCRIBE operation scheduled.
25 1030 [OTA Agent Task] [INFO ][MQTT][10300] (MQTT connection 0x3fff0b00, SUBSCRIBE operation 0x3fff2c2c) Waiting for operation completion.
26 1070 [OTA Agent Task] [INFO ][MQTT][10700] (MQTT connection 0x3fff0b00, SUBSCRIBE operation 0x3fff2c2c) Wait complete with result SUCCESS.
27 1070 [OTA Agent Task] [prvSubscribeToJobNotificationTopics] OK: $aws/things/quickconnect_esp32/jobs/notify-next
28 1070 [OTA Agent Task] [prvRequestJob_Mqtt] Request #0
29 1072 [OTA Agent Task] [INFO ][MQTT][10720] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
30 1072 [OTA Agent Task] [INFO ][MQTT][10720] (MQTT connection 0x3fff0b00, PUBLISH operation 0x3fff2c2c) Waiting for operation completion.
31 1089 [iot_thread] State: Ready  Received: 0   Queued: 0   Processed: 0   Dropped: 0
32 1112 [OTA Agent Task] [INFO ][MQTT][11110] (MQTT connection 0x3fff0b00, PUBLISH operation 0x3fff2c2c) Wait complete with result SUCCESS.
33 1112 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [RequestingJob] Event [RequestJobDocument] New state [WaitingForJob]
I (11428) ota_pal: prvPAL_GetPlatformImageState
I (11428) esp_ota_ops: aws_esp_ota_get_boot_flags: 1
I (11438) esp_ota_ops: [0] aflags/seq:0x2/0x1, pflags/seq:0xffffffff/0x0
I (11448) ota_pal: Writing to partition subtype 17 at offset 0x1a0000
34 1113 [OTA Agent Task] [prvParseJobDoc] Size of OTA_FileContext_t [64]
35 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ clientToken: 0:quickconnect_esp32 ]
36 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ jobId: AFR_OTA-ota_job_3 ]
37 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ protocols: ["MQTT"] ]
38 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ streamname: AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc ]
39 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ filepath: / ]
40 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ filesize: 960896 ]
41 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ fileid: 0 ]
42 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ certfile: AmazonFreeRTOS/demos/include/ ]
43 1113 [OTA Agent Task] [prvParseJSONbyModel] Extracted parameter [ sig-sha256-ecdsa: MEQCIEyjnfqz409JehriFVR2be9lPYPn... ]
44 1113 [OTA Agent Task] [prvParseJobDoc] Job was accepted. Attempting to start transfer.
45 1196 [iot_thread] State: RequestingJob  Received: 1   Queued: 0   Processed: 0   Dropped: 0
46 1298 [iot_thread] State: WaitingForJob  Received: 1   Queued: 0   Processed: 0   Dropped: 0
47 1406 [iot_thread] State: WaitingForJob  Received: 1   Queued: 0   Processed: 0   Dropped: 0
I (14708) ota_pal: aws_esp_ota_begin succeeded
48 1441 [OTA Agent Task] [prvSetDataInterface] Data interface is set to MQTT.
49 1441 [OTA Agent Task] [prvProcessJobHandler] Setting OTA data inerface.
50 1441 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForJob] Event [ReceivedJobDocument] New state [CreatingFile]
51 1441 [OTA Agent Task] [INFO ][MQTT][14410] (MQTT connection 0x3fff0b00) SUBSCRIBE operation scheduled.
52 1441 [OTA Agent Task] [INFO ][MQTT][14410] (MQTT connection 0x3fff0b00, SUBSCRIBE operation 0x3fff2c2c) Waiting for operation completion.
53 1480 [OTA Agent Task] [INFO ][MQTT][14800] (MQTT connection 0x3fff0b00, SUBSCRIBE operation 0x3fff2c2c) Wait complete with result SUCCESS.
54 1480 [OTA Agent Task] [prvInitFileTransfer_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/data/cbor
55 1480 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [CreatingFile] Event [CreateFile] New state [RequestingFileBlock]
56 1480 [OTA Agent Task] [INFO ][MQTT][14800] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
57 1480 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
58 1480 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [RequestingFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
59 1506 [iot_thread] State: WaitingForJob  Received: 1   Queued: 0   Processed: 0   Dropped: 0
60 1606 [iot_thread] State: WaitingForFileBlock  Received: 1   Queued: 0   Processed: 0   Dropped: 0
61 1706 [iot_thread] State: WaitingForFileBlock  Received: 1   Queued: 0   Processed: 0   Dropped: 0
62 1757 [OTA Agent Task] [prvIngestDataBlock] Received file block 2, size 4096
63 1758 [OTA Agent Task] [prvIngestDataBlock] Remaining: 234
64 1758 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
65 1806 [iot_thread] State: WaitingForFileBlock  Received: 2   Queued: 0   Processed: 0   Dropped: 0
66 1849 [OTA Agent Task] [prvIngestDataBlock] Received file block 0, size 4096
67 1850 [OTA Agent Task] [prvIngestDataBlock] Remaining: 233
68 1850 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
69 1906 [iot_thread] State: WaitingForFileBlock  Received: 3   Queued: 0   Processed: 0   Dropped: 0
70 1941 [OTA Agent Task] [prvIngestDataBlock] Received file block 3, size 4096
71 1942 [OTA Agent Task] [prvIngestDataBlock] Remaining: 232
72 1942 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
73 2006 [iot_thread] State: WaitingForFileBlock  Received: 4   Queued: 0   Processed: 0   Dropped: 0
74 2075 [OTA Agent Task] [prvIngestDataBlock] Received file block 4, size 4096
75 2075 [OTA Agent Task] [prvIngestDataBlock] Remaining: 231
76 2075 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
77 2106 [iot_thread] State: WaitingForFileBlock  Received: 5   Queued: 0   Processed: 0   Dropped: 0
78 2167 [OTA Agent Task] [prvIngestDataBlock] Received file block 7, size 4096
79 2167 [OTA Agent Task] [prvIngestDataBlock] Remaining: 230
80 2167 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
81 2206 [iot_thread] State: WaitingForFileBlock  Received: 6   Queued: 0   Processed: 0   Dropped: 0
82 2259 [OTA Agent Task] [prvIngestDataBlock] Received file block 5, size 4096
83 2260 [OTA Agent Task] [prvIngestDataBlock] Remaining: 229
84 2260 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
85 2306 [iot_thread] State: WaitingForFileBlock  Received: 7   Queued: 0   Processed: 0   Dropped: 0
86 2361 [OTA Agent Task] [prvIngestDataBlock] Received file block 1, size 4096
87 2362 [OTA Agent Task] [prvIngestDataBlock] Remaining: 228
88 2362 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
89 2406 [iot_thread] State: WaitingForFileBlock  Received: 8   Queued: 0   Processed: 0   Dropped: 0
90 2454 [OTA Agent Task] [prvIngestDataBlock] Received file block 6, size 4096
91 2455 [OTA Agent Task] [prvIngestDataBlock] Remaining: 227
92 2455 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
93 2455 [OTA Agent Task] [INFO ][MQTT][24550] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
94 2455 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
95 2455 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
96 2506 [iot_thread] State: WaitingForFileBlock  Received: 9   Queued: 0   Processed: 0   Dropped: 0
97 2606 [iot_thread] State: WaitingForFileBlock  Received: 9   Queued: 0   Processed: 0   Dropped: 0
98 2617 [OTA Agent Task] [prvIngestDataBlock] Received file block 8, size 4096
99 2618 [OTA Agent Task] [prvIngestDataBlock] Remaining: 226
100 2618 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
101 2706 [iot_thread] State: WaitingForFileBlock  Received: 10   Queued: 0   Processed: 0   Dropped: 0
102 2730 [OTA Agent Task] [prvIngestDataBlock] Received file block 9, size 4096
103 2731 [OTA Agent Task] [prvIngestDataBlock] Remaining: 225
104 2731 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
105 2806 [iot_thread] State: WaitingForFileBlock  Received: 11   Queued: 0   Processed: 0   Dropped: 0
106 2822 [OTA Agent Task] [prvIngestDataBlock] Received file block 12, size 4096
107 2823 [OTA Agent Task] [prvIngestDataBlock] Remaining: 224
108 2823 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
109 2906 [iot_thread] State: WaitingForFileBlock  Received: 12   Queued: 0   Processed: 0   Dropped: 0
110 2945 [OTA Agent Task] [prvIngestDataBlock] Received file block 13, size 4096
111 2946 [OTA Agent Task] [prvIngestDataBlock] Remaining: 223
112 2946 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
113 3006 [iot_thread] State: WaitingForFileBlock  Received: 13   Queued: 0   Processed: 0   Dropped: 0
114 3037 [OTA Agent Task] [prvIngestDataBlock] Received file block 14, size 4096
115 3038 [OTA Agent Task] [prvIngestDataBlock] Remaining: 222
116 3038 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
117 3106 [iot_thread] State: WaitingForFileBlock  Received: 14   Queued: 0   Processed: 0   Dropped: 0
118 3129 [OTA Agent Task] [prvIngestDataBlock] Received file block 10, size 4096
119 3130 [OTA Agent Task] [prvIngestDataBlock] Remaining: 221
120 3130 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
121 3206 [iot_thread] State: WaitingForFileBlock  Received: 15   Queued: 0   Processed: 0   Dropped: 0
122 3238 [OTA Agent Task] [prvIngestDataBlock] Received file block 15, size 4096
123 3238 [OTA Agent Task] [prvIngestDataBlock] Remaining: 220
124 3238 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
125 3306 [iot_thread] State: WaitingForFileBlock  Received: 16   Queued: 0   Processed: 0   Dropped: 0
126 3334 [OTA Agent Task] [prvIngestDataBlock] Received file block 11, size 4096
127 3335 [OTA Agent Task] [prvIngestDataBlock] Remaining: 219
128 3335 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
129 3335 [OTA Agent Task] [INFO ][MQTT][33350] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
130 3335 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
131 3335 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
132 3406 [iot_thread] State: WaitingForFileBlock  Received: 17   Queued: 0   Processed: 0   Dropped: 0
133 3478 [OTA Agent Task] [prvIngestDataBlock] Received file block 16, size 4096
134 3478 [OTA Agent Task] [prvIngestDataBlock] Remaining: 218
135 3478 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
136 3506 [iot_thread] State: WaitingForFileBlock  Received: 18   Queued: 0   Processed: 0   Dropped: 0
137 3570 [OTA Agent Task] [prvIngestDataBlock] Received file block 18, size 4096
138 3571 [OTA Agent Task] [prvIngestDataBlock] Remaining: 217
139 3571 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
140 3606 [iot_thread] State: WaitingForFileBlock  Received: 19   Queued: 0   Processed: 0   Dropped: 0
141 3673 [OTA Agent Task] [prvIngestDataBlock] Received file block 19, size 4096
142 3674 [OTA Agent Task] [prvIngestDataBlock] Remaining: 216
143 3674 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
144 3706 [iot_thread] State: WaitingForFileBlock  Received: 20   Queued: 0   Processed: 0   Dropped: 0
145 3775 [OTA Agent Task] [prvIngestDataBlock] Received file block 21, size 4096
146 3775 [OTA Agent Task] [prvIngestDataBlock] Remaining: 215
147 3775 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
148 3806 [iot_thread] State: WaitingForFileBlock  Received: 21   Queued: 0   Processed: 0   Dropped: 0
149 3877 [OTA Agent Task] [prvIngestDataBlock] Received file block 22, size 4096
150 3878 [OTA Agent Task] [prvIngestDataBlock] Remaining: 214
151 3878 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
152 3906 [iot_thread] State: WaitingForFileBlock  Received: 22   Queued: 0   Processed: 0   Dropped: 0
153 4006 [iot_thread] State: WaitingForFileBlock  Received: 22   Queued: 0   Processed: 0   Dropped: 0
154 4031 [OTA Agent Task] [prvIngestDataBlock] Received file block 23, size 4096
155 4032 [OTA Agent Task] [prvIngestDataBlock] Remaining: 213
156 4032 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
157 4106 [iot_thread] State: WaitingForFileBlock  Received: 23   Queued: 0   Processed: 0   Dropped: 0
158 4122 [OTA Agent Task] [prvIngestDataBlock] Received file block 17, size 4096
159 4123 [OTA Agent Task] [prvIngestDataBlock] Remaining: 212
160 4124 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
161 4206 [iot_thread] State: WaitingForFileBlock  Received: 24   Queued: 0   Processed: 0   Dropped: 0
162 4225 [OTA Agent Task] [prvIngestDataBlock] Received file block 20, size 4096
163 4226 [OTA Agent Task] [prvIngestDataBlock] Remaining: 211
164 4226 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
165 4226 [OTA Agent Task] [INFO ][MQTT][42260] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
166 4226 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
167 4226 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
168 4306 [iot_thread] State: WaitingForFileBlock  Received: 25   Queued: 0   Processed: 0   Dropped: 0
169 4358 [OTA Agent Task] [prvIngestDataBlock] Received file block 24, size 4096
170 4359 [OTA Agent Task] [prvIngestDataBlock] Remaining: 210
171 4359 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
172 4406 [iot_thread] State: WaitingForFileBlock  Received: 26   Queued: 0   Processed: 0   Dropped: 0
173 4461 [OTA Agent Task] [prvIngestDataBlock] Received file block 25, size 4096
174 4461 [OTA Agent Task] [prvIngestDataBlock] Remaining: 209
175 4461 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
176 4506 [iot_thread] State: WaitingForFileBlock  Received: 27   Queued: 0   Processed: 0   Dropped: 0
177 4606 [iot_thread] State: WaitingForFileBlock  Received: 27   Queued: 0   Processed: 0   Dropped: 0
178 4655 [OTA Agent Task] [prvIngestDataBlock] Received file block 26, size 4096
179 4656 [OTA Agent Task] [prvIngestDataBlock] Remaining: 208
180 4656 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
181 4706 [iot_thread] State: WaitingForFileBlock  Received: 28   Queued: 0   Processed: 0   Dropped: 0
182 4748 [OTA Agent Task] [prvIngestDataBlock] Received file block 28, size 4096
183 4748 [OTA Agent Task] [prvIngestDataBlock] Remaining: 207
184 4748 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
185 4806 [iot_thread] State: WaitingForFileBlock  Received: 29   Queued: 0   Processed: 0   Dropped: 0
186 4906 [iot_thread] State: WaitingForFileBlock  Received: 29   Queued: 0   Processed: 0   Dropped: 0
187 4952 [OTA Agent Task] [prvIngestDataBlock] Received file block 27, size 4096
188 4953 [OTA Agent Task] [prvIngestDataBlock] Remaining: 206
189 4953 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
190 5006 [iot_thread] State: WaitingForFileBlock  Received: 30   Queued: 0   Processed: 0   Dropped: 0
191 5044 [OTA Agent Task] [prvIngestDataBlock] Received file block 29, size 4096
192 5045 [OTA Agent Task] [prvIngestDataBlock] Remaining: 205
193 5045 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
194 5106 [iot_thread] State: WaitingForFileBlock  Received: 31   Queued: 0   Processed: 0   Dropped: 0
195 5137 [OTA Agent Task] [prvIngestDataBlock] Received file block 31, size 4096
196 5137 [OTA Agent Task] [prvIngestDataBlock] Remaining: 204
197 5137 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
198 5206 [iot_thread] State: WaitingForFileBlock  Received: 32   Queued: 0   Processed: 0   Dropped: 0
199 5260 [OTA Agent Task] [prvIngestDataBlock] Received file block 30, size 4096
200 5260 [OTA Agent Task] [prvIngestDataBlock] Remaining: 203
201 5260 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
202 5262 [OTA Agent Task] [INFO ][MQTT][52620] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
203 5262 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
204 5262 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
205 5306 [iot_thread] State: WaitingForFileBlock  Received: 33   Queued: 0   Processed: 0   Dropped: 0
206 5406 [iot_thread] State: WaitingForFileBlock  Received: 33   Queued: 0   Processed: 0   Dropped: 0
207 5423 [OTA Agent Task] [prvIngestDataBlock] Received file block 32, size 4096
208 5424 [OTA Agent Task] [prvIngestDataBlock] Remaining: 202
209 5424 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
210 5506 [iot_thread] State: WaitingForFileBlock  Received: 34   Queued: 0   Processed: 0   Dropped: 0
211 5516 [OTA Agent Task] [prvIngestDataBlock] Received file block 34, size 4096
212 5516 [OTA Agent Task] [prvIngestDataBlock] Remaining: 201
213 5516 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
214 5606 [iot_thread] State: WaitingForFileBlock  Received: 35   Queued: 0   Processed: 0   Dropped: 0
215 5608 [OTA Agent Task] [prvIngestDataBlock] Received file block 35, size 4096
216 5608 [OTA Agent Task] [prvIngestDataBlock] Remaining: 200
217 5608 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
218 5706 [iot_thread] State: WaitingForFileBlock  Received: 36   Queued: 0   Processed: 0   Dropped: 0
219 5806 [iot_thread] State: WaitingForFileBlock  Received: 36   Queued: 0   Processed: 0   Dropped: 0
220 5813 [OTA Agent Task] [prvIngestDataBlock] Received file block 36, size 4096
221 5813 [OTA Agent Task] [prvIngestDataBlock] Remaining: 199
222 5813 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
223 5905 [OTA Agent Task] [prvIngestDataBlock] Received file block 37, size 4096
224 5905 [OTA Agent Task] [prvIngestDataBlock] Remaining: 198
225 5905 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
226 5906 [iot_thread] State: WaitingForFileBlock  Received: 38   Queued: 0   Processed: 0   Dropped: 0
227 6006 [iot_thread] State: WaitingForFileBlock  Received: 38   Queued: 0   Processed: 0   Dropped: 0
228 6007 [OTA Agent Task] [prvIngestDataBlock] Received file block 38, size 4096
229 6008 [OTA Agent Task] [prvIngestDataBlock] Remaining: 197
230 6008 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
231 6099 [OTA Agent Task] [prvIngestDataBlock] Received file block 39, size 4096
232 6100 [OTA Agent Task] [prvIngestDataBlock] Remaining: 196
233 6100 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
234 6106 [iot_thread] State: WaitingForFileBlock  Received: 40   Queued: 0   Processed: 0   Dropped: 0
235 6191 [OTA Agent Task] [prvIngestDataBlock] Received file block 33, size 4096
236 6192 [OTA Agent Task] [prvIngestDataBlock] Remaining: 195
237 6192 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
238 6192 [OTA Agent Task] [INFO ][MQTT][61920] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
239 6192 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
240 6192 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
241 6206 [iot_thread] State: WaitingForFileBlock  Received: 41   Queued: 0   Processed: 0   Dropped: 0
242 6306 [iot_thread] State: WaitingForFileBlock  Received: 41   Queued: 0   Processed: 0   Dropped: 0
243 6324 [OTA Agent Task] [prvIngestDataBlock] Received file block 40, size 4096
244 6325 [OTA Agent Task] [prvIngestDataBlock] Remaining: 194
245 6325 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
246 6406 [iot_thread] State: WaitingForFileBlock  Received: 42   Queued: 0   Processed: 0   Dropped: 0
247 6427 [OTA Agent Task] [prvIngestDataBlock] Received file block 41, size 4096
248 6428 [OTA Agent Task] [prvIngestDataBlock] Remaining: 193
249 6428 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
250 6506 [iot_thread] State: WaitingForFileBlock  Received: 43   Queued: 0   Processed: 0   Dropped: 0
251 6540 [OTA Agent Task] [prvIngestDataBlock] Received file block 42, size 4096
252 6541 [OTA Agent Task] [prvIngestDataBlock] Remaining: 192
253 6541 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
254 6606 [iot_thread] State: WaitingForFileBlock  Received: 44   Queued: 0   Processed: 0   Dropped: 0
255 6693 [OTA Agent Task] [prvIngestDataBlock] Received file block 43, size 4096
256 6694 [OTA Agent Task] [prvIngestDataBlock] Remaining: 191
257 6694 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
258 6706 [iot_thread] State: WaitingForFileBlock  Received: 45   Queued: 0   Processed: 0   Dropped: 0
259 6785 [OTA Agent Task] [prvIngestDataBlock] Received file block 45, size 4096
260 6786 [OTA Agent Task] [prvIngestDataBlock] Remaining: 190
261 6786 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
262 6806 [iot_thread] State: WaitingForFileBlock  Received: 46   Queued: 0   Processed: 0   Dropped: 0
263 6877 [OTA Agent Task] [prvIngestDataBlock] Received file block 46, size 4096
264 6878 [OTA Agent Task] [prvIngestDataBlock] Remaining: 189
265 6878 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
266 6906 [iot_thread] State: WaitingForFileBlock  Received: 47   Queued: 0   Processed: 0   Dropped: 0
267 6980 [OTA Agent Task] [prvIngestDataBlock] Received file block 47, size 4096
268 6980 [OTA Agent Task] [prvIngestDataBlock] Remaining: 188
269 6980 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
270 7006 [iot_thread] State: WaitingForFileBlock  Received: 48   Queued: 0   Processed: 0   Dropped: 0
271 7103 [OTA Agent Task] [prvIngestDataBlock] Received file block 44, size 4096
272 7103 [OTA Agent Task] [prvIngestDataBlock] Remaining: 187
273 7103 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
274 7103 [OTA Agent Task] [INFO ][MQTT][71030] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
275 7103 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
276 7103 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
277 7106 [iot_thread] State: WaitingForFileBlock  Received: 49   Queued: 0   Processed: 0   Dropped: 0
278 7206 [iot_thread] State: WaitingForFileBlock  Received: 49   Queued: 0   Processed: 0   Dropped: 0
279 7256 [OTA Agent Task] [prvIngestDataBlock] Received file block 49, size 4096
280 7257 [OTA Agent Task] [prvIngestDataBlock] Remaining: 186
281 7257 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
282 7306 [iot_thread] State: WaitingForFileBlock  Received: 50   Queued: 0   Processed: 0   Dropped: 0
283 7349 [OTA Agent Task] [prvIngestDataBlock] Received file block 48, size 4096
284 7349 [OTA Agent Task] [prvIngestDataBlock] Remaining: 185
285 7349 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
286 7406 [iot_thread] State: WaitingForFileBlock  Received: 51   Queued: 0   Processed: 0   Dropped: 0
287 7441 [OTA Agent Task] [prvIngestDataBlock] Received file block 51, size 4096
288 7441 [OTA Agent Task] [prvIngestDataBlock] Remaining: 184
289 7441 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
290 7506 [iot_thread] State: WaitingForFileBlock  Received: 52   Queued: 0   Processed: 0   Dropped: 0
291 7533 [OTA Agent Task] [prvIngestDataBlock] Received file block 54, size 4096
292 7534 [OTA Agent Task] [prvIngestDataBlock] Remaining: 183
293 7534 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
294 7606 [iot_thread] State: WaitingForFileBlock  Received: 53   Queued: 0   Processed: 0   Dropped: 0
295 7635 [OTA Agent Task] [prvIngestDataBlock] Received file block 52, size 4096
296 7636 [OTA Agent Task] [prvIngestDataBlock] Remaining: 182
297 7636 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
298 7706 [iot_thread] State: WaitingForFileBlock  Received: 54   Queued: 0   Processed: 0   Dropped: 0
299 7758 [OTA Agent Task] [prvIngestDataBlock] Received file block 53, size 4096
300 7759 [OTA Agent Task] [prvIngestDataBlock] Remaining: 181
301 7759 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
302 7806 [iot_thread] State: WaitingForFileBlock  Received: 55   Queued: 0   Processed: 0   Dropped: 0
303 7850 [OTA Agent Task] [prvIngestDataBlock] Received file block 55, size 4096
304 7851 [OTA Agent Task] [prvIngestDataBlock] Remaining: 180
305 7851 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
306 7906 [iot_thread] State: WaitingForFileBlock  Received: 56   Queued: 0   Processed: 0   Dropped: 0
307 7963 [OTA Agent Task] [prvIngestDataBlock] Received file block 50, size 4096
308 7963 [OTA Agent Task] [prvIngestDataBlock] Remaining: 179
309 7963 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
310 7965 [OTA Agent Task] [INFO ][MQTT][79630] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
311 7965 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
312 7965 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
313 8006 [iot_thread] State: WaitingForFileBlock  Received: 57   Queued: 0   Processed: 0   Dropped: 0
314 8096 [OTA Agent Task] [prvIngestDataBlock] Received file block 57, size 4096
315 8097 [OTA Agent Task] [prvIngestDataBlock] Remaining: 178
316 8097 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
317 8106 [iot_thread] State: WaitingForFileBlock  Received: 58   Queued: 0   Processed: 0   Dropped: 0
318 8188 [OTA Agent Task] [prvIngestDataBlock] Received file block 58, size 4096
319 8189 [OTA Agent Task] [prvIngestDataBlock] Remaining: 177
320 8189 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
321 8206 [iot_thread] State: WaitingForFileBlock  Received: 59   Queued: 0   Processed: 0   Dropped: 0
322 8302 [OTA Agent Task] [prvIngestDataBlock] Received file block 59, size 4096
323 8303 [OTA Agent Task] [prvIngestDataBlock] Remaining: 176
324 8303 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
325 8306 [iot_thread] State: WaitingForFileBlock  Received: 60   Queued: 0   Processed: 0   Dropped: 0
326 8393 [OTA Agent Task] [prvIngestDataBlock] Received file block 60, size 4096
327 8394 [OTA Agent Task] [prvIngestDataBlock] Remaining: 175
328 8394 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
329 8406 [iot_thread] State: WaitingForFileBlock  Received: 61   Queued: 0   Processed: 0   Dropped: 0
330 8506 [iot_thread] State: WaitingForFileBlock  Received: 61   Queued: 0   Processed: 0   Dropped: 0
331 8516 [OTA Agent Task] [prvIngestDataBlock] Received file block 61, size 4096
332 8517 [OTA Agent Task] [prvIngestDataBlock] Remaining: 174
333 8517 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
334 8606 [iot_thread] State: WaitingForFileBlock  Received: 62   Queued: 0   Processed: 0   Dropped: 0
335 8608 [OTA Agent Task] [prvIngestDataBlock] Received file block 62, size 4096
336 8609 [OTA Agent Task] [prvIngestDataBlock] Remaining: 173
337 8609 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
338 8706 [iot_thread] State: WaitingForFileBlock  Received: 63   Queued: 0   Processed: 0   Dropped: 0
339 8711 [OTA Agent Task] [prvIngestDataBlock] Received file block 63, size 4096
340 8711 [OTA Agent Task] [prvIngestDataBlock] Remaining: 172
341 8711 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
342 8806 [iot_thread] State: WaitingForFileBlock  Received: 64   Queued: 0   Processed: 0   Dropped: 0
343 8813 [OTA Agent Task] [prvIngestDataBlock] Received file block 56, size 4096
344 8814 [OTA Agent Task] [prvIngestDataBlock] Remaining: 171
345 8814 [OTA Agent Task] [prvUpdateJobStatus_Mqtt] Msg: {"status":"IN_PROGRESS","statusDetails":{"receive":"64/235"}}
346 8814 [OTA Agent Task] [INFO ][MQTT][88140] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
347 8814 [OTA Agent Task] [prvUpdateJobStatus_Mqtt] 'IN_PROGRESS' to $aws/things/quickconnect_esp32/jobs/AFR_OTA-ota_job_3/update
348 8814 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
349 8816 [OTA Agent Task] [INFO ][MQTT][88160] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
350 8816 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
351 8816 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
352 8906 [iot_thread] State: WaitingForFileBlock  Received: 65   Queued: 0   Processed: 0   Dropped: 0
353 8956 [OTA Agent Task] [prvIngestDataBlock] Received file block 64, size 4096
354 8957 [OTA Agent Task] [prvIngestDataBlock] Remaining: 170
355 8957 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
356 9006 [iot_thread] State: WaitingForFileBlock  Received: 66   Queued: 0   Processed: 0   Dropped: 0
357 9049 [OTA Agent Task] [prvIngestDataBlock] Received file block 65, size 4096
358 9049 [OTA Agent Task] [prvIngestDataBlock] Remaining: 169
359 9049 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
360 9106 [iot_thread] State: WaitingForFileBlock  Received: 67   Queued: 0   Processed: 0   Dropped: 0
361 9140 [OTA Agent Task] [prvIngestDataBlock] Received file block 66, size 4096
362 9141 [OTA Agent Task] [prvIngestDataBlock] Remaining: 168
363 9141 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
364 9206 [iot_thread] State: WaitingForFileBlock  Received: 68   Queued: 0   Processed: 0   Dropped: 0
365 9233 [OTA Agent Task] [prvIngestDataBlock] Received file block 67, size 4096
366 9234 [OTA Agent Task] [prvIngestDataBlock] Remaining: 167
367 9234 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
368 9306 [iot_thread] State: WaitingForFileBlock  Received: 69   Queued: 0   Processed: 0   Dropped: 0
369 9335 [OTA Agent Task] [prvIngestDataBlock] Received file block 68, size 4096
370 9336 [OTA Agent Task] [prvIngestDataBlock] Remaining: 166
371 9336 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
372 9406 [iot_thread] State: WaitingForFileBlock  Received: 70   Queued: 0   Processed: 0   Dropped: 0
373 9427 [OTA Agent Task] [prvIngestDataBlock] Received file block 69, size 4096
374 9428 [OTA Agent Task] [prvIngestDataBlock] Remaining: 165
375 9428 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
376 9506 [iot_thread] State: WaitingForFileBlock  Received: 71   Queued: 0   Processed: 0   Dropped: 0
377 9519 [OTA Agent Task] [prvIngestDataBlock] Received file block 71, size 4096
378 9520 [OTA Agent Task] [prvIngestDataBlock] Remaining: 164
379 9520 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
380 9606 [iot_thread] State: WaitingForFileBlock  Received: 72   Queued: 0   Processed: 0   Dropped: 0
381 9622 [OTA Agent Task] [prvIngestDataBlock] Received file block 70, size 4096
382 9623 [OTA Agent Task] [prvIngestDataBlock] Remaining: 163
383 9623 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
384 9623 [OTA Agent Task] [INFO ][MQTT][96230] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
385 9623 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
386 9623 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
387 9706 [iot_thread] State: WaitingForFileBlock  Received: 73   Queued: 0   Processed: 0   Dropped: 0
388 9796 [OTA Agent Task] [prvIngestDataBlock] Received file block 74, size 4096
389 9797 [OTA Agent Task] [prvIngestDataBlock] Remaining: 162
390 9797 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
391 9806 [iot_thread] State: WaitingForFileBlock  Received: 74   Queued: 0   Processed: 0   Dropped: 0
392 9888 [OTA Agent Task] [prvIngestDataBlock] Received file block 73, size 4096
393 9889 [OTA Agent Task] [prvIngestDataBlock] Remaining: 161
394 9889 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
395 9906 [iot_thread] State: WaitingForFileBlock  Received: 75   Queued: 0   Processed: 0   Dropped: 0
396 9990 [OTA Agent Task] [prvIngestDataBlock] Received file block 72, size 4096
397 9991 [OTA Agent Task] [prvIngestDataBlock] Remaining: 160
398 9991 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
399 10006 [iot_thread] State: WaitingForFileBlock  Received: 76   Queued: 0   Processed: 0   Dropped: 0
400 10106 [iot_thread] State: WaitingForFileBlock  Received: 76   Queued: 0   Processed: 0   Dropped: 0
401 10144 [OTA Agent Task] [prvIngestDataBlock] Received file block 75, size 4096
402 10145 [OTA Agent Task] [prvIngestDataBlock] Remaining: 159
403 10145 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
404 10206 [iot_thread] State: WaitingForFileBlock  Received: 77   Queued: 0   Processed: 0   Dropped: 0
405 10288 [OTA Agent Task] [prvIngestDataBlock] Received file block 76, size 4096
406 10289 [OTA Agent Task] [prvIngestDataBlock] Remaining: 158
407 10289 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
408 10306 [iot_thread] State: WaitingForFileBlock  Received: 78   Queued: 0   Processed: 0   Dropped: 0
409 10400 [OTA Agent Task] [prvIngestDataBlock] Received file block 77, size 4096
410 10401 [OTA Agent Task] [prvIngestDataBlock] Remaining: 157
411 10401 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
412 10406 [iot_thread] State: WaitingForFileBlock  Received: 79   Queued: 0   Processed: 0   Dropped: 0
413 10504 [OTA Agent Task] [prvIngestDataBlock] Received file block 78, size 4096
414 10505 [OTA Agent Task] [prvIngestDataBlock] Remaining: 156
415 10505 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
416 10506 [iot_thread] State: WaitingForFileBlock  Received: 80   Queued: 0   Processed: 0   Dropped: 0
417 10606 [iot_thread] State: WaitingForFileBlock  Received: 80   Queued: 0   Processed: 0   Dropped: 0
418 10615 [OTA Agent Task] [prvIngestDataBlock] Received file block 79, size 4096
419 10616 [OTA Agent Task] [prvIngestDataBlock] Remaining: 155
420 10616 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
421 10616 [OTA Agent Task] [INFO ][MQTT][106160] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
422 10616 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
423 10616 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
424 10706 [iot_thread] State: WaitingForFileBlock  Received: 81   Queued: 0   Processed: 0   Dropped: 0
425 10779 [OTA Agent Task] [prvIngestDataBlock] Received file block 80, size 4096
426 10780 [OTA Agent Task] [prvIngestDataBlock] Remaining: 154
427 10780 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
428 10806 [iot_thread] State: WaitingForFileBlock  Received: 82   Queued: 0   Processed: 0   Dropped: 0
429 10871 [OTA Agent Task] [prvIngestDataBlock] Received file block 81, size 4096
430 10872 [OTA Agent Task] [prvIngestDataBlock] Remaining: 153
431 10872 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
432 10906 [iot_thread] State: WaitingForFileBlock  Received: 83   Queued: 0   Processed: 0   Dropped: 0
433 10994 [OTA Agent Task] [prvIngestDataBlock] Received file block 82, size 4096
434 10995 [OTA Agent Task] [prvIngestDataBlock] Remaining: 152
435 10995 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
436 11006 [iot_thread] State: WaitingForFileBlock  Received: 84   Queued: 0   Processed: 0   Dropped: 0
437 11106 [iot_thread] State: WaitingForFileBlock  Received: 84   Queued: 0   Processed: 0   Dropped: 0
438 11107 [OTA Agent Task] [prvIngestDataBlock] Received file block 84, size 4096
439 11108 [OTA Agent Task] [prvIngestDataBlock] Remaining: 151
440 11108 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
441 11206 [iot_thread] State: WaitingForFileBlock  Received: 85   Queued: 0   Processed: 0   Dropped: 0
442 11291 [OTA Agent Task] [prvIngestDataBlock] Received file block 83, size 4096
443 11292 [OTA Agent Task] [prvIngestDataBlock] Remaining: 150
444 11292 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
445 11306 [iot_thread] State: WaitingForFileBlock  Received: 86   Queued: 0   Processed: 0   Dropped: 0
446 11406 [iot_thread] State: WaitingForFileBlock  Received: 86   Queued: 0   Processed: 0   Dropped: 0
447 11414 [OTA Agent Task] [prvIngestDataBlock] Received file block 87, size 4096
448 11415 [OTA Agent Task] [prvIngestDataBlock] Remaining: 149
449 11415 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
450 11506 [iot_thread] State: WaitingForFileBlock  Received: 87   Queued: 0   Processed: 0   Dropped: 0
451 11547 [OTA Agent Task] [prvIngestDataBlock] Received file block 85, size 4096
452 11548 [OTA Agent Task] [prvIngestDataBlock] Remaining: 148
453 11548 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
454 11606 [iot_thread] State: WaitingForFileBlock  Received: 88   Queued: 0   Processed: 0   Dropped: 0
455 11649 [OTA Agent Task] [prvIngestDataBlock] Received file block 86, size 4096
456 11650 [OTA Agent Task] [prvIngestDataBlock] Remaining: 147
457 11650 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
458 11650 [OTA Agent Task] [INFO ][MQTT][116500] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
459 11650 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
460 11650 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
461 11706 [iot_thread] State: WaitingForFileBlock  Received: 89   Queued: 0   Processed: 0   Dropped: 0
462 11806 [iot_thread] State: WaitingForFileBlock  Received: 89   Queued: 0   Processed: 0   Dropped: 0
463 11814 [OTA Agent Task] [prvIngestDataBlock] Received file block 88, size 4096
464 11815 [OTA Agent Task] [prvIngestDataBlock] Remaining: 146
465 11815 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
466 11905 [OTA Agent Task] [prvIngestDataBlock] Received file block 89, size 4096
467 11906 [iot_thread] State: WaitingForFileBlock  Received: 91   Queued: 0   Processed: 0   Dropped: 0
468 11906 [OTA Agent Task] [prvIngestDataBlock] Remaining: 145
469 11906 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
470 12006 [iot_thread] State: WaitingForFileBlock  Received: 91   Queued: 0   Processed: 0   Dropped: 0
471 12018 [OTA Agent Task] [prvIngestDataBlock] Received file block 90, size 4096
472 12019 [OTA Agent Task] [prvIngestDataBlock] Remaining: 144
473 12019 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
474 12106 [iot_thread] State: WaitingForFileBlock  Received: 92   Queued: 0   Processed: 0   Dropped: 0
475 12131 [OTA Agent Task] [prvIngestDataBlock] Received file block 91, size 4096
476 12131 [OTA Agent Task] [prvIngestDataBlock] Remaining: 143
477 12131 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
478 12206 [iot_thread] State: WaitingForFileBlock  Received: 93   Queued: 0   Processed: 0   Dropped: 0
479 12244 [OTA Agent Task] [prvIngestDataBlock] Received file block 92, size 4096
480 12244 [OTA Agent Task] [prvIngestDataBlock] Remaining: 142
481 12244 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
482 12306 [iot_thread] State: WaitingForFileBlock  Received: 94   Queued: 0   Processed: 0   Dropped: 0
483 12346 [OTA Agent Task] [prvIngestDataBlock] Received file block 94, size 4096
484 12346 [OTA Agent Task] [prvIngestDataBlock] Remaining: 141
485 12347 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
486 12406 [iot_thread] State: WaitingForFileBlock  Received: 95   Queued: 0   Processed: 0   Dropped: 0
487 12438 [OTA Agent Task] [prvIngestDataBlock] Received file block 93, size 4096
488 12439 [OTA Agent Task] [prvIngestDataBlock] Remaining: 140
489 12439 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
490 12506 [iot_thread] State: WaitingForFileBlock  Received: 96   Queued: 0   Processed: 0   Dropped: 0
491 12532 [OTA Agent Task] [prvIngestDataBlock] Received file block 95, size 4096
492 12533 [OTA Agent Task] [prvIngestDataBlock] Remaining: 139
493 12533 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
494 12533 [OTA Agent Task] [INFO ][MQTT][125330] (MQTT connection 0x3fff0b00) MQTT PUBLISH operation queued.
495 12533 [OTA Agent Task] [prvRequestFileBlock_Mqtt] OK: $aws/things/quickconnect_esp32/streams/AFR_OTA-8e649e99-a21f-46b8-a3df-ced243405fcc/get/cbor
496 12533 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [RequestFileBlock] New state [WaitingForFileBlock]
497 12606 [iot_thread] State: WaitingForFileBlock  Received: 97   Queued: 0   Processed: 0   Dropped: 0
498 12694 [OTA Agent Task] [prvIngestDataBlock] Received file block 96, size 4096
499 12695 [OTA Agent Task] [prvIngestDataBlock] Remaining: 138
500 12695 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
501 12706 [iot_thread] State: WaitingForFileBlock  Received: 98   Queued: 0   Processed: 0   Dropped: 0
502 12796 [OTA Agent Task] [prvIngestDataBlock] Received file block 97, size 4096
503 12797 [OTA Agent Task] [prvIngestDataBlock] Remaining: 137
504 12797 [OTA Agent Task] [prvOTAAgentTask] Called handler. Current State [WaitingForFileBlock] Event [ReceivedFileBlock] New state [WaitingForFileBlock]
Kindly respond, I am not sure code working properly or not i am generating software from Amazon Console


E Key Function

On a fresh install of Elysium the E key operates like the interact key even though I have changed the key in settings to something else.
On the title menu the E key will activate the Continue Game, Load, Quit, etc.. My middle mouse button ( which I have set to interact) does not work. The E key also activates things in the inventory and magic menus .
Wondering if someone could direct me where to look to fix this.
Thank's for this mod setup I LOVE IT !!!!
[EDIT]
I researched some more and found that this was an issue back for Skyrim LE and looks like it was patched for SE. I have never played vanilla so I don't know if this is normal. This pertains to Favorited Items using a Default F key and Interaction with E key for keyboard and not being able to remap them.
I play other mods throughout the years and have Aldrnari and Serenity  installed and neither of them have this issue.

Found the issue, skyrim tried to update to anniversary edition when I clicked launch the game in launcher, I had a custom ControlMap_Custom file that was causing it. Deleted it, keybinds are fine now.

[edit2]
I copy and paste a backup of my Skyrim Folder instead of reinstalling the game through steam. I had a ControlMap_Custom because I launched the base game and changed keybinds creating the text, thus conflicting and creating the issue. Just deleted the ControlMap_Custom out of Steams Skyrim and all is fine now.


Add gh actions

Codecov Report

:exclamation: No coverage uploaded for pull request base (master@7f1449f). Click here to learn what that means.
The diff coverage is 100.00%.

@@            Coverage Diff             @@
##             master        #1   +/-   ##
==========================================
  Coverage          ?   100.00%
==========================================
  Files             ?        10
  Lines             ?      1272
  Branches          ?         0
==========================================
  Hits              ?      1272
  Misses            ?         0
  Partials          ?         0

Impacted Files
Coverage Δ

tests/test_backport.py
100.00% <100.00%> (ø)

tests/test_bpo.py
100.00% <100.00%> (ø)

tests/test_close_pr.py
100.00% <100.00%> (ø)

tests/test_news.py
100.00% <100.00%> (ø)

tests/test_stage.py
100.00% <100.00%> (ø)

tests/test_util.py
100.00% <100.00%> (ø)

Codecov Report

:exclamation: No coverage uploaded for pull request base (master@7f1449f). Click here to learn what that means.
The diff coverage is 100.00%.

@@            Coverage Diff             @@
##             master        #1   +/-   ##
==========================================
  Coverage          ?   100.00%
==========================================
  Files             ?        10
  Lines             ?      1272
  Branches          ?         0
==========================================
  Hits              ?      1272
  Misses            ?         0
  Partials          ?         0

Impacted Files
Coverage Δ

tests/test_backport.py
100.00% <100.00%> (ø)

tests/test_bpo.py
100.00% <100.00%> (ø)

tests/test_close_pr.py
100.00% <100.00%> (ø)

tests/test_news.py
100.00% <100.00%> (ø)

tests/test_stage.py
100.00% <100.00%> (ø)

tests/test_util.py
100.00% <100.00%> (ø)


Add some MCMC sampler for Bayesian Inference

Awesome, thank you. Do you feel in a position to write a few sentences about the relationship between those packes? For example: does one package use 3 others under the hood? Are they competing frameworks, or do they build on eachother? Are they all actively maintained? Do any of them have organizational suppert/funding?
If you do, this PR would be even better with some of that detail. I emphatically do not want this project to produce a list of packages, but instead want it to provide beginner-friendly guidance that helps users chose the appropriate package.

I will merge this for now, but feel free to flesh out the section later!


x/tools/cmd/goimports: Not honoring existing import blocks

What version of Go are you using (go version)?

$ go version
go version go1.16.3 darwin/amd64

Does this issue reproduce with the latest release?
Unsure
What operating system and processor architecture are you using (go env)?
go env Output
$ go env
GO111MODULE=""
GOARCH="amd64"
GOBIN=""
GOCACHE="/Users/chris.annino/Library/Caches/go-build"
GOENV="/Users/chris.annino/Library/Application Support/go/env"
GOEXE=""
GOFLAGS=""
GOHOSTARCH="amd64"
GOHOSTOS="darwin"
GOINSECURE=""
GOMODCACHE="/Users/chris.annino/go/pkg/mod"
GOOS="darwin"
GOPATH="/Users/chris.annino/go"
GOPROXY="https://proxy.golang.org,direct"
GOROOT="/usr/local/go"
GOSUMDB="sum.golang.org"
GOTMPDIR=""
GOTOOLDIR="/usr/local/go/pkg/tool/darwin_amd64"
GOVCS=""
GOVERSION="go1.16.3"
GCCGO="gccgo"
AR="ar"
CC="clang"
CXX="clang++"
CGO_ENABLED="1"
CGO_CFLAGS="-g -O2"
CGO_CPPFLAGS=""
CGO_CXXFLAGS="-g -O2"
CGO_FFLAGS="-g -O2"
CGO_LDFLAGS="-g -O2"
PKG_CONFIG="pkg-config"
GOGCCFLAGS="-fPIC -arch x86_64 -m64 -pthread -fno-caret-diagnostics -Qunused-arguments -fmessage-length=0 -fdebug-prefix-map=/var/folders/n7/b590_5_x2fq9l3wvs9v_t_bhmxcn41/T/go-build3430492942=/tmp/go-build -gno-record-gcc-switches -fno-common"

What did you do?
import (
  "github.com/local"
  "github.com/external"
  "fmt"
)

then run:
goimports -local "github.com/local" -w file.go

works wonderfully:
import (
  "fmt"

  "github.com/external"

  "github.com/local"
)

However, my IDE is dumb and doesn't honor import blocks, instead inserting to the first block. I am expecting goimports to help with this and honor existing blocks of system, external and local blocks.
import (
  "fmt"
  "github.com/local/subpackage"

  "github.com/external"

  "github.com/local"
)

goimports -local "github.com/local" -w file.go

What did you expect to see?
import (
  "fmt"

  "github.com/external"

  "github.com/local"
  "github.com/local/subpackage"
)

What did you see instead?
import (
  "fmt"

  "github.com/local/subpackage"

  "github.com/external"

  "github.com/local"
)

This behavior seems to happen whether an external import or local import is included in the first block. In fact, adding a local import to the external block we see similar behavior where instead of adding to the existing local block, it creates a new local block above the existing local block. Is this a bug or by design? I wish it worked differently if this is by design.

Duplicate of #31646


Footer social media links and play store links aren't working

Hello Khushi,
I am a contributor in GSSoC'24. I found this issue and I can solve this by adding social media links to the footer. I can improve the UI by adding logos of google play store and app store instead of text buttons which helps in better user navigation. Please assign this to me under GSSoC'24.
Regards,
Alayna Shaheen

Hello Khushi,
I'm Sumit Kumar, a contributor participating in GSSOC'24. I'm interested in contributing to this particular issue. It seems like it can be resolved by using the href attribute in the already utilized anchor tag. I'm eager to tackle this challenge and contribute to the project. Looking forward to your guidance on how to proceed.
Regards,
Sumit Kumar

Hello @khushi-joshi-05 Can you plz assign this issue to me under GSSOC'24

Hi,
I want to work on this issue

I would like to work on this issue
Please assign it to me
Thank you

I want to work on this issue, please assign me this under GSSoC level 2.

hey,,i am able to complete this task.

Hi @khushi-joshi-05 , Can you please assign me this issue under GSSOC'24. Also please add the level label to it.

I had resolved this issue please see my PR

@khushi-joshi-05
If the issue is solved please close the issue!


runtime: Read lock mutex when [bulk] publishing to pubsub

Read lock the runtime processor pubsub when publishing and bulk publishing messages. This ensures the pubsubs have been init'ed before publishing is executed.
This PR fixes the 2 JS integrations test cases which were failing after https://github.com/dapr/dapr/pull/6688.

/ok-to-test

/ok-sdk-all

/test-sdk-all

The python failure looks to be a flake which has been happening before the runtime changes was merged
https://github.com/dapr/dapr/actions/runs/5548435243


Allow overrides for detailed monitoring and public IP

what

Leverages the changes from https://github.com/masterpointio/terraform-aws-ssm-agent/pull/18 to allow launch config customization
Allows detailed monitoring and public IP association to be configured

why

Detailed monitoring incurs additional Cloudwatch costs, so this allows a user to opt-out
Tailscale recommends public IPs for optimal performance, so allow user to configure this (the default is null which should inherit the default behavior of the subnet)

references

Closes #11

Argh and our CI checks are failing due to prettier lint + README changes.

Argh and our CI checks are failing due to prettier lint + README changes. Can you run trunk fmt locally and commit the result?

:+1:
TIL of trunk

@mheffner thanks for the contribution! Released as https://github.com/masterpointio/terraform-aws-tailscale/releases/tag/0.5.0 👍


[stable/prometheus-operator] Unable to collect container metrics since Kubelets are down after install

Describe the bug
I'm using helm charts prometheus-operator in order to collect container metrics through cAdvisor in kubelets. While I have deployed prometheus-operator and its components without an error, prometheus is unable to reach each node's kubelet to collect metrics.
Version of Helm and Kubernetes:
Helm: 2.13
Kubernetes:1.14
Which chart:
stable/prometheus-operator
What happened:
Kubelet pods aren't up for the node

What you expected to happen:
Kubelet operator pods should have been up.
How to reproduce it (as minimally and precisely as possible):
Just follow installation doc for prometheus operator,
Anything else we need to know:
kubectl get pods

prometheus-rel-grafana-9fbdc7796-9ldrk                     2/2     Running   0          4h28m
prometheus-rel-kube-state-metrics-84b9dfcd84-v8msf         1/1     Running   0          4h28m
prometheus-rel-prometheus-node-exporter-zpvm9              1/1     Running   0          4h28m
prometheus-rel-prometheus-oper-operator-6cb4b65855-5qfp6   1/1     Running   0          4h28m
prometheus-
prometheus-rel-prometheus-oper-prometheus-0     3/3     Running   1          4h28m

Related issues:
https://github.com/istio/istio/issues/14119

Having deployed this into a minikube cluster, running minikube version: v1.1.0 and using the switch --kubernetes-version=v1.14.2 I cannot reproduce your issue.

It's still the same for me @vsliouniaev.
What is interesting is that since I'm deploying in default namespace, prometheus is trying to look for kubelet collector pods in default (as shown in the diagram) whereas the tags say that these kubelet pods should in kube-system namespace.
Am I missing something here?

Kubelet endpoint discovery is done using an endpoints object deployed into the kube-system namespace. The scraping of the endpoint is working fine, the issue is that prometheus is unable to authenticate to the kubelet. The prometheus operator has a troubleshooting guide for setting up your cluster so that this auth works: https://github.com/coreos/prometheus-operator/blob/master/Documentation/troubleshooting.md#prometheus-kubelet-metrics-server-returned-http-status-403-forbidden

@vsliouniaev, thank you! Your solution worked fine for me. I'm closing this issue.


Fix: real-time resize jumping

Fix: real-time resize jumping

Pull Request Test Coverage Report for Build 891992354

0 of 1 (0.0%)  changed or added relevant line in 1 file are covered.
No unchanged relevant lines lost coverage.
Overall coverage decreased (-0.009%) to 2.045%

Changes Missing Coverage
Covered Lines
Changed/Added Lines
%

src/useVirtual.ts
0
1
0.0%

Totals

Change from base Build 891771823:
-0.009%

Covered Lines:
7

Relevant Lines:
265

💛  - Coveralls

Pull Request Test Coverage Report for Build 891992354

0 of 1 (0.0%)  changed or added relevant line in 1 file are covered.
No unchanged relevant lines lost coverage.
Overall coverage decreased (-0.009%) to 2.045%

Changes Missing Coverage
Covered Lines
Changed/Added Lines
%

src/useVirtual.ts
0
1
0.0%

Totals

Change from base Build 891771823:
-0.009%

Covered Lines:
7

Relevant Lines:
265

💛  - Coveralls