aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs
diff options
context:
space:
mode:
authorTeravus Ovares2008-09-27 23:54:08 +0000
committerTeravus Ovares2008-09-27 23:54:08 +0000
commit4f0c759fb0efb16c658522bf573c72f61a6067ec (patch)
tree82779eb058419100421c65d795deaad73feb583a /OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs
parent* Adds flag to enable/disable EventQueueGet. (diff)
downloadopensim-SC-4f0c759fb0efb16c658522bf573c72f61a6067ec.zip
opensim-SC-4f0c759fb0efb16c658522bf573c72f61a6067ec.tar.gz
opensim-SC-4f0c759fb0efb16c658522bf573c72f61a6067ec.tar.bz2
opensim-SC-4f0c759fb0efb16c658522bf573c72f61a6067ec.tar.xz
* With EventQueueGet enabled.. we can see into neighbor regions again on the Security 'fixed' client.. But don't try to cross yet!
Diffstat (limited to 'OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs')
-rw-r--r--OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs20
1 files changed, 10 insertions, 10 deletions
diff --git a/OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs b/OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs
index 14574e0..f77a7c0 100644
--- a/OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs
+++ b/OpenSim/Region/Environment/Modules/Framework/EventQueueGetModule.cs
@@ -126,7 +126,7 @@ namespace OpenSim.Region.Environment.Modules.Framework
126 { 126 {
127 if (!queues.ContainsKey(agentId)) 127 if (!queues.ContainsKey(agentId))
128 { 128 {
129 m_log.DebugFormat("[EVENTQUEUE]: Adding new queue for agent {0}", agentId); 129 m_log.DebugFormat("[EVENTQUEUE]: Adding new queue for agent {0} in region {1}", agentId, m_scene.RegionInfo.RegionName);
130 queues[agentId] = new BlockingLLSDQueue(); 130 queues[agentId] = new BlockingLLSDQueue();
131 } 131 }
132 return queues[agentId]; 132 return queues[agentId];
@@ -136,7 +136,7 @@ namespace OpenSim.Region.Environment.Modules.Framework
136 #region IEventQueue Members 136 #region IEventQueue Members
137 public bool Enqueue(LLSD ev, UUID avatarID) 137 public bool Enqueue(LLSD ev, UUID avatarID)
138 { 138 {
139 m_log.DebugFormat("[EVENTQUEUE]: Enqueuing event for {0}", avatarID); 139 m_log.DebugFormat("[EVENTQUEUE]: Enqueuing event for {0} in region {1}", avatarID, m_scene.RegionInfo.RegionName);
140 BlockingLLSDQueue queue = GetQueue(avatarID); 140 BlockingLLSDQueue queue = GetQueue(avatarID);
141 queue.Enqueue(ev); 141 queue.Enqueue(ev);
142 return true; 142 return true;
@@ -145,7 +145,7 @@ namespace OpenSim.Region.Environment.Modules.Framework
145 145
146 private void OnNewClient(IClientAPI client) 146 private void OnNewClient(IClientAPI client)
147 { 147 {
148 m_log.DebugFormat("[EVENTQUEUE]: New client {0} detected.", client.AgentId); 148 m_log.DebugFormat("[EVENTQUEUE]: New client {0} detected in region {1}", client.AgentId, m_scene.RegionInfo.RegionName);
149 client.OnLogout += ClientClosed; 149 client.OnLogout += ClientClosed;
150 } 150 }
151 151
@@ -158,13 +158,13 @@ namespace OpenSim.Region.Environment.Modules.Framework
158 private void ClientClosed(UUID AgentID) 158 private void ClientClosed(UUID AgentID)
159 { 159 {
160 queues.Remove(AgentID); 160 queues.Remove(AgentID);
161 m_log.DebugFormat("[EVENTQUEUE]: Client {0} deregistered.", AgentID); 161 m_log.DebugFormat("[EVENTQUEUE]: Client {0} deregistered in region {1}.", AgentID, m_scene.RegionInfo.RegionName);
162 } 162 }
163 163
164 private void AvatarEnteringParcel(ScenePresence avatar, int localLandID, UUID regionID) 164 private void AvatarEnteringParcel(ScenePresence avatar, int localLandID, UUID regionID)
165 { 165 {
166 m_log.DebugFormat("[EVENTQUEUE]: Avatar {0} entering parcel {1} in region {2}.", 166 m_log.DebugFormat("[EVENTQUEUE]: Avatar {0} entering parcel {1} in region {2}.",
167 avatar.UUID, localLandID, regionID); 167 avatar.UUID, localLandID, m_scene.RegionInfo.RegionName);
168 168
169 } 169 }
170 170
@@ -175,7 +175,7 @@ namespace OpenSim.Region.Environment.Modules.Framework
175 175
176 public void OnRegisterCaps(UUID agentID, Caps caps) 176 public void OnRegisterCaps(UUID agentID, Caps caps)
177 { 177 {
178 m_log.DebugFormat("[EVENTQUEUE] OnRegisterCaps: agentID {0} caps {1}", agentID, caps); 178 m_log.DebugFormat("[EVENTQUEUE] OnRegisterCaps: agentID {0} caps {1} region", agentID, caps, m_scene.RegionInfo.RegionName);
179 string capsBase = "/CAPS/"; 179 string capsBase = "/CAPS/";
180 caps.RegisterHandler("EventQueueGet", 180 caps.RegisterHandler("EventQueueGet",
181 new RestHTTPHandler("POST", capsBase + UUID.Random().ToString(), 181 new RestHTTPHandler("POST", capsBase + UUID.Random().ToString(),
@@ -203,12 +203,12 @@ namespace OpenSim.Region.Environment.Modules.Framework
203 LLSD element = queue.Dequeue(15000); // 15s timeout 203 LLSD element = queue.Dequeue(15000); // 15s timeout
204 204
205 205
206 String debug = "[EVENTQUEUE]: Got request for agent {0}: [ "; 206 String debug = "[EVENTQUEUE]: Got request for agent {0} in region {1}: [ ";
207 foreach(object key in request.Keys) 207 foreach(object key in request.Keys)
208 { 208 {
209 debug += key.ToString() + "=" + request[key].ToString() + " "; 209 debug += key.ToString() + "=" + request[key].ToString() + " ";
210 } 210 }
211 //m_log.DebugFormat(debug, agentID); 211 m_log.DebugFormat(debug, agentID, m_scene.RegionInfo.RegionName);
212 212
213 if (element == null) // didn't have an event in 15s 213 if (element == null) // didn't have an event in 15s
214 { 214 {
@@ -239,7 +239,7 @@ namespace OpenSim.Region.Environment.Modules.Framework
239 responsedata["content_type"] = "application/llsd+xml"; 239 responsedata["content_type"] = "application/llsd+xml";
240 responsedata["keepalive"] = true; 240 responsedata["keepalive"] = true;
241 responsedata["str_response_string"] = LLSDParser.SerializeXmlString(events); 241 responsedata["str_response_string"] = LLSDParser.SerializeXmlString(events);
242 //m_log.DebugFormat("[EVENTQUEUE]: sending fake response for {0}: {1}", agentID, responsedata["str_response_string"]); 242 m_log.DebugFormat("[EVENTQUEUE]: sending fake response for {0} in region{1}: {2}", agentID, m_scene.RegionInfo.RegionName, responsedata["str_response_string"]);
243 243
244 return responsedata; 244 return responsedata;
245 } 245 }
@@ -269,7 +269,7 @@ namespace OpenSim.Region.Environment.Modules.Framework
269 responsedata["content_type"] = "application/llsd+xml"; 269 responsedata["content_type"] = "application/llsd+xml";
270 responsedata["keepalive"] = true; 270 responsedata["keepalive"] = true;
271 responsedata["str_response_string"] = LLSDParser.SerializeXmlString(events); 271 responsedata["str_response_string"] = LLSDParser.SerializeXmlString(events);
272 m_log.DebugFormat("[EVENTQUEUE]: sending response for {0}: {1}", agentID, responsedata["str_response_string"]); 272 m_log.DebugFormat("[EVENTQUEUE]: sending fake response for {0} in region{1}: {2}", agentID, m_scene.RegionInfo.RegionName, responsedata["str_response_string"]);
273 273
274 return responsedata; 274 return responsedata;
275 } 275 }