OwlCyberSecurity - MANAGER
Edit File: transports.cpython-35.opt-2.pyc
���]R' � @ s� d d l m Z d d d d d d g Z Gd d � d � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e e � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z d S)� )�compat� BaseTransport� ReadTransport�WriteTransport� Transport�DatagramTransport�SubprocessTransportc @ s^ e Z d Z d d d � Z d d d � Z d d � Z d d � Z d d � Z d d � Z d S)r Nc C s | d k r i } | | _ d S)N)�_extra)�self�extra� r �//opt/alt/python35/lib64/python3.5/transports.py�__init__ s zBaseTransport.__init__c C s | j j | | � S)N)r �get)r �name�defaultr r r �get_extra_info s z BaseTransport.get_extra_infoc C s t � d S)N)�NotImplementedError)r r r r � is_closing s zBaseTransport.is_closingc C s t � d S)N)r )r r r r �close s zBaseTransport.closec C s t � d S)N)r )r �protocolr r r � set_protocol$ s zBaseTransport.set_protocolc C s t � d S)N)r )r r r r � get_protocol( s zBaseTransport.get_protocol) �__name__� __module__� __qualname__r r r r r r r r r r r s c @ s( e Z d Z d d � Z d d � Z d S)r c C s t � d S)N)r )r r r r � pause_reading0 s zReadTransport.pause_readingc C s t � d S)N)r )r r r r �resume_reading8 s z ReadTransport.resume_readingN)r r r r r r r r r r - s c @ sj e Z d Z d d d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d S)r Nc C s t � d S)N)r )r �high�lowr r r �set_write_buffer_limitsD s z&WriteTransport.set_write_buffer_limitsc C s t � d S)N)r )r r r r �get_write_buffer_sizeY s z$WriteTransport.get_write_buffer_sizec C s t � d S)N)r )r �datar r r �write] s zWriteTransport.writec C s t j | � } | j | � d S)N)r Zflatten_list_bytesr# )r Z list_of_datar" r r r � writelinese s zWriteTransport.writelinesc C s t � d S)N)r )r r r r � write_eofn s zWriteTransport.write_eofc C s t � d S)N)r )r r r r � can_write_eofw s z WriteTransport.can_write_eofc C s t � d S)N)r )r r r r �abort{ s zWriteTransport.abort) r r r r r! r# r$ r% r& r' r r r r r A s c @ s e Z d Z d S)r N)r r r r r r r r � s c @ s+ e Z d Z d d d � Z d d � Z d S)r Nc C s t � d S)N)r )r r" �addrr r r �sendto� s zDatagramTransport.sendtoc C s t � d S)N)r )r r r r r' � s zDatagramTransport.abort)r r r r) r' r r r r r � s c @ sX e Z d Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d S)r c C s t � d S)N)r )r r r r �get_pid� s zSubprocessTransport.get_pidc C s t � d S)N)r )r r r r �get_returncode� s z"SubprocessTransport.get_returncodec C s t � d S)N)r )r �fdr r r �get_pipe_transport� s z&SubprocessTransport.get_pipe_transportc C s t � d S)N)r )r �signalr r r � send_signal� s z SubprocessTransport.send_signalc C s t � d S)N)r )r r r r � terminate� s z SubprocessTransport.terminatec C s t � d S)N)r )r r r r �kill� s zSubprocessTransport.killN) r r r r* r+ r- r/ r0 r1 r r r r r � s c s| e Z d Z d d � f d d � Z d d � Z d d � Z d d � Z d d d d � Z d d d d � Z d d � Z � S)�_FlowControlMixinNc s0 t � j | � | | _ d | _ | j � d S)NF)�superr �_loop�_protocol_paused�_set_write_buffer_limits)r r Zloop)� __class__r r r � s z_FlowControlMixin.__init__c C s� | j � } | | j k r d S| j s� d | _ y | j j � WnP t k r� } z0 | j j d d d | d | d | j i � WYd d } ~ Xn Xd S)NT�messagez protocol.pause_writing() failed� exception� transportr )r! � _high_waterr5 � _protocolZ pause_writing� Exceptionr4 �call_exception_handler)r �size�excr r r �_maybe_pause_protocol� s z'_FlowControlMixin._maybe_pause_protocolc C s� | j r� | j � | j k r� d | _ y | j j � WnP t k r� } z0 | j j d d d | d | d | j i � WYd d } ~ Xn Xd S)NFr8 z protocol.resume_writing() failedr9 r: r )r5 r! � _low_waterr< Zresume_writingr= r4 r> )r r@ r r r �_maybe_resume_protocol s z(_FlowControlMixin._maybe_resume_protocolc C s | j | j f S)N)rB r; )r r r r �get_write_buffer_limits s z)_FlowControlMixin.get_write_buffer_limitsc C s� | d k r+ | d k r! d } n d | } | d k rA | d } | | k oX d k n ss t d | | f � � | | _ | | _ d S)N�@ i � r z*high (%r) must be >= low (%r) must be >= 0i )� ValueErrorr; rB )r r r r r r r6 s z*_FlowControlMixin._set_write_buffer_limitsc C s$ | j d | d | � | j � d S)Nr r )r6 rA )r r r r r r r - s z)_FlowControlMixin.set_write_buffer_limitsc C s t � d S)N)r )r r r r r! 1 s z'_FlowControlMixin.get_write_buffer_size) r r r r rA rC rD r6 r r! r r )r7 r r2 � s r2 N) Zasyncior �__all__r r r r r r r2 r r r r �<module> s #D4