/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/spi/legacy/interceptor/ |
H A D | RequestInfoExt.java | 28 import com.sun.corba.se.spi.legacy.connection.Connection; 39 * @return The connection on which the request is made. 43 public Connection connection(); method in interface:RequestInfoExt
|
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/ |
H A D | WindowUpdateSender.java | 36 final Http2Connection connection; field in class:WindowUpdateSender 39 WindowUpdateSender(Http2Connection connection) { argument 40 this(connection, connection.clientSettings.getParameter(SettingsFrame.INITIAL_WINDOW_SIZE)); 43 WindowUpdateSender(Http2Connection connection, int initWindowSize) { argument 44 this(connection, connection.getMaxReceiveFrameSize(), initWindowSize); 47 WindowUpdateSender(Http2Connection connection, int maxFrameSize, int initWindowSize) { argument 48 this.connection = connection; [all...] |
H A D | RawChannelImpl.java | 37 * Each RawChannel corresponds to a TCP connection (SocketChannel) but is 44 private final HttpConnection connection; field in class:RawChannelImpl 49 HttpConnection connection, 54 this.connection = connection; 55 SocketChannel chan = connection.channel(); 89 return connection.channel(); 113 assert !connection.channel().isBlocking(); 114 return connection.read(); 131 return connection 48 RawChannelImpl(HttpClientImpl client, HttpConnection connection, ByteBuffer initial) argument [all...] |
H A D | Http1Exchange.java | 55 final HttpConnection connection; field in class:Http1Exchange 69 Http1Exchange(Exchange<T> exchange, HttpConnection connection) argument 78 if (connection != null) { 79 this.connection = connection; 82 this.connection = HttpConnection.getConnection(addr, client, request); 84 this.requestAction = new Http1Request(request, client, this.connection); 88 HttpConnection connection() { method in class:Http1Exchange 89 return connection; 133 if (!connection [all...] |
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/impl/transport/ |
H A D | ReaderThreadImpl.java | 45 private Connection connection; field in class:ReaderThreadImpl 51 Connection connection, Selector selector) 54 this.connection = connection; 66 return connection; 72 dprint(".close: " + connection); 88 dprint(".doWork: Start ReaderThread: " + connection); 95 + connection); 98 if (connection.read()) { 105 + connection); 50 ReaderThreadImpl(ORB orb, Connection connection, Selector selector) argument [all...] |
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/spi/legacy/connection/ |
H A D | Connection.java | 26 package com.sun.corba.se.spi.legacy.connection; 29 * This interface represents the connection on which a request is made.
|
H A D | LegacyServerSocketManager.java | 26 package com.sun.corba.se.spi.legacy.connection; 30 import com.sun.corba.se.spi.legacy.connection.LegacyServerSocketEndPointInfo;
|
H A D | GetEndPointInfoAgainException.java | 26 package com.sun.corba.se.spi.legacy.connection;
|
/openjdk10/jdk/src/java.base/share/classes/sun/security/timestamp/ |
H A D | HttpTimestamper.java | 93 HttpURLConnection connection = 95 connection.setDoOutput(true); 96 connection.setUseCaches(false); // ignore cache 97 connection.setRequestProperty("Content-Type", TS_QUERY_MIME_TYPE); 98 connection.setRequestMethod("POST"); 100 connection.setConnectTimeout(CONNECT_TIMEOUT); 104 connection.getRequestProperties().entrySet(); 105 debug.println(connection.getRequestMethod() + " " + tsaURI + 112 connection.connect(); // No HTTP authentication is performed 117 output = new DataOutputStream(connection [all...] |
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/pept/transport/ |
H A D | InboundConnectionCache.java | 36 public void put(Acceptor acceptor, Connection connection); argument 38 public void remove(Connection connection); argument
|
H A D | ConnectionCache.java | 35 public void stampTime(Connection connection); argument 45 /** Close all connections in the connection cache.
|
H A D | OutboundConnectionCache.java | 36 public void put(ContactInfo contactInfo, Connection connection); argument
|
/openjdk10/jdk/src/jdk.jdi/share/native/libdt_shmem/ |
H A D | SharedMemory.h | 32 #define CONNECTION_TO_ID(connection) ((jlong)connection)
|
H A D | shmemBase.c | 41 * front-end client; the back end interface assumes only a single connection. 307 waitForSpace(SharedMemoryConnection *connection, Stream *stream) argument 314 error = sysEventWait(connection->otherProcess, stream->hasSpace, 0); 316 CHECK_ERROR(enterMutex(stream, connection->shutdown)); 335 waitForData(SharedMemoryConnection *connection, Stream *stream) argument 342 error = sysEventWait(connection->otherProcess, stream->hasData, 0); 344 CHECK_ERROR(enterMutex(stream, connection->shutdown)); 483 freeConnection(SharedMemoryConnection *connection) argument 485 (*callback->free)(connection); 489 closeConnection(SharedMemoryConnection *connection) argument 535 SharedMemoryConnection *connection = allocConnection(); local 599 SharedMemoryConnection *connection = allocConnection(); local 833 SharedMemoryConnection *connection; local 924 shmemBase_closeConnection(SharedMemoryConnection *connection) argument 938 shmemBase_sendByte(SharedMemoryConnection *connection, jbyte data) argument 963 shmemBase_receiveByte(SharedMemoryConnection *connection, jbyte *data) argument 988 sendBytes(SharedMemoryConnection *connection, const void *bytes, jint length) argument 1032 shmemBase_sendPacket(SharedMemoryConnection *connection, const jdwpPacket *packet) argument 1060 receiveBytes(SharedMemoryConnection *connection, void *bytes, jint length) argument 1102 shmemBase_receivePacket(SharedMemoryConnection *connection, jdwpPacket *packet) argument [all...] |
H A D | shmemBack.c | 40 static SharedMemoryConnection *connection = NULL; /* maximum of 1 connection */ variable 126 int rv = shmemBase_receiveByte(connection, &b); 136 int rv = shmemBase_sendByte(connection, (jbyte)hello[i]); 172 if (connection != NULL || transport != NULL) { 206 if (connection != NULL) { 213 rc = shmemBase_accept(transport, (long)acceptTimeout, &connection); 216 RETURN_ERROR(JDWPTRANSPORT_ERROR_TIMEOUT, "Timed out waiting for connection"); 218 RETURN_IO_ERROR("failed to accept shared memory connection"); 224 shmemBase_closeConnection(connection); [all...] |
/openjdk10/jaxws/src/java.xml.ws/share/classes/com/sun/xml/internal/ws/api/server/ |
H A D | AbstractServerAsyncTransport.java | 64 * @param connection that carries the web service request 69 protected Packet decodePacket(T connection, @NotNull Codec codec) throws IOException { argument 71 packet.acceptableMimeTypes = getAcceptableMimeTypes(connection); 72 packet.addSatellite(getPropertySet(connection)); 73 packet.transportBackChannel = getTransportBackChannel(connection); 78 * Encodes the {@link Packet} to infoset and writes on the connection. 80 * @param connection that carries the web service request 85 protected abstract void encodePacket(T connection, @NotNull Packet packet, @NotNull Codec codec) throws IOException; argument 90 * @param connection that carries the web service request 93 protected abstract @Nullable String getAcceptableMimeTypes(T connection); argument 103 getTransportBackChannel(T connection) argument 112 getPropertySet(T connection) argument 120 getWebServiceContextDelegate(T connection) argument 130 handle(final T connection) argument [all...] |
/openjdk10/jdk/test/sun/management/jdp/ |
H A D | JdpOffTestCase.java | 36 public JdpOffTestCase(ClientConnection connection) { argument 37 super(connection); 45 return "Expecting NOT to receive any packets with jdp.name=" + connection.instanceName;
|
H A D | JdpOnTestCase.java | 40 public JdpOnTestCase(ClientConnection connection) { argument 41 super(connection); 49 return "Waiting for 3 packets with jdp.name=" + connection.instanceName; 72 connection.pauseInSeconds + " seconds, but waited for " +
|
H A D | JdpJmxRemoteDynamicPortTestCase.java | 31 public JdpJmxRemoteDynamicPortTestCase(ClientConnection connection) { argument 32 super(connection); 69 connection.pauseInSeconds + " seconds, but waited for " +
|
/openjdk10/jdk/test/java/net/URLConnection/ |
H A D | GetContentType.java | 43 URLConnection connection = url.openConnection(); 44 String contentType = connection.getContentType(); 50 connection = url.openConnection(); 51 contentType = connection.getContentType();
|
/openjdk10/jdk/src/java.management/share/classes/javax/management/ |
H A D | MBeanServerInvocationHandler.java | 102 * to {@code new MBeanServerInvocationHandler(connection, 105 * @param connection the MBean server connection through which all 111 public MBeanServerInvocationHandler(MBeanServerConnection connection, argument 114 this(connection, objectName, false); 126 * @param connection the MBean server connection through which all 138 public MBeanServerInvocationHandler(MBeanServerConnection connection, argument 141 if (connection == null) { 142 throw new IllegalArgumentException("Null connection"); 236 newProxyInstance(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass, boolean notificationBroadcaster) argument 494 private final MBeanServerConnection connection; field in class:MBeanServerInvocationHandler [all...] |
H A D | JMX.java | 149 * boolean) newMBeanProxy(connection, objectName, interfaceClass, 152 * @param connection the MBean server to forward to. 154 * {@code connection} to forward to. 168 public static <T> T newMBeanProxy(MBeanServerConnection connection, argument 171 return newMBeanProxy(connection, objectName, interfaceClass, false); 193 * @param connection the MBean server to forward to. 195 * {@code connection} to forward to. 200 * via {@code connection}. 212 public static <T> T newMBeanProxy(MBeanServerConnection connection, argument 216 return createProxy(connection, objectNam 312 newMXBeanProxy(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass) argument 355 newMXBeanProxy(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass, boolean notificationEmitter) argument 403 createProxy(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass, boolean notificationEmitter, boolean isMXBean) argument [all...] |
/openjdk10/jdk/test/com/sun/jdi/ |
H A D | EventQueueDisconnectTest.java | 63 VMConnection connection = new VMConnection( 66 connection.setConnectorArg("main", "EventQueueDisconnectTarg"); 69 if (connection.connectorArg("options").length() > 0) { 72 connection.setConnectorArg("options", debuggeeVMOptions); 74 VirtualMachine vm = connection.open();
|
/openjdk10/hotspot/src/share/tools/IdealGraphVisualizer/HierarchicalLayout/src/com/sun/hotspot/igv/hierarchicallayout/ |
H A D | ClusterIngoingConnection.java | 40 private Link connection; field in class:ClusterIngoingConnection 46 this.connection = c; 54 return connection;
|
/openjdk10/jdk/test/java/net/HttpURLConnection/ |
H A D | NoProxyTest.java | 56 URLConnection connection; 58 connection = url.openConnection(Proxy.NO_PROXY); 59 connection.connect();
|