Function at_client_obj_recv

components/net/at/src/at_client.c:549–593

* AT client receive fixed-length data. * * @param client current AT client object * @param buf receive data buffer * @param size receive fixed data size * @param timeout receive data timeout (ms) * * @note this function can only be used in execution function of URC data * * @return >0: receive data size * =0: receive failed */

 *         =0: receive failed
 */
rt_size_t at_client_obj_recv(at_client_t client, char *buf, rt_size_t size, rt_int32_t timeout)
{
    rt_size_t read_idx = 0;

    RT_ASSERT(buf);

    if (client == RT_NULL)
    {
        LOG_E("input AT Client object is NULL, please create or get AT Client object!");
        return 0;
    }

#ifndef RT_USING_SERIAL_V2
    while (size)
    {
        rt_size_t read_len;

        rt_event_recv(&client->event, at_client_rx_notice_event, RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR, 0, NULL);

        read_len = rt_device_read(client->device, 0, buf + read_idx, size);
        if (read_len > 0)
        {
            read_idx += read_len;
            size     -= read_len;
        }
        else
        {
            if (rt_event_recv(&client->event, at_client_rx_notice_event, RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR, rt_tick_from_millisecond(timeout), NULL) != RT_EOK)
                break;
        }
    }
#else
    rt_int32_t rx_timeout = rt_tick_from_millisecond(timeout);
    rt_device_control(client->device, RT_SERIAL_CTRL_SET_RX_TIMEOUT, (void *)&rx_timeout);
    read_idx   = rt_device_read(client->device, 0, buf, size);
    rx_timeout = RT_WAITING_NO;
    rt_device_control(client->device, RT_SERIAL_CTRL_SET_RX_TIMEOUT, (void *)&rx_timeout);
#endif

#ifdef AT_PRINT_RAW_CMD
    at_print_raw_cmd("urc_recv", buf, read_idx);
#endif

    return read_idx;
}

/**
 *  AT client set end sign.