package org.couchbase.mock.control;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.couchbase.mock.Bucket;
import org.couchbase.mock.CouchbaseMock;
import org.couchbase.mock.memcached.MemcachedServer;
abstract void (List<String> tokens);
@Override
public void execute(CouchbaseMock mock, List<String> tokens) {
extractParams(tokens);
Set<MemcachedServer> servers = new HashSet<MemcachedServer>();
for (Bucket bucket : mock.getBuckets().values()) {
for (MemcachedServer server : bucket.getServers()) {
if (servers.contains(server) == false) {
doServerCommand(server);
servers.add(server);
}
}
}
}
}