vrr/nfstream
2
0
Fork 0
mirror of https://github.com/nfstream/nfstream.git synced 2026-05-22 03:03:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix Windows CI.

Browse source
This commit is contained in:
aouinizied 2022-04-16 06:38:00 +02:00
parent d4753df318
commit 9b95cc2c43
2 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

3
.coveragerc
View file

@ -1,3 +1,2 @@
[run]
concurrency = multiprocessing
parallel = True
concurrency = multiprocessing

7
nfstream/streamer.py
View file

@ -345,7 +345,7 @@ class NFStreamer(object):
conn_cache = {}
request_cache = {"chrome": RequestCache(timeout=(self.idle_timeout + self.active_timeout) * 1000),
"firefox": RequestCache(timeout=(self.idle_timeout + self.active_timeout) * 1000)}
channel = self._mp_context.JoinableQueue(maxsize=32767) # Backpressure strategy.
channel = self._mp_context.Queue(maxsize=32767) # Backpressure strategy.
# We set it to (2^15-1) to cope with OSX max semaphore value.
n_meters = self.n_meters
group_id = os.getpid() + self._idx # Used for fanout on Linux systems
@ -436,10 +436,9 @@ class NFStreamer(object):
for i in range(n_meters): # We break workflow loop
meters[i].terminate()
break
while not channel.empty(): # Fix join hangs on Windows platforms when Queue is not empty.
channel.get() # https://docs.python.org/3.6/library/multiprocessing.html#pipes-and-queues
for i in range(n_meters):
meters[i].join() # Join metering jobs
if meters[i].is_alive():
meters[i].join() # Join metering jobs
if self._mode == 1 and self.performance_report > 0:
rt.stop()
if self._mode == 1 and self.system_visibility_mode > 0: