public void run()
{
while ((m_isReceiving) && (m_receiveStallThread == Thread.currentThread()))
{
try
{
if (((m_lastReceiveCall != null) && (m_UDPreceiveThread != null)) || ((m_UDPreceiveThread == null) || (!m_UDPreceiveThread.isAlive())))
{
// If we stalled on a receive call for more than X seconds, we restart the thread...
if (((m_lastReceiveCall != null) && ((new Date().getTime() - m_lastReceiveCall.getTime()) > kStallVerificationPeriod)) || ((m_UDPreceiveThread == null) || (!m_UDPreceiveThread.isAlive())))
{
synchronized(UDPRepeaterCommunicationLayerClass.m_threadMutex)
{
m_lastReceiveCall = null;
Thread cleaupThread = m_UDPreceiveThread;
int oldPort = -1;
UDPDatagramConnection oldSocket = m_socket;
if (oldSocket != null)
{
oldPort = oldSocket.getLocalPort();
}
m_UDPreceiveThread = null;
if (m_socket != null)
{
m_socket.close();
m_socket = null;
}
m_socket = (UDPDatagramConnection)Connector.open(m_connectorReceiveAddress, Connector.READ_WRITE, true);
if (m_socket != null)
{
m_cleanUpStack.addElement(m_socket);
}
CUDPReceiverThread dThreadObj = new CUDPReceiverThread(this);
m_UDPreceiveThread = new Thread(dThreadObj, "UDP Receive Thread");
m_UDPreceiveThread.setPriority(kUDPThreadPriorityNotReceive);
if ((oldPort != -1) && (oldPort != m_socket.getLocalPort()) && (IsConnected()))
{
SendData(m_sendDataAddress, CommunicationInterface.eMsgTypeReconnect, "", -1, UDPRepeaterCommunicationLayerClass.kDefaultInterval);
}
if (cleaupThread != null)
{
try
{
cleaupThread.interrupt();
}
catch (Exception e)
{
if (PhoneInputMidlet.m_debug)
{
System.out.println("**** exception in UDPRepeaterCommunicationLayerClass.run.1: " + e.toString());
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}
m_UDPreceiveThread.start();
}
}
else
{
PerformPeriodicalTasks();
if (m_lastReceiveCall != null)
{
Thread.sleep(kStallVerificationPeriod - (new Date().getTime() - m_lastReceiveCall.getTime()));
}
else
{
Thread.sleep(kStallVerificationPeriod);
}
}
}
else
{
PerformPeriodicalTasks();
Thread.sleep(kStallVerificationPeriod);
}
}
catch (Exception e)
{
if (PhoneInputMidlet.m_debug)
{
System.out.println("**** exception in UDPRepeaterCommunicationLayerClass.run.2: " + e.toString());
System.out.println(e.getMessage());
e.printStackTrace();
}
}
PerformPeriodicalTasks();
}
}
public void Dispose()
{
if (IsConnected())
{
ClearAllCommRetries();
if (m_sendDataAddress.length() > 0)
{
SendData(m_sendDataAddress, CommunicationInterface.eMsgTypeClientDisconnect, "", 5, UDPRepeaterCommunicationLayerClass.kDefaultInterval);
}
Date dStartTime = new Date();
while ((IsConnected()) && (IsAwaitingACK()) && ((new Date().getTime()- dStartTime.getTime()) < 5000))
{
PerformPeriodicalTasks();
try
{
Thread.sleep(50);
}
catch (InterruptedException e) {}
}
}
StopReceiveThread();
if (m_socket != null)
{
try
{
m_socket.close();
System.out.println("m_socket closed successfully.");
}
catch (IOException e)
{
if (PhoneInputMidlet.m_debug)
{
System.out.println("**** exception in UDPRepeaterCommunicationLayerClass.Dispose.1: " + e.toString());
System.out.println(e.getMessage());
e.printStackTrace();
}
}
m_socket = null;
}
ClearAllCommRetries();
super.Dispose();
}
