} catch ( Exception x ) {
if (x instanceof InterruptedException) interrupted();
else {
- if (errorCounter==0) log.warn("Error receiving mcast package. Sleeping 500ms",x);
- else log.debug("Error receiving mcast package. Sleeping 500ms",x);
- try { Thread.sleep(500); } catch ( Exception ignore ){}
- if ( (++errorCounter)>=recoveryCounter ) {
- errorCounter=0;
- new RecoveryThread(McastServiceImpl.this);
+ if (errorCounter==0 && doRunReceiver) log.warn("Error receiving mcast package. Sleeping 500ms",x);
+ else if (log.isDebugEnabled()) log.debug("Error receiving mcast package"+(doRunReceiver?". Sleeping 500ms":"."),x);
+ if (doRunReceiver) {
+ try { Thread.sleep(500); } catch ( Exception ignore ){}
+ if ( (++errorCounter)>=recoveryCounter ) {
+ errorCounter=0;
+ new RecoveryThread(McastServiceImpl.this);
+ }
}
}
}