Examples of PoolManager

com.sun.enterprise.PoolManager
PoolManager manages resource connections such as JDBC connections
com.sun.enterprise.resource.pool.PoolManager
PoolManager manages jdbc and connector connection pool
org.apache.cayenne.conn.PoolManager
PoolManager is a Cayenne implementation of a pooling DataSource.
org.apache.directory.ldapstudio.schemas.view.viewers.PoolManager
org.apache.excalibur.mpool.PoolManager
This interface is for a PoolManager that creates pools that are managed asynchronously. The contract is that the controller type is specified in the constructor. @author Avalon Development Team @version CVS $Revision: 1.4 $ $Date: 2004/02/28 11:47:33 $ @since 4.1
org.apache.hadoop.mapred.PoolManager
Maintains a list of pools as well as scheduling parameters for each pool, such as guaranteed share allocations, from the fair scheduler config file.
org.candlepin.controller.PoolManager
org.d_haven.mpool.PoolManager
org.xmlBlaster.util.pool.PoolManager
A little framework to handle a pool of limited resources.
You can use this pool as a base class handling of your limited resources like a 'JDBC connection pool' or a 'thread pool'.
The important attributes of a resource are gathered in the ResourceWrapper class.
You can easily handle bigger number of resources with good performance.
To find out how to use it see the TestPool example in the main() method of this class.
```
 State chart of resource handling: +<------- reserve() if(numIdle==0) ---------------------+ |                                                       | |     +<- reserve() --+        +<-preReserve() *-+      | |     | if(numIdle>0) |        |                 |      | |     |               |        |                 |      | #########               ##########                 ########## #         #             #          #               #          # #  busy   #             #  idle    #               #  undef   # #         #             #          #               #          # #########               ##########                 ########## |  |  |               | |  | | |                 | |  |  | |  |  |   Explicit    | |  | | |   Explicit      | |  |  | |  |  +-- release() ->+ |  | | +-- erase() ----->+ |  |  | |  |                    |  | |                     |  |  | |  +busyToIdleTimeout()>+  | +idleToEraseTimeout()>+  |  | |                          |                          |  | |                          +-- erase on max cycles *->+  | |                                                        | +--------- busyToEraseTimeout() since creation *-------->+ 
```
There are three states:
- busy: The resource is in use
- idle: The resource is allocated and ready but not in use
- undef: The resource is not yet allocated or it is erased again
Note that state transitions marked with '*' are not yet implemented. If you need one of them, code it and contribute it please.
You can choose which states you wish for your resource and how timeouts are used to handle state transitions.

For example if you want to pool user login sessions and want to do an auto logout after 60 minutes, you would use the busyToIdleTimeout and set it to 60*60*1000.
If a user is active you can refresh the session with busyRefresh().
Often you want to use your own generated sessionId as the primary key for this resource, you can pass it as the instanceId argument to reserve(sessionId).
(See example [2] in this main() method)

If you want to pool JDBC connections, reserve() a connection before you do your query and release() it immediately again. If you want to close connections after peak usage, you could set a idleToEraseTimeout, to erase your JDBC connection after some time not used (reducing the current pool size).
Note that in this example the connections are anonymous (all are logged in to the database with the same user name), it is not important which you receive.
(See example [1] in this main() method)

For an implementation example see TestPoolManager.java

This code is derived from the org.jutils.pool package.
@author "Marcel Ruff" @see org.xmlBlaster.util.pool.ResourceWrapper @see org.xmlBlaster.test.classtest.TestPoolManager

Examples of org.apache.cayenne.conn.PoolManager

        this.load(location);


        ConnectionLogger logger = new ConnectionLogger();


        try {
            return new PoolManager(driverInfo.getJdbcDriver(), driverInfo
                    .getDataSourceUrl(), driverInfo.getMinConnections(), driverInfo
                    .getMaxConnections(), driverInfo.getUserName(), driverInfo
                    .getPassword(), logger);
        }
        catch (Exception ex) {

View Full Code Here

Examples of org.apache.cayenne.conn.PoolManager

            maxConnection = 1;
        }


        // this code follows Cayenne DriverDataSourceFactory logic...
        try {
            return new PoolManager(
                    driverName,
                    url,
                    minConnection,
                    maxConnection,
                    properties.getProperty(Provider.DATA_SOURCE_USER_NAME_PROPERTY),

View Full Code Here

Examples of org.apache.cayenne.conn.PoolManager


        assertEquals(PersistenceState.COMMITTED, newObject.getPersistenceState());
    }


    private void changeMaxConnections(int delta) {
        PoolManager manager = (PoolManager) dataSourceFactory.getSharedDataSource();
        manager.setMaxConnections(manager.getMaxConnections() + delta);
    }

View Full Code Here

Examples of org.apache.cayenne.conn.PoolManager

    private DataSource createDataSource() {
        try {
            PoolDataSource poolDS = new PoolDataSource(
                    dataSourceInfo.getJdbcDriver(),
                    dataSourceInfo.getDataSourceUrl());
            return new PoolManager(
                    poolDS,
                    1,
                    1,
                    dataSourceInfo.getUserName(),
                    dataSourceInfo.getPassword()) {

View Full Code Here

Examples of org.apache.cayenne.conn.PoolManager

                Constants.JDBC_MAX_CONNECTIONS_PROPERTY,
                suffix,
                1);


        try {
            return new PoolManager(
                    driver,
                    url,
                    minConnections,
                    maxConnections,
                    username,

View Full Code Here

Examples of org.apache.cayenne.conn.PoolManager

            logger.info(message);
            throw new ConfigurationException(message);
        }
        
        try {
            return new PoolManager(
                    dataSourceDescriptor.getJdbcDriver(),
                    dataSourceDescriptor.getDataSourceUrl(),
                    dataSourceDescriptor.getMinConnections(),
                    dataSourceDescriptor.getMaxConnections(),
                    dataSourceDescriptor.getUserName(),

View Full Code Here

Examples of org.apache.directory.ldapstudio.schemas.view.viewers.PoolManager

    /* (non-Javadoc)
     * @see org.eclipse.jface.action.Action#run()
     */
    public void run()
    {
        PoolManager view = ( PoolManager ) PlatformUI.getWorkbench().getActiveWorkbenchWindow().getActivePage()
            .findView( Application.PLUGIN_ID + ".view.PoolManager" ); //$NON-NLS-1$
        Object selection = ( ( TreeSelection ) view.getViewer().getSelection() ).getFirstElement();


        String schemaName = null;


        // We have to check on which node we are to get the schema name
        if ( selection instanceof SchemaWrapper )

View Full Code Here

Examples of org.apache.excalibur.mpool.PoolManager

        {
            m_poolManager = (PoolManager) m_rootContext.get( PoolManager.ROLE );
        }
        catch ( ContextException ce )
        {
            final PoolManager pm = new DefaultPoolManager( m_sink );
            assumeOwnership( pm );
            m_poolManager = pm;
        }
    }

View Full Code Here

Examples of org.apache.hadoop.mapred.PoolManager

    out.println("<defaultMaxTotalInitedTasks>50000" +
                "</defaultMaxTotalInitedTasks>");
    out.println("</allocations>");
    out.close();


    PoolManager poolManager = scheduler.getPoolManager();
    poolManager.reloadAllocs();


    assertEquals(6, poolManager.getPools().size()); // 5 in file + default pool
    assertEquals(0, poolManager.getMinSlots(Pool.DEFAULT_POOL_NAME,
        TaskType.MAP));
    assertEquals(0, poolManager.getMinSlots(Pool.DEFAULT_POOL_NAME,
        TaskType.REDUCE));
    assertEquals(1, poolManager.getMinSlots("pool_a", TaskType.MAP));
    assertEquals(2, poolManager.getMinSlots("pool_a", TaskType.REDUCE));
    assertEquals(2, poolManager.getMinSlots("pool_b", TaskType.MAP));
    assertEquals(1, poolManager.getMinSlots("pool_b", TaskType.REDUCE));
    assertEquals(2, poolManager.getMinSlots("pool_c", TaskType.MAP));
    assertEquals(0, poolManager.getMinSlots("pool_c", TaskType.REDUCE));
    assertEquals(0, poolManager.getMinSlots("pool_d", TaskType.MAP));
    assertEquals(0, poolManager.getMinSlots("pool_d", TaskType.REDUCE));
    assertEquals(0, poolManager.getMinSlots("pool_e", TaskType.MAP));
    assertEquals(0, poolManager.getMinSlots("pool_e", TaskType.REDUCE));
    assertEquals(10, poolManager.getUserMaxJobs("user1"));
    assertEquals(5, poolManager.getUserMaxJobs("user2"));
    assertEquals(4, poolManager.getMaxSlots("pool_b", TaskType.MAP));
    assertEquals(2, poolManager.getMaxSlots("pool_b", TaskType.REDUCE));
    assertEquals(4, poolManager.getMaxSlots("pool_c", TaskType.MAP));
    assertEquals(100000, poolManager.getPoolMaxInitedTasks("pool_a"));
    assertEquals(20000, poolManager.getPoolMaxInitedTasks("pool_b"));
    assertEquals(50000, poolManager.getPoolMaxInitedTasks("pool_c"));
    assertEquals(50000, poolManager.getPoolMaxInitedTasks("pool_d"));
    assertEquals(50000, poolManager.getPoolMaxInitedTasks("pool_e"));
    assertEquals(Integer.MAX_VALUE,
                 poolManager.getMaxSlots("pool_c", TaskType.REDUCE));
    assertEquals(120000, poolManager.getMinSharePreemptionTimeout(
        Pool.DEFAULT_POOL_NAME));
    assertEquals(120000, poolManager.getMinSharePreemptionTimeout("pool_a"));
    assertEquals(120000, poolManager.getMinSharePreemptionTimeout("pool_b"));
    assertEquals(120000, poolManager.getMinSharePreemptionTimeout("pool_c"));
    assertEquals(120000, poolManager.getMinSharePreemptionTimeout("pool_d"));
    assertEquals(120000, poolManager.getMinSharePreemptionTimeout("pool_a"));
    assertEquals(60000, poolManager.getMinSharePreemptionTimeout("pool_e"));
    assertEquals(300000, poolManager.getFairSharePreemptionTimeout());
  }

View Full Code Here

Examples of org.candlepin.controller.PoolManager

    public void testActivationKeyWithNonMultiPool() {
        ActivationKey ak = genActivationKey();
        ActivationKeyCurator akc = mock(ActivationKeyCurator.class);
        Pool p = genPool();
        p.setProductAttribute("multi-entitlement", "no", "id");
        PoolManager poolManager = mock(PoolManager.class);


        when(akc.verifyAndLookupKey(eq("testKey"))).thenReturn(ak);
        when(poolManager.find(eq("testPool"))).thenReturn(p);


        ActivationKeyResource akr = new ActivationKeyResource(
            akc, i18n, poolManager, serviceLevelValidator, activationKeyRules, null);
        akr.addPoolToKey("testKey", "testPool", 2L);
    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.