| 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 : |
ó
B±Nc @ sû d Z e Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l
m Z d d l m
Z
m Z d d l m Z d d l m Z d d l m Z m Z d
„ Z d e f d „ ƒ YZ d
e f d „ ƒ YZ e ƒ j e j ƒ ƒ d S( s0
Tests for implementations of L{IReactorFDSet}.
iÿÿÿÿN( t
implements( t platform( t SkipTest( t
IReactorFDSett IReadDescriptor( t FileDescriptor( t ReactorBuilder( t EINPROGRESSt EWOULDBLOCKc C sá t j ƒ } | j d ƒ | j d ƒ z£ t j ƒ } y| | j t ƒ y! | j d | j ƒ d f ƒ Wn5 t j k
r } | j d t t
f k rž ‚ qž n X| j ƒ \ } } Wn | j ƒ ‚ n XWd | j ƒ X| | f S( Ns 127.0.0.1i i ( s 127.0.0.1i (
t sockett bindt listent setblockingt Falset connectt getsocknamet errort argsR R t acceptt close( t serverSockett clientt et servert addr( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt
socketpair s$
!
t ReactorFDSetTestsBuilderc B s¤ e Z d Z e g Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z d „ Z d
„ Z e j ƒ r¢ d e _ n RS( s>
Builder defining tests relating to L{IReactorFDSet}.
c C s9 t ƒ \ } } | j | j ƒ | j | j ƒ | | f S( sL
Return the two sockets which make up a new TCP connection.
( R t
addCleanupR ( t selfR R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt _connectedPair6 s c C sC | j ƒ } | j ƒ \ } } t | ƒ } | j | _ | | | f S( N( t buildReactorR R t fileno( R t reactorR R t fd( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt _simpleSetup@ s
c s[ | j ƒ \ ‰ ‰ } ‡ ‡ f d † } | ˆ _ ˆ j ˆ ƒ | j d ƒ | j ˆ ƒ d S( s©
C{reactor.addReader()} accepts an L{IReadDescriptor} provider and calls
its C{doRead} method when there may be data available on its C{fileno}.
c s ˆ j ˆ ƒ ˆ j ƒ d S( N( t removeReadert stop( ( R! R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt
removeAndStopR s
t xN( R" t doReadt addReadert sendallt
runReactor( R R R% ( ( R! R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_addReaderK s
c s ˆ j ƒ \ } } } ‡ f d † } | | _ | j | ƒ | j | ƒ | j d ƒ | j d | j d | j ƒ ˆ j | ƒ d S( sÈ
L{reactor.removeReader()} accepts an L{IReadDescriptor} provider
previously passed to C{reactor.addReader()} and causes it to no longer
be monitored for input events.
c s ˆ j d ƒ d S( Ns doRead should not be called( t fail( ( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR, f s R& i N( R" R' R( R# R) t callLaterR$ R* ( R R R! R R, ( ( R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_removeReader^ s
c sN | j ƒ \ ‰ ‰ } ‡ ‡ f d † } | ˆ _ ˆ j ˆ ƒ | j ˆ ƒ d S( s³
C{reactor.addWriter()} accepts an L{IWriteDescriptor} provider and
calls its C{doWrite} method when it may be possible to write to its
C{fileno}.
c s ˆ j ˆ ƒ ˆ j ƒ d S( N( t removeWriterR$ ( ( R! R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR% ~ s
N( R" t doWritet addWriterR* ( R R R% ( ( R! R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_addWriterv s
c C så | j ƒ } t | d | d ƒ } t | d | ƒ } t | d | ƒ } | j ƒ \ } } | j | | ƒ ƒ | j | | ƒ ƒ | | ƒ | j | | ƒ ƒ | j | | ƒ ƒ | | ƒ | j | | ƒ ƒ | j | | ƒ ƒ d S( s=
Helper for getReaders and getWriters tests.
t gett st addt removeN( R t getattrR t assertNotInt assertIn( R t kindR R3 R5 R6 R R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt
_getFDTestˆ s
c C s | j d ƒ d S( s¡
L{IReactorFDSet.getReaders} reflects the additions and removals made
with L{IReactorFDSet.addReader} and L{IReactorFDSet.removeReader}.
t ReaderN( R; ( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_getReadersŸ s c st ˆ j ƒ \ } } } ‡ f d † } | | _ | j | ƒ | j | ƒ | j d | j d | j ƒ ˆ j | ƒ d S( sÊ
L{reactor.removeWriter()} accepts an L{IWriteDescriptor} provider
previously passed to C{reactor.addWriter()} and causes it to no longer
be monitored for outputability.
c s ˆ j d ƒ d S( Ns doWrite should not be called( R, ( ( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR, ¯ s i N( R" R0 R1 R/ R- R$ R* ( R R R! R R, ( ( R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_removeWriter§ s
c C s | j d ƒ d S( s¡
L{IReactorFDSet.getWriters} reflects the additions and removals made
with L{IReactorFDSet.addWriter} and L{IReactorFDSet.removeWriter}.
t WriterN( R; ( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_getWriters¾ s c s¸ ˆ j ƒ } ˆ j ƒ \ } } } ‡ f d † | _ ‡ f d † | _ | j d ƒ | j | ƒ | j | ƒ | j ƒ } | j d | j d | j ƒ ˆ j
| ƒ ˆ j | | g ƒ d S( s¯
C{reactor.removeAll()} removes all registered L{IReadDescriptor}
providers and all registered L{IWriteDescriptor} providers and returns
them.
c s
ˆ j d ƒ S( Ns doRead should not be called( R, ( ( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt <lambda>Ð s c s
ˆ j d ƒ S( Ns doWrite should not be called( R, ( ( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRA Ñ s R& i N( R R" R' R0 R) R( R1 t removeAllR- R$ R* t assertEqual( R R R! R t removed( ( R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_removeAllÆ s
c C sL | j ƒ } t | ƒ } | j | j ƒ | j | ƒ | j | j g ƒ d S( s†
A descriptor's C{fileno} method should not be called after the
descriptor has been removed from the reactor.
N( R t RemovingDescriptort callWhenRunningt startR* RC t calls( R R t
descriptor( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_removedFromReactorä s
c sŠ | j ƒ ‰ | j ƒ \ ‰ ‰ d t f ‡ ‡ ‡ f d † ƒ Y} | ˆ ƒ } ˆ j | ƒ ˆ j d ƒ | j ˆ ƒ | j | j d ƒ d S( sp
If L{FileDescriptor.fileno} returns C{-1}, the descriptor is removed
from the reactor.
t DisappearingDescriptorc sD e Z ˆ j ƒ Z d Z d „ Z ‡ ‡ f d † Z ‡ f d † Z RS( t c S s | j S( N( t _fileno( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR þ s c s2 d | _ | j ˆ j d ƒ 7_ ˆ j d ƒ d S( Niÿÿÿÿi t y( RN t _receivedt recvt send( R ( R R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR' s c s ˆ j ƒ d S( N( R$ ( R t reason( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt connectionLost s ( t __name__t
__module__R RN RP R' RT ( ( R R R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRL ù s
R& N( R R R R( RR R* RC RP ( R RL RJ ( ( R R R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_negativeOneFileDescriptorð s "
c s¾ ˆ j ƒ ‰ ˆ j j } | d k r: t d | f ƒ ‚ n ˆ j ƒ \ } ‰ d t f ‡ ‡ f d † ƒ Y} ˆ j | ƒ ƒ ‡ ‡ f d † } ˆ j d | ƒ ˆ j ˆ ƒ ˆ j t
j ƒ d S(
s
The file descriptor underlying a FileDescriptor may be closed and
replaced by another at some point. Bytes which arrive on the new
descriptor must not be delivered to the FileDescriptor which was
originally registered with the original descriptor of the same number.
Practically speaking, this is difficult or impossible to detect. The
implementation relies on C{fileno} raising an exception if the original
descriptor has gone away. If C{fileno} continues to return the original
file descriptor value, the reactor may deliver events from that
descriptor. This is a best effort attempt to ease certain debugging
situations. Applications should not rely on it intentionally.
t EPollReactort CFReactors& %r cannot detect lost file descriptorst Victimc s5 e Z d Z ‡ f d † Z d „ Z ‡ f d † Z RS( sŠ
This L{FileDescriptor} will have its socket closed out from under it
and another socket will take its place. It will raise a
socket.error from C{fileno} after this happens (because socket
objects remember whether they have been closed), so as long as the
reactor calls the C{fileno} method the problem will be detected.
c s
ˆ j ƒ S( N( R ( R ( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR 2 s c S s t d ƒ ‚ d S( Ns$ Victim.doRead should never be called( t Exception( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR' 5 s c s ˆ j ƒ d S( sÊ
When the problem is detected, the reactor should disconnect this
file descriptor. When that happens, stop the reactor so the
test ends.
N( R$ ( R RS ( R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRT 8 s ( RU RV t __doc__R R' RT ( ( R R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRZ * s c sO ˆ j ƒ \ } } ˆ j ƒ } ˆ j ƒ t j | j ƒ | ƒ | j d ƒ d S( NR& ( R R R t ost dup2RR ( t newCt newSR ( R R ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt messItUpG s
i N( RX RY ( R t __class__RU R R R R( R- R* t flushLoggedErrorsR R ( R t nameR RZ Ra ( ( R R R sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt test_lostFileDescriptor s
s* Cannot duplicate socket filenos on Windows( RU RV R\ R t requiredInterfacesR R" R+ R. R2 R; R= R> R@ RE RK RW Re R t isWindowst skip( ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR 0 s"
D RF c B sN e Z d Z e e ƒ d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
RS( s˜
A read descriptor which removes itself from the reactor as soon as it
gets a chance to do a read and keeps track of when its own C{fileno}
method is called.
@ivar insideReactor: A flag which is true as long as the reactor has
this descriptor as a reader.
@ivar calls: A list of the bottom of the call stack for any call to
C{fileno} when C{insideReactor} is false.
c C s4 | | _ t | _ g | _ t ƒ \ | _ | _ d S( N( R R
t
insideReactorRI R t readt write( R R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt __init__i s c C s- t | _ | j j | ƒ | j j d ƒ d S( Nt a( t TrueRi R R( Rk RR ( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRH p s c C s d S( Nt foo( ( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt logPrefixv s c C s* | j j | ƒ t | _ | j j ƒ d S( N( R R# R
Ri R$ ( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR' z s c C s9 | j s, | j j t j d d ƒ d ƒ n | j j ƒ S( Nt limiti iÿÿÿÿ( Ri RI t appendt tracebackt
extract_stackRj R ( R ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR € s #c C s d S( N( ( R RS ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRT † s ( RU RV R\ R R Rl RH Rp R' R RT ( ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRF Z s
( R\ t typet
__metaclass__R] R Rs t zope.interfaceR t twisted.python.runtimeR t twisted.trial.unittestR t twisted.internet.interfacesR R t twisted.internet.abstractR t# twisted.internet.test.reactormixinsR t twisted.internet.tcpR R R R t objectRF t globalst updatet makeTestCaseClasses( ( ( sD /usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt <module> s $ ÿ +0