SendThread and ReadThread exception handling.
This commit is contained in:
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -1,7 +1,6 @@
|
|||||||
package org.l2jmobius.commons.network;
|
package org.l2jmobius.commons.network;
|
||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.net.SocketTimeoutException;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -204,10 +203,6 @@ public class ReadThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (SocketTimeoutException e)
|
|
||||||
{
|
|
||||||
onDisconnection(client);
|
|
||||||
}
|
|
||||||
catch (Exception e) // Unexpected disconnection?
|
catch (Exception e) // Unexpected disconnection?
|
||||||
{
|
{
|
||||||
onDisconnection(client);
|
onDisconnection(client);
|
||||||
|
@@ -78,6 +78,8 @@ public class SendThread<E extends NetClient> implements Runnable
|
|||||||
}
|
}
|
||||||
catch (Exception ignored)
|
catch (Exception ignored)
|
||||||
{
|
{
|
||||||
|
_pool.remove(client);
|
||||||
|
client.onDisconnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user