eu.xtreemos.xosd.services
Class SResourceMonitor

java.lang.Object
  extended by eu.xtreemos.xosd.services.SResourceMonitor

public class SResourceMonitor
extends java.lang.Object


Field Summary
private  CommunicationAddress _accesspoint_remoteaddress
           
private  eu.xtreemos.system.eventmachine.queue.Context context
           
static java.lang.String servicename
          AUTOGENERATED CODE
 
Constructor Summary
SResourceMonitor(eu.xtreemos.system.eventmachine.queue.Context context)
           
 
Method Summary
 void addResAttribute(java.lang.String __attribute)
           
 void addResAttribute(java.lang.String __attribute, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void addResAttribute(java.lang.String __attribute, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getProxyResMetricsReply(java.util.ArrayList<java.lang.String> __res)
           
 void getProxyResMetricsReply(java.util.ArrayList<java.lang.String> __res, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getProxyResMetricsReply(java.util.ArrayList<java.lang.String> __res, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getResMetrics()
           
 void getResMetrics(eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getResMetrics(eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getResMonResponse(java.util.Hashtable<java.lang.String,java.lang.Object> __glue)
           
 void getResMonResponse(java.util.Hashtable<java.lang.String,java.lang.Object> __glue, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getResMonResponse(java.util.Hashtable<java.lang.String,java.lang.Object> __glue, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getResMonResponseFailure(java.lang.Exception __ex)
           
 void getResMonResponseFailure(java.lang.Exception __ex, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getResMonResponseFailure(java.lang.Exception __ex, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getXMLExtractorReply(java.util.Hashtable __list)
           
 void getXMLExtractorReply(java.util.Hashtable __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getXMLExtractorReply(java.util.Hashtable __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getXMLExtractorReplyXMon(java.util.Hashtable __list)
           
 void getXMLExtractorReplyXMon(java.util.Hashtable __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getXMLExtractorReplyXMon(java.util.Hashtable __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void query()
          Queries the local monitor data provider for machine status, translates it into GLUE 1.2-compliant XML and transforms it into a Hashtable.
 void query(eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Queries the local monitor data provider for machine status, translates it into GLUE 1.2-compliant XML and transforms it into a Hashtable.
 void query(eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Queries the local monitor data provider for machine status, translates it into GLUE 1.2-compliant XML and transforms it into a Hashtable.
 void queryResInfo()
          Queries the local monitor data provider for machine status and returns the values of the metrics being monitored on this node.
 void queryResInfo(eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Queries the local monitor data provider for machine status and returns the values of the metrics being monitored on this node.
 void queryResInfo(eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Queries the local monitor data provider for machine status and returns the values of the metrics being monitored on this node.
 void queryResourceDescriptor()
          Queries the local monitor data provider for machine status and returns a filled-in collection (that should at this point contain a single element) of resource descriptor records.
 void queryResourceDescriptor(eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Queries the local monitor data provider for machine status and returns a filled-in collection (that should at this point contain a single element) of resource descriptor records.
 void queryResourceDescriptor(eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Queries the local monitor data provider for machine status and returns a filled-in collection (that should at this point contain a single element) of resource descriptor records.
 void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

servicename

public static java.lang.String servicename
AUTOGENERATED CODE


context

private eu.xtreemos.system.eventmachine.queue.Context context

_accesspoint_remoteaddress

private CommunicationAddress _accesspoint_remoteaddress
Constructor Detail

SResourceMonitor

public SResourceMonitor(eu.xtreemos.system.eventmachine.queue.Context context)
Method Detail

setRemoteaddress

public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)

query

public void query()
Queries the local monitor data provider for machine status, translates it into GLUE 1.2-compliant XML and transforms it into a Hashtable. If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


query

public void query(eu.xtreemos.system.communication.bus.CallbackMessage callback)
Queries the local monitor data provider for machine status, translates it into GLUE 1.2-compliant XML and transforms it into a Hashtable. If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


query

public void query(eu.xtreemos.system.communication.bus.CallbackMessage callback,
                  eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Queries the local monitor data provider for machine status, translates it into GLUE 1.2-compliant XML and transforms it into a Hashtable. If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


getXMLExtractorReply

public void getXMLExtractorReply(java.util.Hashtable __list)

getXMLExtractorReply

public void getXMLExtractorReply(java.util.Hashtable __list,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)

getXMLExtractorReply

public void getXMLExtractorReply(java.util.Hashtable __list,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getResMetrics

public void getResMetrics()

getResMetrics

public void getResMetrics(eu.xtreemos.system.communication.bus.CallbackMessage callback)

getResMetrics

public void getResMetrics(eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

queryResInfo

public void queryResInfo()
Queries the local monitor data provider for machine status and returns the values of the metrics being monitored on this node. The metrics returned are those listed by getResMetrics() and regulated by addResAttribute(String). If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


queryResInfo

public void queryResInfo(eu.xtreemos.system.communication.bus.CallbackMessage callback)
Queries the local monitor data provider for machine status and returns the values of the metrics being monitored on this node. The metrics returned are those listed by getResMetrics() and regulated by addResAttribute(String). If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


queryResInfo

public void queryResInfo(eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Queries the local monitor data provider for machine status and returns the values of the metrics being monitored on this node. The metrics returned are those listed by getResMetrics() and regulated by addResAttribute(String). If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


queryResourceDescriptor

public void queryResourceDescriptor()
Queries the local monitor data provider for machine status and returns a filled-in collection (that should at this point contain a single element) of resource descriptor records. If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


queryResourceDescriptor

public void queryResourceDescriptor(eu.xtreemos.system.communication.bus.CallbackMessage callback)
Queries the local monitor data provider for machine status and returns a filled-in collection (that should at this point contain a single element) of resource descriptor records. If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


queryResourceDescriptor

public void queryResourceDescriptor(eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Queries the local monitor data provider for machine status and returns a filled-in collection (that should at this point contain a single element) of resource descriptor records. If the monitorType entry in the configuration file is set to "ganglia", then the method obtains the information from the localhost ganglia daemon. If there is no monitoring system, the service will return a generic answer, contained in the file files/genericAnswer.xml . Alternatively, if the configuration is set to monitorType = "xmonitor", then the information is obtained from local kernel hooks which need to be pre-installed. The call is self-sustainable and does not invlove other services.


getResMonResponseFailure

public void getResMonResponseFailure(java.lang.Exception __ex)

getResMonResponseFailure

public void getResMonResponseFailure(java.lang.Exception __ex,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback)

getResMonResponseFailure

public void getResMonResponseFailure(java.lang.Exception __ex,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getResMonResponse

public void getResMonResponse(java.util.Hashtable<java.lang.String,java.lang.Object> __glue)

getResMonResponse

public void getResMonResponse(java.util.Hashtable<java.lang.String,java.lang.Object> __glue,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)

getResMonResponse

public void getResMonResponse(java.util.Hashtable<java.lang.String,java.lang.Object> __glue,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getXMLExtractorReplyXMon

public void getXMLExtractorReplyXMon(java.util.Hashtable __list)

getXMLExtractorReplyXMon

public void getXMLExtractorReplyXMon(java.util.Hashtable __list,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback)

getXMLExtractorReplyXMon

public void getXMLExtractorReplyXMon(java.util.Hashtable __list,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getProxyResMetricsReply

public void getProxyResMetricsReply(java.util.ArrayList<java.lang.String> __res)

getProxyResMetricsReply

public void getProxyResMetricsReply(java.util.ArrayList<java.lang.String> __res,
                                    eu.xtreemos.system.communication.bus.CallbackMessage callback)

getProxyResMetricsReply

public void getProxyResMetricsReply(java.util.ArrayList<java.lang.String> __res,
                                    eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

addResAttribute

public void addResAttribute(java.lang.String __attribute)

addResAttribute

public void addResAttribute(java.lang.String __attribute,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)

addResAttribute

public void addResAttribute(java.lang.String __attribute,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)