Ticket #6548: asio_bug.cpp

#include <iostream>
#include <string>
#include <boost/thread.hpp>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
using namespace std;
using namespace boost;
using namespace boost::asio;
using namespace boost::asio::local;

void accept(thread::id id)
{
        cout << "accept from " << this_thread::get_id() << ", async_accept from " << id << endl;
}

void thread_run(shared_ptr<io_service> &io, shared_ptr<stream_protocol::acceptor> &acceptor)
{
        shared_ptr<io_service::work> work(new io_service::work(*io));
        cout << "start from " << this_thread::get_id() << endl;
        stream_protocol::socket sock(*(io.get()));
        acceptor->async_accept(sock, bind(&accept, this_thread::get_id()));
        io->run();
}

int main()
{
        ::unlink("/tmp/fcgi_test.sock");
        shared_ptr<io_service> io_1(new io_service()), io_2(new io_service());
        stream_protocol::endpoint ep("/tmp/fcgi_test.sock");
        shared_ptr<stream_protocol::acceptor> acceptor(new stream_protocol::acceptor(*(io_1.get()), ep, true));
        shared_ptr<thread> thread_1(new thread(&thread_run, io_1, acceptor));
        shared_ptr<thread> thread_2(new thread(&thread_run, io_2, acceptor));
        thread_1->join();
        thread_2->join();

        return 0;
}