webclient例程接收数据不全

发布于 2019-12-13 12:10:07 浏览：1234 订阅该版

使用的ec20+AT(v2.0.1)指令联网方式 在进行webclient(v2.1.0)的get试验的时候，发现每次接收数据只能接收到90%多样子。文件大小![QQ截图20191213120016.png](/uploads/201912/13/120035hg2kttmmg9gvk2pa.png)186584,每次接收只有182084字节。怀疑是AT receive timeout (6000)导致，但是又不知道什么原因。请高人指点{:2_27:}这个可能就是每次OTA只能到90%的原因！
```int webclient_get_comm(const char *uri_l)
{
    char *uri = RT_NULL;
    struct webclient_session* session = RT_NULL;
    unsigned char *buffer = RT_NULL;
    int index, ret = 0;
    int bytes_read, resp_status;
    int content_length = -1;
    uri = web_strdup(uri_l);

buffer = (unsigned char *) web_malloc(GET_RESP_BUFSZ);
 if (buffer == RT_NULL)
 {
 rt_kprintf("no memory for receive buffer. ");
 ret = -RT_ENOMEM;
 goto __exit;
 }

/* create webclient session and set header response size */
    session = webclient_session_create(GET_HEADER_BUFSZ);
    
    if (session == RT_NULL)
    {
        ret = -RT_ENOMEM;
        goto __exit;
    }

/* send GET request by default header */
 if ((resp_status = webclient_get(session, uri)) != 200)
 {
 rt_kprintf("webclient GET request failed, response(%d) error. ", resp_status);
 ret = -RT_ERROR;
 goto __exit;
 }

rt_kprintf("webclient get response data: ");

content_length = webclient_content_length_get(session);
 rt_kprintf("data content_length : %d ",content_length);

int content_pos = 0;

do
 {
 bytes_read = webclient_read(session, buffer, content_length - content_pos > GET_RESP_BUFSZ ? GET_RESP_BUFSZ : content_length - content_pos);
 if (bytes_read <= 0)
 {
 break;
 }

content_pos += bytes_read;
 } while (content_pos < content_length);

rt_kprintf("content_pos = %d ",content_pos);

__exit:
    if (session)
    {
         webclient_close(session);
     }

if (buffer)
    {
         web_free(buffer);
    }

return ret;
}```

3 个回答

tanc 2019-12-13

这家伙很懒，什么也没写！

使用wget历程来获取文件也是，每次都只能获取到刚好那么多长度的数据。[attach]12689[/attach]

int webclient_get_file(const char* URI, const char* filename)
{
    int fdd = -1, rc = WEBCLIENT_OK;
    size_t offset;
    int length, total_length = 0;
    unsigned char *ptr = RT_NULL;
    struct webclient_session* session = RT_NULL;
    int resp_status = 0;

session = webclient_session_create(WEBCLIENT_HEADER_BUFSZ);
    if(session == RT_NULL)
    {
        rc = -WEBCLIENT_NOMEM;
        goto __exit;
    }

if ((resp_status = webclient_get(session, URI)) != 200)
    {
        LOG_E("get file failed, wrong response: %d (-0x%X).", resp_status, resp_status);
        rc = -WEBCLIENT_ERROR;
        goto __exit;
    }

// fd = open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0);
// if (fd < 0)
// {
// LOG_E("get file failed, open file(%s) error.", filename);
// rc = -WEBCLIENT_ERROR;
// goto __exit;
// }

ptr = (unsigned char *) web_malloc(WEBCLIENT_RESPONSE_BUFSZ);
 if (ptr == RT_NULL)
 {
 LOG_E("get file failed, no memory for response buffer.");
 rc = -WEBCLIENT_NOMEM;
 goto __exit;
 }
 
 if (session->content_length < 0)
 {
 while (1)
 {
 length = webclient_read(session, ptr, WEBCLIENT_RESPONSE_BUFSZ);
 if (length > 0)
 {
// write(fd, ptr, length);
 total_length += length;
 LOG_RAW(">");
 }
 else
 {
 break;
 }
 }
 }
 else
 {
 for (offset = 0; offset < (size_t) session->content_length;)
 {
 length = webclient_read(session, ptr,
 session->content_length - offset > WEBCLIENT_RESPONSE_BUFSZ ?
 WEBCLIENT_RESPONSE_BUFSZ : session->content_length - offset);

if (length > 0)
            {
//                write(fd, ptr, length);
                total_length += length;
                LOG_RAW(">");
            }
            else
            {
                break;
            }

offset += length;
        }
    }

if (total_length)
    {
        LOG_D("save %d bytes.", total_length);
    }

__exit:
//    if (fd >= 0)
//    {
//        close(fd);
//    }

if (session != RT_NULL)
    {
        webclient_close(session);
    }

if (ptr != RT_NULL)
    {
        web_free(ptr);
    }

return rc;
}