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

12345

/openjdk7/jdk/src/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.java113 PooledConnection conn;
115 conn = factory.createPooledConnection(this);
116 td("Create ", conn ,factory);
117 conns.add(new ConnectionDesc(conn)); // Add new idle conn to pool
139 PooledConnection conn;
144 while ((conn = getOrCreateConnection(factory)) == null) {
169 return conn;
182 PooledConnection conn = null;
190 if ((conn
218 releasePooledConnection(PooledConnection conn) argument
264 removePooledConnection(PooledConnection conn) argument
[all...]
/openjdk7/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) {
/openjdk7/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())
/openjdk7/jdk/src/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.java49 public void free(Connection conn, boolean reuse) throws RemoteException; argument
H A DConnectionInputStream.java118 Connection conn = null;
126 conn = ch.newConnection();
128 new DataOutputStream(conn.getOutputStream());
134 conn.releaseOutputStream();
143 conn.getInputStream().available();
144 conn.releaseInputStream();
151 if (conn != null)
152 ch.free(conn, reuse);
H A DStreamRemoteCall.java51 private Connection conn; field in class:StreamRemoteCall
56 conn = c;
63 conn = c;
69 conn.getOutputStream().write(TransportConstants.Call);
84 return conn;
101 out = new ConnectionOutputStream(conn, resultStream);
119 conn.releaseOutputStream();
133 in = new ConnectionInputStream(conn.getInputStream());
161 in.done(conn);
163 conn
[all...]
/openjdk7/jdk/src/share/classes/sun/rmi/transport/tcp/
H A DTCPChannel.java164 TCPConnection conn;
170 conn = null;
180 conn = freeList.get(elementPos);
185 // at this point, conn is null iff the freelist is empty,
189 if (conn != null) {
191 if (!conn.isDead()) {
193 return conn;
196 // conn is dead, and cannot be reused (reuse => false)
197 this.free(conn, false);
199 } while (conn !
329 free(Connection conn, boolean reuse) argument
402 acceptMultiplexConnection(Connection conn) argument
510 accept(Connection conn) argument
[all...]
/openjdk7/jaxws/src/share/jaxws_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...]
/openjdk7/jdk/test/javax/management/remote/mandatory/connection/
H A DDeadLockTest.java92 MBeanServerConnection conn = client.getMBeanServerConnection();
93 myListener = new MyListener(conn);
101 conn.getDefaultDomain();
118 public MyListener(MBeanServerConnection conn) { argument
119 this.conn = conn;
136 conn.getDefaultDomain();
157 private MBeanServerConnection conn; field in class:DeadLockTest.MyListener
H A DReconnectTest.java99 JMXConnector conn = JMXConnectorFactory.newJMXConnector(u, env);
100 conn.connect();
102 System.out.println(conn.getMBeanServerConnection().getDefaultDomain());
110 +conn.getMBeanServerConnection().getDefaultDomain());
115 conn.close();
/openjdk7/corba/src/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...]
H A DBufferManagerWriteStream.java100 Connection conn = ((OutputObject)outputObject).getMessageMediator().getConnection();
104 conn.writeLock();
108 conn.sendWithoutLock(((OutputObject)outputObject));
114 conn.writeUnlock();
/openjdk7/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);
/openjdk7/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());
/openjdk7/jdk/src/share/classes/sun/rmi/transport/proxy/
H A DHttpSendSocket.java62 protected URLConnection conn = null; field in class:HttpSendSocket
143 if (conn != null) {
148 conn = url.openConnection();
149 conn.setDoOutput(true);
150 conn.setUseCaches(false);
151 conn.setRequestProperty("Content-type", "application/octet-stream");
156 return out = conn.getOutputStream();
172 in = conn.getInputStream();
190 String contentType = conn.getContentType();
192 !conn
[all...]
/openjdk7/jdk/src/solaris/demo/jni/Poller/
H A DSimpleServer.java96 int conn = 0;
97 while ( conn < totalConn ) {
99 connHA[conn] = new ConnHandler(sock.getInputStream());
100 connHA[conn].start();
101 conn++;
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/
H A DLeaky.java103 for (Connection conn: connections) {
104 conn.startRead();
108 for (Connection conn: connections) {
109 conn.write();
113 for (Connection conn: connections) {
114 conn.finishRead();
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/
H A DLdapClient.java70 * conn - no sync; Connection takes care of its own sync
117 Connection conn; // Connection to server; has reader thread field in class:LdapClient
136 conn = new Connection(this, host, port, socketFactory, connectTimeout, readTimeout,
152 int readTimeout = conn.readTimeout;
153 conn.readTimeout = conn.connectTimeout;
194 conn.setBound();
199 conn.host + ":" + conn.port);
215 conn
[all...]
/openjdk7/jdk/test/javax/management/remote/mandatory/loading/
H A DDefaultProviderTest.java56 JMXConnector conn = JMXConnectorFactory.newJMXConnector(url, env);

Completed in 107 milliseconds

12345