aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs
diff options
context:
space:
mode:
Diffstat (limited to 'OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs')
-rw-r--r--OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs12
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