|
@@ -155,10 +155,6 @@ public class PeerCache {
|
|
|
|
|
|
private synchronized Peer getInternal(DatanodeID dnId, boolean isDomain) {
|
|
private synchronized Peer getInternal(DatanodeID dnId, boolean isDomain) {
|
|
List<Value> sockStreamList = multimap.get(new Key(dnId, isDomain));
|
|
List<Value> sockStreamList = multimap.get(new Key(dnId, isDomain));
|
|
- if (sockStreamList == null) {
|
|
|
|
- return null;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
Iterator<Value> iter = sockStreamList.iterator();
|
|
Iterator<Value> iter = sockStreamList.iterator();
|
|
while (iter.hasNext()) {
|
|
while (iter.hasNext()) {
|
|
Value candidate = iter.next();
|
|
Value candidate = iter.next();
|