Home
last modified time | relevance | path

Searched refs:_exchange (Results 1 – 6 of 6) sorted by relevance

/external/jetty/src/java/org/eclipse/jetty/client/
DAbstractHttpConnection.java66 protected volatile HttpExchange _exchange; field in AbstractHttpConnection
105 if (_exchange != null) in send()
108 throw new IllegalStateException(this + " PIPELINED!!! _exchange=" + _exchange); in send()
113 _exchange = ex; in send()
114 _exchange.associate(this); in send()
119 _exchange.disassociate(); in send()
120 _exchange = null; in send()
124 _exchange.setStatus(HttpExchange.STATUS_WAITING_FOR_COMMIT); in send()
139 long timeout = _exchange.getTimeout(); in adjustIdleTimeout()
161 return _exchange == null; in isIdle()
[all …]
DRedirectListener.java35 private final HttpExchange _exchange; field in RedirectListener
50 _exchange = ex; in RedirectListener()
119 _exchange.setURL(_location); in checkExchangeComplete()
123 _exchange.setRequestURI(_location); in checkExchangeComplete()
127 boolean isHttps = HttpSchemes.HTTPS.equals(String.valueOf(_exchange.getScheme())); in checkExchangeComplete()
128 …HttpDestination destination=_destination.getHttpClient().getDestination(_exchange.getAddress(),isH… in checkExchangeComplete()
132 _destination.resend(_exchange); in checkExchangeComplete()
144 _exchange.getEventListener().onRetry(); in checkExchangeComplete()
145 _exchange.reset(); in checkExchangeComplete()
146 _exchange.setEventListener(listener); in checkExchangeComplete()
[all …]
DBlockingHttpConnection.java118 exchange=_exchange; in handle()
124 exchange=_exchange; in handle()
200 LOG.debug("Failure on " + _exchange, e); in handle()
247 exchange=_exchange; in handle()
248 _exchange = null; in handle()
281 _exchange=_pipeline; in handle()
285 … if (_exchange==null && !isReserved()) // TODO how do we return switched connections? in handle()
DAsyncHttpConnection.java74 HttpExchange exchange=_exchange; in handle()
153 LOG.debug("Failure on " + _exchange, e); in handle()
199 exchange=_exchange; in handle()
200 _exchange = null; in handle()
233 _exchange=_pipeline; in handle()
237 … if (_exchange==null && !isReserved()) // TODO how do we return switched connections? in handle()
249 LOG.debug("unhandle {} on {}",_exchange,_endp); in handle()
/external/jetty/src/java/org/eclipse/jetty/client/webdav/
DWebdavListener.java47 private HttpExchange _exchange; field in WebdavListener
59 _exchange=ex; in WebdavListener()
62 if ( HttpMethods.PUT.equalsIgnoreCase( _exchange.getMethod() ) ) in WebdavListener()
128 _destination.resend(_exchange); in onResponseComplete()
177 _destination.resend(_exchange); in onRequestComplete()
220 String uri = _exchange.getURI(); in resolveCollectionIssues()
221 String[] uriCollection = _exchange.getURI().split("/"); in resolveCollectionIssues()
259 propfindExchange.setAddress( _exchange.getAddress() ); in checkExists()
261 propfindExchange.setScheme( _exchange.getScheme() ); in checkExists()
284 mkcolExchange.setAddress( _exchange.getAddress() ); in makeCollection()
[all …]
/external/jetty/src/java/org/eclipse/jetty/client/security/
DSecurityListener.java48 private HttpExchange _exchange; field in SecurityListener
61 _exchange=ex; in SecurityListener()
208 … LOG.debug("onRequestComplete, Both complete: Resending from onResponseComplete "+_exchange); in onRequestComplete()
213 _destination.resend(_exchange); in onRequestComplete()
218 …ug("onRequestComplete, Response not yet complete onRequestComplete, calling super for "+_exchange); in onRequestComplete()
225 …r with Request complete="+_requestComplete+", response complete="+_responseComplete+" "+_exchange); in onRequestComplete()
240 … LOG.debug("onResponseComplete, Both complete: Resending from onResponseComplete"+_exchange); in onResponseComplete()
245 _destination.resend(_exchange); in onResponseComplete()
251 …"onResponseComplete, Request not yet complete from onResponseComplete, calling super "+_exchange); in onResponseComplete()
258 …r with Request complete="+_requestComplete+", response complete="+_responseComplete+" "+_exchange); in onResponseComplete()