diff options
Diffstat (limited to 'OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs')
-rw-r--r-- | OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs b/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs index 810da2f..2deb2d1 100644 --- a/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs +++ b/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs | |||
@@ -135,8 +135,7 @@ namespace OpenSim.Services.Connectors | |||
135 | 135 | ||
136 | for (int i = 0 ; i < 2 ; i++) | 136 | for (int i = 0 ; i < 2 ; i++) |
137 | { | 137 | { |
138 | m_fetchThreads[i] = new Thread(AssetRequestProcessor); | 138 | Util.FireAndForget(delegate { AssetRequestProcessor();}); |
139 | m_fetchThreads[i].Start(); | ||
140 | } | 139 | } |
141 | } | 140 | } |
142 | 141 | ||
@@ -349,8 +348,8 @@ namespace OpenSim.Services.Connectors | |||
349 | public string id; | 348 | public string id; |
350 | } | 349 | } |
351 | 350 | ||
352 | private OpenMetaverse.BlockingQueue<QueuedAssetRequest> m_requestQueue = | 351 | private OpenSim.Framework.BlockingQueue<QueuedAssetRequest> m_requestQueue = |
353 | new OpenMetaverse.BlockingQueue<QueuedAssetRequest>(); | 352 | new OpenSim.Framework.BlockingQueue<QueuedAssetRequest>(); |
354 | 353 | ||
355 | private void AssetRequestProcessor() | 354 | private void AssetRequestProcessor() |
356 | { | 355 | { |
@@ -358,8 +357,9 @@ namespace OpenSim.Services.Connectors | |||
358 | 357 | ||
359 | while (true) | 358 | while (true) |
360 | { | 359 | { |
361 | r = m_requestQueue.Dequeue(); | 360 | r = m_requestQueue.Dequeue(2000); |
362 | 361 | if(r== null) | |
362 | continue; | ||
363 | string uri = r.uri; | 363 | string uri = r.uri; |
364 | string id = r.id; | 364 | string id = r.id; |
365 | 365 | ||