log.debug("FLUSH block at  " + localAddress + " for " + timeout);
if (log.isDebugEnabled()) log.debug("FLUSH block at " + localAddress + " for " + timeout);
	public void down(Event evt) {		switch (evt.getType()) {			case Event.MSG:				synchronized (blockMutex) {					while (isFlushRunning()) {						log.debug("FLUSH block at  " + localAddress + " for " + timeout);						try {							blockMutex.wait(timeout);							if (isFlushRunning()) {								log.warn("Forcing FLUSH unblock at " + localAddress);								passDown(new Event(Event.SUSPEND_OK));								isBlockState=false;							}						} catch (InterruptedException e) {						}					}				}				break;							case Event.SUSPEND:				onSuspend((View) evt.getArg());				return;							case Event.RESUME:				onResume();				return;			}		passDown(evt);	}