[20/50] hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[aengineer]

HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8133cd53
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8133cd53
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8133cd53

Branch: refs/heads/HDFS-7240
Commit: 8133cd5305d7913453abb2d48da12f672c0ce334
Parents: afe1a3c
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:25:05 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/8133cd53/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 5c77c59..5af8a86 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+for (int i = 0; i < remainingSlots; i++) {
+  ConnectionContext cc = pool.getConnection();
+  assertTrue(cc.isUsable());
+  cc.getClient();
+  

[22/50] hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[arp]

HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8133cd53
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8133cd53
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8133cd53

Branch: refs/heads/HDFS-12996
Commit: 8133cd5305d7913453abb2d48da12f672c0ce334
Parents: afe1a3c
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:25:05 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/8133cd53/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 5c77c59..5af8a86 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+for (int i = 0; i < remainingSlots; i++) {
+  ConnectionContext cc = pool.getConnection();
+  assertTrue(cc.isUsable());
+  cc.getClient();
+ 

hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[inigoiri]

Repository: hadoop
Updated Branches:
  refs/heads/branch-2 4b6b07690 -> 0dadcf9ea


HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.

(cherry picked from commit 8133cd5305d7913453abb2d48da12f672c0ce334)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/0dadcf9e
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/0dadcf9e
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/0dadcf9e

Branch: refs/heads/branch-2
Commit: 0dadcf9ea376752a98173d2878dda942826634c0
Parents: 4b6b076
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:28:59 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/0dadcf9e/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 0b10187..06bed9c 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+for 

hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[inigoiri]

Repository: hadoop
Updated Branches:
  refs/heads/branch-2.9 40682baae -> a3c47eba7


HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.

(cherry picked from commit 8133cd5305d7913453abb2d48da12f672c0ce334)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/a3c47eba
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/a3c47eba
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/a3c47eba

Branch: refs/heads/branch-2.9
Commit: a3c47eba7f73cf979ecf2d7c4b0f8d6ab081860e
Parents: 40682ba
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:28:28 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/a3c47eba/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 0b10187..06bed9c 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+

hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[inigoiri]

Repository: hadoop
Updated Branches:
  refs/heads/branch-3.0 c453fcb23 -> 465c3f0e2


HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.

(cherry picked from commit 8133cd5305d7913453abb2d48da12f672c0ce334)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/465c3f0e
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/465c3f0e
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/465c3f0e

Branch: refs/heads/branch-3.0
Commit: 465c3f0e24a1fc5a6768d6e922cf2fd1c84ce176
Parents: c453fcb
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:27:17 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/465c3f0e/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 5c77c59..5af8a86 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+

hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[inigoiri]

Repository: hadoop
Updated Branches:
  refs/heads/branch-3.1 4d41f933a -> 86a1c8975


HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.

(cherry picked from commit 8133cd5305d7913453abb2d48da12f672c0ce334)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/86a1c897
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/86a1c897
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/86a1c897

Branch: refs/heads/branch-3.1
Commit: 86a1c89754db4d925afe1140e6af56cb9f3bc4cc
Parents: 4d41f93
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:25:46 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/86a1c897/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 5c77c59..5af8a86 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+

hadoop git commit: HDFS-13232. RBF: ConnectionPool should return first usable connection. Contributed by Ekanth S.

[inigoiri]

Repository: hadoop
Updated Branches:
  refs/heads/trunk afe1a3ccd -> 8133cd530


HDFS-13232. RBF: ConnectionPool should return first usable connection. 
Contributed by Ekanth S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8133cd53
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8133cd53
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8133cd53

Branch: refs/heads/trunk
Commit: 8133cd5305d7913453abb2d48da12f672c0ce334
Parents: afe1a3c
Author: Inigo Goiri 
Authored: Fri Mar 9 18:25:05 2018 -0800
Committer: Inigo Goiri 
Committed: Fri Mar 9 18:25:05 2018 -0800

--
 .../federation/router/ConnectionPool.java   |  2 +-
 .../router/TestConnectionManager.java   | 43 
 2 files changed, 44 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/8133cd53/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
index 5c77c59..5af8a86 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ConnectionPool.java
@@ -159,7 +159,7 @@ public class ConnectionPool {
 for (int i=0; i poolMap = connManager.getPools();
+final int totalConns = 10;
+int activeConns = 5;
+
+ConnectionPool pool = new ConnectionPool(
+conf, TEST_NN_ADDRESS, TEST_USER1, 0, 10);
+addConnectionsToPool(pool, totalConns, activeConns);
+poolMap.put(new ConnectionPoolId(TEST_USER1, TEST_NN_ADDRESS), pool);
+
+// All remaining connections should be usable
+final int remainingSlots = totalConns - activeConns;
+for (int i = 0; i < remainingSlots; i++) {
+  ConnectionContext cc =