X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Frole%2FRoleContextImpl.java;h=58d8ab212837a24175546514c31646b083498ce0;hb=5fffad88c5940f04001bee1ac4190d47f5fea34b;hp=b636c9fb3021aa379c9651fca999c8ff84be70ca;hpb=3946e8a1a9b173e1978b14dfc6192eaa69398574;p=openflowplugin.git diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/role/RoleContextImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/role/RoleContextImpl.java index b636c9fb30..58d8ab2128 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/role/RoleContextImpl.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/role/RoleContextImpl.java @@ -49,6 +49,9 @@ class RoleContextImpl implements RoleContext { 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; @@ -162,7 +165,7 @@ class RoleContextImpl implements RoleContext { 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);