From d6d54dbd84e59df20860d14369827facf8fa0fd3 Mon Sep 17 00:00:00 2001
From: Quentin Legot <legotquentin@gmail.com>
Date: Thu, 30 Mar 2023 09:33:28 +0200
Subject: [PATCH] First fix of User#createPackets

---
 plot/main.py                          |  2 --
 src/main/java/fr/ntr/AccessPoint.java | 17 ++++------------
 src/main/java/fr/ntr/User.java        | 29 ++++++++++++++++-----------
 3 files changed, 21 insertions(+), 27 deletions(-)

diff --git a/plot/main.py b/plot/main.py
index 69e3350..5f91b25 100644
--- a/plot/main.py
+++ b/plot/main.py
@@ -48,7 +48,6 @@ def delay() -> np.ndarray:
         for x in d:
             delays[nb, 0] = int(nb_users)
             delays[nb, 1] = float(x)
-            print(float(x))
         nb += 1
     return delays
 
@@ -60,7 +59,6 @@ delays.sort(axis=0)
 # Data for plotting
 averages.sort(axis=0)
 
-#print(averages)
 fig, ax = plt.subplots()
 ax.scatter(averages[:, 0], averages[:, 1])
 
diff --git a/src/main/java/fr/ntr/AccessPoint.java b/src/main/java/fr/ntr/AccessPoint.java
index 748bc25..d2ce6c7 100644
--- a/src/main/java/fr/ntr/AccessPoint.java
+++ b/src/main/java/fr/ntr/AccessPoint.java
@@ -25,17 +25,12 @@ public class AccessPoint {
      * trame
      */
     private ResourceBlock[][] frame;
-    /**
-     * Reste pour la prochaine source
-     */
-    private double leftForNextSource;
+
     /**
      * Portée minimum et maximum de l'antenne
      */
     private final double min, max;
 
-    private Random random = new Random();
-
     private FileOutputStream outputDataFile;
 
     
@@ -80,19 +75,15 @@ public class AccessPoint {
     }
 
     private void updateBandwidth(int ticks) {
-        int n = 200;
-        int timeInterval = Math.max(1, random.nextInt(51)); // avoid div by 0
+        int m = 200;
         for(User user : users) {
+            // On régénère les sources toutes les 50-100 ms
+            user.createPackets(m, ticks);
             // On régénère le tableau de débits toutes les 50 ms
             if(ticks % 50 == 0){
                 user.generateBandwidth();
             }
 
-            // On régénère les sources toutes les 0-50 ms
-            if(ticks % timeInterval == 0){
-                timeInterval = Math.max(1, random.nextInt(51));
-                n = user.createPackets(n, ticks);
-            }
         }
     }
 
diff --git a/src/main/java/fr/ntr/User.java b/src/main/java/fr/ntr/User.java
index 0d41e13..7b28066 100644
--- a/src/main/java/fr/ntr/User.java
+++ b/src/main/java/fr/ntr/User.java
@@ -11,6 +11,7 @@ public class User {
     private final List<Packets> packetsToSend;
     private final List<Packets> packetsSent;
     private int leftForNextSource;
+    private int timeInterval = 1;
 
     private final Random random = new Random();
 
@@ -40,20 +41,24 @@ public class User {
      * 
      * @param m
      * @param ticks qui va définir le temps auquel a été créé un paquet
-     * @return
      */
-    public int createPackets(int m, int ticks) {
-        // On tire un nombre entre 0 et 2 * m
-        int mbis = m == 0 ? 0 : random.nextInt(2 * (m + this.leftForNextSource));
-        // On calcule le nombre de paquets qu'on peut transmettre
-        int nbPacketsToSend = mbis / Packets.packetSize;
-        // On conserve le nombre de bits restants pour la prochaine génération
-        this.leftForNextSource = mbis % Packets.packetSize;
-        // On crée les paquets
-        for(int i = 0; i < nbPacketsToSend; i++){
-            this.packetsToSend.add(new Packets(ticks));
+    public void createPackets(int m, int ticks) {
+        timeInterval--;
+        if(timeInterval == 0) {
+            timeInterval = random.nextInt(50, 101);
+            // On tire un nombre entre 0 et 2 * m
+            int mbis = random.nextInt(1, 2 * m) + this.leftForNextSource;
+            // On calcule le nombre de paquets qu'on peut transmettre
+            int bitsToSend = random.nextInt(2 * mbis);
+            int nbPacketsToSend = bitsToSend / Packets.packetSize;
+            // On conserve le nombre de bits restants pour la prochaine génération
+            this.leftForNextSource = bitsToSend % Packets.packetSize;
+            // On crée les paquets
+            for(int i = 0; i < nbPacketsToSend; i++) {
+                this.packetsToSend.add(new Packets(ticks));
+            }
         }
-        return mbis;
+
     }
 
     public double getDistance() {