Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
# operation
self.download_manager_obj = download_manager_obj
# The parent downloads.DownloadWorker object
self.download_worker_obj = download_worker_obj
# The downloads.DownloadItem object describing the URL from which
# youtube-dl should download video(s)
self.download_item_obj = download_item_obj
# This object reads from the child process STDOUT and STDERR in an
# asynchronous way
# Standard Python synchronised queue classes
self.stdout_queue = queue.Queue()
self.stderr_queue = queue.Queue()
# The downloads.PipeReader objects created to handle reading from the
# pipes
self.stdout_reader = PipeReader(self.stdout_queue)
self.stderr_reader = PipeReader(self.stderr_queue)
# The child process created by self.create_child_process()
self.child_process = None
# IV list - other
# ---------------
# The current return code, using values in the range 0-5, as described
# above
# The value remains set to self.OK unless we encounter any problems
# The larger the number, the higher in the hierarchy of return codes.
# Codes lower in the hierarchy (with a smaller number) cannot
# overwrite higher in the hierarchy (with a bigger number)
self.return_code = self.OK
# The time (in seconds) between iterations of the loop in
"""Called by downloads.VideoDownloader.close(), which is the destructor
function for that object.
Join the thread and update IVs.
Args:
timeout (-): No calling code sets a timeout
"""
if DEBUG_FUNC_FLAG:
utils.debug_time('dld 3621 join')
self.running_flag = False
super(PipeReader, self).join(timeout)
self.download_manager_obj = download_manager_obj
# The parent downloads.DownloadWorker object
self.download_worker_obj = download_worker_obj
# The downloads.DownloadItem object describing the URL from which
# youtube-dl should download video(s)
self.download_item_obj = download_item_obj
# This object reads from the child process STDOUT and STDERR in an
# asynchronous way
# Standard Python synchronised queue classes
self.stdout_queue = queue.Queue()
self.stderr_queue = queue.Queue()
# The downloads.PipeReader objects created to handle reading from the
# pipes
self.stdout_reader = PipeReader(self.stdout_queue)
self.stderr_reader = PipeReader(self.stderr_queue)
# The child process created by self.create_child_process()
self.child_process = None
# IV list - other
# ---------------
# The current return code, using values in the range 0-5, as described
# above
# The value remains set to self.OK unless we encounter any problems
# The larger the number, the higher in the hierarchy of return codes.
# Codes lower in the hierarchy (with a smaller number) cannot
# overwrite higher in the hierarchy (with a bigger number)
self.return_code = self.OK
# The time (in seconds) between iterations of the loop in
# self.do_download()