o * i@sddlmZddlmZmZddlZddlmZddlm Z m Z ddl m Z er:ddlm Z ddlmZdd lmZ  dd ddZ d!d"ddZ   d#d$ddZdS)%) annotations) TYPE_CHECKINGAnyN)stream)_get_global_group_warn_cur_rank_not_in_group)convert_tensor_to_object)Tensor)task)GroupTtensorr srcintgroup Group | Nonesync_opboolreturnr cCstj||||ddS)a Receive a tensor to the sender. Args: tensor (Tensor): The tensor to receive. Its data type should be float16, float32, float64, int32, int64, int8, uint8, bool or bfloat16. src (int): The source rank id. group (Group, optional): The group instance return by new_group or None for global default group. Default: None. sync_op (bool, optional): Whether this op is a sync op. The default value is True. Returns: Return a task object. Examples: .. code-block:: python >>> # doctest: +REQUIRES(env: DISTRIBUTED) >>> import paddle >>> import paddle.distributed as dist >>> dist.init_parallel_env() >>> if dist.get_rank() == 0: ... data = paddle.to_tensor([7, 8, 9]) ... dist.send(data, dst=1) >>> else: ... data = paddle.to_tensor([1, 2, 3]) ... dist.recv(data, src=0) >>> print(data) >>> # [7, 8, 9] (2 GPUs) F)r rrZuse_calc_stream)rrecv)r r rrrq/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/paddle/distributed/communication/recv.pyr#s$ r int | NonecCst|||ddS)aG Receive a tensor to the sender. Args: tensor (Tensor): The Tensor to receive. Its data type should be float16, float32, float64, int32, int64, int8, uint8, bool or bfloat16. src (int): The source rank id. group (Group, optional): The group instance return by new_group or None for global default group. Default: None. Returns: Return a task object. Warning: This API only supports the dygraph mode. Examples: .. code-block:: python >>> # doctest: +REQUIRES(env: DISTRIBUTED) >>> import paddle >>> import paddle.distributed as dist >>> dist.init_parallel_env() >>> if dist.get_rank() == 0: ... data = paddle.to_tensor([7, 8, 9]) ... task = dist.isend(data, dst=1) >>> else: ... data = paddle.to_tensor([1, 2, 3]) ... task = dist.irecv(data, src=0) >>> task.wait() # type: ignore[union-attr] >>> print(data) >>> # [7, 8, 9] (2 GPUs) F)r)r)r r rrrrirecvLs$r object_list list[Any] src_in_groupc Cs|dus t|dkrtd|durtn|}t|rdS|dur/|dur)td||}n|dur5dn|}tjt|fdd}t|||dt| }tj|ftj d}t|||dd}t |D]\}} | } |||| } t | | ||<|| 7}qedS)a} Receive a list of Python objects from the sender. Args: object_list (list): The list to store received objects. Must be pre-allocated with correct size. src (int, optional): The source rank id. Default: 0. group (Group, optional): The group instance return by new_group or None for global default group. Default: None. src_in_group (int, optional): The source rank within the group. Cannot be specified together with src. Default: None. Returns: This function does not return any value. Examples: .. code-block:: python >>> # doctest: +REQUIRES(env: DISTRIBUTED) >>> import paddle >>> import paddle.distributed as dist >>> dist.init_parallel_env() >>> if dist.get_rank() == 0: ... data = ["hello", {"key": 100}, [1, 2, 3]] ... dist.send_object_list(data, dst=1) >>> else: ... data = [None] * 3 # type: ignore ... dist.recv_object_list(data, src=0) >>> print(data) >>> # ["hello", {"key": 100}, [1, 2, 3]] (2 GPUs) Nrz#object_list cannot be None or emptyz7Cannot specify both 'src' and 'src_in_group' arguments.Zint64)Zdtype)r r) len ValueErrorrrZget_global_rankpaddleemptyrsumitemZuint8 enumerater) rr rrZobject_sizes_tensor total_sizeZ object_tensoroffsetiZobj_sizeZobj_viewrrrrecv_object_listss0#  r&)rNT) r r r rrrrrrr )NN)r r r rrrrr )NNN)rrr rrrrr) __future__rtypingrrrZ paddle.distributed.communicationrZ&paddle.distributed.communication.grouprrZ4paddle.distributed.communication.serialization_utilsrr Zpaddle.base.corer r rrr&rrrrs(       * )