B ذH/\´%م@sêddlmZmZmZyddlmZWnek r<dZYnXddlZddlm Z ddl Z ddlZddlm ZddlmZddlmZdd lmZmZGd d„deƒZGdd „d eƒZGdd„deƒZGdd„deƒZGdd„deƒZdS)é)عabsolute_importعprint_functionعdivision)عEBADFé N)ع TextIOWrapper)ع_get_hub_noargs)ع integer_types)عreraise)ع SemaphoreعDummySemaphorecseZdZ‡fdd„Z‡ZS)عcancel_wait_excstt|ƒ td،dS)Nz.File descriptor was closed in another greenlet)عsuperr ع__init__r)عself)ع __class__©ْ7lib/python3.7/site-packages/gevent/_fileobjectcommon.pyrs zcancel_wait_ex.__init__)ع__name__ع __module__ع__qualname__rع __classcell__rr)rrr sr cseZdZ‡fdd„Z‡ZS)عFileObjectClosedcstt|ƒ td،dS)Nz+Bad file descriptor (FileObject was closed))rrrr)r)rrrrs zFileObjectClosed.__init__)rrrrrrr)rrrsrc@s–eZdZdZdZdZdZdZdd„Ze dd„d d„ƒZ d d„Zdd „Zdd„Z e dd„ƒZdd„Zdd„Zdd„Zdd„Zdd„Zdd„Zdd„ZdS) عFileObjectBasezo Internal base class to ensure a level of consistency between FileObjectPosix and FileObjectThread )عflushعfilenoعwritableعreadableعseekعseekableعtellعreadعreadlineع readlinesعread1عwriteع writelinesعtruncateFNcCs2||_||_|jr&| d|j|j،n| ،dS)z6 :param io: An io.IOBase-like object. N)ع_ioع_closeع _translateعtranslate_newlinesع_translate_encodingع_translate_errorsع_do_delegate_methods)rعioعclosefdrrrrEs zFileObjectBase.__init__cCs|jS)N)r()عsrrrعVszFileObjectBase.cCst|d|ƒp| ،S)Nr()عsetattrr.)r1Znvrrrr2\scCsdx^|jD]T}t|j|dƒ}tt|ƒ|ƒ}|rD|sDt||| |،ƒqt||ƒr|st||ƒqWdS)N)ع_delegate_methodsعgetattrr(عhasattrعtyper3ع_wrap_methodعdelattr)rZ meth_nameعmethZimplemented_by_classrrrr.^sz#FileObjectBase._do_delegate_methodscCs|S)z› Wrap a method we're copying into our dictionary from the underlying io object to do something special or different, if necessary. r)rعmethodrrrr8gszFileObjectBase._wrap_methodcOs,t|jf|‍|ژ}|r||_||_d|_dS)NT)rr(عmoder/r*)rr<Z text_argsZtext_kwargsعwrapperrrrr+ns z!FileObjectBase.translate_newlinescCs |jdkS)zTrue if the file is closedN)r()rrrrعcloseduszFileObjectBase.closedcCs,|jdkrdS|j}d|_| ||j،dS)N)r(ع _do_closer))rr/rrrعclosezs zFileObjectBase.closecCs tƒ‚dS)N)عNotImplementedError)rعfobjr0rrrr?‚szFileObjectBase._do_closecCs|jdkrtƒ‚t|j|ƒS)N)r(rr5)rعnamerrrع__getattr__…s zFileObjectBase.__getattr__cCsd|jj|j| ،fS)Nz<%s _fobj=%r%s>)rrr/ع_extra_repr)rrrrع__repr__ٹszFileObjectBase.__repr__cCsdS)Nعr)rrrrrEچszFileObjectBase._extra_reprcCs|S)Nr)rrrrع __enter__گszFileObjectBase.__enter__cGs| ،dS)N)r@)rعargsrrrع__exit__“szFileObjectBase.__exit__)rrrع__doc__r4r*r,r-rعpropertyr/r.r8r+r>r@r?rDrFrErHrJrrrrr s& rcs$eZdZ‡fdd„Zdd„Z‡ZS)عFileObjectBlockcs\| dd،}|r td| ،ƒ‚t|tƒrF|s6tdƒ‚tj|f|‍ژ}tt|ƒ ||،dS)Nr@TzUnexpected arguments: %rz6FileObjectBlock does not support close=False on an fd.) عpopع TypeErrorعkeysع isinstancer عosعfdopenrrMr)rrBrIعkwargsr0)rrrrکs zFileObjectBlock.__init__cCs| ،dS)N)r@)rrBr0rrrr?£szFileObjectBlock._do_close)rrrrr?rrr)rrrM–srMcsZeZdZdZd‡fdd„ Zdd„Z‡fd d „Zdd„Zd d„Zdd„Z e Z dd„Z‡ZS)عFileObjectThreadaج 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. NéےےےےTcs¾|}|ptƒj|_||_|jdkr,tƒ|_n|js:tƒ|_t|jdƒsXtdt|jƒƒ‚t|t ƒr |sntdƒ‚|dkr’|dks†t dƒ‚t |،}nt |||،}|g|_ tt|ƒ ||،dS)a :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. TrHz'Expected a Semaphore or boolean, got %rz7FileObjectThread does not support close=False on an fd.NrVz7If you use the default mode, you can't choose a bufsize)عget_hubع threadpoolعlockrrr6rOr7rQr عAssertionErrorrRrSع_FileObjectThread__io_holderrrUr)rrBr<عbufsizer@rXrYr0)rrrrµs$ zFileObjectThread.__init__c Csbd|jd<z$|jڈ|j |j،WdQRXWd|r\|fdd„}~|j |،}~|r\t|ژXdS)NrcSs,z y| ،Wnt ،SWdd}XdS)N)r@عsysعexc_info)Z_fobjrrrr@وs z)FileObjectThread._do_close..close)r[rYrXعapplyrr )rrBr0r@r^rrrr?طs zFileObjectThread._do_closecsBtt|ƒ ،t|dƒs2dt|jddƒkr2|j|_|j|jd<dS)Nr$عrr<rGr) rrUr.r6r5r(r!r$r[)r)rrrr.ُsz%FileObjectThread._do_delegate_methodscCsd|jfS)Nz threadpool=%r)rX)rrrrrEûszFileObjectThread._extra_reprcCs|S)Nr)rrrrع__iter__‏szFileObjectThread.__iter__cCs| ،}|r|St‚dS)N)r"ع StopIteration)rعlinerrrعnextszFileObjectThread.nextcs2|j‰|j‰|j‰t ˆ،‡‡‡‡fdd„ƒ}|S)Nc s0ˆddkrtƒ‚ˆڈˆ ˆ||،SQRXdS)Nr)rr_)rIrT)ع io_holderrYr;rXrrع thread_methodsz4FileObjectThread._wrap_method..thread_method)r[rYrXع functoolsعwraps)rr;rfr)rerYr;rXrr8s zFileObjectThread._wrap_method)NrVTNT) rrrrKrr?r.rErardع__next__r8rrr)rrrU¦s #rU)Z __future__rrrعerrnorعImportErrorrRr/rrgr]Z gevent.hubrrWZgevent._compatr r Zgevent.lockrrعIOErrorr rعobjectrrMrUrrrrعs" v