Merge branch 'master' into ajout_cellule
This commit is contained in:
commit
3b012adf61
@ -1,6 +1,7 @@
|
||||
package fr.ntr.scheduler;
|
||||
import java.util.List;
|
||||
|
||||
import fr.ntr.Cell;
|
||||
import fr.ntr.ResourceBlock;
|
||||
import fr.ntr.User;
|
||||
|
||||
@ -9,7 +10,7 @@ public class MaxSNR extends Scheduler {
|
||||
private final List<User> users;
|
||||
private final ResourceBlock[][] frame;
|
||||
|
||||
public MaxSNR( ResourceBlock[][] frame, List<User> users) {
|
||||
public MaxSNR(ResourceBlock[][] frame, List<User> users) {
|
||||
this.frame = frame;
|
||||
this.users = users;
|
||||
}
|
||||
@ -17,8 +18,8 @@ public class MaxSNR extends Scheduler {
|
||||
@Override
|
||||
public void scheduling(int ticks) {
|
||||
User userMax;
|
||||
for(int ts = 0; ts < 2; ts++){
|
||||
for(int sp = 0; sp < 100; sp++){
|
||||
for(int ts = 0; ts < Cell.getTimeSlotNb(); ts++){
|
||||
for(int sp = 0; sp < Cell.getSubCarrierNb(); sp++){
|
||||
userMax = userSelection(ts, sp);
|
||||
allocateRessource(userMax, frame, ts, sp, ticks);
|
||||
}
|
||||
@ -34,12 +35,11 @@ public class MaxSNR extends Scheduler {
|
||||
private User userSelection(int ts, int sp) {
|
||||
double maxSnr = 0.0;
|
||||
User userMax = null;
|
||||
for(User u: users){
|
||||
if(!u.getPacketsToSend().isEmpty()) {
|
||||
if (maxSnr < u.getBandwidthTable()[ts][sp]) {
|
||||
maxSnr = u.getBandwidthTable()[ts][sp];
|
||||
userMax = u;
|
||||
}
|
||||
for(User u: users) {
|
||||
if (!u.getPacketsToSend().isEmpty() && (maxSnr < u.getBandwidthTable()[ts][sp])) {
|
||||
maxSnr = u.getBandwidthTable()[ts][sp];
|
||||
userMax = u;
|
||||
|
||||
}
|
||||
}
|
||||
return userMax;
|
||||
|
@ -20,7 +20,7 @@ public class ProportionalFair extends Scheduler {
|
||||
|
||||
@Override
|
||||
public void scheduling(int ticks) {
|
||||
ArrayList<Double> averageBandwiths = new ArrayList<Double>();
|
||||
ArrayList<Double> averageBandwiths = new ArrayList<>();
|
||||
for(User u : users){
|
||||
double avg = 0d;
|
||||
double[][] bandwidthTable = u.getBandwidthTable();
|
||||
|
@ -16,18 +16,8 @@ public abstract class Scheduler {
|
||||
protected void allocateRessource(User userMax, ResourceBlock[][] frame, int ts, int sp, int ticks) {
|
||||
if (userMax != null && !userMax.getPacketsToSend().isEmpty()) {
|
||||
Packets p = userMax.getPacketsToSend().get(userMax.getPacketsToSend().size()-1);
|
||||
if(p.getBitsNumberRemaining() >= 0){
|
||||
p.decreaseBitsNumberRemaining((int) userMax.getBandwidthTable()[ts][sp]);
|
||||
if(p.getBitsNumberRemaining() <= 0) {
|
||||
if(ticks == 0){
|
||||
p.setDurationSending(1);
|
||||
}else {
|
||||
p.setDurationSending(ticks);
|
||||
}
|
||||
userMax.getPacketsSent().add(p);
|
||||
userMax.getPacketsToSend().remove(p);
|
||||
}
|
||||
} else {
|
||||
p.decreaseBitsNumberRemaining((int) userMax.getBandwidthTable()[ts][sp]);
|
||||
if(p.getBitsNumberRemaining() <= 0) {
|
||||
if(ticks == 0){
|
||||
p.setDurationSending(1);
|
||||
}else {
|
||||
|
Reference in New Issue
Block a user