public IoSession getActiveSession()

in client/src/main/java/org/apache/ahc/ConnectionPool.java [54:72]

• 16 lines of code
• 6 McCabe index (conditional complexity)

    public IoSession getActiveSession(HttpRequestMessage msg) {
        if (msg == null) {
            throw new IllegalArgumentException("null request was passed in");
        }
        
        Queue<IoSession> queue = pooledSessions.get(getKey(msg));
        if (queue == null) {
            return null;
        }
        
        IoSession pooled = null;
        while ((pooled = queue.poll()) != null) {
        	// see if the session is usable
            if (pooled.isConnected() && !pooled.isClosing()) {
                return pooled;
            }
        }
        return null;
    }