aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/Environment/Modules/TextureDownloadModule.cs
diff options
context:
space:
mode:
Diffstat (limited to 'OpenSim/Region/Environment/Modules/TextureDownloadModule.cs')
-rw-r--r--OpenSim/Region/Environment/Modules/TextureDownloadModule.cs218
1 files changed, 0 insertions, 218 deletions
diff --git a/OpenSim/Region/Environment/Modules/TextureDownloadModule.cs b/OpenSim/Region/Environment/Modules/TextureDownloadModule.cs
deleted file mode 100644
index bde0dc0..0000000
--- a/OpenSim/Region/Environment/Modules/TextureDownloadModule.cs
+++ /dev/null
@@ -1,218 +0,0 @@
1/*
2 * Copyright (c) Contributors, http://opensimulator.org/
3 * See CONTRIBUTORS.TXT for a full list of copyright holders.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 * * Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer.
9 * * Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution.
12 * * Neither the name of the OpenSim Project nor the
13 * names of its contributors may be used to endorse or promote products
14 * derived from this software without specific prior written permission.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27
28using System;
29using System.Collections.Generic;
30using System.Threading;
31using libsecondlife;
32using Nini.Config;
33using OpenSim.Framework;
34using OpenSim.Region.Environment.Interfaces;
35using OpenSim.Region.Environment.Scenes;
36
37namespace OpenSim.Region.Environment.Modules
38{
39 //this is a first attempt, to start breaking the mess thats called the assetcache up.
40 // basically this should be the texture sending (to clients) code moved out of assetcache
41 //and some small clean up
42 public class TextureDownloadModule : IRegionModule
43 {
44 //private static readonly log4net.ILog m_log
45 // = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
46
47 private Scene m_scene;
48 private List<Scene> m_scenes = new List<Scene>();
49
50 /// <summary>
51 /// There is one queue for all textures waiting to be sent, regardless of the requesting user.
52 /// </summary>
53 private readonly BlockingQueue<ITextureSender> m_queueSenders
54 = new BlockingQueue<ITextureSender>();
55
56 /// <summary>
57 /// Each user has their own texture download service.
58 /// </summary>
59 private readonly Dictionary<LLUUID, UserTextureDownloadService> m_userTextureServices =
60 new Dictionary<LLUUID, UserTextureDownloadService>();
61
62 private Thread m_thread;
63
64 public TextureDownloadModule()
65 {
66 }
67
68 public void Initialise(Scene scene, IConfigSource config)
69 {
70 if (m_scene == null)
71 {
72 //Console.WriteLine("Creating Texture download module");
73 m_thread = new Thread(new ThreadStart(ProcessTextureSenders));
74 m_thread.Name = "ProcessTextureSenderThread";
75 m_thread.IsBackground = true;
76 m_thread.Start();
77 ThreadTracker.Add(m_thread);
78 }
79
80 if (!m_scenes.Contains(scene))
81 {
82 m_scenes.Add(scene);
83 m_scene = scene;
84 m_scene.EventManager.OnNewClient += NewClient;
85 m_scene.EventManager.OnRemovePresence += EventManager_OnRemovePresence;
86 }
87 }
88
89 /// <summary>
90 /// Cleanup the texture service related objects for the removed presence.
91 /// </summary>
92 /// <param name="agentId"> </param>
93 private void EventManager_OnRemovePresence(LLUUID agentId)
94 {
95 UserTextureDownloadService textureService;
96
97 lock (m_userTextureServices)
98 {
99 if (m_userTextureServices.TryGetValue(agentId, out textureService))
100 {
101 textureService.Close();
102
103 m_userTextureServices.Remove(agentId);
104 }
105 }
106 }
107
108 public void PostInitialise()
109 {
110 }
111
112 public void Close()
113 {
114 }
115
116 public string Name
117 {
118 get { return "TextureDownloadModule"; }
119 }
120
121 public bool IsSharedModule
122 {
123 get { return false; }
124 }
125
126 public void NewClient(IClientAPI client)
127 {
128 client.OnRequestTexture += TextureRequest;
129 }
130
131 /// <summary>
132 /// Does this user have a registered texture download service?
133 /// </summary>
134 /// <param name="userID"></param>
135 /// <param name="textureService"></param>
136 /// <returns>Always returns true, since a service is created if one does not already exist</returns>
137 private bool TryGetUserTextureService(
138 IClientAPI client, out UserTextureDownloadService textureService)
139 {
140 lock (m_userTextureServices)
141 {
142 if (m_userTextureServices.TryGetValue(client.AgentId, out textureService))
143 {
144 return true;
145 }
146
147 textureService = new UserTextureDownloadService(client, m_scene, m_queueSenders);
148 m_userTextureServices.Add(client.AgentId, textureService);
149
150 return true;
151 }
152 }
153
154 /// <summary>
155 /// Start the process of requesting a given texture.
156 /// </summary>
157 /// <param name="sender"> </param>
158 /// <param name="e"></param>
159 public void TextureRequest(Object sender, TextureRequestArgs e)
160 {
161 IClientAPI client = (IClientAPI) sender;
162 UserTextureDownloadService textureService;
163
164 if (TryGetUserTextureService(client, out textureService))
165 {
166 textureService.HandleTextureRequest(e);
167 }
168 }
169
170 /// <summary>
171 /// Entry point for the thread dedicated to processing the texture queue.
172 /// </summary>
173 public void ProcessTextureSenders()
174 {
175 ITextureSender sender = null;
176
177 while (true)
178 {
179 sender = m_queueSenders.Dequeue();
180
181 if (sender.Cancel)
182 {
183 TextureSent(sender);
184
185 sender.Cancel = false;
186 }
187 else
188 {
189 bool finished = sender.SendTexturePacket();
190 if (finished)
191 {
192 TextureSent(sender);
193 }
194 else
195 {
196 m_queueSenders.Enqueue(sender);
197 }
198 }
199
200 // Make sure that any sender we currently have can get garbage collected
201 sender = null;
202
203 //m_log.InfoFormat("[TEXTURE DOWNLOAD] Texture sender queue size: {0}", m_queueSenders.Count());
204 }
205 }
206
207 /// <summary>
208 /// Called when the texture has finished sending.
209 /// </summary>
210 /// <param name="sender"></param>
211 private void TextureSent(ITextureSender sender)
212 {
213 sender.Sending = false;
214 //m_log.DebugFormat("[TEXTURE DOWNLOAD]: Removing download stat for {0}", sender.assetID);
215 m_scene.AddPendingDownloads(-1);
216 }
217 }
218}
generated by cgit v1.1 at 2024-11-17 14:29:13 +0000