diff options
Diffstat (limited to 'OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs')
-rw-r--r-- | OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs index 7628e23..c2254c4 100644 --- a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs +++ b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs | |||
@@ -203,14 +203,17 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
203 | m_server = pSrv; | 203 | m_server = pSrv; |
204 | m_WorkerThreadCount = pWorkerThreadCount; | 204 | m_WorkerThreadCount = pWorkerThreadCount; |
205 | m_workerThreads = new Thread[m_WorkerThreadCount]; | 205 | m_workerThreads = new Thread[m_WorkerThreadCount]; |
206 | } | ||
206 | 207 | ||
208 | public void Start() | ||
209 | { | ||
207 | //startup worker threads | 210 | //startup worker threads |
208 | for (uint i = 0; i < m_WorkerThreadCount; i++) | 211 | for (uint i = 0; i < m_WorkerThreadCount; i++) |
209 | { | 212 | { |
210 | m_workerThreads[i] | 213 | m_workerThreads[i] |
211 | = Watchdog.StartThread( | 214 | = Watchdog.StartThread( |
212 | PoolWorkerJob, | 215 | PoolWorkerJob, |
213 | String.Format("PollServiceWorkerThread{0}", i), | 216 | string.Format("PollServiceWorkerThread{0}:{1}", i, m_server.Port), |
214 | ThreadPriority.Normal, | 217 | ThreadPriority.Normal, |
215 | false, | 218 | false, |
216 | false, | 219 | false, |
@@ -220,7 +223,7 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
220 | 223 | ||
221 | m_retrysThread = Watchdog.StartThread( | 224 | m_retrysThread = Watchdog.StartThread( |
222 | this.CheckRetries, | 225 | this.CheckRetries, |
223 | "PollServiceWatcherThread", | 226 | string.Format("PollServiceWatcherThread:{0}", m_server.Port), |
224 | ThreadPriority.Normal, | 227 | ThreadPriority.Normal, |
225 | false, | 228 | false, |
226 | true, | 229 | true, |
@@ -228,7 +231,6 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
228 | 1000 * 60 * 10); | 231 | 1000 * 60 * 10); |
229 | } | 232 | } |
230 | 233 | ||
231 | |||
232 | private void ReQueueEvent(PollServiceHttpRequest req) | 234 | private void ReQueueEvent(PollServiceHttpRequest req) |
233 | { | 235 | { |
234 | if (m_running) | 236 | if (m_running) |
@@ -279,14 +281,14 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
279 | } | 281 | } |
280 | } | 282 | } |
281 | 283 | ||
282 | ~PollServiceRequestManager() | 284 | public void Stop() |
283 | { | 285 | { |
284 | m_running = false; | 286 | m_running = false; |
285 | // m_timeout = -10000; // cause all to expire | 287 | // m_timeout = -10000; // cause all to expire |
286 | Thread.Sleep(1000); // let the world move | 288 | Thread.Sleep(1000); // let the world move |
287 | 289 | ||
288 | foreach (Thread t in m_workerThreads) | 290 | foreach (Thread t in m_workerThreads) |
289 | Watchdog.AbortThread(t.ManagedThreadId); | 291 | Watchdog.AbortThread(t.ManagedThreadId); |
290 | 292 | ||
291 | try | 293 | try |
292 | { | 294 | { |