| /external/jetty/src/java/org/eclipse/jetty/server/ |
| HttpInput.java | 31 protected final AbstractHttpConnection _connection; field in class:HttpInput
37 _connection=connection;
61 Buffer content=_parser.blockForContent(_connection.getMaxIdleTime());
64 else if (_connection.isEarlyEOF())
|
| Response.java | 95 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.getRequest(),_connection.getRequest(),this )
[all...] |
| AsyncContinuation.java | 84 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.getRequest()
[all...] |
| HttpOutput.java | 44 protected final AbstractHttpConnection _connection; field in class:HttpOutput
58 _connection=connection;
65 return _connection.getMaxIdleTime();
165 _connection.commitResponse(Generator.MORE);
|
| Request.java | 189 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.getRequestFields().getValues(HttpHeaders.COOKIE_BUFFER)
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/util/resource/ |
| URLResource.java | 43 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.getLastModified()
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/server/bio/ |
| SocketConnector.java | 193 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).getRequest().getAsyncContinuation().cancel()
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| WebSocketConnectionD06.java | 105 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.getMaxBinaryMessageSize()>=0
[all...] |
| WebSocketConnectionD08.java | 112 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.getMaxTextMessageSize()<=0
[all...] |
| WebSocketConnectionRFC6455.java | 144 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.getMaxTextMessageSize())
[all...] |
| AbstractExtension.java | 36 private WebSocket.FrameConnection _connection; field in class:AbstractExtension
45 return _connection;
77 _connection=connection;
|
| WebSocketClient.java | 400 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/ |
| BlockingChannelConnector.java | 176 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/jetty/src/java/org/eclipse/jetty/io/nio/ |
| SelectChannelEndPoint.java | 65 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...] |
| SslConnection.java | 57 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/autotest/database/ |
| database_connection.py | 31 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.cursor(
[all...] |
| /external/webrtc/webrtc/modules/video_capture/ios/ |
| rtc_video_capture_ios_objc.mm | 35 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/ |
| ByteArrayEndPoint.java | 38 protected Connection _connection; field in class:ByteArrayEndPoint
56 return _connection;
65 _connection=connection;
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/ecs/ |
| item.py | 34 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)
|
| /system/bt/vendor_libs/test_vendor_lib/scripts/ |
| test_channel.py | 85 self._connection = Connection(port)
94 self._connection.close()
103 self._connection.send(command)
|
| /external/jetty/src/java/org/eclipse/jetty/client/ |
| HttpExchange.java | 110 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;
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/ |
| xmlrpclib.py | [all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/ |
| xmlrpclib.py | [all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| xmlrpclib.py | [all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| xmlrpclib.py | [all...] |
