Searched refs:_connection (Results 1 - 25 of 30) sorted by relevance

12

/external/jetty/src/java/org/eclipse/jetty/server/
H A DHttpInput.java31 protected final AbstractHttpConnection _connection; field in class:HttpInput
37 _connection=connection;
61 Buffer content=_parser.blockForContent(_connection.getMaxIdleTime());
64 else if (_connection.isEarlyEOF())
H A DResponse.java95 private final AbstractHttpConnection _connection; field in class:Response
113 _connection=connection;
141 _connection.getResponseFields().addSetCookie(cookie);
164 _connection.getResponseFields().addSetCookie(cookie.getName(),
181 return _connection.getResponseFields().containsKey(name);
190 final Request request=_connection.getRequest();
311 if (_connection.isIncluding())
337 Request request = _connection.getRequest();
344 error_handler = _connection.getConnector().getServer().getBean(ErrorHandler.class);
351 error_handler.handle(null,_connection
[all...]
H A DAsyncContinuation.java84 protected AbstractHttpConnection _connection; field in class:AsyncContinuation
112 _connection=connection;
515 _connection.getRequest().setAttribute(RequestDispatcher.ERROR_EXCEPTION,e);
730 EndPoint endp=_connection.getEndPoint();
740 EndPoint endp=_connection.getEndPoint();
749 while (_expireAt>0 && wait>0 && _connection.getServer().isRunning())
762 if (_expireAt>0 && wait<=0 && _connection.getServer().isRunning())
778 EndPoint endp=_connection.getEndPoint();
882 return _connection.getRequest();
890 return _connection
[all...]
H A DHttpOutput.java44 protected final AbstractHttpConnection _connection; field in class:HttpOutput
58 _connection=connection;
65 return _connection.getMaxIdleTime();
165 _connection.commitResponse(Generator.MORE);
H A DRequest.java189 protected AbstractHttpConnection _connection; field in class:Request
320 Object obj = _connection.getConnector().getServer().getAttribute("org.eclipse.jetty.server.Request.maxFormContentSize");
336 Object obj = _connection.getConnector().getServer().getAttribute("org.eclipse.jetty.server.Request.maxFormKeys");
508 return _connection;
517 return (int)_connection.getRequestFields().getLongField(HttpHeaders.CONTENT_LENGTH_BUFFER);
522 if (_connection == null || _connection.getParser() == null)
525 return ((HttpParser)_connection.getParser()).getContentRead();
534 return _connection.getRequestFields().getStringField(HttpHeaders.CONTENT_TYPE_BUFFER);
566 Enumeration enm = _connection
[all...]
/external/jetty/src/java/org/eclipse/jetty/util/resource/
H A DURLResource.java43 protected URLConnection _connection; field in class:URLResource
52 _connection=connection;
65 if (_connection==null)
68 _connection=_url.openConnection();
69 _connection.setUseCaches(_useCaches);
76 return _connection!=null;
91 if (_connection!=null)
92 _connection=null;
107 _in = _connection.getInputStream();
138 return _connection
[all...]
H A DJarResource.java71 if (_jarConnection!=_connection)
89 _jarConnection=(JarURLConnection)_connection;
H A DFileResource.java112 Permission perm = _connection.getPermission();
/external/jetty/src/java/org/eclipse/jetty/server/bio/
H A DSocketConnector.java193 volatile Connection _connection; field in class:SocketConnector.ConnectorEndPoint
199 _connection = newConnection(this);
205 return _connection;
210 if (_connection!=connection && _connection!=null)
211 connectionUpgraded(_connection,connection);
212 _connection=connection;
219 LOG.warn("dispatch failed for {}",_connection);
241 if (_connection instanceof AbstractHttpConnection)
242 ((AbstractHttpConnection)_connection)
[all...]
/external/jetty/src/java/org/eclipse/jetty/websocket/
H A DWebSocketConnectionD06.java105 private final WebSocket.FrameConnection _connection = new FrameConnectionD06(); field in class:WebSocketConnectionD06
132 return _connection;
269 final WebSocket.Connection connection = _connection;
299 _onFrame.onHandshake(_connection);
305 _webSocket.onOpen(_connection);
562 if (_opcode==WebSocketConnectionD06.OP_TEXT && _connection.getMaxTextMessageSize()>=0)
564 if (_utf8.append(buffer.array(),buffer.getIndex(),buffer.length(),_connection.getMaxTextMessageSize()))
577 _connection.close(WebSocketConnectionD06.CLOSE_LARGE,"Text message size > "+_connection.getMaxTextMessageSize()+" chars");
582 else if (_opcode>=0 && _connection
[all...]
H A DWebSocketConnectionD08.java112 private final WebSocket.FrameConnection _connection = new WSFrameConnection(); field in class:WebSocketConnectionD08
148 _connection,
167 return _connection;
353 final WebSocket.Connection connection = _connection;
377 _onFrame.onHandshake(_connection);
383 _webSocket.onOpen(_connection);
645 if (_utf8.append(buffer.array(),buffer.getIndex(),buffer.length(),_connection.getMaxTextMessageSize()))
660 if (_opcode>=0 && _connection.getMaxBinaryMessageSize()>=0)
687 _connection.sendControl(WebSocketConnectionD08.OP_PONG,buffer.array(),buffer.getIndex(),buffer.length());
715 if (_connection
[all...]
H A DWebSocketConnectionRFC6455.java144 private final WebSocket.FrameConnection _connection = new WSFrameConnection(); field in class:WebSocketConnectionRFC6455
180 _connection,
199 return _connection;
395 final WebSocket.Connection connection = _connection;
419 _onFrame.onHandshake(_connection);
425 _webSocket.onOpen(_connection);
714 if (_utf8.append(buffer.array(),buffer.getIndex(),buffer.length(),_connection.getMaxTextMessageSize()))
729 if (_opcode>=0 && _connection.getMaxBinaryMessageSize()>=0)
757 _connection.sendControl(WebSocketConnectionRFC6455.OP_PONG,buffer.array(),buffer.getIndex(),buffer.length());
790 if(_utf8.append(buffer.array(),buffer.getIndex()+2,buffer.length()-2,_connection
[all...]
H A DAbstractExtension.java36 private WebSocket.FrameConnection _connection; field in class:AbstractExtension
45 return _connection;
77 _connection=connection;
H A DWebSocketClient.java400 WebSocketConnection _connection; field in class:WebSocketClient.WebSocketFuture
424 _connection=connection;
425 con=_connection;
519 if (_connection==null && _exception==null && _channel!=null)
543 return _channel==null && _connection==null;
551 return _connection!=null && _exception==null;
577 if (_connection==null)
584 connection=_connection.getConnection();
/external/jetty/src/java/org/eclipse/jetty/server/nio/
H A DBlockingChannelConnector.java176 private Connection _connection; field in class:BlockingChannelConnector.BlockingChannelEndPoint
184 _connection = new BlockingHttpConnection(BlockingChannelConnector.this,this,getServer());
193 return _connection;
199 _connection=connection;
229 LOG.warn("dispatch failed for {}",_connection);
273 connectionOpened(_connection);
279 if (_connection.isIdle())
298 _connection = _connection.handle();
322 connectionClosed(_connection);
[all...]
/external/autotest/database/
H A Ddatabase_connection.py31 self._connection = None
45 if self._connection:
46 self._connection.close()
47 self._connection = None
76 self._connection = self._database_module.connect(
79 self._connection.autocommit(True)
80 self._cursor = self._connection.cursor()
95 self._connection = self._database_module.connect(db_name)
96 self._connection.isolation_level = None # enable autocommit
97 self._cursor = self._connection
[all...]
/external/jetty/src/java/org/eclipse/jetty/io/nio/
H A DSelectChannelEndPoint.java65 private volatile AsyncConnection _connection; field in class:SelectChannelEndPoint
129 return _connection;
135 Connection old=_connection;
136 _connection=(AsyncConnection)connection;
137 if (old!=null && old!=_connection)
351 _connection.onIdleExpired(idleForMs);
585 boolean read_interest = _readBlocked || (_state<STATE_DISPATCHED && !_connection.isSuspended());
696 final AsyncConnection next = (AsyncConnection)_connection.handle();
697 if (next!=_connection)
699 LOG.debug("{} replaced {}",next,_connection);
[all...]
H A DSslConnection.java57 private AsyncConnection _connection; field in class:SslConnection
196 AsyncConnection next = (AsyncConnection)_connection.handle();
197 if (next!=_connection && next!=null)
199 _connection=next;
215 _connection.onInputShutdown();
419 if (toFill==_unwrapBuf && _unwrapBuf.hasContent() && !_connection.isSuspended())
838 return _connection;
843 _connection=(AsyncConnection)connection;
861 _connection);
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/ecs/
H A Ditem.py34 self._connection = connection
62 obj = ResponseGroup(self._connection)
114 self.curItem = Item(self._connection)
150 self._connection.get_response(self.action, self.params, self.page, self)
/external/webrtc/webrtc/modules/video_capture/ios/
H A Drtc_video_capture_ios_objc.mm35 AVCaptureConnection* _connection;
235 _connection = [currentOutput connectionWithMediaType:AVMediaTypeVideo];
246 if (!_connection.supportsVideoOrientation) {
252 _connection.videoOrientation =
256 _connection.videoOrientation =
260 _connection.videoOrientation =
264 _connection.videoOrientation =
271 _connection.videoOrientation =
/external/jetty/src/java/org/eclipse/jetty/io/
H A DByteArrayEndPoint.java38 protected Connection _connection; field in class:ByteArrayEndPoint
56 return _connection;
65 _connection=connection;
/external/jetty/src/java/org/eclipse/jetty/client/
H A DHttpExchange.java110 private volatile AbstractHttpConnection _connection; field in class:HttpExchange
128 AbstractHttpConnection connection = _connection;
796 AbstractHttpConnection httpConnection = _connection;
821 _connection = connection;
828 return this._connection != null;
833 AbstractHttpConnection result = _connection;
834 this._connection = null;
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/fps/
H A Dresponse.py43 self._connection = connection
48 return self._connection
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/sts/
H A Dcredentials.py186 self._connection = connection
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/
H A Dconnection.py566 self._connection = (self.host, self.port, self.is_secure)
598 return self.get_http_connection(*self._connection)
774 self._connection = (host, port, is_secure)
1078 self._connection = None # compat field

Completed in 1646 milliseconds

12