public final class GetPartitionsRequest extends CallableClientRequest implements Portable, RetryableRequest {
@Override
public Object call() throws Exception {
InternalPartitionService service = getService();
service.firstArrangement();
ClusterService clusterService = getClientEngine().getClusterService();
Collection<MemberImpl> memberList = clusterService.getMemberList();
Address[] addresses = new Address[memberList.size()];
Map<Address, Integer> addressMap = new HashMap<Address, Integer>(memberList.size());
int k = 0;
for (MemberImpl member : memberList) {
Address address = member.getAddress();
addresses[k] = address;
addressMap.put(address, k);
k++;
}
InternalPartition[] partitions = service.getPartitions();
int[] indexes = new int[partitions.length];
for (int i = 0; i < indexes.length; i++) {
Address owner = partitions[i].getOwner();
int index = -1;
if (owner != null) {