add ctors

Alluxio · May 16, 2016 · db6712e · db6712e
1 parent 4d20daa
commit db6712e
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 3 deletions.
diff --git a/core/client/src/main/java/alluxio/client/block/BlockMasterClientPool.java b/core/client/src/main/java/alluxio/client/block/BlockMasterClientPool.java
@@ -38,6 +38,17 @@ public BlockMasterClientPool(InetSocketAddress masterAddress) {
     mMasterAddress = masterAddress;
   }
 
+  /**
+   * Creates a new block master client pool.
+   *
+   * @param masterAddress the master address
+   * @param clientThreads the number of client threads to use
+   */
+  public BlockMasterClientPool(InetSocketAddress masterAddress, int clientThreads) {
+    super(clientThreads);
+    mMasterAddress = masterAddress;
+  }
+
   @Override
   public void close() {
     // TODO(calvin): Consider collecting all the clients and shutting them down.

diff --git a/core/client/src/main/java/alluxio/client/file/FileSystemMasterClientPool.java b/core/client/src/main/java/alluxio/client/file/FileSystemMasterClientPool.java
@@ -19,12 +19,15 @@
 
 import javax.annotation.concurrent.ThreadSafe;
 
+/**
+ * A fixed pool of FileSystemMasterClient instances.
+ */
 @ThreadSafe
-final class FileSystemMasterClientPool extends ResourcePool<FileSystemMasterClient> {
+public final class FileSystemMasterClientPool extends ResourcePool<FileSystemMasterClient> {
   private final InetSocketAddress mMasterAddress;
 
   /**
-   * Creates a new file stream master client pool.
+   * Creates a new file system master client pool.
    *
    * @param masterAddress the master address
    */
@@ -33,6 +36,17 @@ public FileSystemMasterClientPool(InetSocketAddress masterAddress) {
     mMasterAddress = masterAddress;
   }
 
+  /**
+   * Creates a new file system master client pool.
+   *
+   * @param masterAddress the master address
+   * @param clientThreads the number of client threads to use
+   */
+  public FileSystemMasterClientPool(InetSocketAddress masterAddress, int clientThreads) {
+    super(clientThreads);
+    mMasterAddress = masterAddress;
+  }
+
   @Override
   public void close() {
     // TODO(calvin): Consider collecting all the clients and shutting them down

diff --git a/core/common/src/main/java/alluxio/Constants.java b/core/common/src/main/java/alluxio/Constants.java
@@ -52,7 +52,7 @@ public final class Constants {
   public static final String MESOS_RESOURCE_DISK = "disk";
   public static final String MESOS_RESOURCE_PORTS = "ports";
 
-  public static final int SECOND_NANO = 1000000000;
+  public static final long SECOND_NANO = 1000000000;
   public static final int SECOND_MS = 1000;
   public static final int MINUTE_MS = SECOND_MS * 60;
   public static final int HOUR_MS = MINUTE_MS * 60;