Searched defs:pool (Results 1 - 25 of 97) sorted by relevance

1234

/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/pool/
H A DPooledConnection.java26 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 DConnectionsRef.java26 package com.sun.jndi.ldap.pool;
33 * <-> com.sun.jndi.ldap.pool.Connections
46 * when they are returned to the pool.
H A DConnectionsWeakRef.java26 package com.sun.jndi.ldap.pool;
49 * Connection thread by making them available to the GC. The pool
H A DPoolCallback.java26 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 DPoolCleaner.java26 package com.sun.jndi.ldap.pool;
H A DPooledConnectionFactory.java26 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 DPooledTestCase.java36 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 DMXBeanException.java42 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 DTest6581734.java34 // 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 Djcomapi.c27 * 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 DShortWrite.java76 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 DMemoryPoolProxy.java42 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 DExecutorCompletionServiceLoops.java46 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 DCancelledFutureLoops.java49 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 DSimpleReentrantLockLoops.java47 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 DMergeSort.java63 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 DSlotTableStack.java49 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 DRepositoryIdCache.java39 // 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 DresolutionErrors.cpp35 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 DresolutionErrors.hpp34 // 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 DAdapter.java66 * 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 DFastInfosetStreamReaderFactory.java40 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 DLdapTimeoutTest.java44 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 DMemoryUtil.java50 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 DCreateSymbols.java176 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);

Completed in 172 milliseconds

1234