o j`@s(ddlmZddlZGdddeZdS)) TransportNc@seZdZdZd%ddZd%ddZddZd d Zd d Zd dZ ddZ ddZ ddZ d&ddZ ddZddZddZddZdd Zd!d"Zd#d$ZdS)' UNITransportzBase class for WSNET transport.NcCs2t|d|_d|_||_d|_d|_d|_dS)Ni)rrF)r__init__write_buffer_sizeread_buffer_sizecomms_write_buffer_limits _protocol _isclosing)self connectionextrar/root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/asysocks/unicomm/common/transport.pyrs  zUNITransport.__init__cCstd|||j||S)z#Get optional transport information. Extrainfo)printrget_extra_info)r namedefaultrrrrs zUNITransport.get_extra_infocC|jS)z2Return True if the transport is closing or closed.)r r rrr is_closingzUNITransport.is_closingcCsd|_t|j}dS)zClose the transport. Buffered data will be flushed asynchronously. No more data will be received. After all buffered data is flushed, the protocol's connection_lost() method will (eventually) be called with None as its argument. TN)r asyncio create_taskrcloser xrrrrszUNITransport.closecCs ||j_dS)zSet a new protocol.Nrprotocol)r rrrr set_protocol% zUNITransport.set_protocolcCs|jjS)zReturn the current protocol.rrrrr get_protocol*szUNITransport.get_protocolcCs |jjS)z*Return True if the transport is receiving.)r read_resumeis_setrrrr is_reading.r!zUNITransport.is_readingcCst|j}dS)zPause the receiving end. No data will be passed to the protocol's data_received() method until resume_reading() is called. N)rrr pause_readingrrrrr&3szUNITransport.pause_readingcCs|jjdS)zrResume the receiving end. Data received will once again be passed to the protocol's data_received() method. N)rr#setrrrrresume_reading;szUNITransport.resume_readingcCs||f|_dS)aJSet the high- and low-water limits for write flow control. These two values control when to call the protocol's pause_writing() and resume_writing() methods. If specified, the low-water limit must be less than or equal to the high-water limit. Neither value can be negative. The defaults are implementation-specific. If only the high-water limit is given, the low-water limit defaults to an implementation-specific value less than or equal to the high-water limit. Setting high to zero forces low to zero as well, and causes pause_writing() to be called whenever the buffer becomes non-empty. Setting low to zero causes resume_writing() to be called only once the buffer is empty. Use of zero for either limit is generally sub-optimal as it reduces opportunities for doing I/O and computation concurrently. Nr)r highlowrrrset_write_buffer_limitsCsz$UNITransport.set_write_buffer_limitscCr)z,Return the current size of the write buffer.)rrrrrget_write_buffer_sizeWrz"UNITransport.get_write_buffer_sizecCr)zGet the high and low watermarks for write flow control. Return a tuple (low, high) where low and high are positive number of bytes.r)rrrrget_write_buffer_limits\sz$UNITransport.get_write_buffer_limitscCst|j|tdS)zWrite some data bytes to the transport. This does not block; it buffers the data and arranges for it to be sent out asynchronously. N)rrun_coroutine_threadsaferwriteget_event_loop)r datarrrr0cszUNITransport.writecCsd|}||dS)zWrite a list (or any iterable) of data bytes to the transport. The default implementation concatenates the arguments and calls write() on the result. N)joinr0)r list_of_datar2rrr writelinesks zUNITransport.writelinescCs|ddS)zClose the write end after flushing buffered data. (This is like typing ^D into a UNIX program reading from stdin.) Data may still be received. r3N)r0rrrr write_eoftszUNITransport.write_eofcCsdS)zAReturn True if this transport supports write_eof(), False if not.Trrrrr can_write_eof|szUNITransport.can_write_eofcCs |dS)zClose the transport immediately. Buffered data will be lost. No more data will be received. The protocol's connection_lost() method will (eventually) be called with None as its argument. N)rrrrraborts zUNITransport.abort)N)NN)__name__ __module__ __qualname____doc__rrrrr r"r%r&r(r,r-r.r0r6r7r8r9rrrrrs&      r)asyncio.transportsrrrrrrrs