/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/pool/ |
H A D | PoolCallback.java | 48 * @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 D | ConnectionDesc.java | 44 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 D | Connections.java | 113 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 D | UNCTest.java | 29 URLConnection conn = url.openConnection(); 30 conn.setRequestProperty( "User-Agent", "Java" );
|
H A D | UnknownContentType.java | 37 URLConnection conn = url.openConnection(); 38 conn.connect(); 39 String s1 = conn.getContentType(); 40 String s2 = conn.getHeaderField("content-type");
|
H A D | GetLastModified.java | 40 URLConnection conn = url.openConnection(); 41 if (conn.getLastModified() == 0) {
|
/openjdk7/jdk/test/sun/net/www/protocol/file/ |
H A D | GetLastModified.java | 41 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 D | ConnectionOutputStream.java | 42 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 D | Channel.java | 49 public void free(Connection conn, boolean reuse) throws RemoteException; argument
|
H A D | ConnectionInputStream.java | 118 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 D | StreamRemoteCall.java | 51 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 D | TCPChannel.java | 164 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 D | AMXGlassfish.java | 166 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 D | DeadLockTest.java | 92 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 D | ReconnectTest.java | 99 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 D | BufferManagerWriteGrow.java | 68 Connection conn = 71 conn.writeLock(); 75 conn.sendWithoutLock((OutputObject)outputObject); 81 conn.writeUnlock();
|
H A D | CachedCodeBase.java | 58 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 D | BufferManagerWriteStream.java | 100 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 D | B7050028.java | 44 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 D | ProtocolRedirect.java | 42 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 D | HttpSendSocket.java | 62 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 D | SimpleServer.java | 96 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 D | Leaky.java | 103 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 D | LdapClient.java | 70 * 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 D | DefaultProviderTest.java | 56 JMXConnector conn = JMXConnectorFactory.newJMXConnector(url, env);
|