Examples of PoolMetaData

org.apache.hadoop.mapred.PoolMetadata
Metadata about a pool that is a snapshot of the actual state of the pool. The fair scheduler for MapReduce and Corona can both use this helper class for calculating fairness metrics.
org.torquebox.core.runtime.PoolMetaData
Ruby interpreter pool configuration.
Pools may be created as non-shared, shared, or backed by the global interpreter. These three types of pools are ranked from most memory-intensive (but more secure) to less memory-intensive (but less secure, due to sharing). Threadsafety of the client application should be considered when configuring a pool.

A non-shared pool allows exclusive access to each pooled interpreter to exactly one client at a time. A non-shared pool has minimum and maximum size settings.

A shared pool is a pool backed by a single interpreter, shared among many client simultaneously. The pool owns the interpreter.

A global pool is backed by a single global interpreter, possibly shared with other global pools.
@author Bob McWhirter

Examples of org.torquebox.core.runtime.PoolMetaData

        if (allMetaData.isEmpty()) {
            return;
        }
        
        List<PoolMetaData> allPoolMetaData = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );
        PoolMetaData poolMetaData = PoolMetaData.extractNamedMetaData( allPoolMetaData, "stomplets" );
        
        if ( poolMetaData == null ) {
            poolMetaData = new PoolMetaData("stomplets");
            poolMetaData.setMinimumSize( allMetaData.size()  );
            poolMetaData.setMaximumSize( allMetaData.size()  );
            unit.addToAttachmentList( PoolMetaData.ATTACHMENTS_KEY, poolMetaData );
        }
    }

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

    public void testPoolDefinedAlready() throws Exception {
        
        DeploymentPhaseContext phaseContext = createPhaseContext();
        DeploymentUnit unit = phaseContext.getDeploymentUnit();
        
        PoolMetaData jobsPoolMetaData = new PoolMetaData( "jobs" );
        jobsPoolMetaData.setShared();
        
        unit.addToAttachmentList( PoolMetaData.ATTACHMENTS_KEY, jobsPoolMetaData );
        deploy( phaseContext );
        
        List<PoolMetaData> allPools = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

    public void testPoolDefinedAlreadyWithJobs() throws Exception {
        
        DeploymentPhaseContext phaseContext = createPhaseContext();
        DeploymentUnit unit = phaseContext.getDeploymentUnit();
        
        PoolMetaData jobsPoolMetaData = new PoolMetaData( "jobs" );
        jobsPoolMetaData.setShared();
        
        unit.addToAttachmentList( PoolMetaData.ATTACHMENTS_KEY, jobsPoolMetaData );
        unit.addToAttachmentList( ScheduledJobMetaData.ATTACHMENTS_KEY, new ScheduledJobMetaData() );
        
        deploy( phaseContext );

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

        deploy( phaseContext );
        
        List<PoolMetaData> allPools = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );
        assertEquals( 1, allPools.size() );
        
        PoolMetaData jobPoolMetaData = allPools.get( 0 );
        
        assertEquals( "jobs", jobPoolMetaData.getName() );
        assertTrue( jobPoolMetaData.isShared() );
        assertTrue( jobPoolMetaData.isDeferUntilRequested() );
    }

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

                return;
            }
        }
        RubyAppMetaData envMetaData = unit.getAttachment( RubyAppMetaData.ATTACHMENT_KEY );
        boolean devMode = envMetaData != null && envMetaData.isDevelopmentMode();
        PoolMetaData pool = devMode ? new PoolMetaData( "messaging", 1, 10 ) : new PoolMetaData( "messaging" );
        unit.addToAttachmentList( PoolMetaData.ATTACHMENTS_KEY, pool );
    }

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

        List<PoolMetaData> pools = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );


        assertFalse( pools.isEmpty() );
        assertEquals( 2, pools.size() );
        
        PoolMetaData poolOne = pools.get( 0 );
        assertNotNull( poolOne );


        assertEquals( "pool_one", poolOne.getName() );
        assertEquals( 1, poolOne.getMinimumSize() );
        assertEquals( 1, poolOne.getMaximumSize() );


        PoolMetaData poolTwo = pools.get( 1 );


        assertEquals( "pool_two", poolTwo.getName() );
        assertEquals( 10, poolTwo.getMinimumSize() );
        assertEquals( 200, poolTwo.getMaximumSize() );
    }

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

        List<PoolMetaData> pools = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );


        assertFalse( pools.isEmpty() );
        assertEquals( 2, pools.size() );
        
        PoolMetaData poolOne = pools.get( 0 );
        assertNotNull( poolOne );
        assertEquals( "pool_one", poolOne.getName() );
        assertTrue( poolOne.isShared() );
        assertTrue( poolOne.isDeferUntilRequested() );
        
        PoolMetaData webPool = pools.get( 1 );
        assertNotNull( webPool );
        assertEquals( "web", webPool.getName() );
        assertTrue( webPool.isShared() );
        assertFalse( webPool.isDeferUntilRequested() );
    }

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

        List<PoolMetaData> pools = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );


        assertFalse( pools.isEmpty() );
        assertEquals( 1, pools.size() );
        
        PoolMetaData poolOne = pools.get( 0 );
        assertNotNull( poolOne );
        assertEquals( "pool_one", poolOne.getName() );
        assertTrue( poolOne.isShared() );
        assertFalse( poolOne.isDeferUntilRequested() );
    }

View Full Code Here

Examples of org.torquebox.core.runtime.PoolMetaData

        deploy( phaseContext );


        List<PoolMetaData> allPools = unit.getAttachmentList( PoolMetaData.ATTACHMENTS_KEY );
        assertEquals( 1, allPools.size() );


        PoolMetaData messagingPoolMetaData = allPools.get( 0 );
        assertEquals( "messaging", messagingPoolMetaData.getName() );
        assertTrue( messagingPoolMetaData.isShared() );
        assertTrue( messagingPoolMetaData.isDeferUntilRequested() );
    }

View Full Code Here

0 1

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.