simqueue_2022/event.cpp at master · isaacmaffeis/simqueue_2022 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
/***********************************************************************
		EVENT.C
***********************************************************************/

#include "event.h"
#include "buffer.h"
#include "calendar.h"
#include "queue.h"
#include "rand.h"
#include <iostream>
#include <random>

extern calendar* cal;
extern double inter;
extern double duration;
extern int q_a, q_b;
extern int trf_model;
extern bool batch;
extern int meanC;
double batch_time;
int batch_size;
std::default_random_engine generator;

void arrival::body() {
	event* ev;

	// generation of next arrival
	double res = 0;
	double esito = 0;
	if (!batch) {	// arrivi singoli
		esito = genArr();
	}

	else {
		if (batch_size <= 1) { // genero il lotto
			std::binomial_distribution<int> distribution(meanC*2, 0.5); // distribuzione binomiale
			batch_size = distribution(generator); // lunghezza del lotto
			esito = genArr();
		}
		else {	// genera un altro arrivo per lo stesso lotto (stesso tempo di arrivo)
			esito = batch_time;
			batch_size--;
		}
	}

	ev = new arrival(time + esito, buf);
	cal->put(ev);


	// insert the new packet in the queue
	packet* pack = new packet(time);
	// if some packet is already in the buffer, just insert the new one
	if (buf->full() || buf->status) {
		buf->insert(pack);
	}
	// otherwise let the packet get in the service
	else {
		buf->tot_packs += 1.0;
		delete pack;
		GEN_EXP(SEED, duration, esito);
		ev = new service(time + esito, buf);
		cal->put(ev);
		buf->status = 1;
	}
}

double arrival::genArr() {
	double res = 0;
	double esito = 0;
	switch (trf_model)
	{
	case 1:
		GEN_EXP(SEED, inter, esito);
		break;
	case 2:
		GEN_UNIF(SEED, q_a, q_b, res);
		esito = 1 / res;
		break;
	default:
		break;
	}
	return esito;
}

void service::body() {
	// printf("ingresso             %f\n", time);
	packet* pack;
	pack = buf->get();
	event* ev;
	double esito;
	GEN_EXP(SEED, duration, esito);
	if (pack != NULL) {
		ev = new service(time + esito, buf);
		cal->put(ev);
		buf->tot_delay += time - pack->get_time();
		// printf("%3.5f    %3.5f\n", time, time-pack->get_time());
		buf->tot_packs += 1.0;
		delete pack;
	}
	else
		buf->status = 0;
}