svn commit: r1516633 - in /hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase: MockRegionServerServices.java util/MockRegionServerServices.java

[jm...@apache.org]

Author: jmhsieh
Date: Thu Aug 22 21:58:28 2013
New Revision: 1516633

URL: http://svn.apache.org/r1516633
Log:
HBASE-9274 ADDENDUM - forgot to include move MockRegionServerServices in commit

Added:
    hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/MockRegionServerServices.java
Removed:
    hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MockRegionServerServices.java

Added: hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/MockRegionServerServices.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/MockRegionServerServices.java?rev=1516633&view=auto
==============================================================================
--- hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/MockRegionServerServices.java (added)
+++ hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/MockRegionServerServices.java Thu Aug 22 21:58:28 2013
@@ -0,0 +1,215 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentSkipListMap;
+
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.hbase.catalog.CatalogTracker;
+import org.apache.hadoop.hbase.executor.ExecutorService;
+import org.apache.hadoop.hbase.fs.HFileSystem;
+import org.apache.hadoop.hbase.ipc.RpcServerInterface;
+import org.apache.hadoop.hbase.master.TableLockManager;
+import org.apache.hadoop.hbase.master.TableLockManager.NullTableLockManager;
+import org.apache.hadoop.hbase.regionserver.CompactionRequestor;
+import org.apache.hadoop.hbase.regionserver.FlushRequester;
+import org.apache.hadoop.hbase.regionserver.HRegion;
+import org.apache.hadoop.hbase.regionserver.Leases;
+import org.apache.hadoop.hbase.regionserver.RegionServerAccounting;
+import org.apache.hadoop.hbase.regionserver.RegionServerServices;
+import org.apache.hadoop.hbase.regionserver.wal.HLog;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher;
+import org.apache.zookeeper.KeeperException;
+
+/**
+ * Basic mock region server services.  Should only be instantiated by HBaseTestingUtility.b
+ */
+class MockRegionServerServices implements RegionServerServices {
+  private final Map<String, HRegion> regions = new HashMap<String, HRegion>();
+  private boolean stopping = false;
+  private final ConcurrentSkipListMap<byte[], Boolean> rit =
+    new ConcurrentSkipListMap<byte[], Boolean>(Bytes.BYTES_COMPARATOR);
+  private HFileSystem hfs = null;
+  private ZooKeeperWatcher zkw = null;
+  private ServerName serverName = null;
+  private RpcServerInterface rpcServer = null;
+
+  MockRegionServerServices(ZooKeeperWatcher zkw) {
+    this.zkw = zkw;
+  }
+  
+  MockRegionServerServices(ZooKeeperWatcher zkw, ServerName serverName) {
+    this.zkw = zkw;
+    this.serverName = serverName;
+  }
+
+  MockRegionServerServices(){
+    this(null);
+  }
+
+  @Override
+  public boolean removeFromOnlineRegions(HRegion r, ServerName destination) {
+    return this.regions.remove(r.getRegionInfo().getEncodedName()) != null;
+  }
+
+  @Override
+  public HRegion getFromOnlineRegions(String encodedRegionName) {
+    return this.regions.get(encodedRegionName);
+  }
+
+  public List<HRegion> getOnlineRegions(TableName tableName) throws IOException {
+    return null;
+  }
+
+  @Override
+  public void addToOnlineRegions(HRegion r) {
+    this.regions.put(r.getRegionInfo().getEncodedName(), r);
+  }
+
+  @Override
+  public void postOpenDeployTasks(HRegion r, CatalogTracker ct)
+      throws KeeperException, IOException {
+    addToOnlineRegions(r);
+  }
+
+  @Override
+  public boolean isStopping() {
+    return this.stopping;
+  }
+
+  @Override
+  public RpcServerInterface getRpcServer() {
+    return rpcServer;
+  }
+
+  public void setRpcServer(RpcServerInterface rpc) {
+    this.rpcServer = rpc;
+  }
+  
+  @Override
+  public ConcurrentSkipListMap<byte[], Boolean> getRegionsInTransitionInRS() {
+    return rit;
+  }
+
+  @Override
+  public FlushRequester getFlushRequester() {
+    return null;
+  }
+
+  @Override
+  public CompactionRequestor getCompactionRequester() {
+    return null;
+  }
+
+  @Override
+  public CatalogTracker getCatalogTracker() {
+    return null;
+  }
+
+  @Override
+  public ZooKeeperWatcher getZooKeeper() {
+    return zkw;
+  }
+
+  public RegionServerAccounting getRegionServerAccounting() {
+    return null;
+  }
+
+  @Override
+  public TableLockManager getTableLockManager() {
+    return new NullTableLockManager();
+  }
+
+  @Override
+  public ServerName getServerName() {
+    return this.serverName;
+  }
+
+  @Override
+  public Configuration getConfiguration() {
+    return null;
+  }
+
+  @Override
+  public void abort(String why, Throwable e) {
+     //no-op
+  }
+
+  @Override
+  public void stop(String why) {
+    //no-op
+  }
+
+  @Override
+  public boolean isStopped() {
+    return false;
+  }
+
+  @Override
+  public boolean isAborted() {
+    return false;
+  }
+
+  @Override
+  public HFileSystem getFileSystem() {
+    return this.hfs;
+  }
+
+  public void setFileSystem(FileSystem hfs) {
+    this.hfs = (HFileSystem)hfs;
+  }
+
+  @Override
+  public Leases getLeases() {
+    return null;
+  }
+
+  @Override
+  public HLog getWAL(HRegionInfo regionInfo) throws IOException {
+    // TODO Auto-generated method stub
+    return null;
+  }
+
+  @Override
+  public ExecutorService getExecutorService() {
+    return null;
+  }
+
+  @Override
+  public void updateRegionFavoredNodesMapping(String encodedRegionName,
+      List<org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ServerName> favoredNodes) {
+  }
+
+  @Override
+  public InetSocketAddress[] getFavoredNodesForRegion(String encodedRegionName) {
+    return null;
+  }
+
+  @Override
+  public Map<String, HRegion> getRecoveringRegions() {
+    // TODO Auto-generated method stub
+    return null;
+  }
+}