云存储模块

iv_err_code_e eErrCode = 0;
iv_cs_init_parm_s stCsInitParm;
memset(&stCsInitParm, 0, sizeof(iv_cs_init_parm_s));
stCsInitParm.u32MaxSizeInAGop = 512*1024;
stCsInitParm.iv_cs_push_stream_start_cb = cloudStorage_start;
stCsInitParm.iv_cs_push_stream_stop_cb = cloudStorage_stop;
stCsInitParm.iv_cs_ai_service_notify_cb = cloudStorage_ai_service_notify;
stCsInitParm.iv_cs_event_capture_picture = cloudStorage_event_capture_picture;
stCsInitParm.iv_cs_event_upload_picture_result = cloudStorage_event_upload_picture_result;
stCsInitParm.event_list_max_depth = IV_CS_MAX_EVENT_LIST_DEPTH;
stCsInitParm.event_record_min_time_s = 8;
stCsInitParm.event_interval_time_s = 3*60;
for(int i = 0; i < IV_CS_EVENT_MAX_TRIGGER;i++)
{
    stCsInitParm.event_trigger_priority[i] = i;
}
eErrCode = iv_cs_init(&stCsInitParm);
if(eErrCode < 0)
{
    GDB_ERR("fail:%d\\n", eErrCode);
    return eErrCode;
}

void* cloudStorage_exit_waiting(void* param)
{
    pthread_detach(pthread_self());
    unsigned int time_cnt = 0;
    while(!cloud_storage_wait_flag)
    {
        if(time_cnt++ > 500)
        {
            if(iv_cs_exit(true) == IV_ERR_CS_EXITING)
            {
                GDB_INFO("exit time too long,set iv_cs_exit force\\n");
            }
            break;
        }
        usleep(10*1000);
    }
    return NULL;
}
int cloudStorage_exit(void)
{
    cloudStorage_stop();
    iv_err_code_e eErrCode = 0;
    pthread_t tid = 0;
    cloud_storage_wait_flag = 0;
    pthread_create(&tid,NULL,cloudStorage_exit_waiting,NULL);
    eErrCode = iv_cs_exit(false);
    cloud_storage_wait_flag = 1;
    if(eErrCode < 0)
    {
        GDB_ERR("fail:%d\\n", eErrCode);
        return eErrCode;
    }

    return 0;
}

pf_audio_stream_s stAudioStream;
iv_cm_aenc_stream_s stIvAencStream;
av_encdec_dst_type_e eEncdecDstType = AV_ENCDEC_DST_TYPE_CS_HD;

pf_venc_stream_s stVencStream;
iv_cm_venc_stream_s *pstIvVencStream;
memset(&stVencStream, 0, sizeof(pf_venc_stream_s));

while(!s32CloudStorageExit)
{
    int s32GetAudioStreamRet = 0;
    int s32GetVideoStreamRet = 0;

    /*audio data*/
    s32GetAudioStreamRet = av_encdec_get_audio_stream(eEncdecDstType, &stAudioStream);
    if(s32GetAudioStreamRet < 0) goto RECORD_NO_AUDIO_DATA;
    if(0 != stAudioStream.u32Len)
    {
        stIvAencStream.pu8Stream = stAudioStream.pStream;
        stIvAencStream.u32Len = stAudioStream.u32Len;
        stIvAencStream.u64TimeStamp = stAudioStream.u64TimeStamp;
        iv_cs_push_stream(IV_CS_STREAM_TYPE_AUDIO, IV_CM_VENC_TYPE_H264, (void *)&stIvAencStream);
    }
    RECORD_NO_AUDIO_DATA:

    /*video data*/
    s32GetVideoStreamRet = av_encdec_get_video_stream(0, eEncdecDstType, &stVencStream);
    if(s32GetVideoStreamRet < 0) goto RECORD_NO_VIDEO_DATA;
    pstIvVencStream = (iv_cm_venc_stream_s*)&stVencStream;
    iv_cs_push_stream(IV_CS_STREAM_TYPE_VIDEO, IV_CM_VENC_TYPE_H264, (void *)pstIvVencStream);
    RECORD_NO_VIDEO_DATA:
    if(s32GetAudioStreamRet < 0 && s32GetVideoStreamRet < 0)
    {
        usleep(5000);
        continue;
    }
}

int event_happen_interval[10] = {1,1,5,5,10,10,20,40,60,200};
int time_cnt = 0;
uint32_t random_index = 0;
int next_event_happen_cnt = 0;
iv_cs_event_trigger_type_e event_type = 0;
while(1)
{
    /* 随机生成 */
    if(demo_mode == 0 && time_cnt >= next_event_happen_cnt)
    {
        srand((unsigned)time(NULL));//用当前时间，设置种子
        random_index = rand()  % sizeof(event_trigger_type) ;
        iv_cs_event_happen_notify(event_trigger_type),time(NULL)*1000);
        random_index = rand()  % 10 ;
        next_event_happen_cnt = time_cnt + event_happen_interval[random_index];
        GDB_INFO("create new event next:%d\\n",event_happen_interval[random_index]);
    }
    time_cnt++;
    sleep(1);
}

//抓图回调
void cloudStorage_event_capture_picture(uint8_t* pic_name,uint32_t pic_name_max_len)
{
    snprintf(pic_name,pic_name_max_len,"/iot_video_raw/alarm_capture.jpg");
    GDB_INFO("cloud storage capture picture:%s\\n",pic_name);
    if(access(pic_name,F_OK) != 0)
    {
        memset(pic_name,0,sizeof(pic_name));
    }
}

//处理图片上传回调
void cloudStorage_event_upload_picture_result(uint8_t* pic_name,iv_cs_event_pic_upload_res_e err_code)
{
    switch(err_code)
    {
        case IV_CS_EVENT_PICTURE_UPLOAD_OK:
            GDB_INFO("upload %s success\\n",pic_name);
        break;
        default:
            GDB_INFO("upload %s fail:%d\\n",pic_name,err_code);
        break;
    }
    remove(pic_name);
}