If the unit is minute, this value means the average number of arrivals + * at each minute. It's the inverse of the {@link #getInterarrivalMeanTime()}.
+ * @return */ public double getLambda(){ return lambda; } /** - * Sets the average number of events that happen at each single time unit. + * Sets the average number of events that are expected to happen at each 1 time unit. + * It is the expected number of events to happen each time, + * also called the event rate or rate parameter. + * + *If the unit is minute, this value means the average number of arrivals + * at each minute. It's the inverse of the {@link #getInterarrivalMeanTime()}.
* @param lambda the value to set */ private void setLambda(double lambda) { @@ -84,7 +109,8 @@ private void setLambda(double lambda) { } /** - * Gets the probability to arrive {@link #getK() K} events in the current time. + * Gets the probability to arrive {@link #getK() K} events in the current time, + * considering the expected average arrival time {@link #getLambda() lambda}. * @return * @see Poisson distribution */ @@ -102,7 +128,7 @@ public double eventsArrivalProbability(){ * @see #eventsArrivalProbability() */ public boolean eventsHappened(){ - return sample() >= eventsArrivalProbability(); + return rand.sample() >= eventsArrivalProbability(); } /** @@ -124,8 +150,8 @@ public void setK(int k) { } /** - * - * @return the mean time between arrival of two events. + * Gets the mean time between arrival of two events. + * @return */ public double getInterarrivalMeanTime(){ final double oneMinute = 1.0; @@ -153,14 +179,14 @@ public static void main(String args[]){ final int SIMULATION_TIME_LENGHT = 25; //If the arrival of each customers must be shown. - final boolean showCustomerArrivals = false; + final boolean showCustomerArrivals = true; /* * Number of simulations to run. */ int NUMBER_OF_SIMULATIONS = 100; - BiConsumerdiff --git a/cloudsim-plus/src/main/java/org/cloudsimplus/faultinjection/HostFaultInjection.java b/cloudsim-plus/src/main/java/org/cloudsimplus/faultinjection/HostFaultInjection.java index c32712eae..42855597c 100644 --- a/cloudsim-plus/src/main/java/org/cloudsimplus/faultinjection/HostFaultInjection.java +++ b/cloudsim-plus/src/main/java/org/cloudsimplus/faultinjection/HostFaultInjection.java @@ -41,28 +41,27 @@ import org.cloudbus.cloudsim.vms.Vm; import org.cloudbus.cloudsim.core.*; import org.cloudbus.cloudsim.distributions.ContinuousDistribution; +import org.cloudbus.cloudsim.distributions.PoissonProcess; import org.cloudbus.cloudsim.distributions.UniformDistr; import org.cloudbus.cloudsim.resources.Pe; import org.cloudbus.cloudsim.resources.Pe.Status; /** - * This class shows how to generate a fault. In this case the fault is in the - * host. - * - * Notes: This class does not work with the injection fault in time 0. Only - * works after the creation of cloudlets and VMs, because when destroying the - * VM, the cloudlet is not returned to be chosen by another VM that did not - * fail, thus causing error in the simulator. + * Generates random failures for the {@link Pe}'s of a specific {@link Host}. + * The events happens in the following order: + *
The PRNG must return values between [0 and 1[. - * The actual number of failed PEs depends on each Host, - * therefore it is computed internally.
+ *+ * This is used to define, randomly + * the actual time, after the time the fault was + * injected, that it will happen. + * For instance, if a fault is generated + * and a value 5 is chosen between 0 and the maximum delay, + * the fault will actually happen just after 5 seconds + * it was generated.
* - * @param failedPesGenerator the failedPesGenerator to set - * @see #setFailureDelayGenerator(org.cloudbus.cloudsim.distributions.ContinuousDistribution) + * @param maxFailureDelay the max delay to set (in seconds) */ - public void setFailedPesGenerator(ContinuousDistribution failedPesGenerator) { - Objects.requireNonNull(failedPesGenerator); - this.failedPesGenerator = failedPesGenerator; + public void setMaxFailureDelay(double maxFailureDelay) { + this.maxFailureDelay = maxFailureDelay; } /** - * Sets the pseudo random number generator used to randomly define - * the delay before the failure is injected. + * Gets the maximum delay after a fault be injected + * that it will in fact happen (in seconds). * *- * For instance, if the generator returns values between 1 and 10 - * and the value 5 is generated, - * when a failure is injected, it will in fact happen just after 5 - * seconds from the current simulation time.
+ * This is used to define, randomly + * the actual time, after the time the fault was + * injected, that it will happen. + * For instance, if a fault is generated + * and a value 5 is chosen between 0 and the maximum delay, + * the fault will actually happen just after 5 seconds + * it was generated. * - * @param failureDelayGenerator the pseudo random number generator to set - * @see #setFailedPesGenerator(org.cloudbus.cloudsim.distributions.ContinuousDistribution) + * @return the maximum failure delay (in seconds) */ - public void setFailureDelayGenerator(ContinuousDistribution failureDelayGenerator) { - Objects.requireNonNull(failureDelayGenerator); - this.failureDelayGenerator = failureDelayGenerator; - } - + public double getMaxFailureDelay() { + return this.maxFailureDelay; + } + /** * Sets a {@link UnaryOperator} that creates a clone of a {@link Vm} * when all Host PEs fail or all VM's PEs are deallocated @@ -423,4 +472,11 @@ public void setCloudletsCloner(Function