package org.couchbase.mock.memcached;
import org.couchbase.mock.memcached.protocol.BinaryCommand;
import org.couchbase.mock.memcached.protocol.BinaryResponse;
import org.couchbase.mock.memcached.protocol.CommandCode;
import org.couchbase.mock.memcached.protocol.ErrorCode;
@Override
public void execute(BinaryCommand cmd, MemcachedServer server, MemcachedConnection client) {
server.getDatastore().flush(server);
if (cmd.getComCode() == CommandCode.FLUSH) {
client.sendResponse(new BinaryResponse(cmd, ErrorCode.SUCCESS));
}
}
}