401|1

100

帖子

0

资源

一粒金砂(中级)

【平头哥RVB2601创意应用开发】使用体验09 -- YoC事件 [复制链接]

本帖最后由 sonicfirr 于 2022-5-13 22:23 编辑

       停滞了一段时间,继续RVB2601创意应用的开发工作。本人的创意项目需要RVB2601连接TCP Server——这个Server是建立在LoRa网关设备上的,所以基本就是用RVB2601去做LoRa网关的无线式上位机。
       工作流程大体是:RVB2601向网关发送轮询帧,网关转发给LoRa终端,终端则采集传感器数据并通过网关回传到RVB2601。因此,RVB2601既要WiFi联网,又要开启TCP应用,而且还需要接收TCP数据。
       好在板子的SDK中有接收回调的注册接口,就是之前帖子已经提到过的w800_packet_input_cb_register(),回调的原型为:

              typedef void (*net_data_input_cb_t)(int linkid, void *data, size_t len, char remote_ip[16], uint16_t remote_ports);

       不过案例的业务逻辑设计了这样一种需求:板子每隔固定周期会发出轮询帧,且发出后等待回复数据一定时间(默认10s),如果超时则再发轮询帧,最多尝试3次(也是默认,可以调整),这个需求通过定时器回调来实现的。好巧不巧上一阶段的工作主要完成NTP功能,自以为对C time库了解的不错,所以本人设计这样“有坑版”的代码写法:

 

//w800 input callback function
void aita_w800in_cb(int linkid, void *data, size_t len, char remote_ip[16], uint16_t remote_ports) {
    uint8_t* d;
    d = (uint8_t *)data;
    printf("linkid: %d\n", linkid);
    printf("len: %d\n", len);
    printf("remote_ip: %s\n", remote_ip);
    printf("remote_port: %d\n", remote_ports);
    printf("data:%s\n", d);
    
    if(remote_ports == GW_PORT) {
        isTimeout = 0;
        memset(USR220resbuff, 0, USR220RES_LEN);
        for(int i=0; i<len; i++) {
            USR220resbuff = d;
        }
    }
}

void aita_PollingFunc(void) {
    int i = 0;
    int cyc = 1;
    time_t nowtime, endtime;
    //connect to USR220 TCP Server
    int ret = -1;    
    ret = w800_connect_remote(0, NET_TYPE_TCP_CLIENT, GW_IP, GW_PORT);
    if(ret < 0) return;
  
    for(i=0; i<endian_count; i++) {
        aita_BuildCommandPack(i); //build polling pack
        cyc = repeat;             //repeat times when timeout
        isOneEndianDone = 0;
        while(cyc--) {
            w800_send_data(comm_pack, COMMPACK_LEN, 3000);
            isTimeout = 1;
            endtime = time(NULL) + timeout;
            while((nowtime=time(NULL)) < endtime) {
                if(!isTimeout) {
                    cyc = 0;
                    isOneEndianDone = 1;
                    break;
                }
            }
            printf("usr220res: %s, len: %d\n", USR220resbuff, sizeof(USR220resbuff));
        }
        if(!isOneEndianDone) {
            printf("%s disconnected\n", EID);
        }
    }
    //断开TCP 连接
    w800_close(0);
}

       

       上述代码的逻辑也很简单,就是基于程序查询思想,发出一帧开始不断通过time(NULL)来获取本地时间,如果时间过去timeout秒,就表示超时了,而w800接收回调会将超时标志isTimeOut清零,帮助结束程序查询的循环——while((nowtime=time(NULL)) < endtime)。
       逻辑看似完美,但是在下忽略了这是在实时系统的平台上,而且代码跑在定时器回调中,而网络接收回调抢不到CPU权,所以查询本地时间的循环会阻塞w800接收回调的出现。
       当时,为了验证自己的想法,干脆将超时查询改为aos_msleep(timeout*1000),果然接收回调出现了,但是每一次轮询都要固定耗时timeout秒钟显然是不行的。因此,想到了引入事件机制,因为只是简单的条件获取,所以选用了事件标志组。YoC的事件标志组可以查看链接:
https://yoc.docs.t-head.cn/yocbook/Chapter3-AliOS/%E6%93%8D%E4%BD%9C%E7%B3%BB%E7%BB%9F%E6%8E%A5%E5%8F%A3/%E4%BA%8B%E4%BB%B6.html 。

       首先定义事件标志组变量和初始化函数,初始化函数会在案例的board_yoc_init()中调用。下述代码中,标志定义为宏EVENT_FLAG_3,选用这个纯粹是从文档抄来也没必要改名字。

 


#define EVENT_FLAG_3 0x000000F0
aos_event_t usr220res_event;

void aita_InitEvent(void) {
    int ret = -1;
    ret = aos_event_new(&usr220res_event, 0);
    if (ret != 0) {
        printf("event create failed\n");
        return;
    }    
}

       

       接着就是修改aita_PollingFunc()函数,它会在定时器回调中调用(有不清楚的朋友可以看本人的RVB2601使用帖子03)。

 


void aita_PollingFunc(void) {
    int i = 0;
    int cyc = 1;
    //connect to USR220(LoRa Gateway) TCP Server
    int ret = -1;    
    ret = w800_connect_remote(0, NET_TYPE_TCP_CLIENT, GW_IP, GW_PORT);
    if(ret < 0) return;
    //once polling request all endians
    for(i=0; i<endian_count; i++) {
        aita_BuildCommandPack(i);//build req pack in USR220 format 
        cyc = repeat;
        isOneEndianDone = 0;
        while(cyc--) {
            w800_send_data(comm_pack, COMMPACK_LEN, 3000);
            isTimeout = 1;
            uint32_t actl_flags;
            //wait for flag(0x000000F0) for timeout-seconds, if get the flag then clear the bit
            aos_event_get(&usr220res_event, EVENT_FLAG_3, AOS_EVENT_OR_CLEAR, &actl_flags, timeout*1000);
            if(!isTimeout) {
                cyc = 0;
                isOneEndianDone = 1;
                printf("usr220res: %s, len: %d\n", USR220resbuff, sizeof(USR220resbuff));
            }            
        }
        if(!isOneEndianDone) {
            printf("%s disconnected\n", EID);
        }
    }
    //once polling done & disconnect to tcp server
    w800_close(0);
}

 

       w800接收回调当然就是在收到回复数据包后,发出事件标志EVENT_FLAG_3。

 


void aita_w800in_cb(int linkid, void *data, size_t len, char remote_ip[16], uint16_t remote_ports) {
    uint8_t* d;
    d = (uint8_t *)data;
    printf("linkid: %d\n", linkid);
    printf("len: %d\n", len);
    printf("remote_ip: %s\n", remote_ip);
    printf("remote_port: %d\n", remote_ports);
    printf("data:%s\n", d);
    
    if(remote_ports == GW_PORT) {
        isTimeout = 0;
        memset(USR220resbuff, 0, USR220RES_LEN);
        for(int i=0; i<len; i++) {
            USR220resbuff = d;
        }
        aos_event_set(&usr220res_event, EVENT_FLAG_3, AOS_EVENT_OR);        
    }
}

 


回复

6748

帖子

0

资源

五彩晶圆(初级)

谢谢分享“有坑版”的代码写法


回复
您需要登录后才可以回帖 登录 | 注册

查找数据手册?

EEWorld Datasheet 技术支持

最新文章 更多>>
    关闭
    站长推荐上一条 1/10 下一条

    About Us 关于我们 客户服务 联系方式 器件索引 网站地图 最新更新 手机版

    站点相关: 安防电子 汽车电子 手机便携 工业控制 家用电子 医疗电子 测试测量 网络通信 物联网

    北京市海淀区知春路23号集成电路设计园量子银座1305 电话:(010)82350740 邮编:100191

    电子工程世界版权所有 京B2-20211791 京ICP备10001474号-1 电信业务审批[2006]字第258号函 京公网安备 11010802033920号 Copyright © 2005-2022 EEWORLD.com.cn, Inc. All rights reserved
    快速回复 返回顶部 返回列表