Commit @e85956183a54c4ca7d3ddc83f9e55335d390eaee

윤영준 05-24

rewriting of event handling class, StreamSources 1. counting error fixed (ok_counts and failure_counts)

1. counting error fixed (ok_counts and failure_counts)

@e85956183a54c4ca7d3ddc83f9e55335d390eaee

9756b57

e859561

postprocess_draft.py

--- postprocess_draft.py

+++ postprocess_draft.py


         if self.sources[source]["force_send_mode"]:
             seek_n_recent_memory = min(len(self.sources[source]["status_counts"]), self.failure_mode_check_past_n)
             print(seek_n_recent_memory)
-            print(self.sources[source]["status_counts"][:-seek_n_recent_memory])
-            self.sources[source]['ok_counts'] = (seek_n_recent_memory
+            print(self.sources[source]["status_counts"][-seek_n_recent_memory:])
+            self.sources[source]['failure_counts'] = (seek_n_recent_memory
                               - sum(self.sources[source]["status_counts"][-seek_n_recent_memory:]))
-            self.sources[source]['failure_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
+            self.sources[source]['ok_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
             flag_send_event = True
 
             # mode switching condition check

             seek_n_recent_memory = min(len(self.sources[source]["status_counts"]), self.normal_mode_check_past_n)
             print(seek_n_recent_memory)
             # mem_len = len(self.sources[source]["status_counts"])
-            # print(self.sources[source]["status_counts"][-seek_n_recent_memory:])
-            self.sources[source]['ok_counts'] = (seek_n_recent_memory
+            print(self.sources[source]["status_counts"][-seek_n_recent_memory:])
+            self.sources[source]['failure_counts'] = (seek_n_recent_memory
                               - sum(self.sources[source]["status_counts"][-seek_n_recent_memory:]))
-            self.sources[source]['failure_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
+            self.sources[source]['ok_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
             # print(self.sources[source]['failure_counts'])
 
             # mode switching condition check

Add a comment

Open 0
Closed 0

List

...	...	@@ -101,10 +101,10 @@
101	101	if self.sources[source]["force_send_mode"]:
102	102	seek_n_recent_memory = min(len(self.sources[source]["status_counts"]), self.failure_mode_check_past_n)
103	103	print(seek_n_recent_memory)
104		- print(self.sources[source]["status_counts"][:-seek_n_recent_memory])
105		- self.sources[source]['ok_counts'] = (seek_n_recent_memory
	104	+ print(self.sources[source]["status_counts"][-seek_n_recent_memory:])
	105	+ self.sources[source]['failure_counts'] = (seek_n_recent_memory
106	106	- sum(self.sources[source]["status_counts"][-seek_n_recent_memory:]))
107		- self.sources[source]['failure_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
	107	+ self.sources[source]['ok_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
108	108	flag_send_event = True
109	109
110	110	# mode switching condition check
...	...	@@ -118,10 +118,10 @@
118	118	seek_n_recent_memory = min(len(self.sources[source]["status_counts"]), self.normal_mode_check_past_n)
119	119	print(seek_n_recent_memory)
120	120	# mem_len = len(self.sources[source]["status_counts"])
121		- # print(self.sources[source]["status_counts"][-seek_n_recent_memory:])
122		- self.sources[source]['ok_counts'] = (seek_n_recent_memory
	121	+ print(self.sources[source]["status_counts"][-seek_n_recent_memory:])
	122	+ self.sources[source]['failure_counts'] = (seek_n_recent_memory
123	123	- sum(self.sources[source]["status_counts"][-seek_n_recent_memory:]))
124		- self.sources[source]['failure_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
	124	+ self.sources[source]['ok_counts'] = seek_n_recent_memory - self.sources[source]['ok_counts']
125	125	# print(self.sources[source]['failure_counts'])
126	126
127	127	# mode switching condition check

Delete comment