Method accept_loop

src/Chain/libraries/rpc/RpcServer.cpp:1272–1307

                }

                void accept_loop()
                {
                    while (!_accept_loop_complete.canceled())
                    {
                        fc::tcp_socket_ptr sock = std::make_shared<fc::tcp_socket>();
                        try
                        {
                            _tcp_serv->accept(*sock);
                        }
                        catch (const fc::canceled_exception&)
                        {
                            throw;
                        }
                        catch (const fc::exception& e)
                        {
                            elog("fatal: error opening socket for rpc connection: ${e}", ("e", e.to_detail_string()));
                            continue;
                        }

                        auto buf_istream = std::make_shared<fc::buffered_istream>(sock);
                        auto buf_ostream = std::make_shared<fc::buffered_ostream>(sock);

                        auto json_con = std::make_shared<fc::rpc::json_connection>(std::move(buf_istream),
                            std::move(buf_ostream));
                        register_methods(json_con);
                        auto receipt = _open_json_connections.insert(json_con);

                        json_con->exec().on_complete([this, receipt, sock](fc::exception_ptr e){
                            ilog("json_con exited");
                            sock->close();
                            _open_json_connections.erase(receipt.first);
                            if (e)
                                elog("Connection exited with error: ${error}", ("error", e->what()));
                        });
                    }
                }

                void encrypted_accept_loop(const thinkyoung::blockchain::PrivateKeyType& server_key)
                {