Method StartInternal

src/brpc/server.cpp:826–1246

}

int Server::StartInternal(const butil::EndPoint& endpoint,
                          const PortRange& port_range,
                          const ServerOptions *opt) {
    std::unique_ptr<Server, RevertServerStatus> revert_server(this);
    if (_failed_to_set_max_concurrency_of_method) {
        _failed_to_set_max_concurrency_of_method = false;
        LOG(ERROR) << "previous call to MaxConcurrencyOf() was failed, "
            "fix it before starting server";
        return -1;
    }
    if (_failed_to_set_ignore_eovercrowded) {
        _failed_to_set_ignore_eovercrowded = false;
        LOG(ERROR) << "previous call to IgnoreEovercrowdedOf() was failed, "
            "fix it before starting server";
        return -1;
    }
    if (InitializeOnce() != 0) {
        LOG(ERROR) << "Fail to initialize Server[" << version() << ']';
        return -1;
    }
    const Status st = status();
    if (st != READY) {
        if (st == RUNNING) {
            LOG(ERROR) << "Server[" << version() << "] is already running on "
                       << _listen_addr;
        } else {
            LOG(ERROR) << "Can't start Server[" << version()
                       << "] which is " << status_str(status());
        }
        return -1;
    }

    copy_and_fill_server_options(_options, opt ? *opt : ServerOptions());

    if (!_options.h2_settings.IsValid(true/*log_error*/)) {
        LOG(ERROR) << "Invalid h2_settings";
        return -1;
    }

    if (_options.bthread_tag < BTHREAD_TAG_DEFAULT ||
        _options.bthread_tag >= FLAGS_task_group_ntags) {
        LOG(ERROR) << "Fail to set tag " << _options.bthread_tag
                   << ", tag range is [" << BTHREAD_TAG_DEFAULT << ":"
                   << FLAGS_task_group_ntags << ")";
        return -1;
    }
    int ret = TransportFactory::ContextInitOrDie(_options.socket_mode, true, &_options);
    if (ret != 0) {
        LOG(ERROR) << "Fail to initialize transport context for server, ret=" << ret;
        return -1;
    }

    if (_options.http_master_service) {
        // Check requirements for http_master_service:
        //  has "default_method" & request/response have no fields
        const google::protobuf::ServiceDescriptor* sd =
            _options.http_master_service->GetDescriptor();
        const google::protobuf::MethodDescriptor* md =