Searched refs:connection (Results 1 - 25 of 132) sorted by relevance

123456

/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/spi/legacy/interceptor/
H A DRequestInfoExt.java28 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 DWindowUpdateSender.java36 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 DRawChannelImpl.java37 * 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 DHttp1Exchange.java55 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 DReaderThreadImpl.java45 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 DConnection.java26 package com.sun.corba.se.spi.legacy.connection;
29 * This interface represents the connection on which a request is made.
H A DLegacyServerSocketManager.java26 package com.sun.corba.se.spi.legacy.connection;
30 import com.sun.corba.se.spi.legacy.connection.LegacyServerSocketEndPointInfo;
H A DGetEndPointInfoAgainException.java26 package com.sun.corba.se.spi.legacy.connection;
/openjdk10/jdk/src/java.base/share/classes/sun/security/timestamp/
H A DHttpTimestamper.java93 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 DInboundConnectionCache.java36 public void put(Acceptor acceptor, Connection connection); argument
38 public void remove(Connection connection); argument
H A DConnectionCache.java35 public void stampTime(Connection connection); argument
45 /** Close all connections in the connection cache.
H A DOutboundConnectionCache.java36 public void put(ContactInfo contactInfo, Connection connection); argument
/openjdk10/jdk/src/jdk.jdi/share/native/libdt_shmem/
H A DSharedMemory.h32 #define CONNECTION_TO_ID(connection) ((jlong)connection)
H A DshmemBase.c41 * 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 DshmemBack.c40 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 DAbstractServerAsyncTransport.java64 * @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 DJdpOffTestCase.java36 public JdpOffTestCase(ClientConnection connection) { argument
37 super(connection);
45 return "Expecting NOT to receive any packets with jdp.name=" + connection.instanceName;
H A DJdpOnTestCase.java40 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 DJdpJmxRemoteDynamicPortTestCase.java31 public JdpJmxRemoteDynamicPortTestCase(ClientConnection connection) { argument
32 super(connection);
69 connection.pauseInSeconds + " seconds, but waited for " +
/openjdk10/jdk/test/java/net/URLConnection/
H A DGetContentType.java43 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 DMBeanServerInvocationHandler.java102 * 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 DJMX.java149 * 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 DEventQueueDisconnectTest.java63 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 DClusterIngoingConnection.java40 private Link connection; field in class:ClusterIngoingConnection
46 this.connection = c;
54 return connection;
/openjdk10/jdk/test/java/net/HttpURLConnection/
H A DNoProxyTest.java56 URLConnection connection;
58 connection = url.openConnection(Proxy.NO_PROXY);
59 connection.connect();

Completed in 212 milliseconds

123456