|
facebook360_dep
Facebook360 Depth Estimation Pipeline
|
Functions | |
| def | generate_foreground_masks_callback (msg) |
| def | resize_images_callback (msg) |
| def | depth_estimation_callback (msg) |
| def | temporal_filter_callback (msg) |
| def | transfer_callback (msg) |
| def | upsample_disparity_callback (msg) |
| def | upsample_layer_disparity_callback (msg) |
| def | convert_to_binary_callback (msg) |
| def | simple_mesh_renderer_callback (msg) |
| def | callback (ch, method, properties, body) |
| def | main_loop (argv) |
Variables | |
| dir_scripts = os.path.dirname(os.path.dirname(os.path.abspath(__file__))) | |
| dir_root = os.path.dirname(dir_scripts) | |
| FLAGS = flags.FLAGS | |
| def scripts.render.worker.callback | ( | ch, | |
| method, | |||
| properties, | |||
| body | |||
| ) |
Dispatches to different callbacks based on the contents of the message.
Args:
Only the body argument is necessary. The others are imposed by Pika.
ch (pika.Channel): N/a
method (pika.spec.Basic): N/a
properties (pika.spec.BasicProperties): N/a
body (bytes): utf-8 encoded message published to the message queue.
| def scripts.render.worker.convert_to_binary_callback | ( | msg | ) |
Runs binary conversion according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.depth_estimation_callback | ( | msg | ) |
Runs depth estimation according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.generate_foreground_masks_callback | ( | msg | ) |
Runs foreground mask generation according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.main_loop | ( | argv | ) |
Sets up the callback loop for the worker.
Args:
argv (list[str]): List of arguments (used interally by abseil).
| def scripts.render.worker.resize_images_callback | ( | msg | ) |
Runs image resizing according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.simple_mesh_renderer_callback | ( | msg | ) |
| def scripts.render.worker.temporal_filter_callback | ( | msg | ) |
Runs temporal filtering according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.transfer_callback | ( | msg | ) |
Runs transfer according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.upsample_disparity_callback | ( | msg | ) |
Runs disparity upsampling according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| def scripts.render.worker.upsample_layer_disparity_callback | ( | msg | ) |
Runs disparity upsampling and layering according to parameters read from the message.
Args:
msg (dict[str, str]): Message received from RabbitMQ publisher.
| scripts.render.worker.dir_root = os.path.dirname(dir_scripts) |
| scripts.render.worker.dir_scripts = os.path.dirname(os.path.dirname(os.path.abspath(__file__))) |
| scripts.render.worker.FLAGS = flags.FLAGS |
1.8.15