public class ReservationPlugin extends Plugin {
public ReservationPlugin() {
- activateNetworkCommunicateCallback();
+ activateCpuCreatedCallback();
+ activateCpuDestructedCallback();
+ activateCpuStateChangedCallback();
+ activateCpuActionStateChangedCallback();
+
+ activateNetworkLinkCreatedCallback();
+ activateNetworkLinkDestructedCallback();
+ activateNetworkLinkStateChangedCallback();
+ activateNetworkActionStateChangedCallback();
+
+ }
+
+ public void init() {
+ NetworkLink[] route = Surf.getRoute("Jacquelin", "Boivin");
+ Msg.info("RouteLength:"+route.length);
+ Msg.info("RouteName0:"+route[0].getName());
+ Msg.info("RouteName1:"+route[1].getName());
}
- //HashMap<String,Reservation> reservations;
- double bandwidth = 0;
- String src = "";
- String dst = "";
+ public void cpuCreatedCallback(Cpu cpu) {
+ Msg.info("Trace: Cpu created "+cpu.getName());
+ }
+
+ public void cpuDestructedCallback(Cpu cpu) {
+ Msg.info("Trace: Cpu destructed "+cpu.getName());
+ }
+
+ public void cpuStateChangedCallback(Cpu cpu){
+ Msg.info("Trace: Cpu state changed "+cpu.getName());
+ }
+
+ public void cpuActionStateChangedCallback(CpuAction action){
+ Msg.info("Trace: CpuAction state changed "+action.getModel().getName());
+ }
+
+ public void networkLinkCreatedCallback(NetworkLink link) {
+ Msg.info("Trace: NetworkLink created "+link.getName());
+ }
- public void limitBandwidthActions(String src, String dst, double bandwidth){
- this.bandwidth = bandwidth;
- this.src = src;
- this.dst = dst;
+ public void networkLinkDestructedCallback(NetworkLink link) {
+ Msg.info("Trace: NetworkLink destructed "+link.getName());
}
- public void updateBandwidthRoute(String src, String dst, double bandwidth){
- NetworkLink[] route = Surf.getRoute(src, dst);
- for (int i =0; i<route.length; i++){
- Msg.info("Trace: bandwidth of "+route[i].getName()+" before "+route[i].getBandwidth());
- route[i].updateBandwidth(bandwidth);//getName();
- Msg.info("Trace: bandwidth of "+route[i].getName()+" after "+route[i].getBandwidth());
- }
+ public void networkLinkStateChangedCallback(NetworkLink link){
+ Msg.info("Trace: NetworkLink state changed "+link.getName());
}
- public void networkCommunicateCallback(NetworkAction action, RoutingEdge src, RoutingEdge dst, double size, double rate){
- if (src.getName().equals(this.src) && dst.getName().equals(this.dst)) {
- action.setBound(this.bandwidth);
- }
- Msg.info("Trace: Communicate message of size "+size+" with rate "+rate+" and bound "+action.getBound()+" from "+src.getName()+" to "+dst.getName());
+ public void networkActionStateChangedCallback(NetworkAction action){
+ Msg.info("Trace: NetworkAction state changed "+action.getModel().getName());
}
}
