Home
last modified time | relevance | path

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

12

/external/jetty/src/java/org/eclipse/jetty/server/
DResponse.java95 private final AbstractHttpConnection _connection; field in Response
113 _connection=connection; in Response()
141 _connection.getResponseFields().addSetCookie(cookie); in addCookie()
164 _connection.getResponseFields().addSetCookie(cookie.getName(), in addCookie()
181 return _connection.getResponseFields().containsKey(name); in containsHeader()
190 final Request request=_connection.getRequest(); in encodeURL()
311 if (_connection.isIncluding()) in sendError()
337 Request request = _connection.getRequest(); in sendError()
344 error_handler = _connection.getConnector().getServer().getBean(ErrorHandler.class); in sendError()
351 error_handler.handle(null,_connection.getRequest(),_connection.getRequest(),this ); in sendError()
[all …]
DAsyncContinuation.java84 protected AbstractHttpConnection _connection; field in AsyncContinuation
112 _connection=connection; in setConnection()
515 _connection.getRequest().setAttribute(RequestDispatcher.ERROR_EXCEPTION,e); in expired()
730 EndPoint endp=_connection.getEndPoint(); in scheduleDispatch()
740 EndPoint endp=_connection.getEndPoint(); in scheduleTimeout()
749 while (_expireAt>0 && wait>0 && _connection.getServer().isRunning()) in scheduleTimeout()
762 if (_expireAt>0 && wait<=0 && _connection.getServer().isRunning()) in scheduleTimeout()
778 EndPoint endp=_connection.getEndPoint(); in cancelTimeout()
882 return _connection.getRequest(); in getBaseRequest()
890 return _connection.getRequest(); in getRequest()
[all …]
DHttpInput.java31 protected final AbstractHttpConnection _connection; field in HttpInput
37 _connection=connection; in HttpInput()
61 Buffer content=_parser.blockForContent(_connection.getMaxIdleTime()); in read()
64 else if (_connection.isEarlyEOF()) in read()
DRequest.java189 protected AbstractHttpConnection _connection; field in Request
320 …Object obj = _connection.getConnector().getServer().getAttribute("org.eclipse.jetty.server.Request… in extractParameters()
336 …Object obj = _connection.getConnector().getServer().getAttribute("org.eclipse.jetty.server.Request… in extractParameters()
508 return _connection; in getConnection()
517 return (int)_connection.getRequestFields().getLongField(HttpHeaders.CONTENT_LENGTH_BUFFER); in getContentLength()
522 if (_connection == null || _connection.getParser() == null) in getContentRead()
525 return ((HttpParser)_connection.getParser()).getContentRead(); in getContentRead()
534 return _connection.getRequestFields().getStringField(HttpHeaders.CONTENT_TYPE_BUFFER); in getContentType()
566 Enumeration enm = _connection.getRequestFields().getValues(HttpHeaders.COOKIE_BUFFER); in getCookies()
590 return _connection.getRequestFields().getDateField(name); in getDateHeader()
[all …]
DHttpOutput.java44 protected final AbstractHttpConnection _connection; field in HttpOutput
58 _connection=connection; in HttpOutput()
65 return _connection.getMaxIdleTime(); in getMaxIdleTime()
165 _connection.commitResponse(Generator.MORE); in write()
/external/jetty/src/java/org/eclipse/jetty/util/resource/
DURLResource.java43 protected URLConnection _connection; field in URLResource
52 _connection=connection; in URLResource()
65 if (_connection==null) in checkConnection()
68 _connection=_url.openConnection(); in checkConnection()
69 _connection.setUseCaches(_useCaches); in checkConnection()
76 return _connection!=null; in checkConnection()
91 if (_connection!=null) in release()
92 _connection=null; in release()
107 _in = _connection.getInputStream(); in exists()
138 return _connection.getLastModified(); in lastModified()
[all …]
DJarResource.java71 if (_jarConnection!=_connection) in checkConnection()
89 _jarConnection=(JarURLConnection)_connection; in newConnection()
/external/jetty/src/java/org/eclipse/jetty/server/bio/
DSocketConnector.java193 volatile Connection _connection; field in SocketConnector.ConnectorEndPoint
199 _connection = newConnection(this); in ConnectorEndPoint()
205 return _connection; in getConnection()
210 if (_connection!=connection && _connection!=null) in setConnection()
211 connectionUpgraded(_connection,connection); in setConnection()
212 _connection=connection; in setConnection()
219 LOG.warn("dispatch failed for {}",_connection); in dispatch()
241 if (_connection instanceof AbstractHttpConnection) in close()
242 ((AbstractHttpConnection)_connection).getRequest().getAsyncContinuation().cancel(); in close()
250 connectionOpened(_connection); in run()
[all …]
/external/jetty/src/java/org/eclipse/jetty/websocket/
DWebSocketConnectionD06.java105 private final WebSocket.FrameConnection _connection = new FrameConnectionD06(); field in WebSocketConnectionD06
132 return _connection; in getConnection()
269 final WebSocket.Connection connection = _connection; in shutdown()
299 _onFrame.onHandshake(_connection); in onFrameHandshake()
305 _webSocket.onOpen(_connection); in onWebSocketOpen()
562 … if (_opcode==WebSocketConnectionD06.OP_TEXT && _connection.getMaxTextMessageSize()>=0) in onFrame()
564 …if (_utf8.append(buffer.array(),buffer.getIndex(),buffer.length(),_connection.getMaxTextMessageSiz… in onFrame()
577 …_connection.close(WebSocketConnectionD06.CLOSE_LARGE,"Text message size > "+_connection.getMaxText… in onFrame()
582 else if (_opcode>=0 && _connection.getMaxBinaryMessageSize()>=0) in onFrame()
586 …_connection.close(WebSocketConnectionD06.CLOSE_LARGE,"Message size > "+_connection.getMaxBinaryMes… in onFrame()
[all …]
DWebSocketConnectionD08.java112 private final WebSocket.FrameConnection _connection = new WSFrameConnection(); field in WebSocketConnectionD08
148 _connection, in WebSocketConnectionD08()
167 return _connection; in getConnection()
353 final WebSocket.Connection connection = _connection; in shutdown()
377 _onFrame.onHandshake(_connection); in onFrameHandshake()
383 _webSocket.onOpen(_connection); in onWebSocketOpen()
645 …if (_utf8.append(buffer.array(),buffer.getIndex(),buffer.length(),_connection.getMaxTextMessageSiz… in onFrame()
660 if (_opcode>=0 && _connection.getMaxBinaryMessageSize()>=0) in onFrame()
687 …_connection.sendControl(WebSocketConnectionD08.OP_PONG,buffer.array(),buffer.getIndex(),buffer.len… in onFrame()
715 if (_connection.getMaxTextMessageSize()<=0) in onFrame()
[all …]
DWebSocketConnectionRFC6455.java144 private final WebSocket.FrameConnection _connection = new WSFrameConnection(); field in WebSocketConnectionRFC6455
180 _connection, in WebSocketConnectionRFC6455()
199 return _connection; in getConnection()
395 final WebSocket.Connection connection = _connection; in shutdown()
419 _onFrame.onHandshake(_connection); in onFrameHandshake()
425 _webSocket.onOpen(_connection); in onWebSocketOpen()
714 …if (_utf8.append(buffer.array(),buffer.getIndex(),buffer.length(),_connection.getMaxTextMessageSiz… in onFrame()
729 if (_opcode>=0 && _connection.getMaxBinaryMessageSize()>=0) in onFrame()
757 …_connection.sendControl(WebSocketConnectionRFC6455.OP_PONG,buffer.array(),buffer.getIndex(),buffer… in onFrame()
790 …if(_utf8.append(buffer.array(),buffer.getIndex()+2,buffer.length()-2,_connection.getMaxTextMessage… in onFrame()
[all …]
DWebSocketClient.java400 WebSocketConnection _connection; field in WebSocketClient.WebSocketFuture
424 _connection=connection; in onConnection()
425 con=_connection; in onConnection()
519 if (_connection==null && _exception==null && _channel!=null) in cancel()
543 return _channel==null && _connection==null; in isCancelled()
551 return _connection!=null && _exception==null; in isDone()
577 if (_connection==null) in get()
584 connection=_connection.getConnection(); in get()
DAbstractExtension.java36 private WebSocket.FrameConnection _connection; field in AbstractExtension
45 return _connection; in getConnection()
77 _connection=connection; in bind()
/external/jetty/src/java/org/eclipse/jetty/server/nio/
DBlockingChannelConnector.java176 private Connection _connection; field in BlockingChannelConnector.BlockingChannelEndPoint
184 … _connection = new BlockingHttpConnection(BlockingChannelConnector.this,this,getServer()); in BlockingChannelEndPoint()
193 return _connection; in getConnection()
199 _connection=connection; in setConnection()
229 LOG.warn("dispatch failed for {}",_connection); in dispatch()
273 connectionOpened(_connection); in run()
279 if (_connection.isIdle()) in run()
298 _connection = _connection.handle(); in run()
322 connectionClosed(_connection); in run()
362 _connection); in toString()
/external/autotest/database/
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.cursor()
[all …]
/external/jetty/src/java/org/eclipse/jetty/io/nio/
DSelectChannelEndPoint.java65 private volatile AsyncConnection _connection; field in SelectChannelEndPoint
129 return _connection; in getConnection()
135 Connection old=_connection; in setConnection()
136 _connection=(AsyncConnection)connection; in setConnection()
137 if (old!=null && old!=_connection) in setConnection()
351 _connection.onIdleExpired(idleForMs); in onIdleExpired()
585 … boolean read_interest = _readBlocked || (_state<STATE_DISPATCHED && !_connection.isSuspended()); in updateKey()
696 final AsyncConnection next = (AsyncConnection)_connection.handle(); in handle()
697 if (next!=_connection) in handle()
699 LOG.debug("{} replaced {}",next,_connection); in handle()
[all …]
DSslConnection.java57 private AsyncConnection _connection; field in SslConnection
196 AsyncConnection next = (AsyncConnection)_connection.handle(); in handle()
197 if (next!=_connection && next!=null) in handle()
199 _connection=next; in handle()
215 _connection.onInputShutdown(); in handle()
419 if (toFill==_unwrapBuf && _unwrapBuf.hasContent() && !_connection.isSuspended()) in process()
838 return _connection; in getConnection()
843 _connection=(AsyncConnection)connection; in setConnection()
861 _connection); in toString()
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/ecs/
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/
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/
DByteArrayEndPoint.java38 protected Connection _connection; field in ByteArrayEndPoint
56 return _connection; in getConnection()
65 _connection=connection; in setConnection()
/external/clang/test/CodeGenObjC/
D2008-10-3-EhValue.m25 static Frob* _connection = ((void *)0); function
36 _connection = (Frob *) -1;
/external/jetty/src/java/org/eclipse/jetty/client/
DHttpExchange.java110 private volatile AbstractHttpConnection _connection; field in HttpExchange
128 AbstractHttpConnection connection = _connection; in expire()
796 AbstractHttpConnection httpConnection = _connection; in abort()
821 _connection = connection; in associate()
828 return this._connection != null; in isAssociated()
833 AbstractHttpConnection result = _connection; in disassociate()
834 this._connection = null; in disassociate()
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/fps/
Dresponse.py43 self._connection = connection
48 return self._connection
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/sts/
Dcredentials.py186 self._connection = connection
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/
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

12