upstream/wesnoth
1
0
Fork 0
mirror of https://github.com/wesnoth/wesnoth synced 2025-05-15 17:25:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Finished implementing network_asio::connection::transfer

Browse Source
This commit is contained in:
Sergey Popov 2011-06-21 15:13:04 +00:00
parent ba69be6682
commit 05ebefffbf
2 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/network_asio.cpp
View File

@ -14,6 +14,7 @@
*/
#include <boost/bind.hpp>
#include <boost/ref.hpp>
#include <boost/cstdint.hpp>
#include <boost/version.hpp>
#include <iostream>
@ -89,7 +90,7 @@ void connection::handle_handshake(
done_ = true;
}
void connection::transfer(const config& request, config& /*response*/)
void connection::transfer(const config& request, config& response)
{
io_service_.reset();
done_ = false;
@ -102,7 +103,7 @@ void connection::transfer(const config& request, config& /*response*/)
boost::asio::async_write(socket_, write_buf_, boost::bind(&connection::handle_write, this, _1, _2));
boost::asio::async_read(socket_, read_buf_,
boost::bind(&connection::is_read_complete, this, _1, _2),
boost::bind(&connection::handle_read, this, _1, _2));
boost::bind(&connection::handle_read, this, _1, _2, boost::ref(response)));
}
void connection::handle_write(
@ -142,7 +143,8 @@ std::size_t connection::is_read_complete(
void connection::handle_read(
const boost::system::error_code& ec,
std::size_t bytes_transferred
std::size_t bytes_transferred,
config& response
)
{
std::cout << "Read " << bytes_transferred << " bytes.\n";
@ -151,9 +153,7 @@ void connection::handle_read(
if(ec && ec != boost::asio::error::eof)
throw error(ec);
std::istream is(&read_buf_);
config cfg;
read_gz(cfg, is);
std::cout << cfg;
read_gz(response, is);
}
}

3
src/network_asio.hpp
View File

@ -72,7 +72,8 @@ class connection
);
void handle_read(
const boost::system::error_code& ec,
std::size_t bytes_transferred
std::size_t bytes_transferred,
config& response
);
boost::optional<std::size_t> bytes_to_read_;
std::size_t bytes_read_;