← Back
Editing: test_sendmsg.cpython-38.pyc
U W[�b � @ sV d Z ddlZddlZddlZddlmZmZmZmZm Z ddl m Z ddl m Z mZmZm Z mZ zddl mZmZ W n ek r� dZY nX dZddlmZ dd lmZmZ dd lmZ dd l m Z dd l m Z m Z m!Z! dd l"m#Z# ddl$m%Z% ddl&m'Z' e%�(� �rddl m)Z) dZ*ndZ*z$ddl+m,Z,m-Z- ddl+m.Z.m/Z/ W n ek �r\ dZ0Y nX dZ0z ddl+m1Z1m2Z2 ddl+m3Z3 W n ek �r� dZ4Y nX dZ4G dd� de5�Z6dd� Z7G d d � d e8�Z9G d d � d e �Z:d d!� 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'�ZAG d,d-� d-e'�ZBG d.d/� d/e'�ZCdS )0z& Tests for L{twisted.python.sendmsg}. � N)�devnull�pipe�read�close�pathsep)�pack)� SOL_SOCKET�AF_INET�AF_INET6�socket�error)�AF_UNIX� socketpairz)Platform does not support AF_UNIX sockets)�reactor)�Deferred�inlineCallbacks)� ProcessDone)�ProcessProtocol)�_PY3� intToBytes� bytesEnviron)�FilePath)�platform)�TestCase)� MSG_DONTWAITz7MSG_DONTWAIT is only known to work as intended on Linux)�sendmsg�recvmsg)� SCM_RIGHTS�getSocketFamilyz!Platform doesn't support sendmsg.)�send1msg�recv1msg)� getsockfamz$Cannot import twisted.python.sendmsgc @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� _FDHolderzP A wrapper around a FD that will remember if it has been closed or not. c C s || _ d S �N��_fd)�self�fd� r( �B/usr/lib/python3/dist-packages/twisted/python/test/test_sendmsg.py�__init__@ s z_FDHolder.__init__c C s | j S )z/ Return the fileno of this FD. r$ �r& r( r( r) �filenoC s z_FDHolder.filenoc C s | j rt| j � d| _ dS )zH Close the FD. If it's already been closed, do nothing. N)r% r r+ r( r( r) r I s z_FDHolder.closec C s. | j r*tst}t�d| j f |� | �� dS )z> If C{self._fd} is unclosed, raise a warning. zFD %s was not closed!N)r% r �Warning�warnings�warnr )r& �ResourceWarningr( r( r) �__del__Q s �z_FDHolder.__del__c C s | S r# r( r+ r( r( r) � __enter__\ s z_FDHolder.__enter__c C s | � � d S r# )r )r& �exc_type� exc_value� tracebackr( r( r) �__exit___ s z_FDHolder.__exit__N) �__name__� __module__� __qualname__�__doc__r* r, r r1 r2 r6 r( r( r( r) r" < s r" c C s t � \} }t| �t|�fS )zI Create a pipe, and return the two FDs wrapped in L{_FDHolders}. )r r" )�r�wr( r( r) � _makePipec s r= c @ s e Zd ZdZdd� ZdS )�ExitedWithStderrz, A process exited with some stderr. c C s& d� dgt| j� �}tr"t|�}|S )zY Dump the errors in a pretty way in the event of a subprocess traceback. � � )�join�list�argsr �repr�r& �resultr( r( r) �__str__q s zExitedWithStderr.__str__N)r7 r8 r9 r: rG r( r( r( r) r> l s r> c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �StartStopProcessProtocola� An L{IProcessProtocol} with a Deferred for events where the subprocess starts and stops. @ivar started: A L{Deferred} which fires with this protocol's L{IProcessTransport} provider when it is connected to one. @ivar stopped: A L{Deferred} which fires with the process output or a failure if the process produces output on standard error. @ivar output: A C{str} used to accumulate standard output. @ivar errors: A C{str} used to accumulate standard error. c C s t � | _t � | _d| _d| _d S )Nr@ )r �started�stopped�output�errorsr+ r( r( r) r* � s z!StartStopProcessProtocol.__init__c C s | j �| j� d S r# )rI �callbackZ transportr+ r( r( r) �connectionMade� s z'StartStopProcessProtocol.connectionMadec C s | j |7 _ d S r# )rK �r& �datar( r( r) � outReceived� s z$StartStopProcessProtocol.outReceivedc C s | j |7 _ d S r# )rL rO r( r( r) � errReceived� s z$StartStopProcessProtocol.errReceivedc C s4 |� t�r| j�| j� n| j�t| j| j�� d S r# )Zcheckr rJ rM rK Zerrbackr> rL )r& �reasonr( r( r) � processEnded� s �z%StartStopProcessProtocol.processEndedN) r7 r8 r9 r: r* rN rQ rR rT r( r( r( r) rH | s rH c C s| t tj��� j}t� }t t�tj���� j|d< t� }t j |||t t �� | d ��� jt |�g|dddddd||id� |S ) z� Start a script that is a peer of this test as a subprocess. @param script: the module name of the script in this directory (no package prefix, no '.py') @type script: C{str} @rtype: L{StartStopProcessProtocol} s PYTHONPATHz.pyr r< � r; � )�envZchildFDs)r �sys� executableZ asBytesMode�pathr r rA rH r Z spawnProcess�__file__Zsiblingr )ZscriptZoutputFDZpyExerW �ssppr( r( r) �_spawn� s" � �� r] c s$ e Zd ZdZdZ� fdd�Z� ZS )�BadLista$ A list which cannot be iterated sometimes. This is a C{list} subclass to get past the type check in L{send1msg}, not as an example of how real programs might want to interact with L{send1msg} (or anything else). A custom C{list} subclass makes it easier to trigger certain error cases in the implementation. @ivar iterate: A flag which indicates whether an instance of L{BadList} will allow iteration over itself or not. If C{False}, an attempt to iterate over the instance will raise an exception. Tc s& | j rd| _ tt| ��� S td��dS )a Allow normal list iteration, or raise an exception. If C{self.iterate} is C{True}, it will be flipped to C{False} and then normal iteration will proceed. If C{self.iterate} is C{False}, L{RuntimeError} is raised instead. FzSomething bad happenedN)�iterate�superr^ �__iter__� RuntimeErrorr+ �� __class__r( r) ra � s zBadList.__iter__)r7 r8 r9 r: r_ ra � __classcell__r( r( rc r) r^ � s r^ c @ s e Zd ZdZdd� ZdS )� WorseListz� A list which at first gives the appearance of being iterable, but then raises an exception. See L{BadList} for a warning about not writing code like this. c C s G dd� dt �}|� S )zn Return an iterator which will raise an exception as soon as C{next} is called on it. c @ s e Zd Zdd� ZdS )z'WorseList.__iter__.<locals>.BadIteratorc S s t d��d S )NzThis is a really bad case.)rb r+ r( r( r) �next� s z,WorseList.__iter__.<locals>.BadIterator.nextN)r7 r8 r9 rg r( r( r( r) � BadIterator� s rh )�object)r& rh r( r( r) ra � s zWorseList.__iter__N)r7 r8 r9 r: ra r( r( r( r) rf � s rf c @ s� e Zd ZdZedk reZn edk r&eZdd� Zdd� Zdd� Z d d � Z d d � Z d d� Z dd� Z dd� Zdd� Zdd� Zdd� Zedk r�ee_dd� Zedd � �Zd d � ZdS ) �CModuleSendmsgTestszf Tests for sendmsg extension module and associated file-descriptor sending functionality. Nc C s t t�\| _| _dS �z0 Create a pair of UNIX sockets. N�r r �inputrK r+ r( r( r) �setUp� s zCModuleSendmsgTests.setUpc C s | j �� | j�� dS �z4 Close the sockets opened by setUp. N�rm r rK r+ r( r( r) �tearDown s z CModuleSendmsgTests.tearDownc C s� | � tt� | � ttd� | � ttdddg t� � | � ttt� ddg � | � ttdt� dg � | � ttddt� g � | � ttdddt� � dS )a� The argument types accepted by L{send1msg} are: 1. C{int} 2. read-only character buffer 3. C{int} 4. sequence The 3rd and 4th arguments are optional. If fewer than two arguments or more than four arguments are passed, or if any of the arguments passed are not compatible with these types, L{TypeError} is raised. rU � hello worldrV N)� assertRaises� TypeErrorr ri r+ r( r( r) �test_sendmsgBadArguments s �z,CModuleSendmsgTests.test_sendmsgBadArgumentsc C sH t � }|�d� d|_| �ttddd|� d|_| �ttddd|� dS )z� If iteration over the ancillary data list fails (at the point of the C{__iter__} call), the exception with which it fails is propagated to the caller of L{send1msg}. )rU rV rr FrU rr rV TN)r^ �appendr_ rs rb r )r& ZbadListr( r( r) �test_badAncillaryIter' s z)CModuleSendmsgTests.test_badAncillaryIterc C s t � }| �ttddd|� dS )z� If iteration over the ancillary data list fails (at the point of a C{next} call), the exception with which it fails is propagated to the caller of L{send1msg}. rU rr rV N)rf rs rb r )r& Z worseListr( r( r) �test_badAncillaryNext8 s �z)CModuleSendmsgTests.test_badAncillaryNextc C s� | � ttddddg� | � ttddddg� | � ttddddg� | � ttddddddt� fg� | � ttdddt� g�}| �dt|�� | � ttdddt� ddfg� | � ttddddt� dfg� | � ttdddddt� fg� d S ) a The ancillary data list contains three-tuples with element types of: 1. C{int} 2. C{int} 3. read-only character buffer If a tuple in the ancillary data list does not elements of these types, L{TypeError} is raised. rU rr rV r( )rU )rU rV ZgoodbyezFsend1msg argument 3 expected list of tuple, got list containing objectN)rs rt r ri � assertEqual�str�r& �excr( r( r) � test_sendmsgBadAncillaryItemC s^ � �� � � �z0CModuleSendmsgTests.test_sendmsgBadAncillaryItemc C sD t t��}|�� }W 5 Q R X | �tt|d�}| �|jd tj � dS )�� If the underlying C{sendmsg} call fails, L{send1msg} raises L{socket.error} with its errno set to the underlying errno value. � hello, worldr N� �openr r, rs r r ry rC �errno�EBADF�r& Zprober' r| r( r( r) �test_syscallErrorh s z%CModuleSendmsgTests.test_syscallErrorc C sJ t t��}|�� }W 5 Q R X | �tt|dddg�}| �|jd tj � dS )z� The behavior when the underlying C{sendmsg} call fails is the same whether L{send1msg} is passed ancillary data or not. r r )r r Z0123Nr� r� r( r( r) �#test_syscallErrorWithControlMessages s �z7CModuleSendmsgTests.test_syscallErrorWithControlMessagec C sH d}| � t|�t| j�� |d�� t| j�� d�}| � ||dg f� dS )zK L{recv1msg} will retrieve a message sent via L{send1msg}. � hello, world!r �r' N)ry �lenr rm r, r rK �r& �messagerF r( r( r) �test_roundtrip s �z"CModuleSendmsgTests.test_roundtripc C s: t | j�� ddg � t| j�� d�}| �|ddg f� dS )z� L{send1msg} treats an empty ancillary data list the same way it treats receiving no argument for the ancillary parameter at all. r� r r� N)r rm r, r rK ry rE r( r( r) � test_roundtripEmptyAncillary� s z0CModuleSendmsgTests.test_roundtripEmptyAncillaryc C st t d�D ]\}zt| j�� dt� W q tk rb } z"| �|jd tj � W Y � qpW 5 d}~X Y qX q| � d� dS )z� The C{flags} argument to L{send1msg} is passed on to the underlying C{sendmsg} call, to affect it in whatever way is defined by those flags. � A xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxr N�HFailed to fill up the send buffer, or maybe send1msg blocked for a while) �ranger rm r, r r ry rC r� �EAGAIN�fail�r& �i�er( r( r) � test_flags� s �z CModuleSendmsgTests.test_flagsc C s. | � tt| j�� ddd�}| �t|�d� dS )z� L{send1msg} will show a helpful exception message when given the wrong type of object for the 'ancillary' argument. r� r i� z*send1msg argument 3 expected list, got intN)rs rt r rm r, ry rz )r& r r( r( r) �test_wrongTypeAncillary� s � �z+CModuleSendmsgTests.test_wrongTypeAncillaryc c s� t d| j�� �}|jV t� \}}| �|j� | �|j� |�, t| j�� ddt t t d|�� �fg� W 5 Q R X |j V | � t|�� d�d� | � t|�� d�d� dS ) z� Calling L{sendsmsg} with SOL_SOCKET, SCM_RIGHTS, and a platform-endian packed file descriptor number should send that file descriptor to a different process, where it can be retrieved by using L{recv1msg}. ZcmodulepullpipeZblonkr r� � zTest fixture data: blonk. � N)r] rK r, rI r= � addCleanupr r rm r r r rJ ry r �r& r\ ZpipeOutZpipeInr( r( r) �test_sendSubProcessFD� s" ��z)CModuleSendmsgTests.test_sendSubProcessFDc C s^ t ttd| j�� �ft ttd| j�� �fg}zt| j�� dd|� W n tk rX Y nX dS )zf L{sendmsg} with two FDs in two separate ancillary entries does not segfault. r� s some datar N)r r r rm r, rK r r )r& � ancillaryr( r( r) �'test_sendmsgTwoAncillaryDoesNotSegfault� s �z;CModuleSendmsgTests.test_sendmsgTwoAncillaryDoesNotSegfault)r7 r8 r9 r: � nonUNIXSkip�skip�CModuleImportSkiprn rq ru rw rx r} r� r� r� r� r� � dontWaitSkipr� r r� r� r( r( r( r) rj � s, % rj c @ sJ e Zd ZdZedk reZdd� Zdd� Zdd� Zd d � Z e dk rFe e _dS ) �CModuleRecvmsgTestszA Tests for L{recv1msg} (primarily error handling cases). Nc C s� | � tt� | � ttddddt� � | � ttt� ddd� | � ttdt� dd� | � ttddt� d� | � ttdddt� � dS )a� The argument types accepted by L{recv1msg} are: 1. C{int} 2. C{int} 3. C{int} 4. C{int} The 2nd, 3rd, and 4th arguments are optional. If fewer than one argument or more than four arguments are passed, or if any of the arguments passed are not compatible with these types, L{TypeError} is raised. rU rV � � N)rs rt r ri r+ r( r( r) �test_badArguments� s z%CModuleRecvmsgTests.test_badArgumentsc C s | � ttdddd� dS )z� L{recv1msg} raises L{OverflowError} if passed a value for the C{cmsg_size} argument which exceeds C{SOCKLEN_MAX}. r i���N)rs � OverflowErrorr r+ r( r( r) �test_cmsgSpaceOverflow s z*CModuleRecvmsgTests.test_cmsgSpaceOverflowc C sB t t��}|�� }W 5 Q R X | �tt|�}| �|jd tj � dS )z� If the underlying C{recvmsg} call fails, L{recv1msg} raises L{socket.error} with its errno set to the underlying errno value. r N) r� r r, rs r r ry rC r� r� r� r( r( r) r� s z%CModuleRecvmsgTests.test_syscallErrorc C s8 t t�\}}| �tt|�� t�}| �|jd t j � dS )z� The C{flags} argument to L{recv1msg} is passed on to the underlying C{recvmsg} call, to affect it in whatever way is defined by those flags. r N) r r rs r r r, r ry rC r� r� )r& �reader�writerr| r( r( r) r� s �z CModuleRecvmsgTests.test_flags) r7 r8 r9 r: r� r� r� r� r� r� r� r( r( r( r) r� � s r� c @ sZ e Zd ZdZedk reZdd� Zdd� Zdd� Zd d � Z d d � Z d d� Z e dk rVe e _dS )�CModuleGetSocketFamilyTestszh Tests for L{getsockfam}, a helper which reveals the address family of an arbitrary socket. Nc C s t |�}| �|j� |�� S �z� Create a new socket using the given address family and return that socket's file descriptor. The socket will automatically be closed when the test is torn down. )r r� r r, �r& Z addressFamily�sr( r( r) �_socket/ s z#CModuleGetSocketFamilyTests._socketc C s0 | � tt� | � ttdd� | � ttt� � dS )z� L{getsockfam} accepts a single C{int} argument. If it is called in some other way, L{TypeError} is raised. rU rV N)rs rt r! ri r+ r( r( r) r� : s z-CModuleGetSocketFamilyTests.test_badArgumentsc C sB t t��}|�� }W 5 Q R X | �tt|�}| �tj|j d � dS )z� If the underlying C{getsockname} call fails, L{getsockfam} raises L{socket.error} with its errno set to the underlying errno value. r N) r� r r, rs r r! ry r� r� rC r� r( r( r) r� D s z-CModuleGetSocketFamilyTests.test_syscallErrorc C s | � tt| �t��� dS )z� When passed the file descriptor of a socket created with the C{AF_INET} address family, L{getsockfam} returns C{AF_INET}. N)ry r r! r� r+ r( r( r) � test_inetO s z%CModuleGetSocketFamilyTests.test_inetc C s | � tt| �t��� dS )z� When passed the file descriptor of a socket created with the C{AF_INET6} address family, L{getsockfam} returns C{AF_INET6}. N)ry r r! r� r+ r( r( r) � test_inet6W s z&CModuleGetSocketFamilyTests.test_inet6c C s | � tt| �t��� dS )z� When passed the file descriptor of a socket created with the C{AF_UNIX} address family, L{getsockfam} returns C{AF_UNIX}. N)ry r r! r� r+ r( r( r) � test_unix_ s z%CModuleGetSocketFamilyTests.test_unix) r7 r8 r9 r: r� r� r� r� r� r� r� r� r� r( r( r( r) r� ' s r� c @ sv e Zd ZdZedk reZdd� Zdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z edk rfee _edd� �ZdS )� SendmsgTestszB Tests for the Python2/3 compatible L{sendmsg} interface. Nc C s t t�\| _| _dS rk rl r+ r( r( r) rn q s zSendmsgTests.setUpc C s | j �� | j�� dS ro rp r+ r( r( r) rq x s zSendmsgTests.tearDownc C s4 | j �� | �tt| j d�}| �|jd tj� dS )r~ � hello, worldr N� rm r rs r r ry rC r� r� r{ r( r( r) r� � s z SendmsgTests.test_syscallErrorc C s: | j �� | �tt| j ddgd�}| �|jd tj� dS )z� The behavior when the underlying C{sendmsg} call fails is the same whether L{sendmsg} is passed ancillary data or not. r� )r r s 0123r Nr� r{ r( r( r) r� � s �z0SendmsgTests.test_syscallErrorWithControlMessagec C sT d}| � t|�t| j|�� t| j�}| � |jd� | � |jd� | � |jg � dS )zI L{recvmsg} will retrieve a message sent via L{sendmsg}. � hello, world!r N) ry r� r rm r rK rP �flagsr� r� r( r( r) r� � s � zSendmsgTests.test_roundtripc C s^ dd d }| j �d� t| j |�}| �|t|�k � t| jt|��}| �t|d �|� dS )zS L{sendmsg} returns the number of bytes which it was able to send. � xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxr� � Fr N)rm Z setblockingr Z assertTruer� r rK ry )r& r� ZsentZreceivedr( r( r) �test_shortsend� s zSendmsgTests.test_shortsendc C s0 t | jdg d� t| j�}| �|dg df� dS )z� L{sendmsg} treats an empty ancillary data list the same way it treats receiving no argument for the ancillary parameter at all. r� r N)r rm r rK ry rE r( r( r) r� � s z)SendmsgTests.test_roundtripEmptyAncillaryc C sr t d�D ]Z}zt| jdtd� W q tk r` } z"| �|jd tj� W Y � qnW 5 d}~X Y qX q| � d� dS )z� The C{flags} argument to L{sendmsg} is passed on to the underlying C{sendmsg} call, to affect it in whatever way is defined by those flags. r� r� )r� r Nr� ) r� r rm r r ry rC r� r� r� r� r( r( r) r� � s �zSendmsgTests.test_flagsc c s� t d| j�� �}|jV t� \}}| �|j� | �|j� |�& t| jdt t t d|�� �fg� W 5 Q R X |j V | � t|�� d�d� | � t|�� d�d� dS )z� Calling L{sendmsg} with SOL_SOCKET, SCM_RIGHTS, and a platform-endian packed file descriptor number should send that file descriptor to a different process, where it can be retrieved by using L{recv1msg}. Zpullpipes blonkr� r� s Test fixture data: blonk. r@ N)r] rK r, rI r= r� r r rm r r r rJ ry r r� r( r( r) r� � s ��z"SendmsgTests.test_sendSubProcessFD)r7 r8 r9 r: � importSkipr� rn rq r� r� r� r� r� r� r� r r� r( r( r( r) r� j s r� c @ sJ e Zd ZdZedk reZdd� Zdd� Zdd� Zd d � Z e dk rFe e _dS ) �GetSocketFamilyTestsz' Tests for L{getSocketFamily}. Nc C s t |�}| �|j� |S r� )r r� r r� r( r( r) r� � s z GetSocketFamilyTests._socketc C s | � tt| �t��� dS )z� When passed the file descriptor of a socket created with the C{AF_INET} address family, L{getSocketFamily} returns C{AF_INET}. N)ry r r r� r+ r( r( r) r� s z GetSocketFamilyTests.test_inetc C s | � tt| �t��� dS )z� When passed the file descriptor of a socket created with the C{AF_INET6} address family, L{getSocketFamily} returns C{AF_INET6}. N)ry r r r� r+ r( r( r) r� s z GetSocketFamilyTests.test_inet6c C s | � tt| �t��� dS )z� When passed the file descriptor of a socket created with the C{AF_UNIX} address family, L{getSocketFamily} returns C{AF_UNIX}. N)ry r r r� r+ r( r( r) r� s z GetSocketFamilyTests.test_unix) r7 r8 r9 r: r� r� r� r� r� r� r� r( r( r( r) r� � s r� )Dr: rX r� r. �osr r r r r Zstructr r r r r r r r � ImportErrorr� Ztwisted.internetr Ztwisted.internet.deferr r Ztwisted.internet.errorr Ztwisted.internet.protocolr Ztwisted.python.compatr r r Ztwisted.python.filepathr Ztwisted.python.runtimer Ztwisted.trial.unittestr ZisLinuxr r� Ztwisted.python.sendmsgr r r r r� r r r! r� ri r" r= � Exceptionr> rH r] rB r^ rf rj r� r� r� r� r( r( r( r) �<module> sb ' + qCC
Save File
Cancel