ebbe.bass
/
PiXelTubes
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

removed cprofiler 

Signed-off-by: Ebbe Baß <ebbe.bass>
main
Ebbe Baß 2024-02-19 16:55:16 +01:00
parent 12fd2b6b6e
commit 6927356998
1 changed files with 10 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
server/app.py
View File

@ -9,8 +9,6 @@ import time
from multiprocessing import Process, Pipe, Queue
from queue import Empty
from ast import literal_eval
import cProfile
import pstats
app = Flask(__name__)
@ -172,19 +170,13 @@ def tube_index_collector(ti_queue, ti_sender):
ti_sender.send(None)
if __name__ == "__main__":
with cProfile.Profile as profile:
try:
(ti_receiver,ti_sender) = Pipe(True)
ti_queue = Queue()
collector_thread = Process(target=tube_index_collector, args=(ti_queue, ti_sender, ))
collector_thread.start()
ti_updater_thread = Process(target=tube_index_updater, args=(ti_queue, ))
ti_updater_thread.start()
publisher_thread = Process(target=mqtt_publisher, args=(ti_receiver, ))
publisher_thread.start()
flask_thread = Process(target=flask_api)
flask_thread.start()
except KeyboardInterrupt:
result = pstats.Stats(profile)
result.sort_stats(pstats.SortKey.TIME)
result.print_stats()
(ti_receiver,ti_sender) = Pipe(True)
ti_queue = Queue()
collector_thread = Process(target=tube_index_collector, args=(ti_queue, ti_sender, ))
collector_thread.start()
ti_updater_thread = Process(target=tube_index_updater, args=(ti_queue, ))
ti_updater_thread.start()
publisher_thread = Process(target=mqtt_publisher, args=(ti_receiver, ))
publisher_thread.start()
flask_thread = Process(target=flask_api)
flask_thread.start()