m2m_ota.c

Go to the documentation of this file.

/*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*
INCLUDES
*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*/
#include "common/include/nm_common.h"
#include "driver/include/m2m_types.h"
#include "driver/include/m2m_ota.h"
#include "driver/include/m2m_wifi.h"
#include "driver/source/m2m_hif.h"
/*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*
MACROS
*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*/

/*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*
DATA TYPES
*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*/
static tpfOtaUpdateCb gpfOtaUpdateCb = NULL;
static tpfOtaNotifCb  gpfOtaNotifCb = NULL;


/*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*
FUNCTION PROTOTYPES
*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*=*/
static void m2m_ota_cb(uint8 u8OpCode, uint16 u16DataSize, uint32 u32Addr)
{
        sint8 ret = M2M_SUCCESS;
        if(u8OpCode == M2M_OTA_RESP_NOTIF_UPDATE_INFO)
        {
                tstrOtaUpdateInfo strOtaUpdateInfo;
                m2m_memset((uint8*)&strOtaUpdateInfo,0,sizeof(tstrOtaUpdateInfo));
                ret = hif_receive(u32Addr,(uint8*)&strOtaUpdateInfo,sizeof(tstrOtaUpdateInfo),0);
                if(ret == M2M_SUCCESS)
                {
                        if(gpfOtaNotifCb)
                                gpfOtaNotifCb(&strOtaUpdateInfo);
                }
        }
        else if (u8OpCode == M2M_OTA_RESP_UPDATE_STATUS)
        {
                tstrOtaUpdateStatusResp strOtaUpdateStatusResp;
                m2m_memset((uint8*)&strOtaUpdateStatusResp,0,sizeof(tstrOtaUpdateStatusResp));
                ret = hif_receive(u32Addr, (uint8*) &strOtaUpdateStatusResp,sizeof(tstrOtaUpdateStatusResp), 0);
                if(ret == M2M_SUCCESS)
                {
                        if(gpfOtaUpdateCb)
                                gpfOtaUpdateCb(strOtaUpdateStatusResp.u8OtaUpdateStatusType,strOtaUpdateStatusResp.u8OtaUpdateStatus);
                }
        }
        else
        {
                M2M_ERR("Invaild OTA resp %d ?\n",u8OpCode);
        }

}
NMI_API sint8  m2m_ota_init(tpfOtaUpdateCb pfOtaUpdateCb, tpfOtaNotifCb pfOtaNotifCb)
{
        sint8 ret = M2M_SUCCESS;

        if(pfOtaUpdateCb){
                gpfOtaUpdateCb = pfOtaUpdateCb;
        }else{
                M2M_ERR("Invaild Ota update cb\n");
        }
        if(pfOtaNotifCb){
                gpfOtaNotifCb = pfOtaNotifCb;
        }else{
                M2M_ERR("Invaild Ota notify cb\n");
        }

        hif_register_cb(M2M_REQ_GROUP_OTA,m2m_ota_cb);

        return ret;
}
NMI_API sint8  m2m_ota_notif_set_url(uint8 * u8Url)
{
        sint8 ret = M2M_SUCCESS;
        uint16 u16UrlSize = m2m_strlen(u8Url) + 1;
        /*Todo: we may change it to data pkt but we need to give it higer priority
                        but the priorty is not implemnted yet in data pkt
        */
        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_START_UPDATE,u8Url,u16UrlSize,NULL,0,0);
        return ret;

}

NMI_API sint8  m2m_ota_notif_check_for_update(void)
{
        sint8 ret = M2M_SUCCESS;
        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_NOTIF_CHECK_FOR_UPDATE,NULL,0,NULL,0,0);
        return ret;
}

NMI_API sint8 m2m_ota_notif_sched(uint32 u32Period)
{
        sint8 ret = M2M_SUCCESS;
        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_NOTIF_CHECK_FOR_UPDATE,NULL,0,NULL,0,0);
        return ret;
}

NMI_API sint8 m2m_ota_start_update(uint8 * u8DownloadUrl)
{
        sint8 ret = M2M_SUCCESS;
        uint16 u16DurlSize = m2m_strlen(u8DownloadUrl) + 1;
        /*Todo: we may change it to data pkt but we need to give it higer priority
                        but the priorty is not implemnted yet in data pkt
        */
        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_START_UPDATE,u8DownloadUrl,u16DurlSize,NULL,0,0);
        return ret;
}


NMI_API sint8 m2m_ota_rollback(void)
{
        sint8 ret = M2M_SUCCESS;
        tstrM2mRev strRev;

        ret = m2m_ota_get_firmware_version(&strRev);
        if(ret == M2M_SUCCESS)
        {
                if(M2M_GET_HIF_BLOCK(strRev.u16FirmwareHifInfo) == M2M_HIF_BLOCK_VALUE)
                {
                        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_ROLLBACK,NULL,0,NULL,0,0);
                }
                else
                {
                        ret = M2M_ERR_FAIL;
                }
        }
        return ret;
}


NMI_API sint8 m2m_ota_abort(void)
{
        sint8 ret = M2M_SUCCESS;
        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_ABORT,NULL,0,NULL,0,0);
        return ret;
}


NMI_API sint8 m2m_ota_switch_firmware(void)
{
        sint8 ret = M2M_SUCCESS;
        tstrM2mRev strRev;

        ret = m2m_ota_get_firmware_version(&strRev);
        if(ret == M2M_SUCCESS)
        {
                if(M2M_GET_HIF_BLOCK(strRev.u16FirmwareHifInfo) == M2M_HIF_BLOCK_VALUE)
                {
                        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_SWITCH_FIRMWARE,NULL,0,NULL,0,0);
                }
                else
                {
                        ret = M2M_ERR_FAIL;
                }
        }
        return ret;
}
#if 0
#define M2M_OTA_FILE    "../../../m2m_ota.dat"
NMI_API sint8 m2m_ota_test(void)
{
        uint32 page  = 0;
        uint8 buffer[1500];
        uint32 u32Sz = 0;
        sint8 ret = M2M_SUCCESS;
        FILE *fp =NULL;
        fp = fopen(M2M_OTA_FILE,"rb");
        if(fp)
        {
                fseek(fp, 0L, SEEK_END);
                u32Sz = ftell(fp);
                fseek(fp, 0L, SEEK_SET);

                while(u32Sz > 0)
                {
                        {
                                page = (rand()%1400);

                                if((page<100)||(page>1400)) page  = 1400;
                        }

                        if(u32Sz>page)
                        {
                                u32Sz-=page;
                        }
                        else
                        {
                                page = u32Sz;
                                u32Sz = 0;
                        }
                        printf("page %d\n", (int)page);
                        fread(buffer,page,1,fp);
                        ret = hif_send(M2M_REQ_GROUP_OTA,M2M_OTA_REQ_TEST|M2M_REQ_DATA_PKT,NULL,0,(uint8*)&buffer,page,0);
                        if(ret != M2M_SUCCESS)
                        {
                                M2M_ERR("\n");
                        }
                        nm_bsp_sleep(1);
                }

        }
        else
        {
                M2M_ERR("nO err\n");
        }
        return ret;
}
#endif