org.redisson.cluster.ClusterSlotRange to java.lang.Integer
No. of Instances - 21
No. of Commits - 1
No. of Projects - {'redisson'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
- Rename Variable
- slotRange to slot
- slotRange to slot
- slotRange to slot
- slotRange to slot
- slotRange to slot
- slotRange to slot
- slotRanges to slots
- slotRanges to slots
- slotRanges to slots
- currentSlotRange to slot
- currentSlotRange to slot
- currentSlotRange to slot
- currentSlotRange to slot
- Add or Remove Method invocation
- partition.getSlotRanges() to partition.getSlots()
- currentPartition.getSlotRanges() to currentPartition.getSlots()
- addEntry(slotRange,e) to initFuture.setFailure(future.cause())
- lastPartitions.put(slotRange,partition) to log.error("Can't add master: {} for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges())
- GlobalEventExecutor.INSTANCE.schedule(new Runnable(){ @Override public void run(){ AtomicReference<Throwable> lastException=new AtomicReference<Throwable>(); Iterator<URI> nodesIterator=iterator; if (nodesIterator == null) { List<URI> nodes=new ArrayList<URI>(); List<URI> slaves=new ArrayList<URI>(); for ( ClusterPartition partition : lastPartitions.values()) { if (!partition.isMasterFail()) { nodes.add(partition.getMasterAddress()); } Set<URI> partitionSlaves=new HashSet<URI>(partition.getSlaveAddresses()); partitionSlaves.removeAll(partition.getFailedSlaveAddresses()); slaves.addAll(partitionSlaves); } nodes.addAll(slaves); nodesIterator=nodes.iterator(); } checkClusterState(cfg,nodesIterator,lastException); } } ,cfg.getScanInterval(),TimeUnit.MILLISECONDS) to GlobalEventExecutor.INSTANCE.schedule(new Runnable(){ @Override public void run(){ AtomicReference<Throwable> lastException=new AtomicReference<Throwable>(); Iterator<URI> nodesIterator=iterator; if (nodesIterator == null) { List<URI> nodes=new ArrayList<URI>(); List<URI> slaves=new ArrayList<URI>(); if (lastPartitions.isEmpty()) { System.out.println("lastPartitions.isEmpty()"); } for ( ClusterPartition partition : getLastPartitions()) { if (!partition.isMasterFail()) { nodes.add(partition.getMasterAddress()); } Set<URI> partitionSlaves=new HashSet<URI>(partition.getSlaveAddresses()); partitionSlaves.removeAll(partition.getFailedSlaveAddresses()); slaves.addAll(partitionSlaves); } nodes.addAll(slaves); nodesIterator=nodes.iterator(); } checkClusterState(cfg,nodesIterator,lastException); } } ,cfg.getScanInterval(),TimeUnit.MILLISECONDS)
- removedSlots to removedSlots.size()
- clusterPartition.getSlotRanges() to slot
- addedSlots to addedSlots.size()
- newPartition.getSlotRanges() to newPartition.getSlots()
- currentPart.getSlotRanges() to currentPart.getSlots()
- Rename Method invocation
- Update Anonymous class
- { @Override public void operationComplete( Future<Void> future) throws Exception { if (!future.isSuccess()) { return; } for ( ClusterSlotRange slotRange : partition.getSlotRanges()) { addEntry(slotRange,e); lastPartitions.put(slotRange,partition); } log.info("master: {} added for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); } } to { @Override public void operationComplete( Future<Void> future) throws Exception { if (!future.isSuccess()) { log.error("Can't add master: {} for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); initFuture.setFailure(future.cause()); return; } for ( Integer slot : partition.getSlots()) { addEntry(slot,e); lastPartitions.put(slot,partition); } log.info("master: {} added for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); initFuture.setSuccess(null); } }
- { @Override public void operationComplete( Future<Map<String,String>> future) throws Exception { if (!future.isSuccess()) { log.error("Can't execute CLUSTER_INFO for " + connection.getRedisClient().getAddr(),future.cause()); result.setFailure(future.cause()); return; } Map<String,String> params=future.getNow(); if ("fail".equals(params.get("cluster_state"))) { RedisException e=new RedisException("Failed to add master: " + partition.getMasterAddress() + " for slot ranges: "+ partition.getSlotRanges()+ ". Reason - cluster_state:fail"); result.setFailure(e); return; } MasterSlaveServersConfig config=create(cfg); config.setMasterAddress(partition.getMasterAddress()); final MasterSlaveEntry e; List<Future<Void>> futures=new ArrayList<Future<Void>>(); if (config.getReadMode() == ReadMode.MASTER) { e=new SingleEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); } else { config.setSlaveAddresses(partition.getSlaveAddresses()); e=new MasterSlaveEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); List<Future<Void>> fs=e.initSlaveBalancer(partition.getFailedSlaveAddresses()); futures.addAll(fs); if (!partition.getSlaveAddresses().isEmpty()) { log.info("slaves: {} added for slot ranges: {}",partition.getSlaveAddresses(),partition.getSlotRanges()); if (!partition.getFailedSlaveAddresses().isEmpty()) { log.warn("slaves: {} is down for slot ranges: {}",partition.getFailedSlaveAddresses(),partition.getSlotRanges()); } } } Future<Void> f=e.setupMasterEntry(config.getMasterAddress().getHost(),config.getMasterAddress().getPort()); f.addListener(new FutureListener<Void>(){ @Override public void operationComplete( Future<Void> future) throws Exception { if (!future.isSuccess()) { return; } for ( ClusterSlotRange slotRange : partition.getSlotRanges()) { addEntry(slotRange,e); lastPartitions.put(slotRange,partition); } log.info("master: {} added for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); } } ); futures.add(f); result.setSuccess(futures); } } to { @Override public void operationComplete( Future<Map<String,String>> future) throws Exception { if (!future.isSuccess()) { log.error("Can't execute CLUSTER_INFO for " + connection.getRedisClient().getAddr(),future.cause()); result.setFailure(future.cause()); return; } Map<String,String> params=future.getNow(); if ("fail".equals(params.get("cluster_state"))) { RedisException e=new RedisException("Failed to add master: " + partition.getMasterAddress() + " for slot ranges: "+ partition.getSlotRanges()+ ". Reason - cluster_state:fail"); log.error("cluster_state:fail for " + connection.getRedisClient().getAddr()); result.setFailure(e); return; } MasterSlaveServersConfig config=create(cfg); config.setMasterAddress(partition.getMasterAddress()); final MasterSlaveEntry e; List<Future<Void>> futures=new ArrayList<Future<Void>>(); if (config.getReadMode() == ReadMode.MASTER) { e=new SingleEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); } else { config.setSlaveAddresses(partition.getSlaveAddresses()); e=new MasterSlaveEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); List<Future<Void>> fs=e.initSlaveBalancer(partition.getFailedSlaveAddresses()); futures.addAll(fs); if (!partition.getSlaveAddresses().isEmpty()) { log.info("slaves: {} added for slot ranges: {}",partition.getSlaveAddresses(),partition.getSlotRanges()); if (!partition.getFailedSlaveAddresses().isEmpty()) { log.warn("slaves: {} is down for slot ranges: {}",partition.getFailedSlaveAddresses(),partition.getSlotRanges()); } } } Future<Void> f=e.setupMasterEntry(config.getMasterAddress().getHost(),config.getMasterAddress().getPort()); final Promise<Void> initFuture=newPromise(); futures.add(initFuture); f.addListener(new FutureListener<Void>(){ @Override public void operationComplete( Future<Void> future) throws Exception { if (!future.isSuccess()) { log.error("Can't add master: {} for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); initFuture.setFailure(future.cause()); return; } for ( Integer slot : partition.getSlots()) { addEntry(slot,e); lastPartitions.put(slot,partition); } log.info("master: {} added for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); initFuture.setSuccess(null); } } ); result.setSuccess(futures); } }
- { @Override public void operationComplete( Future<RedisConnection> future) throws Exception { if (!future.isSuccess()) { result.setFailure(future.cause()); return; } final RedisConnection connection=future.getNow(); Future<Map<String,String>> clusterFuture=connection.async(RedisCommands.CLUSTER_INFO); clusterFuture.addListener(new FutureListener<Map<String,String>>(){ @Override public void operationComplete( Future<Map<String,String>> future) throws Exception { if (!future.isSuccess()) { log.error("Can't execute CLUSTER_INFO for " + connection.getRedisClient().getAddr(),future.cause()); result.setFailure(future.cause()); return; } Map<String,String> params=future.getNow(); if ("fail".equals(params.get("cluster_state"))) { RedisException e=new RedisException("Failed to add master: " + partition.getMasterAddress() + " for slot ranges: "+ partition.getSlotRanges()+ ". Reason - cluster_state:fail"); result.setFailure(e); return; } MasterSlaveServersConfig config=create(cfg); config.setMasterAddress(partition.getMasterAddress()); final MasterSlaveEntry e; List<Future<Void>> futures=new ArrayList<Future<Void>>(); if (config.getReadMode() == ReadMode.MASTER) { e=new SingleEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); } else { config.setSlaveAddresses(partition.getSlaveAddresses()); e=new MasterSlaveEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); List<Future<Void>> fs=e.initSlaveBalancer(partition.getFailedSlaveAddresses()); futures.addAll(fs); if (!partition.getSlaveAddresses().isEmpty()) { log.info("slaves: {} added for slot ranges: {}",partition.getSlaveAddresses(),partition.getSlotRanges()); if (!partition.getFailedSlaveAddresses().isEmpty()) { log.warn("slaves: {} is down for slot ranges: {}",partition.getFailedSlaveAddresses(),partition.getSlotRanges()); } } } Future<Void> f=e.setupMasterEntry(config.getMasterAddress().getHost(),config.getMasterAddress().getPort()); f.addListener(new FutureListener<Void>(){ @Override public void operationComplete( Future<Void> future) throws Exception { if (!future.isSuccess()) { return; } for ( ClusterSlotRange slotRange : partition.getSlotRanges()) { addEntry(slotRange,e); lastPartitions.put(slotRange,partition); } log.info("master: {} added for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); } } ); futures.add(f); result.setSuccess(futures); } } ); } } to { @Override public void operationComplete( Future<RedisConnection> future) throws Exception { if (!future.isSuccess()) { log.error("Can't connect to master: {} with slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); result.setFailure(future.cause()); return; } final RedisConnection connection=future.getNow(); Future<Map<String,String>> clusterFuture=connection.async(RedisCommands.CLUSTER_INFO); clusterFuture.addListener(new FutureListener<Map<String,String>>(){ @Override public void operationComplete( Future<Map<String,String>> future) throws Exception { if (!future.isSuccess()) { log.error("Can't execute CLUSTER_INFO for " + connection.getRedisClient().getAddr(),future.cause()); result.setFailure(future.cause()); return; } Map<String,String> params=future.getNow(); if ("fail".equals(params.get("cluster_state"))) { RedisException e=new RedisException("Failed to add master: " + partition.getMasterAddress() + " for slot ranges: "+ partition.getSlotRanges()+ ". Reason - cluster_state:fail"); log.error("cluster_state:fail for " + connection.getRedisClient().getAddr()); result.setFailure(e); return; } MasterSlaveServersConfig config=create(cfg); config.setMasterAddress(partition.getMasterAddress()); final MasterSlaveEntry e; List<Future<Void>> futures=new ArrayList<Future<Void>>(); if (config.getReadMode() == ReadMode.MASTER) { e=new SingleEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); } else { config.setSlaveAddresses(partition.getSlaveAddresses()); e=new MasterSlaveEntry(partition.getSlotRanges(),ClusterConnectionManager.this,config); List<Future<Void>> fs=e.initSlaveBalancer(partition.getFailedSlaveAddresses()); futures.addAll(fs); if (!partition.getSlaveAddresses().isEmpty()) { log.info("slaves: {} added for slot ranges: {}",partition.getSlaveAddresses(),partition.getSlotRanges()); if (!partition.getFailedSlaveAddresses().isEmpty()) { log.warn("slaves: {} is down for slot ranges: {}",partition.getFailedSlaveAddresses(),partition.getSlotRanges()); } } } Future<Void> f=e.setupMasterEntry(config.getMasterAddress().getHost(),config.getMasterAddress().getPort()); final Promise<Void> initFuture=newPromise(); futures.add(initFuture); f.addListener(new FutureListener<Void>(){ @Override public void operationComplete( Future<Void> future) throws Exception { if (!future.isSuccess()) { log.error("Can't add master: {} for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); initFuture.setFailure(future.cause()); return; } for ( Integer slot : partition.getSlots()) { addEntry(slot,e); lastPartitions.put(slot,partition); } log.info("master: {} added for slot ranges: {}",partition.getMasterAddress(),partition.getSlotRanges()); initFuture.setSuccess(null); } } ); result.setSuccess(futures); } } ); } }
- Cascading Type Change (Similar)
- Update String Literal
- Cascading Type Change (Different)