|
|
@@ -194,7 +194,7 @@ public class StandardFlexRouterService extends SimpleDaemon implements FlexRoute |
|
|
|
for (int i=0; i<MAX_PING_TRIES; i++) { |
|
|
|
sleep(PING_SLEEP_FACTOR * i, "waiting to ping flexRouter"); |
|
|
|
if (i == 0) { |
|
|
|
if (log.isInfoEnabled()) log.info(prefix+"pinging router at "+pingUrl+" ..."); |
|
|
|
if (log.isDebugEnabled()) log.debug(prefix+"pinging router at "+pingUrl+" ..."); |
|
|
|
} else { |
|
|
|
final FlexRouter existing = flexRouterDAO.findByUuid(router.getUuid()); |
|
|
|
if (existing == null) { |
|
|
@@ -214,7 +214,7 @@ public class StandardFlexRouterService extends SimpleDaemon implements FlexRoute |
|
|
|
} else { |
|
|
|
final FlexRouterPing pong = response.getEntity(FlexRouterPing.class); |
|
|
|
if (pong.validate(router)) { |
|
|
|
if (log.isInfoEnabled()) log.info(prefix+"router is ok"); |
|
|
|
if (log.isDebugEnabled()) log.debug(prefix+"router is ok"); |
|
|
|
setStatus(router, FlexRouterStatus.active); |
|
|
|
return true; |
|
|
|
} else { |
|
|
|