U
    ‰d“  ã                   @   sô   G d d„ de ƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG dd	„ d	eƒZG d
d„ deƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZ	G dd„ deƒZ
G dd„ deƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZdS )c                   @   s   e Zd ZdS )ÚDataLoaderQueueMessageN©Ú__name__Ú
__module__Ú__qualname__© r   r   úK/tmp/pip-unpacked-wheel-ua33x9lu/torch/utils/data/communication/messages.pyr      s   r   c                   @   s   e Zd ZdS )ÚRequestNr   r   r   r   r   r      s   r   c                   @   s   e Zd ZdS )ÚResponseNr   r   r   r   r   r	   	   s   r	   c                   @   s   e Zd ZdS )ÚResetIteratorRequestNr   r   r   r   r   r
      s   r
   c                   @   s   e Zd ZdS )ÚResetIteratorResponseNr   r   r   r   r   r      s   r   c                   @   s   e Zd ZdS )ÚTerminateRequestNr   r   r   r   r   r      s   r   c                   @   s   e Zd ZdS )ÚTerminateResponseNr   r   r   r   r   r      s   r   c                   @   s   e Zd ZdS )Ú
LenRequestNr   r   r   r   r   r      s   r   c                   @   s   e Zd ZdZdd„ ZdS )ÚLenResponseÚlenc                 C   s
   || _ d S ©N)r   )Úselfr   r   r   r   Ú__init__$   s    zLenResponse.__init__N©r   r   r   Ú	__slots__r   r   r   r   r   r   !   s   r   c                   @   s   e Zd ZdZdd„ ZdS )ÚGetItemRequestÚkeyc                 C   s
   || _ d S r   )r   )r   r   r   r   r   r   +   s    zGetItemRequest.__init__Nr   r   r   r   r   r   (   s   r   c                   @   s   e Zd ZdZdd„ ZdS )ÚGetItemResponse©r   Úvaluec                 C   s   || _ || _d S r   r   )r   r   r   r   r   r   r   2   s    zGetItemResponse.__init__Nr   r   r   r   r   r   /   s   r   c                   @   s   e Zd ZdS )ÚGetNextRequestNr   r   r   r   r   r   7   s   r   c                   @   s   e Zd ZdZdd„ ZdS )ÚGetNextResponser   c                 C   s
   || _ d S r   )r   )r   r   r   r   r   r   >   s    zGetNextResponse.__init__Nr   r   r   r   r   r   ;   s   r   c                   @   s   e Zd ZdS )ÚStopIterationResponseNr   r   r   r   r   r   B   s   r   c                   @   s   e Zd ZdZdS )ÚInvalidStateResponsez˜
        Returned by DataPipe when it is expecting to get reset request,
        for example RouterDataPipe expecting all workers to request reset'
    N)r   r   r   Ú__doc__r   r   r   r   r   F   s   r   N)Úobjectr   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   Ú<module>   s   