aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs
diff options
context:
space:
mode:
authorJeff Ames2007-11-04 14:34:45 +0000
committerJeff Ames2007-11-04 14:34:45 +0000
commit2d1c255e8c427c8c595be455e6d7f5c4e01c99a6 (patch)
treea95f2a5085505192293603f8b0c9df23c4ac7041 /OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs
parentApplying Teravus patch # 557. Some glue code for the updating of prim's veloc... (diff)
downloadopensim-SC_OLD-2d1c255e8c427c8c595be455e6d7f5c4e01c99a6.zip
opensim-SC_OLD-2d1c255e8c427c8c595be455e6d7f5c4e01c99a6.tar.gz
opensim-SC_OLD-2d1c255e8c427c8c595be455e6d7f5c4e01c99a6.tar.bz2
opensim-SC_OLD-2d1c255e8c427c8c595be455e6d7f5c4e01c99a6.tar.xz
normalized line endings
Diffstat (limited to '')
-rw-r--r--OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs424
1 files changed, 212 insertions, 212 deletions
diff --git a/OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs b/OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs
index 2ade989..e67d413 100644
--- a/OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs
+++ b/OpenSim/Region/Environment/Scenes/SceneCommunicationService.cs
@@ -1,212 +1,212 @@
1using System; 1using System;
2using System.Collections.Generic; 2using System.Collections.Generic;
3using System.Net; 3using System.Net;
4using System.Text; 4using System.Text;
5using libsecondlife; 5using libsecondlife;
6using OpenSim.Framework; 6using OpenSim.Framework;
7using OpenSim.Framework.Console; 7using OpenSim.Framework.Console;
8using OpenSim.Framework.Communications; 8using OpenSim.Framework.Communications;
9 9
10 10
11namespace OpenSim.Region.Environment.Scenes 11namespace OpenSim.Region.Environment.Scenes
12{ 12{
13 public class SceneCommunicationService //one instance per region 13 public class SceneCommunicationService //one instance per region
14 { 14 {
15 protected CommunicationsManager m_commsProvider; 15 protected CommunicationsManager m_commsProvider;
16 protected RegionInfo m_regionInfo; 16 protected RegionInfo m_regionInfo;
17 17
18 protected RegionCommsListener regionCommsHost; 18 protected RegionCommsListener regionCommsHost;
19 19
20 public event AgentCrossing OnAvatarCrossingIntoRegion; 20 public event AgentCrossing OnAvatarCrossingIntoRegion;
21 public event ExpectUserDelegate OnExpectUser; 21 public event ExpectUserDelegate OnExpectUser;
22 22
23 23
24 public SceneCommunicationService(CommunicationsManager commsMan) 24 public SceneCommunicationService(CommunicationsManager commsMan)
25 { 25 {
26 m_commsProvider = commsMan; 26 m_commsProvider = commsMan;
27 } 27 }
28 28
29 public void RegisterRegion(RegionInfo regionInfos) 29 public void RegisterRegion(RegionInfo regionInfos)
30 { 30 {
31 m_regionInfo = regionInfos; 31 m_regionInfo = regionInfos;
32 regionCommsHost = m_commsProvider.GridService.RegisterRegion(m_regionInfo); 32 regionCommsHost = m_commsProvider.GridService.RegisterRegion(m_regionInfo);
33 if (regionCommsHost != null) 33 if (regionCommsHost != null)
34 { 34 {
35 regionCommsHost.OnExpectUser += NewUserConnection; 35 regionCommsHost.OnExpectUser += NewUserConnection;
36 regionCommsHost.OnAvatarCrossingIntoRegion += AgentCrossing; 36 regionCommsHost.OnAvatarCrossingIntoRegion += AgentCrossing;
37 } 37 }
38 } 38 }
39 39
40 public void Close() 40 public void Close()
41 { 41 {
42 regionCommsHost.OnExpectUser -= NewUserConnection; 42 regionCommsHost.OnExpectUser -= NewUserConnection;
43 regionCommsHost.OnAvatarCrossingIntoRegion -= AgentCrossing; 43 regionCommsHost.OnAvatarCrossingIntoRegion -= AgentCrossing;
44 //regionCommsHost.RemoveRegion(m_regionInfo); //TODO add to method to commsManager 44 //regionCommsHost.RemoveRegion(m_regionInfo); //TODO add to method to commsManager
45 regionCommsHost = null; 45 regionCommsHost = null;
46 } 46 }
47 47
48 #region CommsManager Event handlers 48 #region CommsManager Event handlers
49 /// <summary> 49 /// <summary>
50 /// 50 ///
51 /// </summary> 51 /// </summary>
52 /// <param name="regionHandle"></param> 52 /// <param name="regionHandle"></param>
53 /// <param name="agent"></param> 53 /// <param name="agent"></param>
54 public void NewUserConnection(ulong regionHandle, AgentCircuitData agent) 54 public void NewUserConnection(ulong regionHandle, AgentCircuitData agent)
55 { 55 {
56 if (OnExpectUser != null) 56 if (OnExpectUser != null)
57 { 57 {
58 OnExpectUser(regionHandle, agent); 58 OnExpectUser(regionHandle, agent);
59 } 59 }
60 } 60 }
61 61
62 public void AgentCrossing(ulong regionHandle, LLUUID agentID, LLVector3 position, bool isFlying) 62 public void AgentCrossing(ulong regionHandle, LLUUID agentID, LLVector3 position, bool isFlying)
63 { 63 {
64 if (OnAvatarCrossingIntoRegion != null) 64 if (OnAvatarCrossingIntoRegion != null)
65 { 65 {
66 OnAvatarCrossingIntoRegion(regionHandle, agentID, position, isFlying); 66 OnAvatarCrossingIntoRegion(regionHandle, agentID, position, isFlying);
67 } 67 }
68 } 68 }
69 #endregion 69 #endregion
70 70
71 #region Inform Client of Neighbours 71 #region Inform Client of Neighbours
72 private delegate void InformClientOfNeighbourDelegate( 72 private delegate void InformClientOfNeighbourDelegate(
73 ScenePresence avatar, AgentCircuitData a, ulong regionHandle, IPEndPoint endPoint); 73 ScenePresence avatar, AgentCircuitData a, ulong regionHandle, IPEndPoint endPoint);
74 74
75 private void InformClientOfNeighbourCompleted(IAsyncResult iar) 75 private void InformClientOfNeighbourCompleted(IAsyncResult iar)
76 { 76 {
77 InformClientOfNeighbourDelegate icon = (InformClientOfNeighbourDelegate)iar.AsyncState; 77 InformClientOfNeighbourDelegate icon = (InformClientOfNeighbourDelegate)iar.AsyncState;
78 icon.EndInvoke(iar); 78 icon.EndInvoke(iar);
79 } 79 }
80 80
81 /// <summary> 81 /// <summary>
82 /// Async compnent for informing client of which neighbours exists 82 /// Async compnent for informing client of which neighbours exists
83 /// </summary> 83 /// </summary>
84 /// <remarks> 84 /// <remarks>
85 /// This needs to run asynchronesously, as a network timeout may block the thread for a long while 85 /// This needs to run asynchronesously, as a network timeout may block the thread for a long while
86 /// </remarks> 86 /// </remarks>
87 /// <param name="remoteClient"></param> 87 /// <param name="remoteClient"></param>
88 /// <param name="a"></param> 88 /// <param name="a"></param>
89 /// <param name="regionHandle"></param> 89 /// <param name="regionHandle"></param>
90 /// <param name="endPoint"></param> 90 /// <param name="endPoint"></param>
91 private void InformClientOfNeighbourAsync(ScenePresence avatar, AgentCircuitData a, ulong regionHandle, 91 private void InformClientOfNeighbourAsync(ScenePresence avatar, AgentCircuitData a, ulong regionHandle,
92 IPEndPoint endPoint) 92 IPEndPoint endPoint)
93 { 93 {
94 MainLog.Instance.Notice("INTERGRID", "Starting to inform client about neighbours"); 94 MainLog.Instance.Notice("INTERGRID", "Starting to inform client about neighbours");
95 bool regionAccepted = m_commsProvider.InterRegion.InformRegionOfChildAgent(regionHandle, a); 95 bool regionAccepted = m_commsProvider.InterRegion.InformRegionOfChildAgent(regionHandle, a);
96 96
97 if (regionAccepted) 97 if (regionAccepted)
98 { 98 {
99 avatar.ControllingClient.InformClientOfNeighbour(regionHandle, endPoint); 99 avatar.ControllingClient.InformClientOfNeighbour(regionHandle, endPoint);
100 avatar.AddNeighbourRegion(regionHandle); 100 avatar.AddNeighbourRegion(regionHandle);
101 MainLog.Instance.Notice("INTERGRID", "Completed inform client about neighbours"); 101 MainLog.Instance.Notice("INTERGRID", "Completed inform client about neighbours");
102 } 102 }
103 } 103 }
104 104
105 /// <summary> 105 /// <summary>
106 /// 106 ///
107 /// </summary> 107 /// </summary>
108 public void InformClientOfNeighbours(ScenePresence avatar) 108 public void InformClientOfNeighbours(ScenePresence avatar)
109 { 109 {
110 List<SimpleRegionInfo> neighbours = 110 List<SimpleRegionInfo> neighbours =
111 m_commsProvider.GridService.RequestNeighbours(m_regionInfo.RegionLocX, m_regionInfo.RegionLocY); 111 m_commsProvider.GridService.RequestNeighbours(m_regionInfo.RegionLocX, m_regionInfo.RegionLocY);
112 if (neighbours != null) 112 if (neighbours != null)
113 { 113 {
114 for (int i = 0; i < neighbours.Count; i++) 114 for (int i = 0; i < neighbours.Count; i++)
115 { 115 {
116 AgentCircuitData agent = avatar.ControllingClient.RequestClientInfo(); 116 AgentCircuitData agent = avatar.ControllingClient.RequestClientInfo();
117 agent.BaseFolder = LLUUID.Zero; 117 agent.BaseFolder = LLUUID.Zero;
118 agent.InventoryFolder = LLUUID.Zero; 118 agent.InventoryFolder = LLUUID.Zero;
119 agent.startpos = new LLVector3(128, 128, 70); 119 agent.startpos = new LLVector3(128, 128, 70);
120 agent.child = true; 120 agent.child = true;
121 121
122 InformClientOfNeighbourDelegate d = InformClientOfNeighbourAsync; 122 InformClientOfNeighbourDelegate d = InformClientOfNeighbourAsync;
123 d.BeginInvoke(avatar, agent, neighbours[i].RegionHandle, neighbours[i].ExternalEndPoint, 123 d.BeginInvoke(avatar, agent, neighbours[i].RegionHandle, neighbours[i].ExternalEndPoint,
124 InformClientOfNeighbourCompleted, 124 InformClientOfNeighbourCompleted,
125 d); 125 d);
126 } 126 }
127 } 127 }
128 } 128 }
129 #endregion 129 #endregion
130 130
131 /// <summary> 131 /// <summary>
132 /// 132 ///
133 /// </summary> 133 /// </summary>
134 /// <param name="regionHandle"></param> 134 /// <param name="regionHandle"></param>
135 /// <returns></returns> 135 /// <returns></returns>
136 public virtual RegionInfo RequestNeighbouringRegionInfo(ulong regionHandle) 136 public virtual RegionInfo RequestNeighbouringRegionInfo(ulong regionHandle)
137 { 137 {
138 return m_commsProvider.GridService.RequestNeighbourInfo(regionHandle); 138 return m_commsProvider.GridService.RequestNeighbourInfo(regionHandle);
139 } 139 }
140 140
141 /// <summary> 141 /// <summary>
142 /// 142 ///
143 /// </summary> 143 /// </summary>
144 /// <param name="minX"></param> 144 /// <param name="minX"></param>
145 /// <param name="minY"></param> 145 /// <param name="minY"></param>
146 /// <param name="maxX"></param> 146 /// <param name="maxX"></param>
147 /// <param name="maxY"></param> 147 /// <param name="maxY"></param>
148 public virtual void RequestMapBlocks(IClientAPI remoteClient, int minX, int minY, int maxX, int maxY) 148 public virtual void RequestMapBlocks(IClientAPI remoteClient, int minX, int minY, int maxX, int maxY)
149 { 149 {
150 List<MapBlockData> mapBlocks; 150 List<MapBlockData> mapBlocks;
151 mapBlocks = m_commsProvider.GridService.RequestNeighbourMapBlocks(minX, minY, maxX, maxY); 151 mapBlocks = m_commsProvider.GridService.RequestNeighbourMapBlocks(minX, minY, maxX, maxY);
152 remoteClient.SendMapBlock(mapBlocks); 152 remoteClient.SendMapBlock(mapBlocks);
153 } 153 }
154 154
155 /// <summary> 155 /// <summary>
156 /// 156 ///
157 /// </summary> 157 /// </summary>
158 /// <param name="remoteClient"></param> 158 /// <param name="remoteClient"></param>
159 /// <param name="RegionHandle"></param> 159 /// <param name="RegionHandle"></param>
160 /// <param name="position"></param> 160 /// <param name="position"></param>
161 /// <param name="lookAt"></param> 161 /// <param name="lookAt"></param>
162 /// <param name="flags"></param> 162 /// <param name="flags"></param>
163 public virtual void RequestTeleportLocation(ScenePresence avatar, ulong regionHandle, LLVector3 position, 163 public virtual void RequestTeleportLocation(ScenePresence avatar, ulong regionHandle, LLVector3 position,
164 LLVector3 lookAt, uint flags) 164 LLVector3 lookAt, uint flags)
165 { 165 {
166 if (regionHandle == m_regionInfo.RegionHandle) 166 if (regionHandle == m_regionInfo.RegionHandle)
167 { 167 {
168 168
169 avatar.ControllingClient.SendTeleportLocationStart(); 169 avatar.ControllingClient.SendTeleportLocationStart();
170 avatar.ControllingClient.SendLocalTeleport(position, lookAt, flags); 170 avatar.ControllingClient.SendLocalTeleport(position, lookAt, flags);
171 avatar.Teleport(position); 171 avatar.Teleport(position);
172 172
173 } 173 }
174 else 174 else
175 { 175 {
176 RegionInfo reg = RequestNeighbouringRegionInfo(regionHandle); 176 RegionInfo reg = RequestNeighbouringRegionInfo(regionHandle);
177 if (reg != null) 177 if (reg != null)
178 { 178 {
179 avatar.ControllingClient.SendTeleportLocationStart(); 179 avatar.ControllingClient.SendTeleportLocationStart();
180 AgentCircuitData agent = avatar.ControllingClient.RequestClientInfo(); 180 AgentCircuitData agent = avatar.ControllingClient.RequestClientInfo();
181 agent.BaseFolder = LLUUID.Zero; 181 agent.BaseFolder = LLUUID.Zero;
182 agent.InventoryFolder = LLUUID.Zero; 182 agent.InventoryFolder = LLUUID.Zero;
183 agent.startpos = position; 183 agent.startpos = position;
184 agent.child = true; 184 agent.child = true;
185 avatar.Close(); 185 avatar.Close();
186 m_commsProvider.InterRegion.InformRegionOfChildAgent(regionHandle, agent); 186 m_commsProvider.InterRegion.InformRegionOfChildAgent(regionHandle, agent);
187 m_commsProvider.InterRegion.ExpectAvatarCrossing(regionHandle, avatar.ControllingClient.AgentId, position, false); 187 m_commsProvider.InterRegion.ExpectAvatarCrossing(regionHandle, avatar.ControllingClient.AgentId, position, false);
188 AgentCircuitData circuitdata = avatar.ControllingClient.RequestClientInfo(); 188 AgentCircuitData circuitdata = avatar.ControllingClient.RequestClientInfo();
189 string capsPath = Util.GetCapsURL(avatar.ControllingClient.AgentId); 189 string capsPath = Util.GetCapsURL(avatar.ControllingClient.AgentId);
190 avatar.ControllingClient.SendRegionTeleport(regionHandle, 13, reg.ExternalEndPoint, 4, (1 << 4), capsPath); 190 avatar.ControllingClient.SendRegionTeleport(regionHandle, 13, reg.ExternalEndPoint, 4, (1 << 4), capsPath);
191 avatar.MakeChildAgent(); 191 avatar.MakeChildAgent();
192 } 192 }
193 } 193 }
194 } 194 }
195 195
196 /// <summary> 196 /// <summary>
197 /// 197 ///
198 /// </summary> 198 /// </summary>
199 /// <param name="regionhandle"></param> 199 /// <param name="regionhandle"></param>
200 /// <param name="agentID"></param> 200 /// <param name="agentID"></param>
201 /// <param name="position"></param> 201 /// <param name="position"></param>
202 public bool InformNeighbourOfCrossing(ulong regionhandle, LLUUID agentID, LLVector3 position, bool isFlying) 202 public bool InformNeighbourOfCrossing(ulong regionhandle, LLUUID agentID, LLVector3 position, bool isFlying)
203 { 203 {
204 return m_commsProvider.InterRegion.ExpectAvatarCrossing(regionhandle, agentID, position, isFlying); 204 return m_commsProvider.InterRegion.ExpectAvatarCrossing(regionhandle, agentID, position, isFlying);
205 } 205 }
206 206
207 public void CloseAgentConnection(ScenePresence presence) 207 public void CloseAgentConnection(ScenePresence presence)
208 { 208 {
209 throw new Exception("The method or operation is not implemented."); 209 throw new Exception("The method or operation is not implemented.");
210 } 210 }
211 } 211 }
212} 212}
generated by cgit v1.1 at 2024-07-20 01:08:47 +0000