| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python2.7/dist-packages/twisted/internet/test/ |
Upload File : |
ó
™”°Nc @ s{ d Z d d l Z d d l m Z d d l m Z d d l m Z m Z m Z m Z m
Z
m Z d d l m Z d d l
m Z d d l m Z y\ d d l m Z m Z m Z d d
l m Z m Z m Z d d l m Z d d l m Z Wn e k
rd
Z n Xy e e e ƒ j ƒ Wn e
k
r>Z! e" e! ƒ Z# n Xd Z# d e j% f d „ ƒ YZ& d e j% f d „ ƒ YZ' d S( s,
Tests for L{twisted.internet.iocpreactor}.
iÿÿÿÿN( t array( t pack( t AF_INET6t AF_INETt SOCK_STREAMt
SOL_SOCKETt errort socket( t verifyClass( t unittest( t msg( t iocpsupportt tcpt udp( t IOCPReactort EVENTS_PER_LOOPt
KEY_NORMAL( t IReadWriteHandle( t SO_UPDATE_ACCEPT_CONTEXTs% This test only applies to IOCPReactort SupportTestsc B sA e Z d Z d „ Z d „ Z d „ Z e d k r? e e _ n RS( sn
Tests for L{twisted.internet.iocpreactor.iocpsupport}, low-level reactor
implementation helpers.
c C s” t d | f ƒ t | t ƒ } | j | j ƒ | j d ƒ | j d ƒ t | t ƒ } | j | j ƒ | j t ƒ y! | j | | j
ƒ d f ƒ Wn5 t k
rÎ \ } } | j | t
j t
j f ƒ n Xt | t ƒ } | j | j ƒ t d d d ƒ } | j d t j | j ƒ | j ƒ | d
ƒ ƒ | j t t t d | j ƒ ƒ ƒ | j | | j ƒ d | j
ƒ d f t j | j ƒ | ƒ ƒ d
S( s
Create a C{SOCK_STREAM} connection to localhost using a socket with an
address family of C{family} and assert that the result of
L{iocpsupport.get_accept_addrs} is consistent with the result of
C{socket.getsockname} and C{socket.getpeername}.
s family = %rt i i t ct i t Pi N( R i ( R
R R t
addCleanupt closet bindt listent setblockingt Falset connectt getsocknameR t assertInt errnot EINPROGRESSt EWOULDBLOCKR t assertEqualt _iocpt acceptt filenot Nonet
setsockoptR R R t getpeernamet get_accept_addrs( t selft familyt localhostt portt clientt errnumt messaget servert buff( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt _acceptAddressTest& s,
! ( c C s | j t d ƒ d S( s
L{iocpsupport.get_accept_addrs} returns a three-tuple of address
information about the socket associated with the file descriptor passed
to it. For a connection using IPv4:
- the first element is C{AF_INET}
- the second element is a two-tuple of a dotted decimal notation IPv4
address and a port number giving the peer address of the connection
- the third element is the same type giving the host address of the
connection
s 127.0.0.1N( R5 R ( R, ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt test_ipv4AcceptAddressF s c C s | j t d ƒ d S( s‰
Like L{test_ipv4AcceptAddress}, but for IPv6 connections. In this case:
- the first element is C{AF_INET6}
- the second element is a two-tuple of a hexadecimal IPv6 address
literal and a port number giving the peer address of the connection
- the third element is the same type giving the host address of the
connection
s ::1N( R5 R ( R, ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt test_ipv6AcceptAddressU s
N( t __name__t
__module__t __doc__R5 R6 R7 t ipv6SkipR( t skip( ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyR ! s t IOCPReactorTestCasec B s# e Z d „ Z d „ Z d „ Z RS( c C s- t ƒ } | j ƒ | j | j d ƒ ƒ d S( sd
Test reactor behavior (doIteration) when there are no pending time
events.
N( R t wakeUpt failIft doIterationR( ( R, t ir( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt test_noPendingTimerEventsf s
c C s$ t t t j ƒ t t t j ƒ d S( sY
Verify that IOCP socket-representing classes implement IReadWriteHandle
N( R R R t
ConnectionR
t Port( R, ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt test_reactorInterfacesp s c C s³ d d d „ ƒ Y} t ƒ } | ƒ } t j | j | ƒ } x. t t d ƒ D] } | j j d t | ƒ qK W| j d ƒ | j | j t ƒ | j d ƒ | j | j t d ƒ d S( s†
Verify that we don't lose an event when more than EVENTS_PER_LOOP
events occur in the same reactor iteration
t FakeFDc B s e Z d Z d „ Z d „ Z RS( i c S s d S( NRF ( ( R, ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt logPrefix s c S s | j d 7_ d S( Ni ( t counter( R, t rct bytest evt( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt cb s ( R8 R9 RH RG RL ( ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyRF } s i i N( (
R R% t EventRL t rangeR R/ t postEventR R@ R( R$ RH ( R, RF RA t fdt eventt _( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt test_maxEventsPerIterationx s
( R8 R9 RB RE RS ( ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyR= e s
(( R: R! R t structR R R R R R R t zope.interface.verifyR t
twisted.trialR t twisted.python.logR
t twisted.internet.iocpreactorR R% R R
t$ twisted.internet.iocpreactor.reactorR R R t' twisted.internet.iocpreactor.interfacesR t" twisted.internet.iocpreactor.constR t ImportErrorR< R t et strR; R( t TestCaseR R= ( ( ( sC /usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt <module> s* .
D