Чтение объектов Protobuf с помощью boost::asio::read_async

Я пишу приложение с помощью Boost asio, в котором клиент и сервер обмениваются сообщениями, которые сериализуются с помощью протобуферов google.Я не знаю, каков размер сериализованного сообщения, отправляемого по сети. Кажется, что объекты proto-buf не имеют разделителя.

Вот содержимое файла .proto.

 package tutorial;

message Person {
        required string name = 1;
        required int32 id = 2;
        optional string email = 3;
}

Вот как я пишу с сервера

        tutorial::Person p;
        p.set_name("abcd pqrs");
        p.set_id(123456);
        p.set_email("abcdpqrs@gmail.com");
        write(p);

        boost::asio::streambuf b;
        std::ostream os(&b);
        p.SerializeToOstream(&os);
        boost::asio::async_write(socket_, b,
                        boost::bind(&Server::handle_write, this,
                                boost::asio::placeholders::error));

В клиенте я читаю сообщение, отправленное выше, используя boost::asio::async_read. Как узнать значение argв качестве аргумента для boost::asio::transfer_at_leastв приведенном ниже коде?

 boost::asio::async_read(socket_, response_,
                            boost::asio::transfer_at_least(arg),
                            boost::bind(&Client::handle_read_header, this,
                                    boost::asio::placeholders::error));

Или как мне убедиться, что boost::async_read возвращает значение после чтения всего объекта?

6
задан sank 8 June 2012 в 18:43
поделиться