(cough. not often a problem though)
This commit is contained in:
@ -66,7 +66,6 @@ class PeerConnectionOut implements Runnable
|
|||||||
*/
|
*/
|
||||||
public void run()
|
public void run()
|
||||||
{
|
{
|
||||||
try { Thread.sleep(1000); } catch (InterruptedException ie) {}
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
while (!quit && peer.isConnected())
|
while (!quit && peer.isConnected())
|
||||||
@ -180,7 +179,8 @@ class PeerConnectionOut implements Runnable
|
|||||||
// return;
|
// return;
|
||||||
|
|
||||||
quit = true;
|
quit = true;
|
||||||
thread.interrupt();
|
if (thread != null)
|
||||||
|
thread.interrupt();
|
||||||
|
|
||||||
sendQueue.clear();
|
sendQueue.clear();
|
||||||
sendQueue.notify();
|
sendQueue.notify();
|
||||||
|
Reference in New Issue
Block a user