Changeset 26397 in vbox for trunk/src/VBox/Main

Timestamp:

Feb 9, 2010 6:44:52 PM (15 years ago)

Author:

vboxsync

Message:

Web service: error handling, consistency

File:

• trunk/src/VBox/Main/webservice/vboxweb.cpp (modified) (8 diffs)

trunk/src/VBox/Main/webservice/vboxweb.cpp

@@ -102 +102 @@
 unsigned int            g_uBindToPort = 18083;          // port
 unsigned int            g_uBacklog = 100;               // backlog = max queue size for requests
+unsigned int            g_cWorkerThreads = 10;          // no. of worker threads
 
 bool                    g_fVerbose = false;             // be verbose
@@ -283 +284 @@
             pst->pQ = this;
             pst->soap = soap_copy(pSoap);
-            RTThreadCreate(&pst->pThread,
-                           fntSoapQueue,
-                           pst,             // pvUser
-                           0,               // cbStack,
-                           RTTHREADTYPE_MAIN_HEAVY_WORKER,
-                           0,
-                           "SoapQWorker");
+            if (!RT_SUCCESS(RTThreadCreate(&pst->pThread,
+                                           fntSoapQueue,
+                                           pst,             // pvUser
+                                           0,               // cbStack,
+                                           RTTHREADTYPE_MAIN_HEAVY_WORKER,
+                                           0,
+                                           "SoapQWorker")))
+            {
+                RTStrmPrintf(g_pStdErr, "[!] Cannot start worker thread %d\n", pst->u);
+                exit(1);
+            }
+
             m_llAllThreads.push_back(pst);
             ++m_cIdleThreads;
@@ -397 +403 @@
         pst->soap->socket = pst->pQ->get();
 
-        WebLog("T%d handles connection from IP=%lu.%lu.%lu.%lu socket=%d (%d thr idle)\n",
+        WebLog("T%d handles connection from IP=%lu.%lu.%lu.%lu socket=%d (%d threads idle)\n",
                 pst->u,
                 (pst->soap->ip>>24)&0xFF,
@@ -424 +430 @@
  * worker threads.
  */
-void beginProcessing(size_t cThreads)
+void beginProcessing()
 {
     // set up gSOAP
@@ -448 +454 @@
 
         // initialize thread queue, mutex and eventsem, create worker threads
-        SoapQ soapq(cThreads, &soap);
+        SoapQ soapq(g_cWorkerThreads, &soap);
 
         for (uint64_t i = 1;
@@ -487 +493 @@
 {
     int rc;
-
-    uint32_t cWorkerThreads = 5;
 
     // intialize runtime
@@ -536 +540 @@
 
             case 'T':
-                cWorkerThreads = ValueUnion.u32;
+                g_cWorkerThreads = ValueUnion.u32;
             break;
 
@@ -643 +647 @@
     }
 
-    beginProcessing(cWorkerThreads);
+    beginProcessing();
 
     com::Shutdown();