Function CreateServices

library/cpp/neh/http_ut.cpp:59–91

Creates service for serving request. @return ptr to IServices, port and error if occured. Tests failes if server could not be created. */

        @return ptr to IServices, port and error if occured. Tests failes if server could not be created.
     */
    TServ CreateServices(const TServiceFunction& f =
        [](const IRequestRef& req) {
            TDataSaver responseData;
            Sleep(TDuration::MilliSeconds(FromString<int>(req->Data())));
            responseData << req->Data();
            auto* httpReq = dynamic_cast<IHttpRequest*>(req.Get());
            TString headers = "\r\nContent-Type: text/plain";
            httpReq->SendReply(responseData, headers);
        }
    ) {
        TServ serv;
        TString err;

        //in loop try run service (bind port)
        for (ui16 basePort = 20000; basePort < 40000; basePort += 100) {
            serv.Services = CreateLoop();
            try {
                serv.ServerPort = basePort;
                TStringStream addr;
                addr << "http://localhost:" << serv.ServerPort << "/pipeline";

                serv.Services->Add(addr.Str(), f);
                serv.Services->ForkLoop(16); //<< throw exception, if can not bind port
                break;
            } catch (...) {
                serv.Services.Destroy();
                err = CurrentExceptionMessage();
            }
        }

        UNIT_ASSERT_C(serv.Services.Get(), err.data());
        return serv;
    }

    TString Request(SOCKET s, const TString& request) {
        const ssize_t nSend = send(s, request.data(), request.size(), 0);