Получить количество байтов, прочитанных boost :: asio :: async_read - PullRequest
Новая
       24

Получить количество байтов, прочитанных boost :: asio :: async_read

3 голосов
/ 21 мая 2011

Я пытаюсь преобразовать возвращаемое значение функции boost::asio::async_read в int, чтобы посмотреть, получил ли я какие-либо данные: 

int recvlen = boost::asio::async_read (
    socket_,
    boost::asio::buffer((char*)buffer, 1000),
    boost::bind(&Connection::Receive, this, boost::asio::placeholders::error)
);

Вот то утверждение в контексте остальной части моего кода, которое не компилируется:

.h файл: 

#ifndef _CONNECTION_H_
#define _CONNECTION_H_

#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/asio.hpp>
#include <stdint.h>

class Connection 
{
public:
    Connection(boost::asio::io_service& io_service);
    ~Connection();
    boost::asio::ip::tcp::socket& socket() {return socket_;}
    void Send(uint8_t* buffer, int length);
    bool Receive();

protected:
    virtual void OnReceived(uint8_t* buffer, int len) = 0;

private:
    boost::asio::ip::tcp::socket socket_;
};

#endif

.cpp файл: 

#include "Connection.h"

Connection::Connection(boost::asio::io_service& io_service)    
    : socket_(io_service) {}

Connection::~Connection() {}

void Connection::Send(uint8_t* buffer,int length) {
    boost::asio::async_write (
        socket_,
        boost::asio::buffer(buffer, length),
        boost::bind(&Connection::Send, this,boost::asio::placeholders::error)
    );
}

bool Connection::Receive(){
    uint8_t* buffer = new uint8_t[1000];

    //Conversion excerpt
    int recvlen = boost::asio::async_read (
        socket_,
        boost::asio::buffer((char*)buffer, 1000),
        boost::bind(&Connection::Receive, this, boost::asio::placeholders::error)
    );

    if (recvlen <= 0) {
        delete[] buffer;
        return false;
    }

    this->OnReceived(buffer, recvlen);

    delete[] buffer;

    return true;
}

Это ошибки, которые этот код вызывает в Visual C ++: 

error C2825: 'F': must be a class or namespace when followed by '::'    e:\boost_1_46_1\boost_1_46_1\boost\bind\bind.hpp    69
error C2039: 'result_type' : is not a member of '`global namespace''    e:\boost_1_46_1\boost_1_46_1\boost\bind\bind.hpp    69
error C2146: syntax error : missing ';' before identifier 'type'    e:\boost_1_46_1\boost_1_46_1\boost\bind\bind.hpp    69
error C2208: 'boost::_bi::type' : no members defined using this type    e:\boost_1_46_1\boost_1_46_1\boost\bind\bind.hpp    69
error C1903: unable to recover from previous error(s); stopping compilation e:\boost_1_46_1\boost_1_46_1\boost\bind\bind.hpp    69
IntelliSense: a value of type "void" cannot be used to initialize an entity of type "int"   d:\c++\ugs\common\connection.cpp    18
IntelliSense: the #endif for this directive is missing  d:\c++\ugs\common\connection.h  1
IntelliSense: this declaration has no storage class or type specifier   d:\c++\ugs\common\connection.h  26

Как мне добиться того, что я пытаюсь сделать? Кроме того, что означают эти ошибки и как их можно исправить?

1 Ответ

2 голосов
/ 21 мая 2011

async_read не возвращает количество прочитанных байтов. Он выполняет чтение в фоновом режиме, асинхронно. Количество байтов передается обработчику завершения. Обработчик завершения вызывается ASIO после завершения чтения. Вы передаете обработчик завершения в async_read. async_read - это шаблон, который принимает любой объект функции в качестве обработчика. В вашем случае вы передали выходные данные оператора bind.

Есть хорошие примеры в документации . , но есть два быстрых решения.

Вы можете использовать синхронную функцию boost :: asio :: read вместо boost :: asio :: async_read. 

int recvlen = boost::asio::read(socket_,boost::asio::buffer((char*)buffer, 1000));

Или вы можете добавить новую функцию: 

void HandleReceive(boost::system::error_code &error, std::size_t recvlen)
{
    if (!error && error != boost::asio::error::message_length) {
       this->OnReceived(buffer, recvlen);
       delete [] buffer;
    } // else ERROR!!!
}

И вызвать async_read как 

boost::asio::async_read(socket_,boost::asio::buffer((char*)buffer, 1000),
          boost::bind(&Connection::HandleReceive, this,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));

Вам нужно будет сделать buffer переменную класса для работы асинхронного примера, но вы, возможно, захотите придумать лучший способ управления памятью. Кроме того, вам придется что-то предпринять для решения проблем класса Connection. Посмотрите примеры ASIO для лучшего примера.

...