Removed unnecesarry greenlet context switches
This commit is contained in:
parent
e01e96ea3c
commit
9962f0b063
1 changed files with 0 additions and 4 deletions
|
|
@ -159,7 +159,6 @@ class CaptureObject(object):
|
||||||
|
|
||||||
def write(self, s):
|
def write(self, s):
|
||||||
self.stream.write(s)
|
self.stream.write(s)
|
||||||
gevent.sleep()
|
|
||||||
|
|
||||||
def _stream_to_file(self):
|
def _stream_to_file(self):
|
||||||
logging.info(f"Writing to disk {self.file}")
|
logging.info(f"Writing to disk {self.file}")
|
||||||
|
|
@ -168,12 +167,10 @@ class CaptureObject(object):
|
||||||
self.stream.close()
|
self.stream.close()
|
||||||
self.file_ready.set()
|
self.file_ready.set()
|
||||||
logging.info(f"Finished writing to disk {self.file}")
|
logging.info(f"Finished writing to disk {self.file}")
|
||||||
gevent.sleep()
|
|
||||||
|
|
||||||
def flush(self):
|
def flush(self):
|
||||||
logging.debug(f"Flushing {self.file}")
|
logging.debug(f"Flushing {self.file}")
|
||||||
gevent.get_hub().threadpool.spawn(self._stream_to_file)
|
gevent.get_hub().threadpool.spawn(self._stream_to_file)
|
||||||
gevent.sleep()
|
|
||||||
logging.debug(f"Returning flushing {self.file}")
|
logging.debug(f"Returning flushing {self.file}")
|
||||||
|
|
||||||
def open(self, mode):
|
def open(self, mode):
|
||||||
|
|
@ -250,7 +247,6 @@ class CaptureObject(object):
|
||||||
|
|
||||||
def save_metadata(self) -> None:
|
def save_metadata(self) -> None:
|
||||||
gevent.get_hub().threadpool.spawn(self.synchronous_save_metadata)
|
gevent.get_hub().threadpool.spawn(self.synchronous_save_metadata)
|
||||||
gevent.sleep()
|
|
||||||
|
|
||||||
def synchronous_save_metadata(self) -> None:
|
def synchronous_save_metadata(self) -> None:
|
||||||
"""
|
"""
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue