boost/fiber
2
0
Fork 0
mirror of https://github.com/boostorg/fiber.git synced 2026-02-19 02:12:24 +00:00
Code Issues Projects Releases Wiki Activity

change asio/echo example

Browse Source
This commit is contained in:
Oliver Kowalke
2016-02-28 20:24:12 +01:00
parent 3572b00e59
commit d1430e395b
2 changed files with 34 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
examples/asio/echo_client.cpp
View File

@@ -1,55 +0,0 @@
//
// echo_client.cpp
// ~~~~~~~~~~~~~~~
//
// Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
// This source is effectively identical to
// http://www.boost.org/doc/libs/release/doc/html/boost_asio/example/cpp03/echo/blocking_tcp_echo_client.cpp
// It does not use Boost.Fiber. It is copied here only for completeness. A
// server needs a client.
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
#include <cstdlib>
#include <cstring>
#include <iostream>
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
enum {
max_length = 1024
};
int main( int argc, char* argv[]) {
try {
if ( 3 != argc) {
std::cerr << "Usage: echo_client <host> <port>\n";
return EXIT_FAILURE;
}
boost::asio::io_service io_service;
tcp::resolver resolver( io_service);
tcp::resolver::query query( tcp::v4(), argv[1], argv[2]);
tcp::resolver::iterator iterator = resolver.resolve( query);
tcp::socket s( io_service);
boost::asio::connect( s, iterator);
std::cout << "Enter message: ";
char request[max_length];
std::cin.getline( request, max_length);
size_t request_length = std::strlen( request);
boost::asio::write( s, boost::asio::buffer( request, request_length) );
char reply[max_length];
size_t reply_length = boost::asio::read( s, boost::asio::buffer( reply, request_length) );
std::cout << "Reply is: ";
std::cout.write( reply, reply_length);
std::cout << "\n";
return EXIT_SUCCESS;
} catch ( std::exception const& e) {
std::cerr << "Exception: " << e.what() << "\n";
}
return EXIT_FAILURE;
}

42
examples/asio/echo_server.cpp
View File

@@ -62,11 +62,11 @@ void session( socket_ptr sock) {
std::cout << "fiber " << id << " terminates" << std::endl;
}
void server( boost::asio::io_service & io_svc, unsigned short port) {
void server( boost::asio::io_service & io_svc) {
boost::fibers::fiber::id id = boost::this_fiber::get_id();
std::cout << "fiber " << id << " : echo-server started" << std::endl;
try {
tcp::acceptor a( io_svc, tcp::endpoint( tcp::v4(), port) );
tcp::acceptor a( io_svc, tcp::endpoint( tcp::v4(), 9999) );
for (;;) {
socket_ptr socket( new tcp::socket( io_svc) );
boost::system::error_code ec;
@@ -88,20 +88,46 @@ void server( boost::asio::io_service & io_svc, unsigned short port) {
std::cout << "fiber " << id << " terminates" << std::endl;
}
void client( boost::asio::io_service & io_svc) {
tcp::resolver resolver( io_svc);
tcp::resolver::query query( tcp::v4(), "127.0.0.1", "9999");
tcp::resolver::iterator iterator = resolver.resolve( query);
tcp::socket s( io_svc);
boost::asio::connect( s, iterator);
std::cout << "Enter message: ";
char request[max_length];
std::cin.getline( request, max_length);
boost::system::error_code ec;
size_t request_length = std::strlen( request);
boost::asio::async_write(
s,
boost::asio::buffer( request, request_length),
boost::fibers::asio::yield[ec]);
if ( ec == boost::asio::error::eof) {
return; //connection closed cleanly by peer
} else if ( ec) {
throw boost::system::system_error( ec); //some other error
}
char reply[max_length];
size_t reply_length = s.async_read_some(
boost::asio::buffer( reply, request_length),
boost::fibers::asio::yield[ec]);
std::cout << "Reply is: ";
std::cout.write( reply, reply_length);
}
int main( int argc, char* argv[]) {
try {
if ( 2 != argc) {
std::cerr << "Usage: echo_server <port>\n";
return EXIT_FAILURE;
}
boost::fibers::fiber::id id = boost::this_fiber::get_id();
std::cout << "fiber " << id << " : (main-fiber) started" << std::endl;
boost::asio::io_service io_svc;
boost::fibers::use_scheduling_algorithm< boost::fibers::asio::round_robin >( io_svc);
// server fiber
boost::fibers::fiber f(
server, boost::ref( io_svc), std::atoi( argv[1]) );
server, boost::ref( io_svc) );
// client fiber
boost::fibers::fiber(
client, boost::ref( io_svc) ).detach();
// fiber unrelated to asio
boost::fibers::fiber(
[](){