diff options
* some more refactoring + bugfix
Diffstat (limited to 'OpenSim/Framework/Communications/Cache/SQLAssetServer.cs')
-rw-r--r-- | OpenSim/Framework/Communications/Cache/SQLAssetServer.cs | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/OpenSim/Framework/Communications/Cache/SQLAssetServer.cs b/OpenSim/Framework/Communications/Cache/SQLAssetServer.cs index cf54b81..379d609 100644 --- a/OpenSim/Framework/Communications/Cache/SQLAssetServer.cs +++ b/OpenSim/Framework/Communications/Cache/SQLAssetServer.cs | |||
@@ -44,11 +44,6 @@ namespace OpenSim.Framework.Communications.Cache | |||
44 | { | 44 | { |
45 | _assetRequests = new BlockingQueue<ARequest>(); | 45 | _assetRequests = new BlockingQueue<ARequest>(); |
46 | AddPlugin(pluginName); | 46 | AddPlugin(pluginName); |
47 | |||
48 | this._localAssetServerThread = new Thread(new ThreadStart(RunRequests)); | ||
49 | this._localAssetServerThread.IsBackground = true; | ||
50 | this._localAssetServerThread.Start(); | ||
51 | |||
52 | } | 47 | } |
53 | 48 | ||
54 | public SQLAssetServer(IAssetProvider assetProvider) | 49 | public SQLAssetServer(IAssetProvider assetProvider) |
@@ -86,12 +81,13 @@ namespace OpenSim.Framework.Communications.Cache | |||
86 | 81 | ||
87 | public override void Close() | 82 | public override void Close() |
88 | { | 83 | { |
84 | base.Close(); | ||
85 | |||
89 | m_assetProviderPlugin.CommitAssets(); | 86 | m_assetProviderPlugin.CommitAssets(); |
90 | } | 87 | } |
91 | 88 | ||
92 | private void RunRequests() | 89 | override protected void RunRequests() |
93 | { | 90 | { |
94 | |||
95 | while (true) | 91 | while (true) |
96 | { | 92 | { |
97 | ARequest req = this._assetRequests.Dequeue(); | 93 | ARequest req = this._assetRequests.Dequeue(); |