org.gwe.app.daemon.domain
Class InternalDomain

java.lang.Object
  org.gwe.app.daemon.domain.BaseDomain
      org.gwe.app.daemon.domain.InternalDomain

public class InternalDomain
extends BaseDomain

Since:

Jan 1, 2009

Author:

Marco Ruiz

Field Summary

Fields inherited from class org.gwe.app.daemon.domain.BaseDomain

allocationDAO, computeResourceDAO, headResourceDAO, jobDAO, jobExecutionDAO, orderDAO

Constructor Summary

InternalDomain()

Method Summary

void	flagNextPreparedJobAsReady()
void	launchPreparers(java.util.List<JobInfo> jobs)
void	pairNextJobAndAllocationReady()
java.util.List<AllocationInfo>	prepareMoreAllocations()
void	runUpdateOrdersCycle()
java.util.List<JobInfo>	selectNextJobBatch()
void	triggerMoreJobsAndAllocationPreparation()
void	updateOrder(int orderId, int amount)
void	wrapUpJob(JobExecutionInfo exec)

Methods inherited from class org.gwe.app.daemon.domain.BaseDomain

getAllocationDAO, getComputeResourceDAO, getConfig, getHeadResourceDAO, getJobDAO, getJobExecutionDAO, getOrderDAO, setAllocationDAO, setComputeResourceDAO, setConfig, setHeadResourceDAO, setJobDAO, setJobExecutionDAO, setOrderDAO, verifyAccount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InternalDomain

public InternalDomain()

Method Detail

triggerMoreJobsAndAllocationPreparation

public void triggerMoreJobsAndAllocationPreparation()

prepareMoreAllocations

@Transactional(propagation=REQUIRES_NEW)
public java.util.List<AllocationInfo> prepareMoreAllocations()

selectNextJobBatch

@Transactional(propagation=REQUIRES_NEW)
public java.util.List<JobInfo> selectNextJobBatch()

launchPreparers

@Transactional(propagation=NEVER)
public void launchPreparers(java.util.List<JobInfo> jobs)

flagNextPreparedJobAsReady

@Transactional(propagation=REQUIRES_NEW)
public void flagNextPreparedJobAsReady()
                                throws java.lang.InterruptedException,
                                       java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

wrapUpJob

@Transactional(propagation=REQUIRES_NEW)
public void wrapUpJob(JobExecutionInfo exec)

pairNextJobAndAllocationReady

@Transactional(propagation=REQUIRES_NEW)
public void pairNextJobAndAllocationReady()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

runUpdateOrdersCycle

public void runUpdateOrdersCycle()

updateOrder

@Transactional(propagation=REQUIRES_NEW)
public void updateOrder(int orderId,
                                      int amount)