Function broadcast

caffe2/python/data_parallel_model.py:1199–1207

(params)

        params_group = list(model._device_grouped_blobs[param_name].values())

        def broadcast(params):
            comm_world, control_input = context.get_control_and_context(params)
            net.Broadcast(
                inputs=[comm_world] + params,
                outputs=params,
                name=param_name,
                engine=rendezvous['engine'],
                control_input=control_input
            )

        device_opt = gpu_device_opt if _IsGPUBlob(
            model, param_name