| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ |
| H A D | RegionServerTracker.java | 51 private NavigableMap<ServerName, RegionServerInfo> regionServers = field in RegionServerTracker
79 synchronized(this.regionServers) { in add()
80 this.regionServers.clear(); in add()
83 if (regionServers.get(sn) == null) { in add()
102 this.regionServers.put(sn, rsInfoBuilder.build()); in add()
109 synchronized(this.regionServers) { in remove()
110 this.regionServers.remove(sn); in remove()
148 return regionServers.get(sn); in getRegionServerInfo()
156 synchronized (this.regionServers) { in getOnlineServers()
157 return new ArrayList<ServerName>(this.regionServers.keySet()); in getOnlineServers()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ |
| H A D | Action.java | 90 Collection<ServerName> regionServers = initialStatus.getServers(); in init() local
91 initialServers = regionServers.toArray(new ServerName[regionServers.size()]); in init()
114 Collection<ServerName> regionServers = clusterStatus.getServers(); in getCurrentServers() local
115 int count = regionServers == null ? 0 : regionServers.size(); in getCurrentServers()
120 if (master == null || !regionServers.contains(master)) { in getCurrentServers()
121 return regionServers.toArray(new ServerName[count]); in getCurrentServers()
127 tmp.addAll(regionServers); in getCurrentServers()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/ |
| H A D | HBaseReplicationEndpoint.java | 55 private List<ServerName> regionServers = new ArrayList<ServerName>(0); field in HBaseReplicationEndpoint
179 return regionServers; in getRegionServers()
186 public synchronized void setRegionServers(List<ServerName> regionServers) { in setRegionServers() argument
187 this.regionServers = regionServers; in setRegionServers()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/ |
| H A D | EnabledTableSnapshotHandler.java | 73 Set<String> regionServers = new HashSet<String>(regions.size()); in snapshotRegions() local
78 regionServers.add(region.getSecond().toString()); in snapshotRegions()
84 this.snapshot.toByteArray(), Lists.newArrayList(regionServers)); in snapshotRegions()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/util/ |
| H A D | TestFSVisitor.java | 59 private Set<String> regionServers; field in TestFSVisitor
77 regionServers = new HashSet<String>(); in setUp()
81 createLogs(logsDir, regionServers, serverLogs); in setUp()
133 assertEquals(regionServers, servers); in testVisitLogFiles()
|
| H A D | TestHBaseFsck.java | 817 Collection<ServerName> regionServers = status.getServers(); in getDeployedHRIs() local
820 for (ServerName hsi : regionServers) { in getDeployedHRIs()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/flush/ |
| H A D | MasterFlushTableProcedureManager.java | 139 Set<String> regionServers = new HashSet<String>(regionsAndLocations.size()); in execProcedure() local
144 regionServers.add(region.getSecond().toString()); in execProcedure()
154 new byte[0], Lists.newArrayList(regionServers)); in execProcedure()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/migration/ |
| H A D | UpgradeTo96.java | 171 List<String> regionServers = ZKUtil.listChildrenNoWatch(zkw, zkw.rsZNode); in isAnyHBaseProcessAlive() local
172 if (!regionServers.isEmpty()) { in isAnyHBaseProcessAlive()
173 LOG.warn("Region server(s) " + regionServers + " are alive or rs znodes not expired."); in isAnyHBaseProcessAlive()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-it/src/test/java/org/apache/hadoop/hbase/test/ |
| H A D | IntegrationTestReplication.java | 204 Set<ServerName> regionServers = new TreeSet<>(); in setupTablesAndReplication() local
207 regionServers.add(rl.getServerName()); in setupTablesAndReplication()
210 for (ServerName server : regionServers) { in setupTablesAndReplication()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/ |
| H A D | TestRollingRestart.java | 162 List<RegionServerThread> regionServers = in testBasicRollingRestart() local
165 int total = regionServers.size(); in testBasicRollingRestart()
166 for (RegionServerThread rst : regionServers) { in testBasicRollingRestart()
|
| H A D | TestAssignmentManagerOnCluster.java | 396 List<JVMClusterUtil.RegionServerThread> regionServers = in testMoveRegion() local
398 for (JVMClusterUtil.RegionServerThread regionServer: regionServers) { in testMoveRegion()
1293 int regionServers = services.getServerManager().countOfRegionServers(); in roundRobinAssignment() local
1294 if (regionServers < countRegionServers.intValue()) { in roundRobinAssignment()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/ |
| H A D | RegionLocationFinder.java | 235 Collection<ServerName> regionServers = status.getServers(); in mapHostNameToServerName() local
239 for (ServerName sn : regionServers) { in mapHostNameToServerName()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ |
| H A D | ZkSplitLogWorkerCoordination.java | 337 List<String> regionServers = in calculateAvailableSplitters() local
339 availableRSs = Math.max(availableRSs, (regionServers == null) ? 0 : regionServers.size()); in calculateAvailableSplitters()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/util/ |
| H A D | HBaseFsck.java | 518 Collection<ServerName> regionServers = status.getServers(); in loadDeployedRegions() local
519 errors.print("Number of live region servers: " + regionServers.size()); in loadDeployedRegions()
521 for (ServerName rsinfo: regionServers) { in loadDeployedRegions()
560 processRegionServers(regionServers); in loadDeployedRegions()
|