AT Client URC 数据处理问题？

发布于 2020-07-15 23:28:33 浏览：1625 订阅该版

系统版本 `RT-Thread 4.0.0`
文件 at组件 `(V1.2.0)`

问题是回调函数有时候不能正确执行，rt_sem_take也不超时

下面这种情况可以正确处理
```
[D/AT] recvline: 0000-0020: 00 55 53 52 2D 47 4D 33  20 56 33 2E 32 2E 30 0D  0A                                                  .USR-GM3 V3.2.0..
[D/AT] recvline: 0000-0020: 69 70 3D 31 31 30 2E 31  31 2E 37 33 2E 33 32 3B  70 6F 72 74 3D 38 39 30  30 3B 66 72 65 71 3D 36    ip=110.11.73.32;port=8900;freq=6
[D/AT] recvline: 0020-0040: 30 30 30 0D 0A                                                                                        000..
```

**下面这种情况不能正确处理，回调函数有时候不能正确执行，rt_sem_take也不超时**
```
[D/AT] recvline: 0000-0020: 00 55 53 52 2D 47 4D 33  20 56 33 2E 32 2E 30 0D  69 70 3D 31 31 30 2E 31  31 2E 37 33 2E 33 32 3B    .USR-GM3 V3.2.0.ip=114.11.73.32;
[D/AT] recvline: 0020-0040: 70 6F 72 74 3D 38 39 30  30 3B 66 72 65 71 3D 36  30 30 30 0D 0A                                      port=8900;freq=6000..
```

相关代码如下：
```c
void send_my_messsage(uint8_t Msg)
{
    uint8_t buf = Msg;

rt_mq_send(&mq, &buf, sizeof(buf));
}

static void func_recv_welcome(const char *data, rt_size_t size)
{
    rt_kprintf("--->[Info] --->  AT data=%s  size=%d\r\n", data, size);

send_my_messsage(1);

rt_sem_release(&welcome_sem);
}

static struct at_urc urc_table[] = {
    {"ip=",    "\r\n",    func_recv_welcome},
};

ALIGN(RT_ALIGN_SIZE)
static rt_uint8_t test_stack[1024];
static struct rt_thread test_thread;
static void test_thread_entry(void* parameter)
{
    int ret;

send_my_messsage(1);

ret = gm3_gprs_para_config(current_para->para_server_ip, current_para->para_server_port, GPRS_AT_CMD_TIMEOUT);

// 等待欢迎信息
    ret = rt_sem_take(&welcome_sem, rt_tick_from_millisecond(5000));
    if (ret != RT_EOK)
    {
        send_my_messsage(2);
        rt_kprintf("--->[Warn] ---> No welcome message received !\r\n");
    }
}

int at_client_port_init(void)
{
    rt_sem_init(&welcome_sem, "welcome_sem", 0, RT_IPC_FLAG_FIFO);

at_client_init("uart3", MAX_AT_INFO_SIZE);

at_set_urc_table(urc_table, sizeof(urc_table) / sizeof(urc_table[0]));

ret = rt_thread_init(&test_thread,
                            "test",
                            test_thread_entry,
                            RT_NULL,
                            (rt_uint8_t*)&test_stack[0],
                            sizeof(test_stack),
                            priority,
                            5);
    if (ret == RT_EOK)
    {
        rt_thread_startup(&test_thread);
    }

return RT_EOK;
}
```