private static final Logger LOG = LoggerFactory.getLogger(RoleContextImpl.class);
+ // Timeout in seconds after what we will give up on propagating role
+ private static final int SET_ROLE_TIMEOUT = 10;
+
private SalRoleService salRoleService = null;
private final HashedWheelTimer hashedWheelTimer;
private final DeviceInfo deviceInfo;
setRoleOutputFuture.cancel(true);
}
};
- hashedWheelTimer.newTimeout(timerTask, 5, TimeUnit.SECONDS);
+ hashedWheelTimer.newTimeout(timerTask, SET_ROLE_TIMEOUT, TimeUnit.SECONDS);
} else {
LOG.info("Device: {} with version: {} does not support role", deviceInfo.getLOGValue(), deviceInfo.getVersion());
return Futures.immediateFuture(null);