Method Run

CodeFormatServer/src/Session/StandardIOSession.cpp:83–122

int StandardIOSession::Run(LanguageServer &server) {
    auto &ioc = server.GetIOContext();
    IOSession::Run(server);
    while (true) {
        do {
            char *writableCursor = _protocolBuffer.GetWritableCursor();
            std::size_t capacity = _protocolBuffer.GetRestCapacity();

            std::size_t readSize = StandardIO::GetInstance().ReadSome(writableCursor, capacity);

            if (StandardIO::GetInstance().HasError()) {
                goto endLoop;
            }

            _protocolBuffer.SetWriteSize(readSize);

            if (_protocolBuffer.CanReadOneProtocol()) {
                break;
            }

            _protocolBuffer.FitCapacity();
        } while (true);

        do {
            auto content = _protocolBuffer.ReadOneProtocol();
            auto parser = std::make_shared<ProtocolParser>();
            parser->Parse(content);
            _protocolBuffer.Reset();
            asio::post(ioc, [this, parser, &server]() {
                std::string result = Handle(server, parser);

                if (!result.empty()) {
                    Send(result);
                }
            });
        } while (_protocolBuffer.CanReadOneProtocol());
    }
endLoop:
    return 0;
}

void StandardIOSession::Send(std::string_view content) {
    StandardIO::GetInstance().Write(content);