/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/pool/ |
H A D | PooledConnection.java | 26 package com.sun.jndi.ldap.pool; 29 * Represents a connection that is managed in a pool. The connection 34 * method would interact with the connection pool to return the connection 35 * to the pool (see PoolCallback). 38 * connection pool can use to physically close the connection. 39 * The pool might need to physically close the connection as determined 40 * by the pool's policy (for example, to manage the pool size or idle
|
H A D | ConnectionsRef.java | 26 package com.sun.jndi.ldap.pool; 33 * <-> com.sun.jndi.ldap.pool.Connections 46 * when they are returned to the pool.
|
H A D | ConnectionsWeakRef.java | 26 package com.sun.jndi.ldap.pool; 49 * Connection thread by making them available to the GC. The pool
|
H A D | PoolCallback.java | 26 package com.sun.jndi.ldap.pool; 30 * into the pool. 35 * interact with the connection pool to return the connection 36 * to the pool. 40 * pool manager. 46 * Releases a useable connection back to the pool. 50 * is no longer in the pool. 55 * Removes a connection from the pool. The connection should not be reused. 60 * is no longer in the pool prior to removal.
|
H A D | PoolCleaner.java | 26 package com.sun.jndi.ldap.pool;
|
H A D | PooledConnectionFactory.java | 26 package com.sun.jndi.ldap.pool; 32 * The user of the connection pool should provide an implementation of this 43 * connection from the pool.
|
/openjdk7/jdk/src/macosx/native/jobjc/src/tests/java/com/apple/jobjc/ |
H A D | PooledTestCase.java | 36 NSAutoreleasePool pool; field in class:PooledTestCase 40 pool = foundation.NSAutoreleasePool().alloc(); 41 pool.init(); 45 pool.drain();
|
/openjdk7/jdk/test/java/lang/management/ManagementFactory/ |
H A D | MXBeanException.java | 42 private static MemoryPoolMXBean pool; field in class:MXBeanException 49 pool = p; 56 pool.setUsageThreshold(1000); 67 ",name=" + pool.getName());
|
/openjdk7/hotspot/test/gc/6581734/ |
H A D | Test6581734.java | 34 // 6581734 states that memory pool usage via the mbean is wrong 53 System.out.println("Defaulting to monitor CMS pool and collector."); 59 public Test6581734(String pool, String collector) { argument 60 poolName = pool; 80 MemoryPoolMXBean pool = pools.get(i); 81 String name = pool.getName(); 82 System.out.println("found pool: " + name); 85 long usage = pool.getCollectionUsage().getUsed();
|
/openjdk7/jdk/src/share/native/sun/awt/image/jpeg/ |
H A D | jcomapi.c | 27 * the permanent pool, so we will be able to close all temp files here. 35 int pool; local 44 for (pool = JPOOL_NUMPOOLS-1; pool > JPOOL_PERMANENT; pool--) { 45 (*cinfo->mem->free_pool) (cinfo, pool);
|
/openjdk7/jdk/test/java/nio/channels/SocketChannel/ |
H A D | ShortWrite.java | 76 static void test(ExecutorService pool, argument 89 Future<Long> result = pool.submit(new Reader(sink, size)); 106 ExecutorService pool = Executors.newSingleThreadExecutor(); 121 test(pool, source, sink, size); 127 test(pool, source, sink, size); 133 pool.shutdown();
|
/openjdk7/jdk/src/share/classes/sun/tools/jconsole/ |
H A D | MemoryPoolProxy.java | 42 private MemoryPoolMXBean pool; field in class:MemoryPoolProxy 48 this.pool = client.getMXBean(poolName, MemoryPoolMXBean.class); 49 this.poolName = this.pool.getName(); 53 String[] mgrNames = pool.getMemoryManagerNames(); 73 long usageThreshold = (pool.isUsageThresholdSupported() 74 ? pool.getUsageThreshold() 76 long collectThreshold = (pool.isCollectionUsageThresholdSupported() 77 ? pool.getCollectionUsageThreshold() 114 MemoryUsage usage = pool.getUsage();
|
/openjdk7/jdk/test/java/util/concurrent/ExecutorCompletionService/ |
H A D | ExecutorCompletionServiceLoops.java | 46 static final ExecutorService pool = field in class:ExecutorCompletionServiceLoops 49 new ExecutorCompletionService<Integer>(pool); 69 pool.shutdown(); 70 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS))
|
/openjdk7/jdk/test/java/util/concurrent/FutureTask/ |
H A D | CancelledFutureLoops.java | 49 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:CancelledFutureLoops 75 pool.shutdown(); 76 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 94 futures[i] = pool.submit(this);
|
/openjdk7/jdk/test/java/util/concurrent/locks/ReentrantLock/ |
H A D | SimpleReentrantLockLoops.java | 47 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:SimpleReentrantLockLoops 69 pool.shutdown(); 70 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 88 pool.execute(this);
|
/openjdk7/jdk/src/share/sample/forkjoin/mergesort/ |
H A D | MergeSort.java | 63 private final ForkJoinPool pool; field in class:MergeSort 126 pool = new ForkJoinPool(parallelism); 134 ForkJoinTask<Void> job = pool.submit(new MergeSortTask(array, 0, array.length));
|
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/interceptors/ |
H A D | SlotTableStack.java | 49 private SlotTable[] pool; field in class:SlotTableStack.SlotTablePool 51 // High water mark for the pool 52 // If the pool size reaches this limit then putSlotTable will 53 // not put SlotTable to the pool. 60 pool = new SlotTable[HIGH_WATER_MARK]; 65 * Puts SlotTable to the re-usable pool. 68 // If there are enough SlotTables in the pool, then don't add 69 // this table to the pool. 74 pool[currentIndex] = table; 79 * Gets SlotTable from the re-usable pool [all...] |
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/util/ |
H A D | RepositoryIdCache.java | 39 // Really limited pool - in this case just creating several at a time... 89 private RepositoryIdPool pool = new RepositoryIdPool(); field in class:RepositoryIdCache 92 pool.setCaches(this); 101 //repId = pool.popId().init(key);
|
/openjdk7/hotspot/src/share/vm/classfile/ |
H A D | resolutionErrors.cpp | 35 constantPoolHandle pool, int cp_index, Symbol* error) 38 assert(!pool.is_null() && error != NULL, "adding NULL obj"); 40 ResolutionErrorEntry* entry = new_entry(hash, pool(), cp_index, error); 46 constantPoolHandle pool, int cp_index) 53 if (error_probe->hash() == hash && error_probe->pool() == pool()) { 67 ResolutionErrorEntry* ResolutionErrorTable::new_entry(int hash, constantPoolOop pool, argument 70 ResolutionErrorEntry* entry = (ResolutionErrorEntry*)Hashtable<constantPoolOop, mtClass>::new_entry(hash, pool); 97 assert(probe->pool() != (constantPoolOop)NULL, "resolution error table is corrupt"); 115 assert(entry->pool() ! 34 add_entry(int index, unsigned int hash, constantPoolHandle pool, int cp_index, Symbol* error) argument 45 find_entry(int index, unsigned int hash, constantPoolHandle pool, int cp_index) argument 116 constantPoolOop pool = entry->pool(); local [all...] |
H A D | resolutionErrors.hpp | 34 // constant pool resolution (JVMS 5.4.3). 41 ResolutionErrorEntry* new_entry(int hash, constantPoolOop pool, int cp_index, Symbol* error); 58 constantPoolHandle pool, int which, Symbol* error); 61 // find error given the constant pool and constant pool index 63 constantPoolHandle pool, int cp_index); 66 unsigned int compute_hash(constantPoolHandle pool, int cp_index) { argument 67 return (unsigned int) pool->identity_hash() + cp_index; 84 constantPoolOop pool() const { return (constantPoolOop)literal(); } function in class:ResolutionErrorEntry
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/server/ |
H A D | Adapter.java | 66 * a pool of them and you assign it to a patient.) 100 * Instances of this pool may be replaced at runtime. Therefore, when you take 101 * an object out of the pool, you must make sure that it is recycled by the 102 * same instance of the pool. 104 protected volatile Pool<TK> pool = new Pool<TK>() { field in class:Adapter 122 * The pool instance needs to be recreated to prevent reuse of old Toolkit instances. 125 this.pool = new Pool<TK>() { 152 * Returns a reference to the pool of Toolkits for this adapter. 154 * The pool may be recreated during runtime reconfiguration and this method 156 * you must make sure that you return it to the same pool instanc [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/encoding/fastinfoset/ |
H A D | FastInfosetStreamReaderFactory.java | 40 private ThreadLocal<StAXDocumentParser> pool = new ThreadLocal<StAXDocumentParser>(); field in class:FastInfosetStreamReaderFactory 61 StAXDocumentParser parser = pool.get(); 62 pool.set(null); 68 pool.set((StAXDocumentParser) r);
|
/openjdk7/jdk/test/com/sun/jndi/ldap/ |
H A D | LdapTimeoutTest.java | 44 private static final ScheduledExecutorService pool = field in class:LdapTimeoutTest 77 LdapTimeoutTest.pool.shutdown(); 154 return LdapTimeoutTest.pool.schedule(new Callable<Void>() {
|
/openjdk7/jdk/test/java/lang/management/MemoryMXBean/ |
H A D | MemoryUtil.java | 50 public static void printMemoryPool(MemoryPoolMXBean pool) { argument 51 System.out.println(INDENT + "Memory Pool name: " + pool.getName()); 52 System.out.println(INDENT + "Type: " + pool.getType()); 54 pool.getUsage()); 56 (pool.isUsageThresholdSupported() ? pool.getUsageThreshold() : -1)); 58 String[] mgrs = pool.getMemoryManagerNames(); 72 MemoryPoolMXBean pool = (MemoryPoolMXBean) iter.next(); 73 printMemoryPool(pool);
|
/openjdk7/langtools/src/share/classes/com/sun/tools/javac/sym/ |
H A D | CreateSymbols.java | 176 Pool pool = new Pool(); 213 writeClass(pool, cs, writer); 228 void writeClass(final Pool pool, final ClassSymbol cs, final ClassWriter writer) argument 232 pool.reset(); 233 cs.pool = pool; 239 writeClass(pool, nestedClass, writer);
|