Searched refs:managedConn (Results 1 – 6 of 6) sorted by relevance
64 protected ManagedClientConnection managedConn; field in BasicManagedEntity89 this.managedConn = conn; in BasicManagedEntity()113 if (managedConn == null) in consumeContent()120 managedConn.markReusable(); in consumeContent()148 if (managedConn != null) { in abortConnection()150 managedConn.abortConnection(); in abortConnection()152 managedConn = null; in abortConnection()163 if (attemptReuse && (managedConn != null)) { in eofDetected()167 managedConn.markReusable(); in eofDetected()181 if (attemptReuse && (managedConn != null)) { in streamClosed()[all …]
58 protected ManagedClientConnection managedConn; field in BasicEofSensorWatcher77 managedConn = conn; in BasicEofSensorWatcher()91 managedConn.markReusable(); in eofDetected()94 managedConn.releaseConnection(); in eofDetected()109 managedConn.markReusable(); in streamClosed()112 managedConn.releaseConnection(); in streamClosed()122 managedConn.abortConnection(); in streamAbort()
178 protected ManagedClientConnection managedConn; field in DefaultRequestDirector271 this.managedConn = null; in DefaultRequestDirector()385 if (managedConn == null) { in execute()393 managedConn = connRequest.getConnection(timeout, TimeUnit.MILLISECONDS); in execute()402 if (managedConn.isOpen()) { in execute()404 if (managedConn.isStale()) { in execute()406 managedConn.close(); in execute()413 ((AbortableHttpRequest) orig).setReleaseTrigger(managedConn); in execute()417 if (!managedConn.isOpen()) { in execute()418 managedConn.open(route, context, params); in execute()[all …]
157 protected ManagedClientConnection managedConn; field in DefaultRequestDirector242 this.managedConn = null; in DefaultRequestDirector()324 if (managedConn == null) { in execute()332 managedConn = connRequest.getConnection(timeout, TimeUnit.MILLISECONDS); in execute()342 if (managedConn.isStale()) { in execute()346 managedConn.close(); in execute()361 ((AbortableHttpRequest) orig).setReleaseTrigger(managedConn); in execute()365 if (!managedConn.isOpen()) { in execute()366 managedConn.open(route, context, params); in execute()371 managedConn.setSocketTimeout(HttpConnectionParams.getSoTimeout(params)); in execute()[all …]
97 protected ConnAdapter managedConn; field in SingleClientConnManager130 this.managedConn = null; in SingleClientConnManager()223 if (managedConn != null)271 managedConn = new ConnAdapter(uniquePoolEntry, route);273 return managedConn;331 managedConn = null;356 if ((managedConn == null) && uniquePoolEntry.connection.isOpen()) {376 if (managedConn != null)377 managedConn.detach();396 if (managedConn == null)[all …]
1628 field @Deprecated protected org.apache.http.conn.ManagedClientConnection managedConn;1640 field @Deprecated protected org.apache.http.conn.ManagedClientConnection managedConn;2596 field @Deprecated protected org.apache.http.conn.ManagedClientConnection managedConn;2819 …ld @Deprecated protected org.apache.http.impl.conn.SingleClientConnManager.ConnAdapter managedConn;