throw new MemcachedException("could not find session for "
+ SystemUtils.getRawAddress(address) + ":"
+ address.getPort() + ",maybe it have not been connected");
}
Command command = this.commandFactory.createFlushAllCommand(latch,
<BUG>exptime, noreply);
sessionQueue.peek().write(command);
if (!noreply) {
this.latchWait(command, timeout);
</BUG>
}

throw new MemcachedException("could not find session for "
+ SystemUtils.getRawAddress(address) + ":"
+ address.getPort() + ",maybe it have not been connected");
