* @param deviceConnectedHandler
*/
void setDeviceConnectedHandler(DeviceConnectedHandler deviceConnectedHandler);
+ void setEchoReplyTimeout(long echoReplyTimeout);
}
#Maximum outbound queue depth
#requires to be configured before switch connection, else require a switch restart
barrier-count-limit=25600
+#Echo reply timeout specified on the controller side beyond which the connection is deemed dead
+#requires to be configured before switch connection, else require a switch restart
+echo-reply-timeout=2000
if(deviceManager != null && props.containsKey("barrier-count-limit")){
deviceManager.setBarrierCountLimit(Integer.valueOf(props.get("barrier-count-limit").toString()));
}
- if(deviceManager !=null && props.containsKey("barrier-interval-timeout-limit")){
+ if(deviceManager != null && props.containsKey("barrier-interval-timeout-limit")){
deviceManager.setBarrierInterval(Long.valueOf(props.get("barrier-interval-timeout-limit").toString()));
}
+ if (connectionManager != null && props.containsKey("echo-reply-timeout") ){
+ connectionManager.setEchoReplyTimeout(Long.valueOf(props.get("echo-reply-timeout").toString()));
+ }
}
private static void registerMXBean(final MessageIntelligenceAgency messageIntelligenceAgency) {
private static final Logger LOG = LoggerFactory.getLogger(ConnectionManagerImpl.class);
private static final boolean BITMAP_NEGOTIATION_ENABLED = true;
private DeviceConnectedHandler deviceConnectedHandler;
- private final long echoReplyTimeout;
+ private long echoReplyTimeout;
private final ThreadPoolExecutor threadPool;
public ConnectionManagerImpl(long echoReplyTimeout, final ThreadPoolExecutor threadPool) {
public void setDeviceConnectedHandler(final DeviceConnectedHandler deviceConnectedHandler) {
this.deviceConnectedHandler = deviceConnectedHandler;
}
+
+ public void setEchoReplyTimeout(long echoReplyTimeout){
+ this.echoReplyTimeout = echoReplyTimeout;
+ }
}