|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.gridbus.broker.common.BrokerBase
org.gridbus.broker.common.Broker
public class Broker
| Field Summary | |
|---|---|
protected java.util.Map |
jobMons
|
protected java.util.Map |
schedulers
|
protected java.util.Map |
serviceMons
|
protected BrokerStorage |
store
|
| Constructor Summary | |
|---|---|
Broker()
|
|
Broker(boolean setupDb)
|
|
Broker(BrokerProperties props)
|
|
Broker(BrokerProperties props,
boolean setupDb)
|
|
| Method Summary | |
|---|---|
void |
addCredential(java.lang.String applicationId,
UserCredential uc)
|
void |
addCredentialMapping(java.lang.String applicationId,
java.lang.String credentialID,
java.lang.String serviceMappingID)
|
void |
addJob(java.lang.String applicationId,
WorkUnit workUnit)
|
void |
addSCSJob(java.lang.String applicationId,
WorkUnit workUnit)
|
void |
addService(java.lang.String applicationId,
Service s)
Adds a service to the given application in the broker. |
java.lang.String |
createApplication(ApplicationContext app)
|
protected java.lang.Thread |
findThread(java.lang.String name,
java.lang.ThreadGroup group)
Helper method to find the thread in the given group, by name |
ApplicationContext |
getApplication(java.lang.String appId)
|
ApplicationContext |
getApplication(java.lang.String username,
java.lang.String appname)
Get an application by the username and application name |
UserCredential |
getCredentialsForService(java.lang.String applicationId,
Service s)
|
Job |
getJob(java.lang.String applicationId,
java.lang.String jobName)
|
long |
getJobCount(java.lang.String applicationID,
int status,
java.lang.String serverName)
|
java.util.Collection |
getJobs(java.lang.String applicationId)
|
java.util.Collection |
getJobs(java.lang.String applicationID,
int status)
Gets all the jobs with the given status |
java.util.Collection |
getJobs(java.lang.String applicationID,
int pageNumber,
int pageSize)
Gets all the jobs with the given status |
java.util.Collection |
getJobs(java.lang.String applicationID,
int status,
java.lang.String serverName)
|
JobStatistics |
getJobStatistics(java.lang.String applicationId,
java.lang.String serverName)
|
Qos |
getQos(java.lang.String applicationID)
|
org.gridbus.scs.common.SCSJob |
getSCSJob(java.lang.String applicationId,
java.lang.String jobName)
|
long |
getSCSJobCount(java.lang.String applicationID,
int status,
java.lang.String serverName)
|
java.util.Collection |
getSCSJobs(java.lang.String applicationId)
|
java.util.Collection |
getSCSJobs(java.lang.String applicationID,
int status)
|
Service |
getService(java.lang.String applicationId,
int serviceType,
java.lang.String serverName)
|
java.util.Collection |
getServices(java.lang.String applicationId,
int serviceType)
|
void |
removeJob(java.lang.String applicationId,
Job job)
Kills the job and removes it from the database |
void |
resetJob(java.lang.String applicationId,
java.lang.String jobName)
Resets the job, so that it will be re-scheduled |
void |
saveObject(java.lang.Object object)
|
void |
shutdown(long waitTimeout)
Note: Pass -1 for waitTimeout to wait forever. |
void |
startApplication(java.lang.String applicationID)
|
protected void |
startJobMonitor(org.gridbus.broker.common.JobMonitor jobmonitor)
In the jobMonitors thread group, each jobMonitor thread is added by its name. |
protected void |
startJobMonitorThreads(java.lang.String applicationID)
|
protected void |
startScheduler(Scheduler scheduler)
In the scheduler thread group, each scheduler thread is added by its name. |
protected void |
startSchedulerThreads(java.lang.String applicationID)
|
protected void |
startServiceMonitor(ServiceMonitor servicemonitor)
In the serviceMonitors thread group, each serviceMonitor thread is added by its name. |
protected void |
startServiceMonitorThreads(java.lang.String applicationID)
|
protected void |
stopAllJobMonitors()
|
protected void |
stopAllRunningJobs(java.lang.String applicationId)
|
protected void |
stopAllSchedulers()
|
protected void |
stopAllServiceMonitors()
|
void |
stopApplication(java.lang.String appId)
|
protected void |
stopJobMonitorThreads(java.lang.String applicationID)
|
protected void |
stopSchedulerThreads(java.lang.String applicationID)
|
protected void |
stopServiceMonitorThreads(java.lang.String applicationId)
|
java.lang.String |
updateApplication(ApplicationContext app)
|
void |
updateJob(java.lang.String applicationID,
Job job)
Updates a given job (i.e saves it to a persistent store) |
void |
updateQos(java.lang.String applicationId,
Qos qos)
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected java.util.Map jobMons
protected java.util.Map schedulers
protected java.util.Map serviceMons
protected BrokerStorage store
| Constructor Detail |
|---|
public Broker()
throws GridBrokerException
GridBrokerException
public Broker(boolean setupDb)
throws GridBrokerException
setupDb -
GridBrokerException
public Broker(BrokerProperties props)
throws GridBrokerException
props -
GridBrokerException
public Broker(BrokerProperties props,
boolean setupDb)
throws GridBrokerException
props - setupDb -
GridBrokerException| Method Detail |
|---|
protected void stopSchedulerThreads(java.lang.String applicationID)
protected java.lang.Thread findThread(java.lang.String name,
java.lang.ThreadGroup group)
name - group -
protected void startScheduler(Scheduler scheduler)
protected void startServiceMonitor(ServiceMonitor servicemonitor)
protected void startJobMonitor(org.gridbus.broker.common.JobMonitor jobmonitor)
protected void stopJobMonitorThreads(java.lang.String applicationID)
throws java.lang.Exception
java.lang.Exceptionprotected void stopServiceMonitorThreads(java.lang.String applicationId)
public void shutdown(long waitTimeout)
waitTimeout - protected void stopAllSchedulers()
protected void stopAllJobMonitors()
protected void stopAllServiceMonitors()
public void updateJob(java.lang.String applicationID,
Job job)
throws GridBrokerException
job -
GridBrokerException
public void removeJob(java.lang.String applicationId,
Job job)
throws GridBrokerException
job -
GridBrokerException
public void addService(java.lang.String applicationId,
Service s)
throws GridBrokerException
s -
GridBrokerException
public java.lang.String createApplication(ApplicationContext app)
throws GridBrokerException
GridBrokerExceptionApplicationManager.createApplication(org.gridbus.broker.common.ApplicationContext)
public void addJob(java.lang.String applicationId,
WorkUnit workUnit)
throws GridBrokerException
GridBrokerExceptionApplicationManager.addJob(java.lang.String,WorkUnit)
public void addSCSJob(java.lang.String applicationId,
WorkUnit workUnit)
throws GridBrokerException
GridBrokerException
public UserCredential getCredentialsForService(java.lang.String applicationId,
Service s)
org.gridbus.broker.common.ApplicationManager#getCredentialsForService(org.gridbus.broker.common.Service)
public java.util.Collection getJobs(java.lang.String applicationId)
throws GridBrokerException
GridBrokerExceptionImplements Broker.getJobs(String applicationId).
NOTE: Here we are getting only USER type jobs because we are hiding other job types from users.
public java.util.Collection getSCSJobs(java.lang.String applicationId)
throws GridBrokerException
GridBrokerException
public java.util.Collection getServices(java.lang.String applicationId,
int serviceType)
throws GridBrokerException
GridBrokerExceptionApplicationManager.getServices(java.lang.String,int)
public ApplicationContext getApplication(java.lang.String appId)
throws GridBrokerException
GridBrokerExceptionorg.gridbus.broker.common.ApplicationManager#getApplication()
public ApplicationContext getApplication(java.lang.String username,
java.lang.String appname)
throws GridBrokerException
ApplicationManager
GridBrokerExceptionorg.gridbus.broker.common.ApplicationManager#getApplication()
public void addCredentialMapping(java.lang.String applicationId,
java.lang.String credentialID,
java.lang.String serviceMappingID)
org.gridbus.broker.common.CredentialManager#addCredentialMappings(java.lang.String, java.lang.String)
public void addCredential(java.lang.String applicationId,
UserCredential uc)
org.gridbus.broker.common.CredentialManager#addCredentials(org.gridbus.broker.common.security.UserCredential)
public void resetJob(java.lang.String applicationId,
java.lang.String jobName)
throws java.lang.Exception
java.lang.ExceptionApplicationManager.resetJob(java.lang.String, java.lang.String)protected void stopAllRunningJobs(java.lang.String applicationId)
public void startApplication(java.lang.String applicationID)
throws java.lang.Exception
applicationID -
java.lang.Exception
public void stopApplication(java.lang.String appId)
throws java.lang.Exception
appId -
java.lang.Exception
protected void startJobMonitorThreads(java.lang.String applicationID)
throws java.lang.Exception
java.lang.Exception
protected void startServiceMonitorThreads(java.lang.String applicationID)
throws java.lang.Exception
java.lang.Exception
protected void startSchedulerThreads(java.lang.String applicationID)
throws java.lang.Exception
java.lang.Exception
public long getJobCount(java.lang.String applicationID,
int status,
java.lang.String serverName)
throws GridBrokerException
GridBrokerExceptionApplicationManager.getJobCount(String, int, java.lang.String)
public long getSCSJobCount(java.lang.String applicationID,
int status,
java.lang.String serverName)
throws GridBrokerException
GridBrokerException
public java.util.Collection getJobs(java.lang.String applicationID,
int status)
throws GridBrokerException
ApplicationManager
GridBrokerExceptionApplicationManager.getJobs(String, int)
public java.util.Collection getSCSJobs(java.lang.String applicationID,
int status)
throws GridBrokerException
GridBrokerException
public Qos getQos(java.lang.String applicationID)
throws GridBrokerException
GridBrokerExceptionApplicationManager.getQos(String)
public java.lang.String updateApplication(ApplicationContext app)
throws GridBrokerException
GridBrokerExceptionApplicationManager.updateApplication(org.gridbus.broker.common.ApplicationContext)
public java.util.Collection getJobs(java.lang.String applicationID,
int pageNumber,
int pageSize)
throws GridBrokerException
ApplicationManager
GridBrokerException
public java.util.Collection getJobs(java.lang.String applicationID,
int status,
java.lang.String serverName)
throws GridBrokerException
GridBrokerException
public void updateQos(java.lang.String applicationId,
Qos qos)
throws GridBrokerException
applicationId - qos -
GridBrokerException
public Service getService(java.lang.String applicationId,
int serviceType,
java.lang.String serverName)
throws GridBrokerException
applicationId - serviceType - serverName -
GridBrokerException
public Job getJob(java.lang.String applicationId,
java.lang.String jobName)
throws GridBrokerException
GridBrokerException
public org.gridbus.scs.common.SCSJob getSCSJob(java.lang.String applicationId,
java.lang.String jobName)
throws GridBrokerException
GridBrokerException
public JobStatistics getJobStatistics(java.lang.String applicationId,
java.lang.String serverName)
throws GridBrokerException
applicationId - serverName -
GridBrokerException
public void saveObject(java.lang.Object object)
throws GridBrokerException
GridBrokerException
|
Copyright © The University of Melbourne. 2006 | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||