net-sim/Simulator.py at master · welandx/net-sim · 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
103
104
105
106
107
108
109
110
111
from Event import Event
from NormalDistribution import NormalDistribution
import time
from RandTimeGenerator import RandTimeGenerator


class Simulator:
    def __init__(self):
        self.event_dict = {}
        self.event_list = []
        self.current_time = 0
        self.next_time = None
        self.next_next_time = None
        self.total_time = 0
        self.due_now_list = []
        self.due_c_list = []
        self.b_phrase_success = 0
        self.c_phrase_success = 0
        self.success_ID = []

    def add_event(self, event):
        self.event_dict[event] = event.event_date
        #print("Add a new event:" + event.event_name )
        #print("*** Event ID: " + str(event.event_nums))
        #print("+++ Event Type: " + event.event_type)
        #print("event date")
        # print(event.event_date)
        # print("----------------------")

    def arrange_event(self):
        self.event_list = sorted(
            self.event_dict.items(), key=lambda x: x[1], reverse=False)

    def a_phrase(self):
        self.event_list = list(self.event_list)
        self.next_time = self.event_list[0][0].event_date
        # 此时就得到了最近的时间

        self.due_now_list.clear()
        for temp in self.event_list:
            if temp[0].event_date == self.next_time:
                self.due_now_list.append(temp[0])
            if temp[0].event_date > self.next_time:
                self.next_next_time = temp[0].event_date
                break

        for temp in self.due_now_list:
            self.event_dict.pop(temp)
        self.event_list.clear()
        return self.due_now_list

    def cal_success_times(self, phrase, event_state, event_nums):
        if phrase == "C" and event_state == "Success":
            self.c_phrase_success += 1
        elif phrase == "B" and event_state == "Success":
            self.b_phrase_success += 1
            self.success_ID.append(event_nums)

    def b_phrase(self, *event_list):
        #print("B phrase")
        for temp in event_list:
            # self.due_c_list.append(temp[0].run(self.current_time,self.next_time,self.next_next_time,0))
            temp[0].run(self.current_time, self.next_time, self.next_next_time)
            self.current_time = temp[0].event_date
            self.cal_success_times(
                "B", temp[0].event_state, temp[0].event_nums)
        self.due_now_list.clear()

    def c_pharese(self, *event_list):
        if event_list[0].__len__() != 0:
            print("C phrase")
            for temp in event_list:
                self.current_time = temp[0].event_date
                temp[0].run()
                print(temp[0].event_nums)
                self.cal_success_times(
                    "C", temp[0].event_state, temp[0].event_nums)
        self.due_c_list.clear()

    def run(self, event_list):
        for i in event_list:
            self.add_event(i)
        while len(self.event_dict) != 0:
            self.arrange_event()
            self.a_phrase()
            # print(self.current_time)
            # print(self.next_time)

            self.b_phrase(self.due_now_list)
            # print(self.current_time)
            # print(self.next_time)
            # print(self.b_phrase_success)

            self.c_pharese(self.due_c_list)
            # print(self.current_time)
            # print(self.next_time)
            # print(self.c_phrase_success)


#Sim = Simulator()
#a = Event("TCP","TCP",0)
#b = Event("TCP1","TCP",1)
#
# a.ud_event_initialize("0",0,1)
# print(a.event_date)
#
# b.ud_event_initialize("0",101,200)
#
#c  = [b,a]
#
# Sim.run(c)