|
facebook360_dep
Facebook360 Depth Estimation Pipeline
|
Public Member Functions | |
| def | __init__ (self, master_ip, base_params, frame_chunks, background_frame, force_recompute=False) |
| def | purge_queue (self, queue_name) |
| def | run_halted_queue (self, params, frame_chunks) |
| def | generate_foreground_masks (self) |
| def | precompute_resizes_foreground (self) |
| def | precompute_resizes (self) |
| def | depth_estimation (self) |
| def | convert_to_binary (self) |
| def | fusion (self) |
| def | simple_mesh_renderer (self) |
| def | run (self, stages) |
Public Attributes | |
| base_params | |
| frame_chunks | |
| background_frame | |
| master_ip | |
| force_recompute | |
Pipeline class for rendering stages. Pipeline stages process sequentially.
Attributes:
background_frame (dict[str, str]): Map of the background frame chunk with keys
"first" and "last" corresponding to the appropriate frame names for the chunk.
base_params (dict[str, _]): Map of all the FLAGS defined in render.py.
force_recompute (bool): Whether or not to overwrite previous computations.
frame_chunks (list[dict[str, str]]): List of frame chunk with keys
"first" and "last" corresponding to the appropriate frame names for the chunk.
master_ip (str): IP of the master host.
| def scripts.render.pipeline.Pipeline.__init__ | ( | self, | |
| master_ip, | |||
| base_params, | |||
| frame_chunks, | |||
| background_frame, | |||
force_recompute = False |
|||
| ) |
Constructs empty pipeline.
Args:
master_ip (str): IP of the master host.
base_params (dict[str, _]): Map of all the FLAGS defined in render.py.
frame_chunks (list[dict[str, str]]): List of frame chunk with keys
"first" and "last" corresponding to the appropriate frame names for the chunk.
background_frame (dict[str, str]): Map of the background frame chunk with keys
"first" and "last" corresponding to the appropriate frame names for the chunk.
force_recompute (bool, optional): Whether or not to overwrite previous computations.
| def scripts.render.pipeline.Pipeline.convert_to_binary | ( | self | ) |
Runs distributed binary conversion.
| def scripts.render.pipeline.Pipeline.depth_estimation | ( | self | ) |
Runs distributed depth estimation with temporal filtering.
| def scripts.render.pipeline.Pipeline.fusion | ( | self | ) |
Runs distributed binary striping.
| def scripts.render.pipeline.Pipeline.generate_foreground_masks | ( | self | ) |
Runs distributed foreground mask generation.
| def scripts.render.pipeline.Pipeline.precompute_resizes | ( | self | ) |
Runs distributed color, background color, and background disparity resizing.
| def scripts.render.pipeline.Pipeline.precompute_resizes_foreground | ( | self | ) |
Runs distributed foreground mask resizing.
| def scripts.render.pipeline.Pipeline.purge_queue | ( | self, | |
| queue_name | |||
| ) |
Clears contents of a queue.
Args:
queue_name (str): Name of the queue to clear.
| def scripts.render.pipeline.Pipeline.run | ( | self, | |
| stages | |||
| ) |
Runs the pipeline stages.
Args:
stages (list[tuple(func : void -> void), bool]): List of functions and whether
or not they are to be executed.
| def scripts.render.pipeline.Pipeline.run_halted_queue | ( | self, | |
| params, | |||
| frame_chunks | |||
| ) |
Runs a queue with params for each of the frame chunks. The program halts while
awaiting the completion of tasks in the queue and shows a progress bar meanwhile. Any
frame chunks that have been previously completed will be marked as complete unless
running with force_recompute.
Args:
params (dict[str, _]): Message to be published to RabbitMQ.
frame_chunks (list[dict[str, str]]): List of frame chunk with keys
"first" and "last" corresponding to the appropriate frame names for the chunk.
| def scripts.render.pipeline.Pipeline.simple_mesh_renderer | ( | self | ) |
| scripts.render.pipeline.Pipeline.background_frame |
| scripts.render.pipeline.Pipeline.base_params |
| scripts.render.pipeline.Pipeline.force_recompute |
| scripts.render.pipeline.Pipeline.frame_chunks |
| scripts.render.pipeline.Pipeline.master_ip |
1.8.15