Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge tag 'v3_9_90' into hypervisor
[simgrid.git] / src / bindings / java / org / simgrid / msg / VM.java
index eb61988..7b73404 100644 (file)
@@ -1,7 +1,7 @@
 /*
  * JNI interface to virtual machine in Simgrid
  * 
- * Copyright 2006-2012 The SimGrid Team.           
+ * Copyright (c) 2006-2013. The SimGrid Team.
  * All right reserved. 
  *
  * This program is free software; you can redistribute 
@@ -21,30 +21,70 @@ public class VM extends Host{
        // GetByName is inherited from the super class Host
        
 
+        private static VM[] vms=null;    
+    private Host currentHost; 
+
        /* Constructors / destructors */
     /**
         * Create a `basic' VM (i.e. 1 core, 1GB of RAM, other values are not taken into account).
         */
        public VM(Host host, String name) {
-               this(host,name,1,1024*1024*1024, -1, null, -1);
+               this(host,name,1,1024, -1, null, -1,0 , 0);
        }
 
        /**
-        * Create a `basic' VM (i.e. 1 core, 1GB of RAM, other values are not taken into account).
+        * Create a  VM
+        * @param host, Host node
+        * @param name, name of the machine
+        * @param nCore, number of core
+        * @param ramSize, size of the RAM that should be allocated (in MBytes) 
+        * @param netCap (not used for the moment)
+        * @param diskPath (not used for the moment)
+        * @param diskSize (not used for the moment)
+        * @param migNetSpeed (network bandwith allocated for migrations in MB/s, if you don't know put zero ;))
+        * @param dpIntensity (dirty page percentage according to migNetSpeed, [0-100], if you don't know put zero ;))
         */
-       public VM(Host host, String name, int nCore,  long ramSize, 
-                        long netCap, String diskPath, long diskSize){
+       
+       public VM(Host host, String name, int nCore,  int ramSize, 
+                       int netCap, String diskPath, int diskSize, int migNetSpeed, int dpIntensity){
                super();
                super.name = name; 
-               create(host, name, nCore, ramSize, netCap, diskPath, diskSize);
+               this.currentHost = host; 
+               create(host, name, nCore, ramSize, netCap, diskPath, diskSize, migNetSpeed, dpIntensity);
+               VM.addVM(this);
        }
 
+       private static void addVM(VM vm){
+               VM[] vmsN=null; 
+               int i=0;
+               if(VM.vms == null)
+                       vmsN = new VM[1]; 
+               else
+                       vmsN = new VM[vms.length+1]; 
+               
+               for (i=0; i<vmsN.length-1 ; i ++){
+                       vmsN[i]=vms[i]; 
+               } 
+               vmsN[i]=vm;
+               vms=vmsN;
+       }
+   public static VM[] all(){
+               return vms;
+       }
+       public static VM getVMByName(String name){
+               for (int i=0 ; i < vms.length ; i++){
+                         if (vms[i].getName().equals(name))
+                                       return vms[i];          
+               }
+               return null; 
+       }
        protected void finalize() {
                destroy();
        }
        
 
        /* JNI / Native code */
+
        /* get/set property methods are inherited from the Host class. */
        
        /** Returns whether the given VM is currently suspended
@@ -78,14 +118,23 @@ public class VM extends Host{
        /**
         * Natively implemented method create the VM.
         * @param nCore, number of core
-        * @param ramSize, size of the RAM that should be allocated 
+        * @param ramSize, size of the RAM that should be allocated (in MB) 
         * @param netCap (not used for the moment)
         * @param diskPath (not used for the moment)
         * @param diskSize (not used for the moment)
+        * @param migNetSpeed (network bandwith allocated for migrations in MB/s, if you don't know put zero ;))
+        * @param dpIntensity (dirty page intensity, a percentage of migNetSpeed [0-100],  if you don't know put zero ;))
         */
-       private native void create(Host host, String name, int nCore, long ramSize, 
-                        long netCap, String diskPath, long diskSize);
-       
+       private native void create(Host host, String name, int nCore, int ramSize, 
+                        int netCap, String diskPath, int diskSize, int migNetSpeed, int dpIntensity);
+
+
+       /**
+        * Bound the VM to a certain % of its vcpu capability (e.g. 75% of vm.getSpeed())
+        * @param load, percentage (between [0,100]
+        */
+       public native void setBound(int load);
+
        /**
         * start the VM
         */
@@ -98,14 +147,19 @@ public class VM extends Host{
         */
        public native void shutdown();
        
+       /**  
+        * Invoke native migration routine
+       */
+       public native void internalmig(Host destination);
+
        
-       /** Immediately change the host on which all processes are running
-        *
-        * No migration cost occurs. If you want to simulate this too, you want to use a
-        * Task.send() before or after, depending on whether you want to do cold or hot
-        * migration.
+       /** Change the host on which all processes are running
+        * (pre-copy is implemented)
         */     
-       public native void migrate(Host destination);
+       public void migrate(Host destination){
+               this.internalmig(destination);
+               this.currentHost = destination; 
+       }
        
        /** Immediately suspend the execution of all processes within the given VM
         *
@@ -146,7 +200,7 @@ public class VM extends Host{
        /**
         * Destroy the VM
         */
-       protected native void destroy();
+       public native void destroy();