Browse Source

Some fixes for HashedWheelScheduler

master
Nikita 11 years ago
parent
commit
034f2e1fb5
  1. 15
      src/main/java/com/corundumstudio/socketio/Configuration.java
  2. 2
      src/main/java/com/corundumstudio/socketio/scheduler/HashedWheelScheduler.java

15
src/main/java/com/corundumstudio/socketio/Configuration.java

@ -43,7 +43,6 @@ public class Configuration {
private int pollingDuration = 20; private int pollingDuration = 20;
private int heartbeatThreadPoolSize = Runtime.getRuntime().availableProcessors() * 2;
private int heartbeatTimeout = 60; private int heartbeatTimeout = 60;
private int heartbeatInterval = 25; private int heartbeatInterval = 25;
private int closeTimeout = 60; private int closeTimeout = 60;
@ -80,7 +79,6 @@ public class Configuration {
setCloseTimeout(conf.getCloseTimeout()); setCloseTimeout(conf.getCloseTimeout());
setHeartbeatInterval(conf.getHeartbeatInterval()); setHeartbeatInterval(conf.getHeartbeatInterval());
setHeartbeatThreadPoolSize(conf.getHeartbeatThreadPoolSize());
setHeartbeatTimeout(conf.getHeartbeatTimeout()); setHeartbeatTimeout(conf.getHeartbeatTimeout());
setHostname(conf.getHostname()); setHostname(conf.getHostname());
@ -202,19 +200,6 @@ public class Configuration {
return heartbeatTimeout > 0; return heartbeatTimeout > 0;
} }
/**
* Heartbeat thread pool size
*
* @param value
* - threads amount
*/
public void setHeartbeatThreadPoolSize(int heartbeatThreadPoolSize) {
this.heartbeatThreadPoolSize = heartbeatThreadPoolSize;
}
public int getHeartbeatThreadPoolSize() {
return heartbeatThreadPoolSize;
}
/** /**
* Channel close timeout due inactivity * Channel close timeout due inactivity
* *

2
src/main/java/com/corundumstudio/socketio/scheduler/HashedWheelScheduler.java

@ -31,7 +31,7 @@ public class HashedWheelScheduler implements CancelableScheduler {
private volatile ChannelHandlerContext ctx; private volatile ChannelHandlerContext ctx;
@Override @Override
public void update(ChannelHandlerContext ctx) throws Exception {
public void update(ChannelHandlerContext ctx) {
this.ctx = ctx; this.ctx = ctx;
} }

Loading…
Cancel
Save