ó
|
Q\¬Qc @ s» d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z e e d s e j
|
d n d e j f d YZ d Z e d k r· e n d S(
|
s
|
Tests for kqueue wrapper.
|
iÿÿÿÿN( t test_supportt kqueues test works only on BSDt
|
TestKQueuec B s, e Z d Z d Z d Z d Z RS( c C sp t j } | j | j d k | j | j | j | j | j | j | j t | j d S( Ni ( t selectR t
|
assertTruet filenot closedt closet assertRaisest
|
ValueError( t selft kq( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyt test_create_queue s "
|
c C s! t j j } t j | } t j d } | j | j | | j | j t j | j | j t j
|
| j | j d | j | j d | j | j d | j | | | j | | | j t | | d | j | | k | j | | k | j t t | d | j t t | d | j t t | d t j | t j } | j | j | | j | j t j | j | j t j
|
| j | j d | j | j d | j | j d | j | | | j | | t j | t j t j } | j | j | | j | j t j | j | j t j | j | j d | j | j d | j | j d | j | | | j | | t j d d d d d d
|
} | j | j d | j | j d | j | j d | j | j d | j | j d | j | j d
|
| j | | | j | | t j d d } t j | d d d t j | } | j | j | | j | j d | j | j d | j | j d | j | j t j | j | j | | j | | | j | | d S( Niè i iÿÿÿÿi t evi i i i i ( t syst stderrR R t keventt assertEqualt identt filtert KQ_FILTER_READt flagst KQ_EV_ADDt fflagst datat udatat assertNotEqualt cmpR R t TypeErrort Nonet KQ_FILTER_WRITEt KQ_EV_ONESHOTt maxsize( R
|
t fdR t othert bignum( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyt test_create_event sl !c C s t j } | j d | j d t j } | j t y! | j d | j d f Wn0 t j k
|
r } | j | j d t
|
j n X| j \ } } t j } t j j | j } t j | j t j t j t j B } | j | g d t j | j t j t j t j B } | j | g d t j | j t j t j t j B } | j | g d t j | j t j t j t j B } | j | g d | j d d d } t d | D } | j | t | j t j f | j t j f g | j d | j d xY t d D]> }
|
| j d d d } t | d k rrPn t j d qAW| j d
|
t d | D } | j | t | j t j f | j t j f | j t j f | j t j f g t j | j t j t j } | j | g d t j | j t j t j } | j | g d t j | j t j t j } | j | g d d | j g d d } t d | D } | j | t | j t j f g | j | j | j d S( Ns 127.0.0.1i i i c s s! | ] } | j | j f Vq d S( N( R R ( t .0t e( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pys <genexpr>x s s Hello!s world!!!i
|
g ð?s' timeout waiting for event notificationsc s s! | ] } | j | j f Vq d S( N( R R ( R% R& ( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pys <genexpr> s g®Gáz®ï?c s s! | ] } | j | j f Vq d S( N( R R ( R% R& ( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pys <genexpr> s ( s 127.0.0.1i (! t sockett bindt listent setblockingt Falset connectt getsocknamet errorR t argst errnot EINPROGRESSt acceptR R t fromfdR R R R t KQ_EV_ENABLEt controlR R t sett sendt ranget lent timet sleept failt KQ_EV_DELETER ( R
|
t serverSockett clientR& t servert addrR t kq2R t eventst i( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyt test_queue_eventT s !
|
|
c C sô t j } t j \ } } | j d t j | t j t j t j B } t j | t j t j t j B } | j | | g d d } | j
|
| | j | d j t j @ | j | j | d j d | j | j | j d S( Nt fooi i ( R R R' t
|
socketpairR7 R R R R4 R5 R t assertFalseR t KQ_EV_ERRORR t recvR R ( R
|
R t at bt event1t event2t r( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyt testPair§ s ""
|
|
( t __name__t
|
__module__R R$ RE RP ( ( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyR s < Sc C s t j t d S( N( R t run_unittestR ( ( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyt test_main· s t __main__( t __doc__R' R0 R: R R t unittestt testR t hasattrt SkipTestt TestCaseR RT RQ ( ( ( sX /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_kqueue.pyt <module> s ¨
|
