From 74940c7b1dbd44dc236b6b1bf6a7d03ce8e6ea43 Mon Sep 17 00:00:00 2001 From: Jeff Ames Date: Tue, 26 Feb 2008 15:36:17 +0000 Subject: Update svn properties. --- .../Modules/VoiceChat/VoiceChatServer.cs | 686 ++++++++++----------- 1 file changed, 343 insertions(+), 343 deletions(-) (limited to 'OpenSim/Region/Environment/Modules/VoiceChat/VoiceChatServer.cs') diff --git a/OpenSim/Region/Environment/Modules/VoiceChat/VoiceChatServer.cs b/OpenSim/Region/Environment/Modules/VoiceChat/VoiceChatServer.cs index 68197bb..5ec0ca8 100644 --- a/OpenSim/Region/Environment/Modules/VoiceChat/VoiceChatServer.cs +++ b/OpenSim/Region/Environment/Modules/VoiceChat/VoiceChatServer.cs @@ -1,343 +1,343 @@ -using System; -using System.Collections.Generic; -using System.Text; -using System.Threading; -using System.Net.Sockets; -using System.Net; -using OpenSim.Region.Environment.Scenes; -using OpenSim.Framework; -using OpenSim.Region.Environment.Modules; -using OpenSim.Region.Environment.Interfaces; -using Nini; -using libsecondlife; - -namespace OpenSim.Region.Environment.Modules.VoiceChat -{ - public class VoiceChatServer : IRegionModule - { - private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); - - int m_dummySocketPort = 53134; - - Thread m_listenerThread; - Thread m_mainThread; - List m_scenes = new List(); - Socket m_server; - Socket m_selectCancel; - bool m_enabled = false; - - Dictionary m_clients = new Dictionary(); - Dictionary m_uuidToClient = new Dictionary(); - - - #region IRegionModule Members - - public void Initialise(Scene scene, Nini.Config.IConfigSource source) - { - try - { - m_enabled = source.Configs["Voice"].GetBoolean("enabled", m_enabled); - } - catch (Exception) - { } - - if (m_enabled) - { - if (!m_scenes.Contains(scene)) - m_scenes.Add(scene); - - scene.EventManager.OnNewClient += NewClient; - scene.EventManager.OnRemovePresence += RemovePresence; - } - } - - public void PostInitialise() - { - if (m_enabled != true) - return; - - try - { - CreateListeningSocket(); - } - catch (Exception) - { - m_log.Error("[VOICECHAT]: Unable to start listening"); - return; - } - - m_listenerThread = new Thread(new ThreadStart(ListenIncomingConnections)); - m_listenerThread.IsBackground = true; - m_listenerThread.Start(); - - m_mainThread = new Thread(new ThreadStart(RunVoiceChat)); - m_mainThread.IsBackground = true; - m_mainThread.Start(); - - Thread.Sleep(500); - m_selectCancel = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); - m_selectCancel.Connect("localhost", m_dummySocketPort); - } - - public void Close() - { - throw new NotImplementedException(); - } - - public string Name - { - get { return "VoiceChatModule"; } - } - - public bool IsSharedModule - { - get { return true; } // I think we can share this one. - } - - #endregion - - public void NewClient(IClientAPI client) - { - m_log.Info("[VOICECHAT]: New client: " + client.AgentId); - lock (m_uuidToClient) - { - m_uuidToClient[client.AgentId] = null; - } - } - - public void RemovePresence(LLUUID uuid) - { - lock (m_uuidToClient) - { - if (m_uuidToClient.ContainsKey(uuid)) - { - if (m_uuidToClient[uuid] != null) - { - RemoveClient(m_uuidToClient[uuid].m_socket); - } - m_uuidToClient.Remove(uuid); - } - else - { - m_log.Error("[VOICECHAT]: Presence not found on RemovePresence: " + uuid); - } - } - } - - public bool AddClient(VoiceClient client, LLUUID uuid) - { - lock (m_uuidToClient) - { - if (m_uuidToClient.ContainsKey(uuid)) - { - if (m_uuidToClient[uuid] != null) { - m_log.Warn("[VOICECHAT]: Multiple login attempts for " + uuid); - return false; - } - m_uuidToClient[uuid] = client; - return true; - } - } - return false; - } - - public void RemoveClient(Socket socket) - { - m_log.Info("[VOICECHAT]: Removing client"); - lock(m_clients) - { - VoiceClient client = m_clients[socket]; - - lock(m_uuidToClient) - { - if (m_uuidToClient.ContainsKey(client.m_clientId)) - { - m_uuidToClient[client.m_clientId] = null; - } - } - - m_clients.Remove(socket); - client.m_socket.Close(); - } - } - - protected void CreateListeningSocket() - { - IPEndPoint listenEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), 12000); - m_server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); - m_server.Bind(listenEndPoint); - m_server.Listen(50); - } - - void ListenIncomingConnections() - { - m_log.Info("[VOICECHAT]: Listening connections..."); - //ServerStatus.ReportThreadName("VoiceChat: Connection listener"); - - byte[] dummyBuffer = new byte[1]; - - while (true) - { - try - { - Socket connection = m_server.Accept(); - lock (m_clients) - { - m_clients[connection] = new VoiceClient(connection, this); - m_selectCancel.Send(dummyBuffer); - m_log.Info("[VOICECHAT]: Voicechat connection from " + connection.RemoteEndPoint.ToString()); - } - } - catch (SocketException e) - { - m_log.Error("[VOICECHAT]: During accept: " + e.ToString()); - } - } - } - - Socket ListenLoopbackSocket() - { - IPEndPoint listenEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), m_dummySocketPort); - Socket dummyListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); - dummyListener.Bind(listenEndPoint); - dummyListener.Listen(1); - Socket socket = dummyListener.Accept(); - dummyListener.Close(); - return socket; - } - - void RunVoiceChat() - { - m_log.Info("[VOICECHAT]: Connection handler started..."); - //ServerStatus.ReportThreadName("VoiceChat: Connection handler"); - - //Listen a loopback socket for aborting select call - Socket dummySocket = ListenLoopbackSocket(); - - List sockets = new List(); - byte[] buffer = new byte[65536]; - - while (true) - { - if (m_clients.Count == 0) - { - Thread.Sleep(100); - continue; - } - - lock (m_clients) - { - foreach (Socket s in m_clients.Keys) - { - sockets.Add(s); - } - } - sockets.Add(dummySocket); - - try - { - Socket.Select(sockets, null, null, 200000); - } - catch (SocketException e) - { - m_log.Warn("[VOICECHAT]: " + e.Message); - } - - foreach (Socket s in sockets) - { - try - { - if (s.RemoteEndPoint != dummySocket.RemoteEndPoint) - { - ReceiveFromSocket(s, buffer); - } - else - { - //Receive data and check if there was an error with select abort socket - if (s.Receive(buffer) <= 0) - { - //Just give a warning for now - m_log.Error("[VOICECHAT]: Select abort socket was closed"); - } - } - } - catch(ObjectDisposedException e) - { - m_log.Warn("[VOICECHAT]: Connection has been already closed"); - } - catch (Exception e) - { - m_log.Error("[VOICECHAT]: Exception: " + e.Message); - - RemoveClient(s); - } - } - - sockets.Clear(); - } - } - - private void ReceiveFromSocket( Socket s, byte[] buffer ) - { - int byteCount = s.Receive(buffer); - if (byteCount <= 0) - { - m_log.Info("[VOICECHAT]: Connection lost to " + s.RemoteEndPoint); - lock (m_clients) - { - RemoveClient(s); - } - } - else - { - //ServerStatus.ReportInPacketTcp(byteCount); - lock (m_clients) - { - if (m_clients.ContainsKey(s)) - { - m_clients[s].OnDataReceived(buffer, byteCount); - } - else - { - m_log.Warn("[VOICECHAT]: Got data from " + s.RemoteEndPoint + - ", but source is not a valid voice client"); - } - } - } - } - - public LLVector3 getScenePresencePosition(LLUUID clientID) - { - foreach (Scene scene in m_scenes) - { - ScenePresence x; - if ((x = scene.GetScenePresence(clientID)) != null) - { - return x.AbsolutePosition + new LLVector3(Constants.RegionSize * scene.RegionInfo.RegionLocX, - Constants.RegionSize * scene.RegionInfo.RegionLocY, 0); - } - } - return LLVector3.Zero; - } - - public void BroadcastVoice(VoicePacket packet) - { - libsecondlife.LLVector3 origPos = getScenePresencePosition(packet.m_clientId); - - byte[] bytes = packet.GetBytes(); - foreach (VoiceClient client in m_clients.Values) - { - if (client.IsEnabled() && client.m_clientId != packet.m_clientId && - client.m_authenticated && client.IsCodecSupported(packet.m_codec)) - { - LLVector3 presenceLoc = getScenePresencePosition(client.m_clientId); - - if (presenceLoc != LLVector3.Zero && Util.GetDistanceTo(presenceLoc, origPos) < 20) - { - client.SendTo(bytes); - } - } - } - } - } -} +using System; +using System.Collections.Generic; +using System.Text; +using System.Threading; +using System.Net.Sockets; +using System.Net; +using OpenSim.Region.Environment.Scenes; +using OpenSim.Framework; +using OpenSim.Region.Environment.Modules; +using OpenSim.Region.Environment.Interfaces; +using Nini; +using libsecondlife; + +namespace OpenSim.Region.Environment.Modules.VoiceChat +{ + public class VoiceChatServer : IRegionModule + { + private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); + + int m_dummySocketPort = 53134; + + Thread m_listenerThread; + Thread m_mainThread; + List m_scenes = new List(); + Socket m_server; + Socket m_selectCancel; + bool m_enabled = false; + + Dictionary m_clients = new Dictionary(); + Dictionary m_uuidToClient = new Dictionary(); + + + #region IRegionModule Members + + public void Initialise(Scene scene, Nini.Config.IConfigSource source) + { + try + { + m_enabled = source.Configs["Voice"].GetBoolean("enabled", m_enabled); + } + catch (Exception) + { } + + if (m_enabled) + { + if (!m_scenes.Contains(scene)) + m_scenes.Add(scene); + + scene.EventManager.OnNewClient += NewClient; + scene.EventManager.OnRemovePresence += RemovePresence; + } + } + + public void PostInitialise() + { + if (m_enabled != true) + return; + + try + { + CreateListeningSocket(); + } + catch (Exception) + { + m_log.Error("[VOICECHAT]: Unable to start listening"); + return; + } + + m_listenerThread = new Thread(new ThreadStart(ListenIncomingConnections)); + m_listenerThread.IsBackground = true; + m_listenerThread.Start(); + + m_mainThread = new Thread(new ThreadStart(RunVoiceChat)); + m_mainThread.IsBackground = true; + m_mainThread.Start(); + + Thread.Sleep(500); + m_selectCancel = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); + m_selectCancel.Connect("localhost", m_dummySocketPort); + } + + public void Close() + { + throw new NotImplementedException(); + } + + public string Name + { + get { return "VoiceChatModule"; } + } + + public bool IsSharedModule + { + get { return true; } // I think we can share this one. + } + + #endregion + + public void NewClient(IClientAPI client) + { + m_log.Info("[VOICECHAT]: New client: " + client.AgentId); + lock (m_uuidToClient) + { + m_uuidToClient[client.AgentId] = null; + } + } + + public void RemovePresence(LLUUID uuid) + { + lock (m_uuidToClient) + { + if (m_uuidToClient.ContainsKey(uuid)) + { + if (m_uuidToClient[uuid] != null) + { + RemoveClient(m_uuidToClient[uuid].m_socket); + } + m_uuidToClient.Remove(uuid); + } + else + { + m_log.Error("[VOICECHAT]: Presence not found on RemovePresence: " + uuid); + } + } + } + + public bool AddClient(VoiceClient client, LLUUID uuid) + { + lock (m_uuidToClient) + { + if (m_uuidToClient.ContainsKey(uuid)) + { + if (m_uuidToClient[uuid] != null) { + m_log.Warn("[VOICECHAT]: Multiple login attempts for " + uuid); + return false; + } + m_uuidToClient[uuid] = client; + return true; + } + } + return false; + } + + public void RemoveClient(Socket socket) + { + m_log.Info("[VOICECHAT]: Removing client"); + lock(m_clients) + { + VoiceClient client = m_clients[socket]; + + lock(m_uuidToClient) + { + if (m_uuidToClient.ContainsKey(client.m_clientId)) + { + m_uuidToClient[client.m_clientId] = null; + } + } + + m_clients.Remove(socket); + client.m_socket.Close(); + } + } + + protected void CreateListeningSocket() + { + IPEndPoint listenEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), 12000); + m_server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); + m_server.Bind(listenEndPoint); + m_server.Listen(50); + } + + void ListenIncomingConnections() + { + m_log.Info("[VOICECHAT]: Listening connections..."); + //ServerStatus.ReportThreadName("VoiceChat: Connection listener"); + + byte[] dummyBuffer = new byte[1]; + + while (true) + { + try + { + Socket connection = m_server.Accept(); + lock (m_clients) + { + m_clients[connection] = new VoiceClient(connection, this); + m_selectCancel.Send(dummyBuffer); + m_log.Info("[VOICECHAT]: Voicechat connection from " + connection.RemoteEndPoint.ToString()); + } + } + catch (SocketException e) + { + m_log.Error("[VOICECHAT]: During accept: " + e.ToString()); + } + } + } + + Socket ListenLoopbackSocket() + { + IPEndPoint listenEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), m_dummySocketPort); + Socket dummyListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); + dummyListener.Bind(listenEndPoint); + dummyListener.Listen(1); + Socket socket = dummyListener.Accept(); + dummyListener.Close(); + return socket; + } + + void RunVoiceChat() + { + m_log.Info("[VOICECHAT]: Connection handler started..."); + //ServerStatus.ReportThreadName("VoiceChat: Connection handler"); + + //Listen a loopback socket for aborting select call + Socket dummySocket = ListenLoopbackSocket(); + + List sockets = new List(); + byte[] buffer = new byte[65536]; + + while (true) + { + if (m_clients.Count == 0) + { + Thread.Sleep(100); + continue; + } + + lock (m_clients) + { + foreach (Socket s in m_clients.Keys) + { + sockets.Add(s); + } + } + sockets.Add(dummySocket); + + try + { + Socket.Select(sockets, null, null, 200000); + } + catch (SocketException e) + { + m_log.Warn("[VOICECHAT]: " + e.Message); + } + + foreach (Socket s in sockets) + { + try + { + if (s.RemoteEndPoint != dummySocket.RemoteEndPoint) + { + ReceiveFromSocket(s, buffer); + } + else + { + //Receive data and check if there was an error with select abort socket + if (s.Receive(buffer) <= 0) + { + //Just give a warning for now + m_log.Error("[VOICECHAT]: Select abort socket was closed"); + } + } + } + catch(ObjectDisposedException e) + { + m_log.Warn("[VOICECHAT]: Connection has been already closed"); + } + catch (Exception e) + { + m_log.Error("[VOICECHAT]: Exception: " + e.Message); + + RemoveClient(s); + } + } + + sockets.Clear(); + } + } + + private void ReceiveFromSocket( Socket s, byte[] buffer ) + { + int byteCount = s.Receive(buffer); + if (byteCount <= 0) + { + m_log.Info("[VOICECHAT]: Connection lost to " + s.RemoteEndPoint); + lock (m_clients) + { + RemoveClient(s); + } + } + else + { + //ServerStatus.ReportInPacketTcp(byteCount); + lock (m_clients) + { + if (m_clients.ContainsKey(s)) + { + m_clients[s].OnDataReceived(buffer, byteCount); + } + else + { + m_log.Warn("[VOICECHAT]: Got data from " + s.RemoteEndPoint + + ", but source is not a valid voice client"); + } + } + } + } + + public LLVector3 getScenePresencePosition(LLUUID clientID) + { + foreach (Scene scene in m_scenes) + { + ScenePresence x; + if ((x = scene.GetScenePresence(clientID)) != null) + { + return x.AbsolutePosition + new LLVector3(Constants.RegionSize * scene.RegionInfo.RegionLocX, + Constants.RegionSize * scene.RegionInfo.RegionLocY, 0); + } + } + return LLVector3.Zero; + } + + public void BroadcastVoice(VoicePacket packet) + { + libsecondlife.LLVector3 origPos = getScenePresencePosition(packet.m_clientId); + + byte[] bytes = packet.GetBytes(); + foreach (VoiceClient client in m_clients.Values) + { + if (client.IsEnabled() && client.m_clientId != packet.m_clientId && + client.m_authenticated && client.IsCodecSupported(packet.m_codec)) + { + LLVector3 presenceLoc = getScenePresencePosition(client.m_clientId); + + if (presenceLoc != LLVector3.Zero && Util.GetDistanceTo(presenceLoc, origPos) < 20) + { + client.SendTo(bytes); + } + } + } + } + } +} -- cgit v1.1