|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of CommunicationAddress in eu.xtreemos.service.test |
---|
Methods in eu.xtreemos.service.test that return types with arguments of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
Test.getDaemons()
|
Methods in eu.xtreemos.service.test with parameters of type CommunicationAddress | |
---|---|
java.lang.Integer |
Test.delegateExecution(CommunicationAddress targetAddress)
|
Uses of CommunicationAddress in eu.xtreemos.system.communication.net |
---|
Methods in eu.xtreemos.system.communication.net that return CommunicationAddress | |
---|---|
CommunicationAddress |
CommunicationAddress.getExternalAddress()
Composes an instance of CommunicationAddress that points to the external address of an xosd machine. |
static CommunicationAddress |
CommunicationAddress.getFromHostPort(java.lang.String hostport)
Parse the address from a string. |
static CommunicationAddress |
CommunicationAddress.parse(java.lang.String text)
Convert a String formatted as the communication address. |
Methods in eu.xtreemos.system.communication.net with parameters of type CommunicationAddress | |
---|---|
boolean |
CommunicationAddress.equals(CommunicationAddress other)
|
boolean |
CommunicationAddress.isSame(CommunicationAddress address)
Checks whether the two CommunicationAddress instances point to the same address. |
protected boolean |
CommunicationAddress.isSameHostPort(CommunicationAddress address)
Check the equality of the port numbers and the host IPs. |
boolean |
CommunicationAddress.isSameLAN(CommunicationAddress arg0)
Checks whether the two communication addresses share the same LAN. |
Constructors in eu.xtreemos.system.communication.net with parameters of type CommunicationAddress | |
---|---|
CommunicationAddress(CommunicationAddress address)
|
Uses of CommunicationAddress in eu.xtreemos.xati.API |
---|
Methods in eu.xtreemos.xati.API that return CommunicationAddress | |
---|---|
static CommunicationAddress |
XJobDirectory.getJobAddr(java.lang.String __jobId)
|
static CommunicationAddress |
XSRDSMng.getJobContactPoint(java.lang.String __jobID)
|
Methods in eu.xtreemos.xati.API that return types with arguments of type CommunicationAddress | |
---|---|
static java.util.ArrayList<CommunicationAddress> |
XResMng.createRequest(java.util.Hashtable<java.lang.String,java.lang.Object> __jsdlTable)
|
static java.util.ArrayList<CommunicationAddress> |
XDaemon.getDaemons()
"global" method (i.e. gets invoked on the root address xosd) |
static java.util.ArrayList<CommunicationAddress> |
XCronDaemon.getDaemons()
|
static java.util.ArrayList<CommunicationAddress> |
XTest.getDaemons()
|
static java.util.ArrayList<CommunicationAddress> |
XVOPS.getFilteredResources()
Deprecated. |
static java.util.ArrayList<CommunicationAddress> |
XJobDirectory.getJobAddrList(java.util.ArrayList<java.lang.String> __jobList)
|
static java.util.Hashtable<java.lang.String,CommunicationAddress> |
XJobDirectory.getJobsUser(java.lang.String __userId)
|
static java.util.ArrayList<CommunicationAddress> |
XDaemon.getNodesRunningService(java.lang.String __serviceName)
|
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResources(java.lang.String __query,
java.security.cert.X509Certificate __userCtx,
java.lang.Integer __howMany)
Retrieve a collection of resources that match the job's resource demands. |
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesADS(java.lang.String __query,
java.security.cert.X509Certificate __userCtx,
java.lang.Integer __howMany)
|
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesCentral(java.lang.String __query,
java.security.cert.X509Certificate __userCtx,
java.lang.Integer __howMany)
Retrieve a collection of resources that match the job's resource demands. |
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesFromParsedCommand(ParsedCommand __command)
|
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesFromString(java.lang.String __query)
Retrieve a collection of resources that match the job's resource demands. |
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesFromStructure(java.util.Hashtable<java.lang.String,java.lang.Object> __jsdl)
Retrieve a collection of resources that match the job's resource demands. |
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesScored(java.lang.String __query)
|
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesScoredWeighted(java.lang.String __query,
java.util.Hashtable<java.lang.Integer,java.lang.Double> __weights)
|
static java.util.ArrayList<CommunicationAddress> |
XResMng.getResourcesSorted(java.lang.String __query,
ResourceDescriptorComparatorSerializable __comparator)
Retrieve a collection of resources that match the job's resource demands. |
static java.util.ArrayList<CommunicationAddress> |
XSRDSMng.resourceQuery(java.lang.String __jsdlDocument,
java.lang.String __xacmlDocument,
java.security.cert.X509Certificate __userXOSDCert)
|
static java.util.ArrayList<CommunicationAddress> |
XResMng.testCall()
A function for testing stuff. |
Methods in eu.xtreemos.xati.API with parameters of type CommunicationAddress | |
---|---|
static void |
XJobDirectory.addJob(java.lang.String __jobId,
CommunicationAddress __addrJobMng,
java.lang.String __userId)
|
static java.lang.Object |
XCDAMng.authenticateWithCDA(CommunicationAddress __caCDAServer,
java.security.cert.X509Certificate __caCert,
java.security.KeyPair __keyPair,
java.lang.String __voUserName,
java.lang.String __voUserPass)
This method authenticates user with CDA server. |
static java.lang.Integer |
XCRExecMng.checkpointJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __options,
java.lang.String __cpImageVersion,
java.lang.String __checkpointPath,
CommunicationAddress __jobCpAddr)
|
static java.lang.Object |
XCDAMng.connectToCDA(CommunicationAddress __caHost,
java.security.cert.X509Certificate __cdaCert)
Connect to CDA server. |
static void |
XCRExecMng.continueRebuildJobUnit(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __initialJobId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __checkpointVersion,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr)
|
static java.lang.Integer |
XExecMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
It is supposed to be "similar" to a fork but in XOS. |
static java.lang.Integer |
XJobMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. |
static java.lang.Integer |
XTest.delegateExecution(CommunicationAddress __targetAddress)
|
static FreeSlots |
XReservationManager.getAllFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.security.cert.X509Certificate __userCert)
Returns all free slots in a timetable for some metric on the node. |
static FreeSlots |
XReservationManager.getFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.util.GregorianCalendar __from,
java.util.GregorianCalendar __to,
java.security.cert.X509Certificate __userCert)
Returns all free slots for a given resource and time frame on the node. |
static java.lang.String |
XJobMng.getJobId(CommunicationAddress __resourceId,
java.lang.Integer __pid,
java.security.cert.X509Certificate __userCtx)
Returns the jobID corresponding to a |
static java.util.ArrayList<ResourceDescriptorRecord> |
XResMng.getNodeResourceDescriptor(CommunicationAddress __address)
A proxy call to ResourceMonitor.query of a service running at particular node. |
static java.util.Hashtable<java.lang.String,java.lang.Object> |
XResMng.getNodeResourceGLUE(CommunicationAddress __address)
A proxy call to ResourceMonitor.query of a service running at particular node. |
static VivaldiCoordinates |
XVivaldi.getRemoteCoordinates(CommunicationAddress __ca)
|
static java.util.Hashtable<java.lang.String,java.lang.String> |
XResMng.getResInfo(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
Returns the monitoring information associated with the resource. |
static java.util.ArrayList<java.lang.String> |
XResMng.getResMetrics(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
Returns the list of metrics available on that resource. |
static java.lang.Object |
XVivaldi.initializeVivaldiRemote(CommunicationAddress __remoteAddress)
This is for calling initialize Vivaldi from service |
static void |
XJobMng.lockCheckpoint(java.lang.String __jobId,
java.lang.String __initialJobId,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name |
static java.lang.Integer |
XSRDSMng.modifyJobContactPoint(java.lang.String __jobID,
CommunicationAddress __newContactPoint)
|
static java.lang.Integer |
XCRExecMng.prepareJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert)
|
static java.lang.Integer |
XSRDSMng.putJob(java.lang.String __jobID,
CommunicationAddress __contactPoint,
java.lang.String __userID)
|
static void |
XExecMng.rebuildJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __checkpointVersion,
CommunicationAddress __jobMngAddr,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert)
|
static void |
XJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert)
set up structures that represent a job in AEM at restart |
static java.lang.Boolean |
XVOPS.registerVOPSToGlobalVOPS(CommunicationAddress __address,
java.security.cert.X509Certificate __certificate)
This registers VOPS to global VOPS service where decisions are made. |
static java.lang.Integer |
XSRDSMng.removeResource(CommunicationAddress __nodeToRemove)
|
static java.lang.Integer |
XCRExecMng.resumeJobUnitCP(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executableName,
java.lang.String __cpImageVersion,
CommunicationAddress __jobCpAddr)
|
static void |
XCRExecMng.resumeJobUnitRST(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
CommunicationAddress __jobCpAddr,
java.lang.String __userCert)
|
static void |
XCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
static java.lang.Integer |
XJobMng.runJobRes(java.lang.String __jobId,
java.lang.String __reservationID,
CommunicationAddress __resourceID,
java.security.cert.X509Certificate __userCtx)
Starts the scheduling process of a previously created job. |
static java.lang.Integer |
XCRExecMng.selectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.Integer __kernelCheckpointerId,
java.lang.String __preferredKernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert)
select on each grid node kernel checkpointer bound to node, no job-unit checkpointer matching yet!! |
static java.lang.Integer |
XJobMng.setMetricValue(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.String __value,
java.security.cert.X509Certificate __userCtx)
Sets the value of a Metric. |
static java.lang.Integer |
XJobMng.setMonitorBuffering(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.Integer __flags,
java.security.cert.X509Certificate __userCtx)
Switches on and off buffering for the specified metric. |
static java.lang.Integer |
XCRExecMng.stopJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __cpImageVersion,
CommunicationAddress __jcAddr)
|
Method parameters in eu.xtreemos.xati.API with type arguments of type CommunicationAddress | |
---|---|
static java.util.ArrayList<ResourceDescriptorRecord> |
XResMng.getResourceDescriptors(java.util.ArrayList<CommunicationAddress> __resources)
Retrieve the resource descriptors of the nodes from the given list. |
static void |
XCRJobMng.matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
BEST SERVICE! |
static void |
XJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert)
set up structures that represent a job in AEM at restart |
static void |
XCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
Uses of CommunicationAddress in eu.xtreemos.xosd.crondaemon |
---|
Methods in eu.xtreemos.xosd.crondaemon that return types with arguments of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
CronDaemon.getDaemons()
|
Uses of CommunicationAddress in eu.xtreemos.xosd.daemon |
---|
Fields in eu.xtreemos.xosd.daemon with type parameters of type CommunicationAddress | |
---|---|
private java.util.ArrayList<CommunicationAddress> |
Daemon.list
|
protected java.util.Hashtable<java.lang.String,java.util.ArrayList<CommunicationAddress>> |
Daemon.serviceDir
Stage directory containing the list of addresses for each service known to be running at those addresses. |
Methods in eu.xtreemos.xosd.daemon that return types with arguments of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
Daemon.getDaemons()
"global" method (i.e. gets invoked on the root address xosd) |
java.util.ArrayList<CommunicationAddress> |
Daemon.getNodesRunningService(java.lang.String serviceName)
"global" method (i.e. gets invoked on the root address xosd) Retrieve a list of nodes that run a particular service. |
Methods in eu.xtreemos.xosd.daemon with parameters of type CommunicationAddress | |
---|---|
void |
Daemon.registerDaemon(CommunicationAddress address)
"global" method (i.e. gets invoked on the root address xosd) |
java.lang.Integer |
Daemon.registerServices(CommunicationAddress address,
java.util.ArrayList<java.lang.String> activeServices)
Register the list of services running within an xosd. |
protected void |
Daemon.removeRegisteredServices(CommunicationAddress address)
Purge all entries of Daemon.serviceDir of the given XOSD's address. |
void |
Daemon.unregisterDaemon(CommunicationAddress address)
"global" method (i.e. gets invoked on the root address xosd) Unregisters the xosd from the list of running daemons. |
Uses of CommunicationAddress in eu.xtreemos.xosd.execMng |
---|
Fields in eu.xtreemos.xosd.execMng declared as CommunicationAddress | |
---|---|
CommunicationAddress |
ExecMng.startJobParams.jobMngAddr
|
Methods in eu.xtreemos.xosd.execMng with parameters of type CommunicationAddress | |
---|---|
java.lang.Integer |
ExecMng.createProcess(java.lang.String jobId,
java.lang.String JSDL,
java.lang.String reservationId,
CommunicationAddress resource,
java.security.cert.X509Certificate userCtx)
It is supposed to be "similar" to a fork but in XOS. |
void |
ExecMng.getProcessList(java.lang.String jobId,
java.lang.String initialJobId,
java.lang.String jsdlFile,
java.lang.String jobUnitID,
java.util.ArrayList<java.lang.String> dependentJobs,
java.lang.String executable,
CommunicationAddress jobCpAddr,
CommunicationAddress superJobCpAddr,
java.lang.String kernelCheckpointer,
java.lang.String checkpointVersion,
java.lang.String pidCGroupName,
java.lang.String strategy,
java.lang.String options,
java.lang.String mode,
java.security.cert.X509Certificate userCert)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst |
void |
ExecMng.rebuildJobUnit(java.lang.String jobId,
java.lang.String initialJobId,
java.lang.String jobUnitId,
java.lang.String checkpointVersion,
CommunicationAddress jobMngAddr,
java.lang.String processGroupReferenceId,
java.lang.String processGroupReferenceType,
java.lang.String pidCGroupName,
java.lang.String kernelCheckpointer,
java.lang.String jsdlFile,
java.lang.String input,
java.lang.String output,
java.lang.String cmd,
java.lang.String error,
java.security.cert.X509Certificate userCert)
|
java.lang.Integer |
ExecMng.startJob(java.lang.String jobId,
CommunicationAddress jobMngAddr,
java.lang.String command,
java.lang.Object params_aux,
java.lang.Object env_aux,
java.lang.String output,
java.lang.String error,
java.lang.String input,
java.security.cert.X509Certificate userCtx)
Starts running a job already created |
java.lang.Integer |
ExecMng.startProcess(java.lang.String jobId,
CommunicationAddress jobMngAddr,
java.lang.String command,
java.lang.Object params_aux,
java.lang.Object env_aux,
java.lang.String output,
java.lang.String error,
java.lang.String input,
java.security.cert.X509Certificate userCtx)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource. |
Constructors in eu.xtreemos.xosd.execMng with parameters of type CommunicationAddress | |
---|---|
ExecMng.startJobParams(java.lang.String jobId,
CommunicationAddress jobMngAddr,
java.lang.String command,
java.lang.Object params_aux,
java.lang.Object env_aux,
java.lang.String output,
java.lang.String error,
java.lang.String input,
java.security.cert.X509Certificate userCtx)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.execMng.data |
---|
Fields in eu.xtreemos.xosd.execMng.data declared as CommunicationAddress | |
---|---|
CommunicationAddress |
JobUnit.jobMngAddr
|
Constructors in eu.xtreemos.xosd.execMng.data with parameters of type CommunicationAddress | |
---|---|
JobUnit(java.lang.String jobId,
CommunicationAddress jobMngAddr,
java.lang.String command,
java.lang.String[] params,
java.lang.String[] env,
java.lang.String output,
java.lang.String error,
java.lang.String input,
java.security.cert.X509Certificate userCtx)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.jobDirectory |
---|
Fields in eu.xtreemos.xosd.jobDirectory declared as CommunicationAddress | |
---|---|
static CommunicationAddress |
JobDirectoryGlobal.rootaddress
|
Fields in eu.xtreemos.xosd.jobDirectory with type parameters of type CommunicationAddress | |
---|---|
private java.util.Hashtable<java.lang.String,CommunicationAddress> |
JobDirectory.list
|
Methods in eu.xtreemos.xosd.jobDirectory that return CommunicationAddress | |
---|---|
CommunicationAddress |
JobDirectory.getJobAddr(java.lang.String jobId)
|
CommunicationAddress |
JobDirectory.getJobAddrSucceeded(CommunicationAddress result)
|
Methods in eu.xtreemos.xosd.jobDirectory that return types with arguments of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
JobDirectory.getJobAddrList(java.util.ArrayList<java.lang.String> jobList)
|
java.util.Hashtable<java.lang.String,CommunicationAddress> |
JobDirectory.getJobsUser(java.lang.String userId)
|
java.util.Hashtable<java.lang.String,CommunicationAddress> |
JobDirectory.getJobsUserSucceeded(java.util.Hashtable<java.lang.String,CommunicationAddress> result)
|
Methods in eu.xtreemos.xosd.jobDirectory with parameters of type CommunicationAddress | |
---|---|
void |
JobDirectory.addJob(java.lang.String jobId,
CommunicationAddress addrJobMng,
java.lang.String userId)
|
CommunicationAddress |
JobDirectory.getJobAddrSucceeded(CommunicationAddress result)
|
Method parameters in eu.xtreemos.xosd.jobDirectory with type arguments of type CommunicationAddress | |
---|---|
java.util.Hashtable<java.lang.String,CommunicationAddress> |
JobDirectory.getJobsUserSucceeded(java.util.Hashtable<java.lang.String,CommunicationAddress> result)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.jobmng |
---|
Fields in eu.xtreemos.xosd.jobmng declared as CommunicationAddress | |
---|---|
(package private) CommunicationAddress |
JobMng.CleaningCronEntry.ca
|
private CommunicationAddress |
JobMng.myAddr
|
CommunicationAddress |
JobMng.ReservationCallBack.resource
|
CommunicationAddress |
JobMng.JobFunction.resourceId
|
(package private) CommunicationAddress |
JobMng.DependentJobsAddress.superJobCpAddr
|
Fields in eu.xtreemos.xosd.jobmng with type parameters of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
JobMng.ReservationCallBack.available
|
java.util.ArrayList<CommunicationAddress> |
JobMng.ResourceInfo.list
|
java.util.ArrayList<CommunicationAddress> |
JobMng.ReservationCallBack.resources
|
Methods in eu.xtreemos.xosd.jobmng that return CommunicationAddress | |
---|---|
CommunicationAddress |
JobMng.selectResource(java.util.ArrayList<CommunicationAddress> list,
java.lang.Integer schedule)
Returns a resource from a list of resources |
Methods in eu.xtreemos.xosd.jobmng with parameters of type CommunicationAddress | |
---|---|
java.lang.Integer |
JobMng.createProcess(java.lang.String jobId,
java.lang.String JSDL,
java.lang.String reservationId,
CommunicationAddress resource,
java.security.cert.X509Certificate userCtx)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. |
java.lang.Object |
JobMng.execJob(CommunicationAddress addrResource)
Executes the job in the resource specified |
java.lang.String |
JobMng.getJobId(CommunicationAddress resourceId,
java.lang.Integer pid,
java.security.cert.X509Certificate userCtx)
Returns the jobID corresponding to a |
void |
JobMng.jobFinished(java.lang.String jobId,
java.lang.Integer exitStatus,
CommunicationAddress execMng)
|
void |
JobMng.lockCheckpoint(java.lang.String jobId,
java.lang.String initialJobId,
java.security.cert.X509Certificate userCert,
CommunicationAddress jobCpAddr,
CommunicationAddress superJobCpAddr,
java.lang.String strategy,
java.lang.String options,
java.lang.String mode,
java.util.ArrayList<java.lang.String> dependentJobs)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name |
void |
JobMng.recreateJob(java.lang.String jobId,
java.lang.String initialJobId,
java.lang.String jsdlFileContent,
java.lang.String checkpointVersion,
CommunicationAddress superJobCpAddr,
java.util.ArrayList<CommunicationAddress> jobResourceList,
java.security.cert.X509Certificate userCert)
set up structures that represent a job in AEM at restart |
java.lang.Object |
JobMng.redirectFunctionCB(CommunicationAddress addrJob)
|
java.lang.Integer |
JobMng.runJobRes(java.lang.String jobId,
java.lang.String reservationID,
CommunicationAddress resourceID,
java.security.cert.X509Certificate userCtx)
|
java.lang.Integer |
JobMng.setMetricValue(java.lang.String jobId,
java.lang.String metricName,
CommunicationAddress resourceID,
java.lang.Integer pid,
java.lang.String value,
java.security.cert.X509Certificate userCtx)
Sets the value of a Metric. |
java.lang.Integer |
JobMng.setMonitorBuffering(java.lang.String jobId,
java.lang.String metricName,
CommunicationAddress resourceID,
java.lang.Integer pid,
java.lang.Integer flags,
java.security.cert.X509Certificate userCtx)
Switches on and off buffering for the specified metric. |
Method parameters in eu.xtreemos.xosd.jobmng with type arguments of type CommunicationAddress | |
---|---|
(package private) boolean |
JobMng.checkGridNodeForJobUnitRestart(java.util.ArrayList<CommunicationAddress> list,
java.lang.String jobId,
java.lang.Integer jobUnitId)
verify that each job unit of a job resides on a separate grid node |
java.lang.Integer |
JobMng.getAllResourcesCB(java.util.ArrayList<CommunicationAddress> list)
Callback where I get a list of candidates. |
java.lang.Object |
JobMng.getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> addrJobList)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected |
void |
JobMng.recreateJob(java.lang.String jobId,
java.lang.String initialJobId,
java.lang.String jsdlFileContent,
java.lang.String checkpointVersion,
CommunicationAddress superJobCpAddr,
java.util.ArrayList<CommunicationAddress> jobResourceList,
java.security.cert.X509Certificate userCert)
set up structures that represent a job in AEM at restart |
CommunicationAddress |
JobMng.selectResource(java.util.ArrayList<CommunicationAddress> list,
java.lang.Integer schedule)
Returns a resource from a list of resources |
Constructors in eu.xtreemos.xosd.jobmng with parameters of type CommunicationAddress | |
---|---|
JobMng.CleaningCronEntry(java.util.GregorianCalendar time,
CommunicationAddress ca,
java.lang.String jobId)
|
|
JobMng.JobFunction(java.lang.String jobId,
JobMng.RedirFuncs function,
java.lang.String str1,
CommunicationAddress resourceId,
java.lang.Integer int1,
java.lang.Integer enable,
java.security.cert.X509Certificate userCert)
|
|
JobMng.JobFunction(java.lang.String jobId,
JobMng.RedirFuncs function,
java.lang.String str1,
CommunicationAddress resourceID,
java.lang.Integer int1,
java.lang.String str2,
java.security.cert.X509Certificate userCert)
|
|
JobMng.JobFunction(java.lang.String jobId,
JobMng.RedirFuncs function,
java.lang.String JSDL,
java.lang.String reservationId,
CommunicationAddress resourceId,
java.security.cert.X509Certificate userCert)
|
Constructor parameters in eu.xtreemos.xosd.jobmng with type arguments of type CommunicationAddress | |
---|---|
JobMng.ResourceInfo(java.util.ArrayList<CommunicationAddress> list)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.jobmng.data |
---|
Fields in eu.xtreemos.xosd.jobmng.data declared as CommunicationAddress | |
---|---|
CommunicationAddress |
UsedResource.addrResource
|
CommunicationAddress |
ResourceInfo.resource
|
Fields in eu.xtreemos.xosd.jobmng.data with type parameters of type CommunicationAddress | |
---|---|
private java.util.Hashtable<CommunicationAddress,java.lang.Boolean> |
XJob.bufferLocations
|
private java.util.Hashtable<CommunicationAddress,java.lang.String> |
XJob.resources
|
Methods in eu.xtreemos.xosd.jobmng.data that return types with arguments of type CommunicationAddress | |
---|---|
java.util.Set<CommunicationAddress> |
XJob.getBufferLocations()
|
java.util.ArrayList<CommunicationAddress> |
XJob.getListResources()
|
Methods in eu.xtreemos.xosd.jobmng.data with parameters of type CommunicationAddress | |
---|---|
void |
XJob.addBufferLocation(CommunicationAddress resource)
|
void |
XJob.addBufferLocation(CommunicationAddress resource,
java.lang.Boolean enable)
Adds resource to a structure that keeps track of the used resources that will need cleaning after job's death. |
int |
XJob.addResource(CommunicationAddress resource)
Add the resource to the list of resources |
void |
XJob.removeBufferLocation(CommunicationAddress resource)
|
void |
XJob.removeResource(CommunicationAddress resource)
Remove the resource from the list of resources |
void |
XJob.start(CommunicationAddress resAddr)
|
Method parameters in eu.xtreemos.xosd.jobmng.data with type arguments of type CommunicationAddress | |
---|---|
void |
XJob.start(java.util.ArrayList<CommunicationAddress> resAddr)
|
Constructors in eu.xtreemos.xosd.jobmng.data with parameters of type CommunicationAddress | |
---|---|
ResourceInfo(CommunicationAddress resource)
|
|
UsedResource(CommunicationAddress addrResource)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.reservationmanager.base |
---|
Fields in eu.xtreemos.xosd.reservationmanager.base declared as CommunicationAddress | |
---|---|
CommunicationAddress |
ReservationSlot.location
Location of the reservations |
CommunicationAddress |
ReservationRequest.nodeAddress
The address of the node that the request applies to. |
CommunicationAddress |
UpdateRequest.nodeAddress
The address of the node that the request applies to. |
CommunicationAddress |
NodeFreeSlots.nodeCommunicationAddress
|
Uses of CommunicationAddress in eu.xtreemos.xosd.resmng |
---|
Fields in eu.xtreemos.xosd.resmng declared as CommunicationAddress | |
---|---|
CommunicationAddress |
ResMngStorage.currentQueryingAddress
Address of resource which is being queried |
Fields in eu.xtreemos.xosd.resmng with type parameters of type CommunicationAddress | |
---|---|
java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> |
ResMngStorage.alResourceCerts
Resources that are in the list for calling vops (policyEnforceRequest) |
java.util.ArrayList<CommunicationAddress> |
ResMngStorage.alResources
Resources that are in the list for calling vops (policyEnforceRequest) |
java.util.ArrayList<CommunicationAddress> |
ResMngStorage.resourceList
|
Methods in eu.xtreemos.xosd.resmng that return types with arguments of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
ResMng.createRequest(java.util.Hashtable<java.lang.String,java.lang.Object> jsdlTable)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.getResources(java.lang.String query,
java.security.cert.X509Certificate userCtx,
java.lang.Integer howMany)
Retrieve a collection of resources that match the job's resource demands. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesADS(java.lang.String query,
java.security.cert.X509Certificate userCtx,
java.lang.Integer howMany)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesADSSucceeded(java.util.ArrayList<CommunicationAddress> selection)
The SRDSMng retuns here after the call to getResources[ADS] to provide its selection based on the JSDL. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesCentral(java.lang.String query,
java.security.cert.X509Certificate userCtx,
java.lang.Integer howMany)
Retrieve a collection of resources that match the job's resource demands. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesFromParsedCommand(ParsedCommand command)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesFromPath(java.lang.String queryFileName)
Retrieve a collection of resources that match the job's resource demands. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesFromString(java.lang.String query)
Retrieve a collection of resources that match the job's resource demands. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesFromStructure(java.util.Hashtable<java.lang.String,java.lang.Object> jsdl)
Retrieve a collection of resources that match the job's resource demands. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesScored(java.lang.String query)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesScoredWeighted(java.lang.String query,
java.util.Hashtable<java.lang.Integer,java.lang.Double> weights)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesSorted(java.lang.String query,
ResourceDescriptorComparatorSerializable comparator)
Retrieve a collection of resources that match the job's resource demands. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getXMLExtractorReply(java.util.Hashtable list)
The callback with the final piece of processing of the #getResources(String) service call. |
protected java.util.ArrayList<CommunicationAddress> |
ResMng.matchProcesses(java.util.ArrayList fullList,
java.util.ArrayList glues,
java.util.Hashtable jsdl,
ResMngStorage storage)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.testCall()
A function for testing stuff. |
java.util.ArrayList<CommunicationAddress> |
ResMng.VerifyPolicyAEMSuccess(ResourceMatching verifiedMatching)
|
java.util.ArrayList<CommunicationAddress> |
ResMng.verifyPolicyCertResHandler(ResourceMatching rmList)
Reads VOPS' public key and checks if rmList has been written with VOPS' private key. |
Methods in eu.xtreemos.xosd.resmng with parameters of type CommunicationAddress | |
---|---|
java.util.ArrayList<ResourceDescriptorRecord> |
ResMng.getNodeResourceDescriptor(CommunicationAddress address)
A proxy call to ResourceMonitor.query of a service running at particular node. |
java.util.Hashtable<java.lang.String,java.lang.Object> |
ResMng.getNodeResourceGLUE(CommunicationAddress address)
A proxy call to ResourceMonitor.query of a service running at particular node. |
java.util.Hashtable<java.lang.String,java.lang.String> |
ResMng.getResInfo(CommunicationAddress resource,
java.security.cert.X509Certificate userCtx)
Returns the monitoring information associated with the resource. |
java.util.ArrayList<java.lang.String> |
ResMng.getResMetrics(CommunicationAddress resource,
java.security.cert.X509Certificate userCtx)
Returns the list of metrics available on that resource. |
private java.lang.Integer |
ResMng.inheritMetrics(java.lang.String jobId,
CommunicationAddress jobMngAddr)
|
Method parameters in eu.xtreemos.xosd.resmng with type arguments of type CommunicationAddress | |
---|---|
java.lang.Object |
ResMng.createRequestAnswer(java.util.ArrayList<CommunicationAddress> alRes)
|
java.util.ArrayList<ResourceDescriptorRecord> |
ResMng.getResourceDescriptors(java.util.ArrayList<CommunicationAddress> resources)
Retrieve the resource descriptors of the nodes from the given list. |
java.util.ArrayList<CommunicationAddress> |
ResMng.getResourcesADSSucceeded(java.util.ArrayList<CommunicationAddress> selection)
The SRDSMng retuns here after the call to getResources[ADS] to provide its selection based on the JSDL. |
java.lang.Object |
ResMng.policyEnforceRequest(java.util.ArrayList<CommunicationAddress> list)
Call to VOPS service. |
Uses of CommunicationAddress in eu.xtreemos.xosd.resmng.data |
---|
Fields in eu.xtreemos.xosd.resmng.data declared as CommunicationAddress | |
---|---|
CommunicationAddress |
ResourceDescriptorRecord.communicationAddress
|
Fields in eu.xtreemos.xosd.resmng.data with type parameters of type CommunicationAddress | |
---|---|
private java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> |
ResourceMatching.listOfResourceCerts
This is list of certificates, so that we can extract info from them. |
private java.util.ArrayList<CommunicationAddress> |
ResourceMatching.suitable_resources
|
Methods in eu.xtreemos.xosd.resmng.data that return types with arguments of type CommunicationAddress | |
---|---|
java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> |
ResourceMatching.getListOfResourceCerts()
|
java.util.ArrayList<CommunicationAddress> |
ResourceMatching.getSuitableResources()
|
java.util.Iterator<CommunicationAddress> |
ResourceMatching.iterator()
|
java.util.ArrayList<CommunicationAddress> |
ResourceMatching.list()
|
Methods in eu.xtreemos.xosd.resmng.data with parameters of type CommunicationAddress | |
---|---|
void |
ResourceMatching.testResource(CommunicationAddress e)
|
Method parameters in eu.xtreemos.xosd.resmng.data with type arguments of type CommunicationAddress | |
---|---|
void |
ResourceMatching.setListOfResourceCerts(java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> listOfResourceCerts)
|
void |
ResourceMatching.setSuitableResources(java.util.ArrayList<CommunicationAddress> suitable_resources)
|
Constructors in eu.xtreemos.xosd.resmng.data with parameters of type CommunicationAddress | |
---|---|
ResourceDescriptorRecord(CommunicationAddress communicationAddress,
java.lang.String hostUniqueID,
java.lang.String operatingSystemName,
java.lang.String processorArchitecture,
double CPUSpeed,
double CPUCount,
double RAMSize,
int cpuLoadLast15min,
int cpuLoadLast5min,
int cpuLoadLast1min)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.security.rca |
---|
Fields in eu.xtreemos.xosd.security.rca declared as CommunicationAddress | |
---|---|
CommunicationAddress |
RCASignedResponse.siteAddress
The communication address of the xosd. |
Uses of CommunicationAddress in eu.xtreemos.xosd.security.vops |
---|
Fields in eu.xtreemos.xosd.security.vops declared as CommunicationAddress | |
---|---|
CommunicationAddress |
ReturnMessage.address
|
Fields in eu.xtreemos.xosd.security.vops with type parameters of type CommunicationAddress | |
---|---|
java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> |
VOPSStorage.alResourceCerts
Resources that are in the list for calling vops (policyEnforceRequest) |
java.util.ArrayList<CommunicationAddress> |
VOPSStorage.alResources
Resources that are in the list for calling vops (policyEnforceRequest) |
private java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> |
VOPS.listOfRegisteredVOPS
|
java.util.ArrayList<CommunicationAddress> |
VOPSStorage.resourceList
|
Methods in eu.xtreemos.xosd.security.vops that return types with arguments of type CommunicationAddress | |
---|---|
java.util.ArrayList<CommunicationAddress> |
VOPS.getFilteredResources()
Deprecated. |
Methods in eu.xtreemos.xosd.security.vops with parameters of type CommunicationAddress | |
---|---|
java.lang.Boolean |
VOPS.registerVOPSToGlobalVOPS(CommunicationAddress address,
java.security.cert.X509Certificate certificate)
This registers VOPS to global VOPS service where decisions are made. |
Method parameters in eu.xtreemos.xosd.security.vops with type arguments of type CommunicationAddress | |
---|---|
java.lang.Object |
VOPS.getResultsFromResMng(java.util.ArrayList<CommunicationAddress> list)
Deprecated. |
protected ResourceMatching |
VOPS.makePolicyDecision(java.util.HashMap<CommunicationAddress,java.security.cert.X509Certificate> resourceCerts,
VOPSStorage storage)
|
Constructors in eu.xtreemos.xosd.security.vops with parameters of type CommunicationAddress | |
---|---|
ReturnMessage(CommunicationAddress ca,
java.lang.Boolean isPer)
|
Uses of CommunicationAddress in eu.xtreemos.xosd.security.vops.config |
---|
Fields in eu.xtreemos.xosd.security.vops.config declared as CommunicationAddress | |
---|---|
CommunicationAddress |
VOPSConfig.globalVOPS
Deprecated. |
Uses of CommunicationAddress in eu.xtreemos.xosd.security.vops.xacml.utils |
---|
Methods in eu.xtreemos.xosd.security.vops.xacml.utils with parameters of type CommunicationAddress | |
---|---|
static com.sun.xacml.ctx.RequestCtx |
RequestFactory.createRequest(java.util.ArrayList<com.sun.xacml.ctx.Attribute> attrsUsr,
java.util.ArrayList<com.sun.xacml.ctx.Attribute> attrsRes,
CommunicationAddress resource,
java.util.ArrayList<com.sun.xacml.ctx.Attribute> action)
Deprecated. |
static com.sun.xacml.ctx.RequestCtx |
RequestFactory.createRequest(java.lang.String userGlobalName,
java.lang.String subjectGroupId,
CommunicationAddress resource,
java.lang.String action)
Deprecated. |
Uses of CommunicationAddress in eu.xtreemos.xosd.services |
---|
Methods in eu.xtreemos.xosd.services with parameters of type CommunicationAddress | |
---|---|
void |
SJobDirectory.addJob(java.lang.String __jobId,
CommunicationAddress __addrJobMng,
java.lang.String __userId)
|
void |
SJobDirectory.addJob(java.lang.String __jobId,
CommunicationAddress __addrJobMng,
java.lang.String __userId,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SJobDirectory.addJob(java.lang.String __jobId,
CommunicationAddress __addrJobMng,
java.lang.String __userId,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCDAMng.authenticateWithCDA(CommunicationAddress __caCDAServer,
java.security.cert.X509Certificate __caCert,
java.security.KeyPair __keyPair,
java.lang.String __voUserName,
java.lang.String __voUserPass)
This method authenticates user with CDA server. |
void |
SCDAMng.authenticateWithCDA(CommunicationAddress __caCDAServer,
java.security.cert.X509Certificate __caCert,
java.security.KeyPair __keyPair,
java.lang.String __voUserName,
java.lang.String __voUserPass,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
This method authenticates user with CDA server. |
void |
SCDAMng.authenticateWithCDA(CommunicationAddress __caCDAServer,
java.security.cert.X509Certificate __caCert,
java.security.KeyPair __keyPair,
java.lang.String __voUserName,
java.lang.String __voUserPass,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This method authenticates user with CDA server. |
void |
SCRExecMng.checkpointJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __options,
java.lang.String __cpImageVersion,
java.lang.String __checkpointPath,
CommunicationAddress __jobCpAddr)
|
void |
SCRExecMng.checkpointJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __options,
java.lang.String __cpImageVersion,
java.lang.String __checkpointPath,
CommunicationAddress __jobCpAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.checkpointJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __options,
java.lang.String __cpImageVersion,
java.lang.String __checkpointPath,
CommunicationAddress __jobCpAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCDAMng.connectToCDA(CommunicationAddress __caHost,
java.security.cert.X509Certificate __cdaCert)
Connect to CDA server. |
void |
SCDAMng.connectToCDA(CommunicationAddress __caHost,
java.security.cert.X509Certificate __cdaCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Connect to CDA server. |
void |
SCDAMng.connectToCDA(CommunicationAddress __caHost,
java.security.cert.X509Certificate __cdaCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Connect to CDA server. |
void |
SCRExecMng.continueRebuildJobUnit(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __initialJobId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __checkpointVersion,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr)
|
void |
SCRExecMng.continueRebuildJobUnit(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __initialJobId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __checkpointVersion,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.continueRebuildJobUnit(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __initialJobId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __checkpointVersion,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SJobMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. |
void |
SExecMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
It is supposed to be "similar" to a fork but in XOS. |
void |
SJobMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. |
void |
SExecMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
It is supposed to be "similar" to a fork but in XOS. |
void |
SJobMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. |
void |
SExecMng.createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
It is supposed to be "similar" to a fork but in XOS. |
void |
STest.delegateExecution(CommunicationAddress __targetAddress)
|
void |
STest.delegateExecution(CommunicationAddress __targetAddress,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
STest.delegateExecution(CommunicationAddress __targetAddress,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.envPreparationComplete(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __jsdlFile,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __initialJobId,
java.lang.String __oldMetaData,
java.lang.String __newMetaData,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __executable,
java.lang.String __kernelCheckpointer,
java.lang.String __jobUnitCpVersion,
java.lang.String __pidCGroupName,
CommunicationAddress __jucAddress,
java.lang.String __options,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert)
JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed |
void |
SCRJobMng.envPreparationComplete(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __jsdlFile,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __initialJobId,
java.lang.String __oldMetaData,
java.lang.String __newMetaData,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __executable,
java.lang.String __kernelCheckpointer,
java.lang.String __jobUnitCpVersion,
java.lang.String __pidCGroupName,
CommunicationAddress __jucAddress,
java.lang.String __options,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed |
void |
SCRJobMng.envPreparationComplete(java.lang.String __jobId,
java.lang.String __jobUnitId,
java.lang.String __jsdlFile,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __initialJobId,
java.lang.String __oldMetaData,
java.lang.String __newMetaData,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __executable,
java.lang.String __kernelCheckpointer,
java.lang.String __jobUnitCpVersion,
java.lang.String __pidCGroupName,
CommunicationAddress __jucAddress,
java.lang.String __options,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed |
void |
SJobMng.execJob(CommunicationAddress __addrResource)
Executes the job in the resource specified |
void |
SJobMng.execJob(CommunicationAddress __addrResource,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Executes the job in the resource specified |
void |
SJobMng.execJob(CommunicationAddress __addrResource,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Executes the job in the resource specified |
void |
SReservationManager.getAllFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.security.cert.X509Certificate __userCert)
Returns all free slots in a timetable for some metric on the node. |
void |
SReservationManager.getAllFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns all free slots in a timetable for some metric on the node. |
void |
SReservationManager.getAllFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns all free slots in a timetable for some metric on the node. |
void |
SReservationManager.getFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.util.GregorianCalendar __from,
java.util.GregorianCalendar __to,
java.security.cert.X509Certificate __userCert)
Returns all free slots for a given resource and time frame on the node. |
void |
SReservationManager.getFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.util.GregorianCalendar __from,
java.util.GregorianCalendar __to,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns all free slots for a given resource and time frame on the node. |
void |
SReservationManager.getFreeSlotsFor(CommunicationAddress __nodeAddress,
java.lang.String __resourceID,
java.util.GregorianCalendar __from,
java.util.GregorianCalendar __to,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns all free slots for a given resource and time frame on the node. |
void |
SJobDirectory.getJobAddrSucceeded(CommunicationAddress __result)
|
void |
SJobDirectory.getJobAddrSucceeded(CommunicationAddress __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SJobDirectory.getJobAddrSucceeded(CommunicationAddress __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SJobMng.getJobId(CommunicationAddress __resourceId,
java.lang.Integer __pid,
java.security.cert.X509Certificate __userCtx)
Returns the jobID corresponding to a |
void |
SJobMng.getJobId(CommunicationAddress __resourceId,
java.lang.Integer __pid,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the jobID corresponding to a |
void |
SJobMng.getJobId(CommunicationAddress __resourceId,
java.lang.Integer __pid,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the jobID corresponding to a |
void |
SResMng.getNodeResourceDescriptor(CommunicationAddress __address)
A proxy call to ResourceMonitor.query of a service running at particular node. |
void |
SResMng.getNodeResourceDescriptor(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
A proxy call to ResourceMonitor.query of a service running at particular node. |
void |
SResMng.getNodeResourceDescriptor(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
A proxy call to ResourceMonitor.query of a service running at particular node. |
void |
SResMng.getNodeResourceGLUE(CommunicationAddress __address)
A proxy call to ResourceMonitor.query of a service running at particular node. |
void |
SResMng.getNodeResourceGLUE(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
A proxy call to ResourceMonitor.query of a service running at particular node. |
void |
SResMng.getNodeResourceGLUE(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
A proxy call to ResourceMonitor.query of a service running at particular node. |
void |
SExecMng.getProcessList(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __kernelCheckpointer,
java.lang.String __checkpointVersion,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst |
void |
SExecMng.getProcessList(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __kernelCheckpointer,
java.lang.String __checkpointVersion,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst |
void |
SExecMng.getProcessList(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __kernelCheckpointer,
java.lang.String __checkpointVersion,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst |
void |
SVivaldi.getRemoteCoordinates(CommunicationAddress __ca)
AUTOGENERATED CODE |
void |
SVivaldi.getRemoteCoordinates(CommunicationAddress __ca,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SVivaldi.getRemoteCoordinates(CommunicationAddress __ca,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SResMng.getResInfo(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
Returns the monitoring information associated with the resource. |
void |
SResMng.getResInfo(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the monitoring information associated with the resource. |
void |
SResMng.getResInfo(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the monitoring information associated with the resource. |
void |
SResMng.getResMetrics(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
Returns the list of metrics available on that resource. |
void |
SResMng.getResMetrics(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the list of metrics available on that resource. |
void |
SResMng.getResMetrics(CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the list of metrics available on that resource. |
void |
SVivaldi.initializeVivaldiRemote(CommunicationAddress __remoteAddress)
This is for calling initialize Vivaldi from service |
void |
SVivaldi.initializeVivaldiRemote(CommunicationAddress __remoteAddress,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
This is for calling initialize Vivaldi from service |
void |
SVivaldi.initializeVivaldiRemote(CommunicationAddress __remoteAddress,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This is for calling initialize Vivaldi from service |
void |
SJobMng.jobFinished(java.lang.String __jobId,
java.lang.Integer __exitStatus,
CommunicationAddress __execMng)
|
void |
SJobMng.jobFinished(java.lang.String __jobId,
java.lang.Integer __exitStatus,
CommunicationAddress __execMng,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SJobMng.jobFinished(java.lang.String __jobId,
java.lang.Integer __exitStatus,
CommunicationAddress __execMng,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SJobMng.lockCheckpoint(java.lang.String __jobId,
java.lang.String __initialJobId,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name |
void |
SJobMng.lockCheckpoint(java.lang.String __jobId,
java.lang.String __initialJobId,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name |
void |
SJobMng.lockCheckpoint(java.lang.String __jobId,
java.lang.String __initialJobId,
java.security.cert.X509Certificate __userCert,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name |
void |
SSRDSMng.modifyJobContactPoint(java.lang.String __jobID,
CommunicationAddress __newContactPoint)
|
void |
SSRDSMng.modifyJobContactPoint(java.lang.String __jobID,
CommunicationAddress __newContactPoint,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SSRDSMng.modifyJobContactPoint(java.lang.String __jobID,
CommunicationAddress __newContactPoint,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRExecMng.prepareJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert)
|
void |
SCRExecMng.prepareJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.prepareJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitID,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SSRDSMng.putJob(java.lang.String __jobID,
CommunicationAddress __contactPoint,
java.lang.String __userID)
|
void |
SSRDSMng.putJob(java.lang.String __jobID,
CommunicationAddress __contactPoint,
java.lang.String __userID,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SSRDSMng.putJob(java.lang.String __jobID,
CommunicationAddress __contactPoint,
java.lang.String __userID,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.readRestartMetaData(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.lang.String __jobUnitAddresses,
java.security.cert.X509Certificate __userCert)
|
void |
SCRJobMng.readRestartMetaData(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.lang.String __jobUnitAddresses,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRJobMng.readRestartMetaData(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.lang.String __jobUnitAddresses,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.rebuildJobComplete(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
CommunicationAddress __jucAddr,
java.lang.Integer __ret)
|
void |
SCRJobMng.rebuildJobComplete(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
CommunicationAddress __jucAddr,
java.lang.Integer __ret,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRJobMng.rebuildJobComplete(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
CommunicationAddress __jucAddr,
java.lang.Integer __ret,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SExecMng.rebuildJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __checkpointVersion,
CommunicationAddress __jobMngAddr,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert)
|
void |
SExecMng.rebuildJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __checkpointVersion,
CommunicationAddress __jobMngAddr,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SExecMng.rebuildJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __checkpointVersion,
CommunicationAddress __jobMngAddr,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __kernelCheckpointer,
java.lang.String __jsdlFile,
java.lang.String __input,
java.lang.String __output,
java.lang.String __cmd,
java.lang.String __error,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert)
set up structures that represent a job in AEM at restart |
void |
SJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
set up structures that represent a job in AEM at restart |
void |
SJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
set up structures that represent a job in AEM at restart |
void |
SJobMng.redirectFunctionCB(CommunicationAddress __addrJob)
|
void |
SJobMng.redirectFunctionCB(CommunicationAddress __addrJob,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SJobMng.redirectFunctionCB(CommunicationAddress __addrJob,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SDaemon.registerDaemon(CommunicationAddress __address)
"global" method (i.e. gets invoked on the root address xosd) |
void |
SDaemon.registerDaemon(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
"global" method (i.e. gets invoked on the root address xosd) |
void |
SDaemon.registerDaemon(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
"global" method (i.e. gets invoked on the root address xosd) |
void |
SDaemon.registerServices(CommunicationAddress __address,
java.util.ArrayList<java.lang.String> __activeServices)
Register the list of services running within an xosd. |
void |
SDaemon.registerServices(CommunicationAddress __address,
java.util.ArrayList<java.lang.String> __activeServices,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Register the list of services running within an xosd. |
void |
SDaemon.registerServices(CommunicationAddress __address,
java.util.ArrayList<java.lang.String> __activeServices,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Register the list of services running within an xosd. |
void |
SVOPS.registerVOPSToGlobalVOPS(CommunicationAddress __address,
java.security.cert.X509Certificate __certificate)
This registers VOPS to global VOPS service where decisions are made. |
void |
SVOPS.registerVOPSToGlobalVOPS(CommunicationAddress __address,
java.security.cert.X509Certificate __certificate,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
This registers VOPS to global VOPS service where decisions are made. |
void |
SVOPS.registerVOPSToGlobalVOPS(CommunicationAddress __address,
java.security.cert.X509Certificate __certificate,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This registers VOPS to global VOPS service where decisions are made. |
void |
SSRDSMng.removeResource(CommunicationAddress __nodeToRemove)
|
void |
SSRDSMng.removeResource(CommunicationAddress __nodeToRemove,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SSRDSMng.removeResource(CommunicationAddress __nodeToRemove,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRExecMng.resumeJobUnitCP(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executableName,
java.lang.String __cpImageVersion,
CommunicationAddress __jobCpAddr)
|
void |
SCRExecMng.resumeJobUnitCP(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executableName,
java.lang.String __cpImageVersion,
CommunicationAddress __jobCpAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.resumeJobUnitCP(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executableName,
java.lang.String __cpImageVersion,
CommunicationAddress __jobCpAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRExecMng.resumeJobUnitRST(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
CommunicationAddress __jobCpAddr,
java.lang.String __userCert)
|
void |
SCRExecMng.resumeJobUnitRST(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
CommunicationAddress __jobCpAddr,
java.lang.String __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.resumeJobUnitRST(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __checkpointVersion,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
CommunicationAddress __jobCpAddr,
java.lang.String __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.returnFromGetProcessList(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitId,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
CommunicationAddress __jobUnitAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __checkpointVersion,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert)
|
void |
SCRJobMng.returnFromGetProcessList(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitId,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
CommunicationAddress __jobUnitAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __checkpointVersion,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRJobMng.returnFromGetProcessList(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __jobUnitId,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __executable,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
CommunicationAddress __jobUnitAddr,
java.lang.String __processList,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __kernelCheckpointer,
java.lang.String __checkpointVersion,
java.lang.String __pidCGroupName,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
void |
SCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
void |
SCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
void |
SCRJobMng.returnFromSelectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.String __kernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert)
|
void |
SCRJobMng.returnFromSelectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.String __kernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRJobMng.returnFromSelectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.String __kernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SJobMng.runJobRes(java.lang.String __jobId,
java.lang.String __reservationID,
CommunicationAddress __resourceID,
java.security.cert.X509Certificate __userCtx)
Starts the scheduling process of a previously created job. |
void |
SJobMng.runJobRes(java.lang.String __jobId,
java.lang.String __reservationID,
CommunicationAddress __resourceID,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts the scheduling process of a previously created job. |
void |
SJobMng.runJobRes(java.lang.String __jobId,
java.lang.String __reservationID,
CommunicationAddress __resourceID,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts the scheduling process of a previously created job. |
void |
SCRExecMng.selectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.Integer __kernelCheckpointerId,
java.lang.String __preferredKernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert)
select on each grid node kernel checkpointer bound to node, no job-unit checkpointer matching yet!! |
void |
SCRExecMng.selectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.Integer __kernelCheckpointerId,
java.lang.String __preferredKernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
select on each grid node kernel checkpointer bound to node, no job-unit checkpointer matching yet!! |
void |
SCRExecMng.selectCheckpointer(java.lang.String __initialJobId,
java.lang.String __jobId,
java.lang.Integer __jobUnitId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.lang.Integer __kernelCheckpointerId,
java.lang.String __preferredKernelCheckpointer,
CommunicationAddress __jobUnitCpAddr,
CommunicationAddress __jobCpAddr,
CommunicationAddress __superJobCpAddr,
java.lang.String __lastCheckpointVersion,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
select on each grid node kernel checkpointer bound to node, no job-unit checkpointer matching yet!! |
void |
SJobMng.setMetricValue(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.String __value,
java.security.cert.X509Certificate __userCtx)
Sets the value of a Metric. |
void |
SJobMng.setMetricValue(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.String __value,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Sets the value of a Metric. |
void |
SJobMng.setMetricValue(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.String __value,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Sets the value of a Metric. |
void |
SJobMng.setMonitorBuffering(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.Integer __flags,
java.security.cert.X509Certificate __userCtx)
Switches on and off buffering for the specified metric. |
void |
SJobMng.setMonitorBuffering(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.Integer __flags,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Switches on and off buffering for the specified metric. |
void |
SJobMng.setMonitorBuffering(java.lang.String __jobId,
java.lang.String __metricName,
CommunicationAddress __resourceID,
java.lang.Integer __pid,
java.lang.Integer __flags,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Switches on and off buffering for the specified metric. |
void |
SCronDaemon.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SRCAClient.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SJobMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SCRJobMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SResourceMonitor.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SAemServiceSample.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SDaemon.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SXMLService.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
STest.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SResAllocator.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SAemServiceInvocation.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SVOPS.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SRCAServer.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SXMLExtractor.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SReservationManager.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SResMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SVivaldi.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SCDAMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SJobDirectory.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SSRDSMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SExecMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SCRExecMng.setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
|
void |
SExecMng.startJob(java.lang.String __jobId,
CommunicationAddress __jobMngAddr,
java.lang.String __command,
java.lang.Object __params_aux,
java.lang.Object __env_aux,
java.lang.String __output,
java.lang.String __error,
java.lang.String __input,
java.security.cert.X509Certificate __userCtx)
Starts running a job already created |
void |
SExecMng.startJob(java.lang.String __jobId,
CommunicationAddress __jobMngAddr,
java.lang.String __command,
java.lang.Object __params_aux,
java.lang.Object __env_aux,
java.lang.String __output,
java.lang.String __error,
java.lang.String __input,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts running a job already created |
void |
SExecMng.startJob(java.lang.String __jobId,
CommunicationAddress __jobMngAddr,
java.lang.String __command,
java.lang.Object __params_aux,
java.lang.Object __env_aux,
java.lang.String __output,
java.lang.String __error,
java.lang.String __input,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts running a job already created |
void |
SExecMng.startProcess(java.lang.String __jobId,
CommunicationAddress __jobMngAddr,
java.lang.String __command,
java.lang.Object __params_aux,
java.lang.Object __env_aux,
java.lang.String __output,
java.lang.String __error,
java.lang.String __input,
java.security.cert.X509Certificate __userCtx)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource. |
void |
SExecMng.startProcess(java.lang.String __jobId,
CommunicationAddress __jobMngAddr,
java.lang.String __command,
java.lang.Object __params_aux,
java.lang.Object __env_aux,
java.lang.String __output,
java.lang.String __error,
java.lang.String __input,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource. |
void |
SExecMng.startProcess(java.lang.String __jobId,
CommunicationAddress __jobMngAddr,
java.lang.String __command,
java.lang.Object __params_aux,
java.lang.Object __env_aux,
java.lang.String __output,
java.lang.String __error,
java.lang.String __input,
java.security.cert.X509Certificate __userCtx,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource. |
void |
SCRExecMng.stopJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __cpImageVersion,
CommunicationAddress __jcAddr)
|
void |
SCRExecMng.stopJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __cpImageVersion,
CommunicationAddress __jcAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.stopJobUnit(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jobUnitId,
java.lang.String __processGroupReferenceId,
java.lang.String __processGroupReferenceType,
java.lang.String __pidCGroupName,
java.lang.String __processList,
java.lang.String __executable,
java.lang.String __cpImageVersion,
CommunicationAddress __jcAddr,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SDaemon.unregisterDaemon(CommunicationAddress __address)
"global" method (i.e. gets invoked on the root address xosd) Unregisters the xosd from the list of running daemons. |
void |
SDaemon.unregisterDaemon(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
"global" method (i.e. gets invoked on the root address xosd) Unregisters the xosd from the list of running daemons. |
void |
SDaemon.unregisterDaemon(CommunicationAddress __address,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
"global" method (i.e. gets invoked on the root address xosd) Unregisters the xosd from the list of running daemons. |
Method parameters in eu.xtreemos.xosd.services with type arguments of type CommunicationAddress | |
---|---|
void |
SSRDSMng.checkResourceQueryResults(java.util.ArrayList<CommunicationAddress> __result,
java.lang.Long __queryTicket,
java.lang.Long __timeoutTime,
java.lang.Long __nextQueryTime)
|
void |
SSRDSMng.checkResourceQueryResults(java.util.ArrayList<CommunicationAddress> __result,
java.lang.Long __queryTicket,
java.lang.Long __timeoutTime,
java.lang.Long __nextQueryTime,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SSRDSMng.checkResourceQueryResults(java.util.ArrayList<CommunicationAddress> __result,
java.lang.Long __queryTicket,
java.lang.Long __timeoutTime,
java.lang.Long __nextQueryTime,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SResMng.createRequestAnswer(java.util.ArrayList<CommunicationAddress> __alRes)
|
void |
SResMng.createRequestAnswer(java.util.ArrayList<CommunicationAddress> __alRes,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SResMng.createRequestAnswer(java.util.ArrayList<CommunicationAddress> __alRes,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list)
|
void |
SCRJobMng.dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRJobMng.dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SJobMng.getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list)
Callback where I get a list of candidates. |
void |
SJobMng.getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get a list of candidates. |
void |
SJobMng.getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get a list of candidates. |
void |
SJobMng.getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected |
void |
SJobMng.getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected |
void |
SJobMng.getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected |
void |
SJobDirectory.getJobsUserSucceeded(java.util.Hashtable<java.lang.String,CommunicationAddress> __result)
|
void |
SJobDirectory.getJobsUserSucceeded(java.util.Hashtable<java.lang.String,CommunicationAddress> __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SJobDirectory.getJobsUserSucceeded(java.util.Hashtable<java.lang.String,CommunicationAddress> __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SResMng.getResourceDescriptors(java.util.ArrayList<CommunicationAddress> __resources)
Retrieve the resource descriptors of the nodes from the given list. |
void |
SResMng.getResourceDescriptors(java.util.ArrayList<CommunicationAddress> __resources,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Retrieve the resource descriptors of the nodes from the given list. |
void |
SResMng.getResourceDescriptors(java.util.ArrayList<CommunicationAddress> __resources,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Retrieve the resource descriptors of the nodes from the given list. |
void |
SResMng.getResourcesADSSucceeded(java.util.ArrayList<CommunicationAddress> __selection)
The SRDSMng retuns here after the call to getResources[ADS] to provide its selection based on the JSDL. |
void |
SResMng.getResourcesADSSucceeded(java.util.ArrayList<CommunicationAddress> __selection,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
The SRDSMng retuns here after the call to getResources[ADS] to provide its selection based on the JSDL. |
void |
SResMng.getResourcesADSSucceeded(java.util.ArrayList<CommunicationAddress> __selection,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
The SRDSMng retuns here after the call to getResources[ADS] to provide its selection based on the JSDL. |
void |
SReservationManager.getResourcesSuccess(java.util.ArrayList<CommunicationAddress> __result)
A call-back for internal use only. |
void |
SReservationManager.getResourcesSuccess(java.util.ArrayList<CommunicationAddress> __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
A call-back for internal use only. |
void |
SReservationManager.getResourcesSuccess(java.util.ArrayList<CommunicationAddress> __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
A call-back for internal use only. |
void |
SVOPS.getResultsFromResMng(java.util.ArrayList<CommunicationAddress> __list)
|
void |
SVOPS.getResultsFromResMng(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SVOPS.getResultsFromResMng(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SVivaldi.initHandler(java.util.ArrayList<CommunicationAddress> __alDaemons)
|
void |
SVivaldi.initHandler(java.util.ArrayList<CommunicationAddress> __alDaemons,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SVivaldi.initHandler(java.util.ArrayList<CommunicationAddress> __alDaemons,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SVivaldi.initializeVivaldiGotDeamons(java.util.ArrayList<CommunicationAddress> __alDaemons)
When we get all daemons back. |
void |
SVivaldi.initializeVivaldiGotDeamons(java.util.ArrayList<CommunicationAddress> __alDaemons,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
When we get all daemons back. |
void |
SVivaldi.initializeVivaldiGotDeamons(java.util.ArrayList<CommunicationAddress> __alDaemons,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
When we get all daemons back. |
void |
SCRExecMng.matchRemainingNodes(java.util.ArrayList<CommunicationAddress> __list)
|
void |
SCRExecMng.matchRemainingNodes(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SCRExecMng.matchRemainingNodes(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
BEST SERVICE! |
void |
SCRJobMng.matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
BEST SERVICE! |
void |
SCRJobMng.matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
BEST SERVICE! |
void |
SCRJobMng.matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list)
UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst |
void |
SCRJobMng.matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst |
void |
SCRJobMng.matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst |
void |
SCRJobMng.matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst |
void |
SCRJobMng.matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst |
void |
SCRJobMng.matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst |
void |
SResMng.policyEnforceRequest(java.util.ArrayList<CommunicationAddress> __list)
Call to VOPS service. |
void |
SResMng.policyEnforceRequest(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Call to VOPS service. |
void |
SResMng.policyEnforceRequest(java.util.ArrayList<CommunicationAddress> __list,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Call to VOPS service. |
void |
SJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert)
set up structures that represent a job in AEM at restart |
void |
SJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
set up structures that represent a job in AEM at restart |
void |
SJobMng.recreateJob(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFileContent,
java.lang.String __checkpointVersion,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<CommunicationAddress> __jobResourceList,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
set up structures that represent a job in AEM at restart |
void |
SSRDSMng.resourceQuerySucceeded(java.util.ArrayList<CommunicationAddress> __result)
|
void |
SSRDSMng.resourceQuerySucceeded(java.util.ArrayList<CommunicationAddress> __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
|
void |
SSRDSMng.resourceQuerySucceeded(java.util.ArrayList<CommunicationAddress> __result,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
void |
SCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
void |
SCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
void |
SCRJobMng.returnFromJobLocking(java.lang.String __jobId,
java.lang.String __initialJobId,
java.lang.String __jsdlFile,
java.lang.String __executable,
java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
CommunicationAddress __superJobCpAddr,
java.util.ArrayList<java.lang.String> __dependentJobs,
java.lang.String __strategy,
java.lang.String __options,
java.lang.String __mode,
java.lang.Integer __ret,
java.security.cert.X509Certificate __userCert,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer |
void |
SJobMng.selectResource(java.util.ArrayList<CommunicationAddress> __list,
java.lang.Integer __schedule)
Returns a resource from a list of resources |
void |
SJobMng.selectResource(java.util.ArrayList<CommunicationAddress> __list,
java.lang.Integer __schedule,
eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns a resource from a list of resources |
void |
SJobMng.selectResource(java.util.ArrayList<CommunicationAddress> __list,
java.lang.Integer __schedule,
eu.xtreemos.system.communication.bus.CallbackMessage callback,
eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns a resource from a list of resources |
Uses of CommunicationAddress in eu.xtreemos.xosd.srdsaccess.jobDirectory |
---|
Methods in eu.xtreemos.xosd.srdsaccess.jobDirectory with parameters of type CommunicationAddress | |
---|---|
int |
IJobDirectory.modifyJobContactPoint(java.lang.String jobID,
CommunicationAddress newContactPoint,
IJobDirectoryListener listener)
Change a contact point of a job already in the directory. |
int |
IJobDirectory.putJob(java.lang.String jobID,
CommunicationAddress contactPoint,
java.lang.String userID,
IJobDirectoryListener listener)
Put a job information into the directory. |
Uses of CommunicationAddress in eu.xtreemos.xosd.srdsaccess.resmng |
---|
Methods in eu.xtreemos.xosd.srdsaccess.resmng with parameters of type CommunicationAddress | |
---|---|
int |
IResourceDiscovery.registerResource(CommunicationAddress hostAddress)
Requests that the host to be added to the directory service. |
int |
IResourceDiscovery.removeResource(CommunicationAddress hostAddress)
Requests that the host is to be removed from the directory service, effectively no longer being discoverable. |
Method parameters in eu.xtreemos.xosd.srdsaccess.resmng with type arguments of type CommunicationAddress | |
---|---|
void |
IResourceDiscoveryListener.queryCallSucceeded(java.util.ArrayList<CommunicationAddress> nodeAddressList)
The query success invocation method, receiving the list of communication addresses of the resources selected by the query. |
Uses of CommunicationAddress in eu.xtreemos.xosd.utilities.resmng |
---|
Methods in eu.xtreemos.xosd.utilities.resmng with parameters of type CommunicationAddress | |
---|---|
static java.util.ArrayList<ResourceDescriptorRecord> |
ResourceDescriptorRecordHelper.extractGLUE(java.util.Hashtable<java.lang.String,java.lang.Object> glue,
CommunicationAddress communicationAddress)
Extracts the selected substructures from a hashtable representing an XML formatted according to the GLUE v1.2 schema. |
Uses of CommunicationAddress in eu.xtreemos.xosd.vivaldi |
---|
Fields in eu.xtreemos.xosd.vivaldi declared as CommunicationAddress | |
---|---|
private CommunicationAddress |
VivaldiCoordinates.localAddress
|
Methods in eu.xtreemos.xosd.vivaldi that return CommunicationAddress | |
---|---|
CommunicationAddress |
VivaldiCoordinates.getLocalAddress()
Returns local address, whom this coordinates belong to. |
Constructors in eu.xtreemos.xosd.vivaldi with parameters of type CommunicationAddress | |
---|---|
VivaldiCoordinates(vivaldi.primitives.LocalCoordinate lc,
CommunicationAddress localAddress)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |