C ++ boost :: asio :: ip :: tcp :: acceptor иногда не принимает соединитель? - PullRequest
Новая
       42

C ++ boost :: asio :: ip :: tcp :: acceptor иногда не принимает соединитель?

0 голосов
/ 06 февраля 2020

У меня сейчас очень странная проблема. Иногда мой :: acceptor (используя async_accept) не принимает сокет (нет вызова функции accept, указанной в async_accept), но коннектор возвращает true для функции connect (оба boost :: asio :: занятия). Иногда все работает, но иногда я не получаю гнездо акцептора .... Я действительно не знаю почему. Я протестировал все под Win10 64bit с разными listen_ports.
Моя структура сервера следующая:
io_service: 

_io_thread = std::make_unique<std::thread>([this]() {
            while (1)
            {
                try
                {
                    _io_service->run();
                    break;
                }
                catch (const boost::exception& e)
                {
                    spdlog::error("IO_SERVICE_EXCEPTION: ", boost::diagnostic_information(e));
                }
            }
        });

акцептор: 

void Server::initialize(uint16_t listen_port)
    {
        // at this point the io_thread is running already

        auto endpoint = ip::tcp::endpoint(ip::tcp::v4(), listen_port);

        _acceptor = std::make_unique<boost::asio::ip::tcp::acceptor>(*_io_service, endpoint.protocol());
        _acceptor->set_option(boost::asio::ip::tcp::acceptor::reuse_address(false));
        _acceptor->bind(endpoint);
        _acceptor->listen();

        _listen_port = listen_port;

        __accept();
    }

__ accept (): 

void Server::__accept()
    {
        // create socket for next connection
        _acceptor_socket = std::make_unique<ip::tcp::socket>(*_io_service);

        _acceptor->async_accept(*_acceptor_socket, [this](const boost::system::error_code& err)
            {
                spdlog::info("Accept new socket..."); // this sometimes doesn't get called :(

                if (err.failed())
                {
                    // acceptor closed
                    if (err == boost::asio::error::operation_aborted)
                    {
                        spdlog::info("network server stopped accepting sockets");
                        return;
                    }

                    // unknown error
                    spdlog::error("network server accepting socket failed {} message {} num {}", err.failed(), err.message(), err.value());

                    // accept next connection
                    __accept();
                    return;
                }

                // accept new socket
                _new_connections_mutex.lock();

                auto con = __create_new_connection();
                con->initialize(++_connection_id_counter, std::move(_acceptor_socket));
                con->set_handler(_input_handler);
                con->goto_phase(_initial_phase);
                spdlog::info("new connection from {} with id {}", con->get_host_name(), con->get_unique_id());

                _new_connections[con->get_unique_id()] = std::move(con);

                _new_connections_mutex.unlock();

                // wait for next connection
                __accept();
            }
        );
    }



Мой клиентский разъем прост: 

        auto socket = std::make_unique<boost::asio::ip::tcp::socket>(*_io_service);

        spdlog::info("try to connect to {}:{}", endpoint.address().to_string(), endpoint.port());
        try
        {
            socket->connect(endpoint);
        }
        catch (const boost::system::system_error & e)
        {
            spdlog::error("cannot connect to {}:{}", endpoint.address().to_string(), endpoint.port());
            return false;
        }

        // this succeeds everytime...
        [...]

Итак ... не должно ли создаваться каждый раз, когда гнездо разъема успешно соединяется с гнездом акцептора? Я надеюсь, что кто-то знает, что здесь происходит не так: /

1 Ответ

0 голосов
/ 06 февраля 2020

Хорошо, я нашел ответ .... функция io_service :: run не работает, как я ожидал. Я думал, что он просто заблокируется навсегда, если io_service :: stop не вызывается. Похоже, это неправильно. Так как я прерываю вызов one :: run из моего while l oop, а затем поток завершается, io_service иногда больше не запускается, когда подключается сокет соединителя. Изменили io_service :: run -> run_one () и удалили разрыв. Теперь добавим переменную al oop -cancel, чтобы она не была бесконечной l oop ...
Спасибо за ваши ответы!

...