* In the client stack, if the BeginReceive() throws an exception then do print this out to the log once

* This may help us detect if mysterious UDP disconnects are happening because of this.
* Shouldn't be any functional change but I would appreciate a buddy check from Teravus if he has time (as for all client stack changes)
0.6.0-stable
Justin Clarke Casey 2008-10-31 19:41:07 +00:00
parent 4df3a19be6
commit 465a931c05
2 changed files with 53 additions and 57 deletions

View File

@ -271,15 +271,57 @@ namespace OpenSim.Region.ClientStack.LindenUDP
m_socket.BeginReceiveFrom(
RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref reusedEpSender, ReceivedData, null);
}
catch (SocketException)
catch (SocketException e)
{
// We don't need to see this error, reset connection and get next UDP packet off the buffer
// ENDLESS LOOP ON PURPOSE!
// Reset connection and get next UDP packet off the buffer
// If the UDP packet is part of the same stream, this will happen several hundreds of times before
// the next set of UDP data is for a valid client.
//m_log.ErrorFormat("[CLIENT]: BeginRecieve threw exception " + e.Message + ": " + e.StackTrace );
ResetServerEndPoint(e);
}
}
// ENDLESS LOOP ON PURPOSE!
ResetEndPoint();
/// <summary>
/// Reset the server endpoint
/// </summary>
/// <param name="e">
/// The exception that has triggered the reset. Can be null if there was no exception.
/// </param>
private void ResetServerEndPoint(Exception e)
{
try
{
CloseCircuit(reusedEpSender, e);
}
catch (Exception a)
{
m_log.Error("[UDPSERVER]: " + a);
}
// ENDLESS LOOP ON PURPOSE!
// We need to purge the UDP stream of crap from the client that disconnected nastily or the UDP server will die
// The only way to do that is to beginreceive again!
BeginReceive();
}
/// <summary>
/// Close a client circuit. This is done in response to an exception on receive, and should not be called
/// normally.
/// </summary>
/// <param name="sender"></param>
/// <param name="e">The exception that caused the close. Can be null if there was no exception</param>
private void CloseCircuit(EndPoint sender, Exception e)
{
uint circuit;
lock (clientCircuits)
{
if (clientCircuits.TryGetValue(sender, out circuit))
{
m_packetServer.CloseCircuit(circuit);
if (e != null)
m_log.ErrorFormat("[CLIENT]: Closed circuit {0} {1} due to exception {2}", circuit, sender, e);
}
}
}
@ -327,53 +369,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
return hasReceivedOkay;
}
private void ResetEndPoint()
{
try
{
CloseEndPoint(reusedEpSender);
}
catch (Exception a)
{
m_log.Error("[UDPSERVER]: " + a);
}
// ENDLESS LOOP ON PURPOSE!
// We need to purge the UDP stream of crap from the client that disconnected nastily or the UDP server will die
// The only way to do that is to beginreceive again!
BeginReceive();
try
{
// m_socket.BeginReceiveFrom(
// RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref reusedEpSender, ReceivedData, null);
// Ter: For some stupid reason ConnectionReset basically kills our async event structure..
// so therefore.. we've got to tell the server to BeginReceiveFrom again.
// This will happen over and over until we've gone through all packets
// sent to and from this particular user.
// Stupid I know..
// but Flusing the buffer would be even more stupid... so, we're stuck with this ugly method.
}
catch (SocketException e)
{
m_log.DebugFormat("[UDPSERVER]: Exception {0} : {1}", e.Message, e.StackTrace );
}
}
private void CloseEndPoint(EndPoint sender)
{
uint circuit;
lock (clientCircuits)
{
if (clientCircuits.TryGetValue(sender, out circuit))
{
m_packetServer.CloseCircuit(circuit);
}
}
}
/// <summary>
/// Add a new client circuit.
/// </summary>

View File

@ -40,11 +40,12 @@ namespace OpenSim.Region.Environment.Scenes.Tests
[TestFixture]
public class SceneTests
{
/// <summary>
/// Test adding an object to a scene. Doesn't yet do what it says on the tin.
/// </summary>
[Test]
public void TestAddSceneObject()
{
//System.Console.WriteLine("Hello mum!");
RegionInfo regInfo = new RegionInfo(1000, 1000, null, null);
regInfo.RegionName = "Unit test region";
AgentCircuitManager acm = new AgentCircuitManager();