Function New

engine/script/src/http_service.cpp:485–528

    }

    HHttpService New(const Params* params)
    {
        HttpService* service = new HttpService;

        service->m_HttpCache = params->m_HttpCache;

        int threadcount = params->m_ThreadCount;
#if defined(__NX__)
        if (threadcount > 2)
            threadcount = 2;
#endif

        service->m_Run = true;
        dmMessage::NewSocket(HTTP_SOCKET_NAME, &service->m_Socket);
        service->m_Workers.SetCapacity(threadcount);
        for (uint32_t i = 0; i < threadcount; ++i)
        {
            Worker* worker = new Worker();
            char tmp[128];
            dmSnPrintf(tmp, sizeof(tmp), "@__http_worker_%d", i);
            dmMessage::NewSocket(tmp, &worker->m_Socket);
            worker->m_Client = 0;
            memset(&worker->m_CurrentURL, 0, sizeof(worker->m_CurrentURL));
            memset(&worker->m_CurrentProxyURL, 0, sizeof(worker->m_CurrentProxyURL));
            worker->m_Request = 0;
            worker->m_Status = 0;
            worker->m_Service = service;
            worker->m_CacheFlusher = i == 0 && worker->m_Service->m_HttpCache != 0;
            worker->m_Run = true;
            worker->m_Canceled = 0;
            worker->m_ReportProgress = false;
            service->m_Workers.Push(worker);

            dmThread::Thread t = dmThread::New(&Loop, THREAD_STACK_SIZE, worker, "http");
            worker->m_Thread = t;
        }

        dmThread::Thread t = dmThread::New(&LoadBalancer, THREAD_STACK_SIZE, service, "http_balance");
        service->m_Balancer = t;

        service->m_ReportProgressCallback = params->m_ReportProgressCallback;

        return service;
    }

    dmMessage::HSocket GetSocket(HHttpService http_service)
    {