ó ÐH/\c@`s6ddlmZmZmZyddlmZWnek rIdZnXddlZddlm Z ddl Z ddl Z ddl m ZddlmZddlmZdd lmZmZd efd „ƒYZd efd „ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(i(tabsolute_importtprint_functiontdivision(tEBADFi N(t TextIOWrapper(t_get_hub_noargs(t integer_types(treraise(t SemaphoretDummySemaphoretcancel_wait_excB`seZd„ZRS(cC`stt|ƒjtdƒdS(Ns.File descriptor was closed in another greenlet(tsuperR t__init__R(tself((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR s(t__name__t __module__R (((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR stFileObjectClosedcB`seZd„ZRS(cC`stt|ƒjtdƒdS(Ns+Bad file descriptor (FileObject was closed)(R RR R(R ((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR s(RRR (((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyRstFileObjectBasecB`s­eZdZdZeZdZdZd„Z e d„d„ƒZ d„Z d„Z d„Ze d„ƒZd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(so Internal base class to ensure a level of consistency between FileObjectPosix and FileObjectThread tflushtfilenotwritabletreadabletseektseekablettelltreadtreadlinet readlinestread1twritet writelinesttruncatecC`sE||_||_|jr7|jd|j|jƒn |jƒdS(s6 :param io: An io.IOBase-like object. N(t_iot_closet _translatettranslate_newlinestNonet_translate_encodingt_translate_errorst_do_delegate_methods(R tiotclosefd((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR Es    cC`s|jS(N(R (ts((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pytVscC`st|d|ƒp|jƒS(NR (tsetattrR'(R*tnv((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR+\scC`s‘xŠ|jD]}t|j|dƒ}tt|ƒ|ƒ}|rc| rct|||j|ƒƒq t||ƒr | r t||ƒq q WdS(N( t_delegate_methodstgetattrR R$thasattrttypeR,t _wrap_methodtdelattr(R t meth_nametmethtimplemented_by_class((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR'^s cC`s|S(s› Wrap a method we're copying into our dictionary from the underlying io object to do something special or different, if necessary. ((R tmethod((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR2gscO`s=t|j||Ž}|r'||_n||_t|_dS(N(RR tmodeR(tTrueR"(R R8t text_argst text_kwargstwrapper((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR#ns   cC`s |jdkS(sTrue if the file is closedN(R R$(R ((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pytcloseduscC`s<|jdkrdS|j}d|_|j||jƒdS(N(R R$t _do_closeR!(R R(((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pytclosezs   cC`s tƒ‚dS(N(tNotImplementedError(R tfobjR)((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR>‚scC`s+|jdkrtƒ‚nt|j|ƒS(N(R R$RR/(R tname((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyt __getattr__…s cC`s d|jj|j|jƒfS(Ns<%s _fobj=%r%s>(t __class__RR(t _extra_repr(R ((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyt__repr__ŠscC`sdS(Nt((R ((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyREscC`s|S(N((R ((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyt __enter__scG`s|jƒdS(N(R?(R targs((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyt__exit__“s(RRRRRRRRRRRRRRN(RRt__doc__R.tFalseR"R$R%R&R tpropertyR(R'R2R#R=R?R>RCRFRERHRJ(((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR s@           tFileObjectBlockcB`seZd„Zd„ZRS(cO`s‡|jdtƒ}|r1td|jƒƒ‚nt|tƒrj|sUtdƒ‚ntj||Œ}ntt |ƒj ||ƒdS(NR?sUnexpected arguments: %rs6FileObjectBlock does not support close=False on an fd.( tpopR9t TypeErrortkeyst isinstanceRtostfdopenR RNR (R RARItkwargsR)((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR ˜scC`s|jƒdS(N(R?(R RAR)((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR>£s(RRR R>(((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyRN–s tFileObjectThreadcB`sbeZdZd ded ed„Zd„Zd„Zd„Zd„Z d„Z e Z d„Z RS( sÌ A file-like object wrapping another file-like object, performing all blocking operations on that object in a background thread. .. caution:: Attempting to change the threadpool or lock of an existing FileObjectThread has undefined consequences. .. versionchanged:: 1.1b1 The file object is closed using the threadpool. Note that whether or not this action is synchronous or asynchronous is not documented. iÿÿÿÿcC`s#|}|ptƒj|_||_|jtkrBtƒ|_n|jsZtƒ|_nt|jdƒsˆtdt|jƒƒ‚nt |t ƒrú|s¬tdƒ‚n|dkrâ|dksÐt dƒ‚t j|ƒ}qút j|||ƒ}n|g|_tt|ƒj||ƒdS(s :param fobj: The underlying file-like object to wrap, or an integer fileno that will be pass to :func:`os.fdopen` along with *mode* and *bufsize*. :keyword bool lock: If True (the default) then all operations will be performed one-by-one. Note that this does not guarantee that, if using this file object from multiple threads/greenlets, operations will be performed in any particular order, only that no two operations will be attempted at the same time. You can also pass your own :class:`gevent.lock.Semaphore` to synchronize file operations with an external resource. :keyword bool close: If True (the default) then when this object is closed, the underlying object is closed as well. RHs'Expected a Semaphore or boolean, got %rs7FileObjectThread does not support close=False on an fd.iÿÿÿÿs7If you use the default mode, you can't choose a bufsizeN(tget_hubt threadpooltlockR9RR R0RPR1RRRR$tAssertionErrorRSRTt_FileObjectThread__io_holderR RVR (R RAR8tbufsizeR?RXRYR)((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyR µs$     cC`s|d|jdØs   cC`satt|ƒjƒt|dƒ rMdt|jddƒkrM|j|_n|j|jdR'RERbRet__next__R2(((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyRV¦s #     (t __future__RRRterrnoRt ImportErrorRSR(RRhR]t gevent.hubRRWtgevent._compatRRt gevent.lockRR tIOErrorR RtobjectRRNRV(((s7lib/python2.7/site-packages/gevent/_fileobjectcommon.pyts"     v