Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_unix.cpython-39.pyc
Ðазад
a k�h&� � @ s` d Z ddlmZ ddlmZmZmZmZmZ ddl m Z ddl m Z m Z mZm Z ddlmZ ddlmZ ddlmZmZ dd lmZmZmZ dd lmZ zdd l mZ W n e y� d ZY n0 e Zdd l m Z m Z ddl!m"Z"m#Z# ddl$m%Z% ddl&m'Z'm(Z(m)Z) ddl*m+Z+m,Z, ddl-m.Z.m/Z/m0Z0 ddl1m2Z2m3Z3m4Z4m5Z5 ddl6m7Z7m8Z8m9Z9 ddl:m;Z; ddl<m=Z=m>Z>m?Z?m@Z@mAZA ddlBmCZC ddlDmEZEmFZFmGZGmHZH ddlImJZJ ddlKmLZL ddlMmNZN dd lOmPZPmQZQmRZR dd lSmTZT dd lUmVZV eTd �ZWd ZXeTd �d u�rd!ZXG d"d#� d#�ZYd$d%� ZZG d&d'� d'e?�Z[G d(d)� d)e=�Z\e e2�G d*d+� d+e=��Z]G d,d-� d-eYeCe>�Z^G d.d/� d/eYeC�Z_G d0d1� d1�Z`G d2d3� d3�ZaG d4d5� d5�ZbG d6d7� d7eaebeCeG�ZcG d8d9� d9e`ebeCeG�ZdG d:d;� d;eHeC�Zeef� �ge^�h� � ef� �ge_�h� � ef� �gec�h� � ef� �ged�h� � ef� �gee�h� � G d<d=� d=eCe@�Zief� �gei�h� � d S )>z/ Tests for implementations of L{IReactorUNIX}. � )�md5)�close�fstat�stat�unlink�urandom)�pformat)�AF_INET� SOCK_STREAM� SOL_SOCKET�socket)�S_IMODE)�pack)�mkstemp�mktemp)�Optional�Sequence�Type)�skipIf)�AF_UNIXN)� Interface� implementer)�base� interfaces)� UNIXAddress)�Deferred�fail� gatherResults)�UNIXClientEndpoint�UNIXServerEndpoint)�CannotListenError�ConnectionClosed�FileDescriptorOverrun)�IFileDescriptorReceiver� IReactorFDSet�IReactorSocket� IReactorUNIX)� ClientFactory�DatagramProtocol� ServerFactory)� LoopingCall)�ConnectableProtocol�ConnectionTestsMixin�EndpointCreator�StreamClientTestsMixin�runProtocolsWithReactor)�ReactorBuilder)�MyClientFactory�MyServerFactory�StreamTransportTestsMixin�WriteSequenceTestsMixin)� nativeString)�Failure)�_coerceToFilesystemEncoding)� addObserver�err�removeObserver)� requireModule)�platformztwisted.python.sendmsg� z>sendmsg extension unavailable, extended UNIX features disabledc @ s e Zd ZdZdd� ZdS )�UNIXFamilyMixinzK Test-helper defining mixin for things related to AF_UNIX sockets. c C sB d}| � � }t||�|||d�}|�� | �tt|�j�|� dS )z} Assert that the mode of the created unix socket is set to the mode specified to the reactor method. i� )�modeN)� buildReactor�getattr� stopListening� assertEqualr r �st_mode)�self� methodName�path�factoryr? �reactorZunixPort� rJ ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/test_unix.py� _modeTestO s zUNIXFamilyMixin._modeTestN)�__name__� __module__� __qualname__�__doc__rL rJ rJ rJ rK r> J s r> c C s t td���� S )zI Return a new, unique abstract namespace path to be listened on. �d )r r � hexdigest)�caserJ rJ rK � _abstractPath[ s rT c @ s> e Zd ZU dZejfZeee e e d< dd� Z dd� Z dS )� UNIXCreatorz( Create UNIX socket end points. �requiredInterfacesc C s t ddd�}t||�S )z3 Construct a UNIX server endpoint. �.sock�.��suffix�dir)r r )rE rI rG rJ rJ rK �serveri s zUNIXCreator.serverc C s t ||j�S )z3 Construct a UNIX client endpoint. )r �name)rE rI Z serverAddressrJ rJ rK �clientq s zUNIXCreator.clientN)rM rN rO rP r r& rV r r r r �__annotations__r\ r^ rJ rJ rJ rK rU b s rU c @ s, e Zd ZdZdZdd� Zdd� Zdd� ZdS ) �SendFileDescriptorz� L{SendFileDescriptorAndBytes} sends a file descriptor and optionally some normal bytes and then closes its connection. @ivar reason: The reason the connection was lost, after C{connectionLost} is called. Nc C s || _ || _dS )z� @param fd: A C{int} giving a file descriptor to send over the connection. @param data: A C{str} giving data to send over the connection, or L{None} if no data is to be sent. N)�fd�data)rE ra rb rJ rJ rK �__init__� s zSendFileDescriptor.__init__c C s0 | j �| j� | jr"| j �| j� | j �� dS )zn Send C{self.fd} and, if it is not L{None}, C{self.data}. Then close the connection. N)� transport�sendFileDescriptorra rb �write�loseConnection�rE rJ rJ rK �connectionMade� s z!SendFileDescriptor.connectionMadec C s t �| |� || _d S �N)r+ �connectionLost�reason�rE rl rJ rJ rK rk � s z!SendFileDescriptor.connectionLost)rM rN rO rP rl rc ri rk rJ rJ rJ rK r` x s r` c @ s8 e Zd ZdZdZdZdd� Zdd� Zdd� Zd d � Z dS ) �ReceiveFileDescriptora} L{ReceiveFileDescriptor} provides an API for waiting for file descriptors to be received. @ivar reason: The reason the connection was lost, after C{connectionLost} is called. @ivar waiting: A L{Deferred} which fires with a file descriptor once one is received, or with a failure if the connection is lost with no descriptor arriving. Nc C s& | j du rt� | _| jS t| j �S dS )z� Return a L{Deferred} which will fire with the next file descriptor received, or with a failure if the connection is or has already been lost. N)rl r �waitingr rh rJ rJ rK �waitForDescriptor� s z'ReceiveFileDescriptor.waitForDescriptorc C s | j �|� d| _ dS )z� Fire the waiting Deferred, initialized by C{waitForDescriptor}, with the file descriptor just received. N)ro �callback)rE � descriptorrJ rJ rK �fileDescriptorReceived� s z,ReceiveFileDescriptor.fileDescriptorReceivedc C s0 | j dur,| j �ttd|�d���� d| _ dS )a_ Fail the waiting Deferred, if it has not already been fired by C{fileDescriptorReceived}. The bytes sent along with a file descriptor are guaranteed to be delivered to the protocol's C{dataReceived} method only after the file descriptor has been delivered to the protocol's C{fileDescriptorReceived}. NzReceived bytes (z) before descriptor.)ro �errbackr6 � Exception�rE rb rJ rJ rK � dataReceived� s �z"ReceiveFileDescriptor.dataReceivedc C s2 t �| |� | jdur(| j�|� d| _|| _dS )zj Fail the waiting Deferred, initialized by C{waitForDescriptor}, if there is one. N)r+ rk ro rt rl rm rJ rJ rK rk � s z$ReceiveFileDescriptor.connectionLost) rM rN rO rP rl ro rp rs rw rk rJ rJ rJ rK rn � s rn c @ s e Zd ZdZefZe� Zdd� Ze e � � d�dd� �Z dd� Z e e � � d�d d � �Zd d � Ze e e�d d� �Ze e e�dd� �Ze e e�dd� �Zdd� Ze e e�dd� �Ze e �� d�e e e�dd� ��Ze e e�dd� �Ze e e�d d � �Ze e e�d d � �Zd S )!�UNIXTestsBuilderz= Builder defining tests relating to L{IReactorUNIX}. c C s | � d| �� t� � dS )zs The UNIX socket created by L{IReactorUNIX.listenUNIX} is created with the mode specified. � listenUNIXN)rL r r) rh rJ rJ rK � test_mode� s zUNIXTestsBuilder.test_mode�8Abstract namespace UNIX sockets only supported on Linux.c C s> t | �}| �� }|�d| t� �}| �|�� td| �� dS )z� On Linux, a UNIX socket path may begin with C{' '} to indicate a socket in the abstract namespace. L{IReactorUNIX.listenUNIX} accepts such a path. � N)rT r@ ry r) rC �getHostr �rE rG rI �portrJ rJ rK �#test_listenOnLinuxAbstractNamespace� s z4UNIXTestsBuilder.test_listenOnLinuxAbstractNamespacec C s\ dd� }| � tjd|� | �� }| �t�� |�dt� � W d � n1 sN0 Y dS )z� L{IReactorUNIX.listenUNIX} raises L{CannotListenError} if the underlying port's createInternetSocket raises a socket error. c S s t d��d S )Nz FakeBasePort forced socket.error)�OSErrorrh rJ rJ rK �raiseSocketError s z=UNIXTestsBuilder.test_listenFailure.<locals>.raiseSocketErrorZcreateInternetSocketznot-usedN)�patchr ZBasePortr@ Z assertRaisesr ry r) )rE r� rI rJ rJ rK �test_listenFailure� s z#UNIXTestsBuilder.test_listenFailurec C s> t | �}| �� }|�d| t� �}| �|�� td| �� dS )zc L{IReactorUNIX.connectUNIX} also accepts a Linux abstract namespace path. r| N)rT r@ � connectUNIXr' rC ZgetDestinationr )rE rG rI Z connectorrJ rJ rK �$test_connectToLinuxAbstractNamespace s z5UNIXTestsBuilder.test_connectToLinuxAbstractNamespacec C s` G dd� dt �}|� }|� }t| ||| j� | �|jd |jd � | �|jd |jd � dS )z� A client's transport's C{getHost} and C{getPeer} return L{UNIXAddress} instances which have the filesystem path of the host and peer ends of the connection. c @ s e Zd Zdd� ZdS )z4UNIXTestsBuilder.test_addresses.<locals>.SaveAddressc S s" t |�� |�� d�| _|�� d S )N)�host�peer)�dictr} �getPeer� addressesrg )rE rd rJ rJ rK �makeConnection s �zCUNIXTestsBuilder.test_addresses.<locals>.SaveAddress.makeConnectionN)rM rN rO r� rJ rJ rJ rK � SaveAddress s r� r� r� N)r+ r/ � endpointsrC r� )rE r� r\ r^ rJ rJ rK �test_addresses s z UNIXTestsBuilder.test_addressesc s� ddl m� t � ���d� t��� d��t� }|�� }� ��fdd�}|�|� |�t d� |� �fdd �� t ��|�j � d S ) z� L{IUNIXTransport.sendFileDescriptor} accepts an integer file descriptor and sends a copy of it to the process reading from the connection. r )�fromfd)r= r � junkc s@ � | t t�}t| � ����� |�� � ����� |�� � d S rj )r r r rC � getsocknameZassertNotEqual�fileno)rr �received)r� �srE rJ rK �checkDescriptor= s zAUNIXTestsBuilder.test_sendFileDescriptor.<locals>.checkDescriptorz-Sending file descriptor encountered a problemc s � j �� S rj �rd rg �Zignored�r\ rJ rK �<lambda>M � z:UNIXTestsBuilder.test_sendFileDescriptor.<locals>.<lambda>N) r r� �bindr` r� rn rp � addCallback� addErrbackr9 �addBothr/ r� )rE r^ �dr� rJ )r� r� rE r\ rK �test_sendFileDescriptor. s z(UNIXTestsBuilder.test_sendFileDescriptorc C sT G dd� dt �}G dd� dt �}|� }|� }||_t| ||| j� | �|jd� dS )z� If a L{IUNIXTransport.sendFileDescriptor} call fills up the send buffer, any registered producer is paused. c @ s e Zd Zdd� ZdS )zSUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.DoesNotReadc S s | j �� d S rj )rd �pauseProducingrh rJ rJ rK ri Y s zbUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.DoesNotRead.connectionMadeN�rM rN rO ri rJ rJ rJ rK � DoesNotReadX s r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) z`UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptorsFc sP t � � _ � j�� d� � fdd�}t|�� _� jj� j_� j�d��t d� d S )NTc s" � j �� j�� � � j �d� d S )N� x)rd re r r� rf rJ rh rJ rK �senderc s zUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptors.connectionMade.<locals>.senderr zSend loop failure) r rd ZregisterProducerr* �taskrI �clock�startr� r9 )rE r� rJ rh rK ri _ s zoUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptors.connectionMadec S s | � � d S rj �� _disconnectrh rJ rJ rK � stopProducingk s znUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptors.stopProducingc S s | � � d S rj r� rh rJ rJ rK �resumeProducingn s zpUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptors.resumeProducingc S s d| _ | j�� | �� d S )NT)�pausedrd ZunregisterProducerr� rh rJ rJ rK r� q s zoUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptors.pauseProducingc S s$ | j �� | j�� | jj�� d S rj )r� �stoprd ZabortConnection�otherrh rJ rJ rK r� v s zlUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing.<locals>.SendsManyFileDescriptors._disconnectN) rM rN rO r� ri r� r� r� r� rJ rJ rJ rK �SendsManyFileDescriptors\ s r� z*sendFileDescriptor producer was not pausedN)r+ r� r/ r� � assertTruer� )rE r� r� r\ r^ rJ rJ rK �-test_sendFileDescriptorTriggersPauseProducingQ s z>UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducingc s� t � }t|�� d�� t� }g }|�� }|�|j� |�� fdd�� t| � || j� | � |d t � |d � t � | � � j jt� dS )ag If L{IUNIXTransport.sendFileDescriptor} is used to queue a greater number of file descriptors than the number of bytes sent using L{ITransport.write}, the connection is closed and the protocol connected to the transport has its C{connectionLost} method called with a failure wrapping L{FileDescriptorOverrun}. Nc s � j �� S rj r� r� r� rJ rK r� � r� z=UNIXTestsBuilder.test_fileDescriptorOverrun.<locals>.<lambda>r )r r` r� rn rp r� �appendr/ r� �assertIsInstancer6 Ztrapr! rl �valuer" )rE �cargor^ �resultr� rJ r� rK �test_fileDescriptorOverrun� s z+UNIXTestsBuilder.test_fileDescriptorOverrunc s> ddl m} ddlm} ddlm} dd� � tt�G � fdd�dt��}G d d � d |�}|t t �\}}| � |j � | � |j � |� } ||| �} t � \} } t � \} }| � t| � | � t|� d }| | g}||�\}}||||� | �� | �t| j�|� | �t|��t| j��� | j�r:� fd d �|D �}| �|| j� dS )a� Drive _SendmsgMixin via sendmsg socket calls to check that L{IFileDescriptorReceiver.fileDescriptorReceived} is called once for each file descriptor received in the ancillary messages. @param ancillaryPacker: A callable that will be given a list of two file descriptors and should return a two-tuple where: The first item is an iterable of zero or more (cmsg_level, cmsg_type, cmsg_data) tuples in the same order as the given list for actual sending via sendmsg; the second item is an integer indicating the expected number of FDs to be received. r �� socketpair)� _SendmsgMixin��sendmsgc S s t | �}|j|jfS rj )r �st_dev�st_ino)ra �fsrJ rJ rK �deviceInodeTuple� s zTUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.deviceInodeTuplec s e Zd Zdd� Z� fdd�ZdS )zPUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeProtocolc S s g | _ g | _d S rj )�fds�deviceInodesReceivedrh rJ rJ rK rc � s zYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeProtocol.__init__c s( | j �|� | j�� |�� t|� d S rj )r� r� r� r )rE ra �r� rJ rK rs � s zgUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeProtocol.fileDescriptorReceivedN)rM rN rO rc rs rJ r� rJ rK � FakeProtocol� s r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) zPUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeReceiver� c S s || _ || _d S rj )r �protocol)rE �skt�protorJ rJ rK rc � s zYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeReceiver.__init__c S s d S rj rJ rv rJ rJ rK � _dataReceived� s z^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeReceiver._dataReceivedc S s d S rj rJ rh rJ rJ rK r} � s zXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeReceiver.getHostc S s d S rj rJ rh rJ rJ rK r� � s zXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeReceiver.getPeerc S s d S rj rJ )rE �orJ rJ rK � _getLogPrefix� s z^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.FakeReceiver._getLogPrefixN) rM rN rO Z bufferSizerc r� r} r� r� rJ rJ rJ rK � FakeReceiver� s r� s some data needs to be sentc s g | ] }� |��qS rJ rJ ��.0ra r� rJ rK � <listcomp>� r� zNUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver.<locals>.<listcomp>N)r r� Ztwisted.internet.unixr� �twisted.python.sendmsgr� r r# r+ r r � addCleanupr r r ZdoReadrC �lenr� Z assertFalse�set� intersectionr� )rE �ancillaryPackerr� r� r� r� r� Z sendSocketZ recvSocketr� ZreceiverZ fileOneFDZ fileOneNameZ fileTwoFDZ fileTwoNameZ dataToSend� fdsToSend� ancillary� expectedCountZdeviceInodesSentrJ r� rK �)_sendmsgMixinFileDescriptorReceivedDriver� s4 z:UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriverc s& ddl m� � fdd�}| �|� dS )z� _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: single CMSG with two FDs. r �� SCM_RIGHTSc s$ t � tdg| �R � fg}d}||fS )N�ii� �r r �r� r� r� r� rJ rK r� s z[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSG.<locals>.ancillaryPackerN�r� r� r� �rE r� rJ r� rK �1test_multiFileDescriptorReceivedPerRecvmsgOneCMSG� s zBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSGz=Multi control message ancillary sendmsg not supported on Mac.c s& ddl m� � fdd�}| �|� dS )z� _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: two CMSGs with one FD each. r r� c s � fdd�| D �}d}||fS )Nc s g | ]}t � td |�f�qS )�ir� r� r� rJ rK r� r� zpUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs.<locals>.ancillaryPacker.<locals>.<listcomp>r� rJ r� r� rJ rK r� s z\UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs.<locals>.ancillaryPackerNr� r� rJ r� rK �2test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs s zCUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGsc s~ ddl m� dd� }�fdd�}g }t|j� | �t|j� | ��d|� | �|� d� t� fd d �|D ��}| � |d � d S ) z� _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: unsupported CMSGs. r r� c S s g }d}||fS )Nr rJ r� rJ rJ rK r� 0 s z[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG.<locals>.ancillaryPackerc s d}dg}d}� � |||�S )Ns some data)NNr� r )ZReceivedMessage)r� �args�kwargsrb r� �flagsr� rJ rK � fakeRecvmsgUnsupportedAncillary5 s zkUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG.<locals>.fakeRecvmsgUnsupportedAncillary�recvmsgz#received unsupported ancillary datac 3 s | ]}� |d v V qdS )�formatNrJ )r� �e)�expectedMessagerJ rK � <genexpr>D r� zUUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG.<locals>.<genexpr>z+Expected message not found in logged eventsN) Ztwisted.pythonr� r8 r� r� r: r� r� �anyr� )rE r� r� �events�foundrJ )r� r� rK �1test_multiFileDescriptorReceivedPerRecvmsgBadCMSG! s zBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSGc C s� ddl m} |� \}}g }t|j� | �t|j� G dd� dt�}||�� d�}t� }t | ||| j � |� � |� d� | � d|�d�� d }d } t|j|j| |d �} |D ],} | �� D ]\} } | | �| �kr� q�q� q�q�| �d | t|�f � d S )z� If associated with a protocol which does not provide L{IFileDescriptorReceiver}, file descriptors received by the L{IUNIXTransport} implementation are closed and a warning is emitted. r r� c @ s e Zd Zdd� ZdS )zRUNIXTestsBuilder.test_avoidLeakingFileDescriptors.<locals>.RecordEndpointAddressesc S s& | j �� | _| j �� | _t�| � d S rj )rd r} � hostAddressr� � peerAddressr` ri rh rJ rJ rK ri \ s zaUNIXTestsBuilder.test_avoidLeakingFileDescriptors.<locals>.RecordEndpointAddresses.connectionMadeNr� rJ rJ rJ rK �RecordEndpointAddresses[ s r� r� Fr� r� z�%(protocolName)s (on %(hostAddress)r) does not provide IFileDescriptorReceiver; closing file descriptor received (from %(peerAddress)r).r+ )r� r� Z protocolNamer� z3Expected event (%s) not found in logged events (%s)N)r r� r8 r� r� r: r` r� r+ r/ r� r � setblockingrC �recvr� r� r� �items�getr r )rE r� Z probeClientZ probeServerr� r� r\ r^ r� ZclsNameZ expectedEventZlogEvent�k�vrJ rJ rK � test_avoidLeakingFileDescriptorsG sF ������z1UNIXTestsBuilder.test_avoidLeakingFileDescriptorsc sv t t�G � fdd�dt��}t� }t|�� d�}|� }t� ||� j� � �t |j d � � �dt |j dd� �� dS )z� L{IUNIXTransport.sendFileDescriptor} sends file descriptors before L{ITransport.write} sends normal bytes. c s( e Zd Zdd� Z� fdd�Zdd� ZdS )zJUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes.<locals>.RecordEventsc S s t �| � g | _d S rj )r+ ri r� rh rJ rJ rK ri � s zYUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes.<locals>.RecordEvents.connectionMadec s � � t|� | j�t|�� d S rj )r� r r� r� �type)Z innerSelfrr rh rJ rK rs � s zaUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes.<locals>.RecordEvents.fileDescriptorReceivedc S s | j �|� d S rj )r� �extendrv rJ rJ rK rw � s zWUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes.<locals>.RecordEvents.dataReceivedN)rM rN rO ri rs rw rJ rh rJ rK � RecordEvents� s r r� r � N) r r# r+ r r` r� r/ r� rC �intr� �bytes)rE r r� r\ r^ rJ rh rK �#test_descriptorDeliveredBeforeBytes� s z4UNIXTestsBuilder.test_descriptorDeliveredBeforeBytesN) rM rN rO rP r& rV rU r� rz r r< �isLinuxr� r� r� r� r� �sendmsgSkipReasonr� r� r� r� r� ZisMacOSXr� r� r� r rJ rJ rJ rK rx � sJ � � " 0 c � % L rx c @ s8 e Zd ZdZejfZdd� Zee � � d�dd� �Z dS )�UNIXDatagramTestsBuilderzE Builder defining tests relating to L{IReactorUNIXDatagram}. c C s | � d| �� t� � dS )z� The UNIX socket created by L{IReactorUNIXDatagram.listenUNIXDatagram} is created with the mode specified. �listenUNIXDatagramN)rL r r( rh rJ rJ rK �test_listenMode� s z(UNIXDatagramTestsBuilder.test_listenModer{ c C s> t | �}| �� }|�d| t� �}| �|�� td| �� dS )z� On Linux, a UNIX socket path may begin with C{' '} to indicate a socket in the abstract namespace. L{IReactorUNIX.listenUNIXDatagram} accepts such a path. r| N)rT r@ r r( rC r} r r~ rJ rJ rK r� � s z<UNIXDatagramTestsBuilder.test_listenOnLinuxAbstractNamespaceN) rM rN rO rP r ZIReactorUNIXDatagramrV r r r< r r� rJ rJ rJ rK r � s �r c @ s> e Zd ZU dZeefZeee e e d< dd� Z dd� Z dS )�SocketUNIXMixinzb Mixin which uses L{IReactorSocket.adoptStreamPort} to hand out listening UNIX ports. rV c C s` t t�}tddd�}|�|� |�d� |�d� z |�|�� |j|�W |� � S |� � 0 dS )zj Get a UNIX port from a reactor, wrapping an already-initialized file descriptor. rW rX rY � FN) r r r r� �listenr� ZadoptStreamPortr� �familyr )rE rI rH ZportSockrG rJ rJ rK �getListeningPort� s �z SocketUNIXMixin.getListeningPortc C s |� |j|�S �aZ Connect to a listening UNIX socket. @param reactor: The reactor under test. @type reactor: L{IReactorUNIX} @param address: The listening's address. @type address: L{UNIXAddress} @param factory: The client factory. @type factory: L{ClientFactory} @return: The connector �r� r] �rE rI �addressrH rJ rJ rK �connectToListener� s z!SocketUNIXMixin.connectToListenerN)rM rN rO rP r& r% rV r r r r r_ r r rJ rJ rJ rK r � s �r c @ s e Zd ZdZdd� Zdd� ZdS )�ListenUNIXMixinzZ Mixin which uses L{IReactorTCP.listenUNIX} to hand out listening UNIX ports. c C s t ddd�}|�||�S )z0 Get a UNIX port from a reactor rW rX rY )r ry )rE rI rH rG rJ rJ rK r s z ListenUNIXMixin.getListeningPortc C s |� |j|�S r r r rJ rJ rK r s z!ListenUNIXMixin.connectToListenerN)rM rN rO rP r r rJ rJ rJ rK r s r c @ s8 e Zd ZU efZeeee e d< dd� Z dd� Z dS )�UNIXPortTestsMixinrV c C s |� dt |�� j���S )zZ Get the message expected to be logged when a UNIX port starts listening. z starting on �r5 r} r] )rE r rH rJ rJ rK �#getExpectedStartListeningLogMessage# s z6UNIXPortTestsMixin.getExpectedStartListeningLogMessagec C s dt |�� j�� d�S )zJ Get the expected connection lost message for a UNIX port z (UNIX Port z Closed)r )rE r rJ rJ rK � getExpectedConnectionLostLogMsg) s z2UNIXPortTestsMixin.getExpectedConnectionLostLogMsgN) rM rN rO r& rV r r r r r_ r r rJ rJ rJ rK r s r c @ s e Zd ZdZdS )�UNIXPortTestsBuilderz. Tests for L{IReactorUNIX.listenUnix} N�rM rN rO rP rJ rJ rJ rK r 0 s r c @ s e Zd ZdZdS )�UNIXFDPortTestsBuilderz3 Tests for L{IReactorUNIX.adoptStreamPort} Nr rJ rJ rJ rK r ; s r c @ s. e Zd ZeeefZdd� Zdd� Zdd� Z dS )�%UNIXAdoptStreamConnectionTestsBuilderc C s~ | � � }ddlm} G dd� dt�}|tt�\}}|�d� | �|j� | �|j� |� � }|� }|� |t|�}| � |� dS )z� {IReactorSocket.adoptStreamConnection} returns None if the given factory's buildProtocol returns None. r r� c @ s e Zd Zdd� ZdS )zXUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone.<locals>.NoneFactoryc S s d S rj rJ )rE r rJ rJ rK � buildProtocol\ s zfUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone.<locals>.NoneFactory.buildProtocolN)rM rN rO r rJ rJ rJ rK � NoneFactory[ s r FN) r@ r r� r) r r r� r� r r� �adoptStreamConnectionZ assertIsNone) rE rI r� r �s1�s2Zs1FDrH r� rJ rJ rK � test_buildProtocolReturnsNoneM s zCUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNonec s< � fdd�}� � � }� j|ddd�}|�|� � �|� dS )z> Helper method to test UNIX server addresses. c s� | \}}}zpt d|�� j�}� �d|jj|f t|j�� � �d|jj|f |jj� |jj d }� � |t � W |j� � n |j� � 0 d S )Nr= z <AccumulatingProtocol #%s on %s>zAccumulatingProtocol,%s,%sr ) r7 r} r] rC rd Z sessionno�strZlogstrrH Z peerAddressesr� r rg )� protocolsr^ r\ r ZportPathr� rh rJ rK � connectedn s$ �� �� zOUNIXAdoptStreamConnectionTestsBuilder.test_ServerAddressUNIX.<locals>.connectedN)� interface� addressFamily)r@ �getConnectedClientAndServerr� Z runReactor)rE r% rI r� rJ rh rK �test_ServerAddressUNIXi s � z<UNIXAdoptStreamConnectionTestsBuilder.test_ServerAddressUNIXc s� t � }t� |_t � �t� �_t� �_t� }t� |_t� |_tddd�}��||����fdd�}|j�|� t|j�jg�}�fdd�} |� | � t� � � � | � t|j�jg�} � �fdd �} | �| � �� �� � j |� � S ) a0 Return a L{Deferred} firing with a L{MyClientFactory} and L{MyServerFactory} connected pair, and the listening C{Port}. The particularity is that the server protocol has been obtained after doing a C{adoptStreamConnection} against the original server connection. rW rX rY c s0 � � | j� � �| j� � �| j�� t�� d S rj )Z removeReaderrd Z removeWriterr r� r )r� )rI r\ rJ rK �firstServerConnected� s z_UNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer.<locals>.firstServerConnectedc s � j r� �� | S rj )�runningr� )r� )rI rJ rK r� � s zOUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer.<locals>.stopc s | \}}� � ||�f� d S rj )rq )r$ r^ r\ )�deferredr rJ rK r� � s zPUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer.<locals>.start)r2 r ZprotocolConnectionMadeZprotocolConnectionLostr1 r ry r� r r� r� r� r} r] ) rE rI r& r' Z firstServerr^ rG r* Z lostDeferredr� Z startDeferredr� rJ )r, r rI r\ rK r( � s4 � � zAUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServerN) rM rN rO r$ r% r& rV r" r) r( rJ rJ rJ rK r F s � "r c @ s6 e Zd ZdZefZdZedd� �Zdd� Z dd� Z dS ) �UnixClientTestsBuilderz7 Define tests for L{IReactorUNIX.connectUNIX}. Nc C s | j du rt| �| _ | j S )z� Return a path usable by C{connectUNIX} and C{listenUNIX}. @return: A path instance, built with C{_abstractPath}. N)�_pathrT rh rJ rJ rK rG � s zUnixClientTestsBuilder.pathc C s |� | j|�S )z� Start an UNIX server with the given C{factory}. @param reactor: The reactor to create the UNIX port in. @param factory: The server factory. @return: A UNIX port instance. )ry rG �rE rI rH rJ rJ rK r � s z UnixClientTestsBuilder.listenc C s |� | j|�S )z� Start an UNIX client with the given C{factory}. @param reactor: The reactor to create the connection in. @param factory: The client factory. @return: A UNIX connector instance. )r� rG r/ rJ rJ rK �connect� s z UnixClientTestsBuilder.connect) rM rN rO rP r& rV r. �propertyrG r r0 rJ rJ rJ rK r- � s r- )jrP �hashlibr �osr r r r r �pprintr r r r r r �structr �tempfiler r �typingr r r Zunittestr r Z_AF_UNIX� ImportErrorZzope.interfacer r Ztwisted.internetr r Ztwisted.internet.addressr Ztwisted.internet.deferr r r Ztwisted.internet.endpointsr r Ztwisted.internet.errorr r! r" Ztwisted.internet.interfacesr# r$ r% r& Ztwisted.internet.protocolr' r( r) Ztwisted.internet.taskr* Z&twisted.internet.test.connectionmixinsr+ r, r- r. r/ Z#twisted.internet.test.reactormixinsr0 Z twisted.internet.test.test_tcpr1 r2 r3 r4 Ztwisted.python.compatr5 Ztwisted.python.failurer6 Ztwisted.python.filepathr7 Ztwisted.python.logr8 r9 r: Ztwisted.python.reflectr; Ztwisted.python.runtimer< r� r r> rT rU r` rn rx r r r r r r r �globals�updateZmakeTestCaseClassesr- rJ rJ rJ rK �<module> s� �%> Y!- � � ~-
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка