Searched refs:conn (Results 1 - 25 of 136) sorted by relevance

123456

/openjdk9/jdk/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPoolCallback.java48 * @param conn The connection to release.
52 public abstract boolean releasePooledConnection(PooledConnection conn); argument
58 * @param conn The connection to return.
62 public abstract boolean removePooledConnection(PooledConnection conn); argument
H A DConnectionDesc.java44 final private PooledConnection conn; field in class:ConnectionDesc
50 ConnectionDesc(PooledConnection conn) { argument
51 this.conn = conn;
54 ConnectionDesc(PooledConnection conn, boolean use) { argument
55 this.conn = conn;
70 && ((ConnectionDesc)obj).conn == conn;
78 return conn
[all...]
H A DConnections.java112 PooledConnection conn;
114 conn = factory.createPooledConnection(this);
115 td("Create ", conn ,factory);
116 conns.add(new ConnectionDesc(conn)); // Add new idle conn to pool
138 PooledConnection conn;
143 while ((conn = getOrCreateConnection(factory)) == null) {
168 return conn;
181 PooledConnection conn = null;
189 if ((conn
217 releasePooledConnection(PooledConnection conn) argument
263 removePooledConnection(PooledConnection conn) argument
[all...]
/openjdk9/jdk/test/java/net/URLConnection/
H A DUNCTest.java29 URLConnection conn = url.openConnection();
30 conn.setRequestProperty( "User-Agent", "Java" );
H A DUnknownContentType.java37 URLConnection conn = url.openConnection();
38 conn.connect();
39 String s1 = conn.getContentType();
40 String s2 = conn.getHeaderField("content-type");
H A DGetLastModified.java40 URLConnection conn = url.openConnection();
41 if (conn.getLastModified() == 0) {
/openjdk9/jdk/test/java/net/HttpURLConnection/SetAuthenticator/
H A DHTTPTestClient.java51 HttpURLConnection conn = openConnection(url, authType, proxy);
52 configure(conn, auth);
53 System.out.println("Response code: " + conn.getResponseCode());
54 String result = new String(conn.getInputStream().readAllBytes(), "UTF-8");
60 conn = openConnection(url, authType, proxy);
61 configure(conn, auth);
62 conn.setRequestMethod("POST");
63 conn.setDoOutput(true);
64 conn.setDoInput(true);
65 conn
76 configure(HttpURLConnection conn, Authenticator auth) argument
[all...]
/openjdk9/jdk/test/sun/net/www/protocol/file/
H A DGetLastModified.java41 URLConnection conn = null;
42 conn = url.openConnection();
43 conn.connect();
44 if (f.lastModified() != conn.getLastModified())
/openjdk9/jdk/src/java.rmi/share/classes/sun/rmi/transport/
H A DConnectionOutputStream.java42 private final Connection conn; field in class:ConnectionOutputStream
59 ConnectionOutputStream(Connection conn, boolean resultStream) argument
62 super(conn.getOutputStream());
63 this.conn = conn;
H A DChannel.java45 * @param conn The connection.
49 public void free(Connection conn, boolean reuse) throws RemoteException; argument
H A DConnectionInputStream.java126 Connection conn = null;
134 conn = ch.newConnection();
136 new DataOutputStream(conn.getOutputStream());
142 conn.releaseOutputStream();
151 conn.getInputStream().available();
152 conn.releaseInputStream();
159 if (conn != null)
160 ch.free(conn, reuse);
H A DStreamRemoteCall.java52 private Connection conn; field in class:StreamRemoteCall
57 conn = c;
64 conn = c;
70 conn.getOutputStream().write(TransportConstants.Call);
85 return conn;
102 out = new ConnectionOutputStream(conn, resultStream);
120 conn.releaseOutputStream();
134 in = new ConnectionInputStream(conn.getInputStream());
162 in.done(conn);
164 conn
[all...]
/openjdk9/jdk/src/java.rmi/share/classes/sun/rmi/transport/tcp/
H A DTCPChannel.java162 TCPConnection conn;
168 conn = null;
178 conn = freeList.get(elementPos);
183 // at this point, conn is null iff the freelist is empty,
187 if (conn != null) {
189 if (!conn.isDead()) {
191 return conn;
194 // conn is dead, and cannot be reused (reuse => false)
195 this.free(conn, false);
197 } while (conn !
331 free(Connection conn, boolean reuse) argument
404 acceptMultiplexConnection(Connection conn) argument
512 accept(Connection conn) argument
[all...]
/openjdk9/jaxws/src/java.xml.ws/share/classes/com/sun/org/glassfish/external/amx/
H A DAMXGlassfish.java166 public void invokeBootAMX(final MBeanServerConnection conn) argument
171 conn.invoke( getBootAMXMBeanObjectName(), BootAMXMBean.BOOT_AMX_OPERATION_NAME, null, null);
183 private static void invokeWaitAMXReady(final MBeanServerConnection conn, final ObjectName objectName) argument
187 conn.invoke( objectName, "waitAMXReady", null, null );
211 public WaitForDomainRootListenerCallback( final MBeanServerConnection conn ) {
212 mConn = conn;
260 public BootAMXCallback(final MBeanServerConnection conn) argument
262 mConn = conn;
277 @param conn connection to the MBeanServer
280 public ObjectName bootAMX(final MBeanServerConnection conn) argument
[all...]
/openjdk9/jdk/test/java/net/httpclient/http2/server/
H A DBodyOutputStream.java43 final Http2TestServerConnection conn; field in class:BodyOutputStream
46 BodyOutputStream(int streamid, int initialWindow, Http2TestServerConnection conn) { argument
49 this.conn = conn;
50 this.outputQ = conn.outputQ;
51 conn.registerStreamWindowUpdater(streamid, this::updateWindow);
63 conn.obtainConnectionWindow(demand);
H A DBodyInputStream.java45 final Http2TestServerConnection conn; field in class:BodyInputStream
48 BodyInputStream(Queue q, int streamid, Http2TestServerConnection conn) { argument
51 this.conn = conn;
67 conn.handleStreamReset((ResetFrame) frame); // throws IOException
78 conn.sendWindowUpdates(len, streamid);
/openjdk9/jdk/test/javax/management/remote/mandatory/connection/
H A DDeadLockTest.java93 MBeanServerConnection conn = client.getMBeanServerConnection();
94 myListener = new MyListener(conn);
102 conn.getDefaultDomain();
119 public MyListener(MBeanServerConnection conn) { argument
120 this.conn = conn;
137 conn.getDefaultDomain();
158 private MBeanServerConnection conn; field in class:DeadLockTest.MyListener
H A DReconnectTest.java100 JMXConnector conn = JMXConnectorFactory.newJMXConnector(u, env);
101 conn.connect();
103 System.out.println(conn.getMBeanServerConnection().getDefaultDomain());
111 +conn.getMBeanServerConnection().getDefaultDomain());
116 conn.close();
/openjdk9/corba/src/java.corba/share/classes/com/sun/corba/se/impl/encoding/
H A DBufferManagerWriteGrow.java68 Connection conn =
71 conn.writeLock();
75 conn.sendWithoutLock((OutputObject)outputObject);
81 conn.writeUnlock();
H A DCachedCodeBase.java58 private CorbaConnection conn; field in class:CachedCodeBase
74 conn = connection;
169 if (conn.getCodeBaseIOR() == null) {
172 if (conn.getBroker().transportDebugFlag)
173 conn.dprint("CodeBase unavailable on connection: " + conn);
186 delegate = CachedCodeBase.iorMap.get(conn.getCodeBaseIOR());
195 CachedCodeBase.iorMap.put(conn.getCodeBaseIOR(), delegate);
204 conn.getCodeBaseIOR(), null /*stubFactory*/, conn
[all...]
/openjdk9/jdk/test/java/net/URLClassLoader/
H A DB7050028.java44 URLConnection conn = B7050028.class.getResource("B7050028.class").openConnection();
45 int len = conn.getContentLength();
47 InputStream is = conn.getInputStream();
50 conn.setDefaultUseCaches(false);
/openjdk9/jdk/test/sun/net/www/protocol/http/
H A DProtocolRedirect.java42 HttpURLConnection conn = (HttpURLConnection)url.openConnection();
43 conn.connect();
44 if (conn.getResponseCode() != 302) {
45 throw new RuntimeException("Test failed. Should get RespCode: 302. Got:"+conn.getResponseCode());
/openjdk9/jdk/src/jdk.jdi/windows/classes/com/sun/tools/jdi/
H A DSharedMemoryTransportService.java109 SharedMemoryConnection conn = new SharedMemoryConnection(id);
110 conn.handshake(handshakeTimeout);
111 return conn;
165 SharedMemoryConnection conn = new SharedMemoryConnection(connectId);
166 conn.handshake(handshakeTimeout);
167 return conn;
/openjdk9/jdk/test/java/nio/channels/AsynchronousSocketChannel/
H A DLeaky.java104 for (Connection conn: connections) {
105 conn.startRead();
109 for (Connection conn: connections) {
110 conn.write();
114 for (Connection conn: connections) {
115 conn.finishRead();
/openjdk9/jdk/src/java.naming/share/classes/com/sun/jndi/ldap/
H A DLdapClient.java70 * conn - no sync; Connection takes care of its own sync
118 Connection conn; // Connection to server; has reader thread field in class:LdapClient
137 conn = new Connection(this, host, port, socketFactory, connectTimeout, readTimeout,
153 int readTimeout = conn.readTimeout;
154 conn.readTimeout = conn.connectTimeout;
195 conn.setBound();
200 conn.host + ":" + conn.port);
216 conn
[all...]

Completed in 160 milliseconds

123456