Function acceptWireProtocol

src/main.cpp:11–39

namespace {

void acceptWireProtocol(
    const std::string& host, int port, const std::string& unixPath, bool verbose
) {
    using namespace ::cucumber::internal;
    CukeEngineImpl cukeEngine;
    JsonWireMessageCodec wireCodec;
    WireProtocolHandler protocolHandler(wireCodec, cukeEngine);
    std::unique_ptr<SocketServer> server;
#if defined(ASIO_HAS_LOCAL_SOCKETS)
    if (!unixPath.empty()) {
        UnixSocketServer* const unixServer = new UnixSocketServer(&protocolHandler);
        server.reset(unixServer);
        unixServer->listen(unixPath);
        if (verbose)
            std::clog << "Listening on socket " << unixServer->listenEndpoint() << std::endl;
    } else
#else
    // Prevent warning about unused parameter
    static_cast<void>(unixPath);
#endif
    {
        TCPSocketServer* const tcpServer = new TCPSocketServer(&protocolHandler);
        server.reset(tcpServer);
        tcpServer->listen(asio::ip::tcp::endpoint(asio::ip::make_address(host), port));
        if (verbose)
            std::clog << "Listening on " << tcpServer->listenEndpoint() << std::endl;
    }
    server->acceptOnce();
}

}