o 0׾g(2@s.ddlmZddlmZddlZddlZddlmZddlmZddlmZddlm Z ddlm Z dd l m Z dd l mZdd l mZdd l mZdd l mZddlmZddlmZddlmZddlmZddlmZddlmZGddde ZGdddeeZGdddeZGdddeZdS))absolute_import)print_functionN)BytesIO)DEFAULT_BUFFER_SIZE)FileIO) RawIOBase)UnsupportedOperation)reraise)cancel_wait_ex)FileObjectBase)OpenDescriptor)WriteIsWriteallMixin)wait_on_watcher)get_hub)_read)_write)ignored_errors)make_nonblockingc@seZdZdZdZdZdZdZd%ddZddZ dd Z d d Z d d Z ddZ eddZddZddZeddZddZddZddZddZd&d!d"Zd#d$ZdS)'GreenFileDescriptorIONFTcCst|||_||_||_|j|_t||j}|j }t |_ |j j j }z|r.||d|_|r9||d|_WdSWdS|)N)r__init___closefd_filenoname fileio_modemodercan_read can_writerhubloopio _read_watcher_write_watcherclose)selffilenoopen_descriptorclosefdreadablewritable io_watcherr,a/var/www/html/backend_erp/backend_erp_env/lib/python3.10/site-packages/gevent/_fileobjectposix.pyr)s&   zGreenFileDescriptorIO.__init__cCs,t|jdd}z |W|S|w)NrF)rrisattyr$)r%fr,r,r-r/MszGreenFileDescriptorIO.isattycC |jduSN)r"r%r,r,r-r)U zGreenFileDescriptorIO.readablecCr1r2)r#r3r,r,r-r*Xr4zGreenFileDescriptorIO.writablecCsJ|jdur"z t|jdtjWntyd|_Y|jSwd|_|jS)NrFT) _seekableoslseekrSEEK_CUROSErrorr3r,r,r-seekable[s  zGreenFileDescriptorIO.seekablecC|jSr2)rr3r,r,r-r&eszGreenFileDescriptorIO.filenocCr;r2)_closedr3r,r,r-closedhszGreenFileDescriptorIO.closedcCsH|j}|j}|j}d|_|_|_|||ft|j|j|j|jdSr2) r"r#rcancel_waits_close_and_thenr $_GreenFileDescriptorIO__finish_closerr _keep_alive)r% read_event write_eventrr,r,r-__destroy_eventslsz&GreenFileDescriptorIO.__destroy_eventsc CsB|jrdS|d|_z |Wd|_|_dSd|_|_w)NT)r<flush&_GreenFileDescriptorIO__destroy_eventsrr@r3r,r,r-r${s zGreenFileDescriptorIO.closec CsBz|rt|Wt|dr|dSdSt|dr |ww)Nr$)r6r$hasattr)r(r& keep_aliver,r,r-__finish_closes    z$GreenFileDescriptorIO.__finish_closec Cl|jdur td zt|j|WSty+}z|jdtvr!WYd}~nd}~wwt|jdd|jq )Nreadrr) r"rrrr9argsrrr)r%nexr,r,r-__read  zGreenFileDescriptorIO.__readcCsHt} z|t}Wn tyd}Ynw|s |S||qr2)r_GreenFileDescriptorIO__readrr writegetvalue)r%retdatar,r,r-readalls  zGreenFileDescriptorIO.readallc Cs||t|}t|}z ||d|<W|Sty=}zddl}t||js(||d||d|<WYd}~|Sd}~ww)Nrb)rPlen TypeErrorarray isinstance)r%brTrLerrrYr,r,r-readintos zGreenFileDescriptorIO.readintoc CrI)NrQTr) r#rrrr9rKrrr)r%r[rMr,r,r-rQrOzGreenFileDescriptorIO.writerc Csbz t|j||WStyty0}zttt|jtdWYd}~dSd}~ww)Nr) r6r7rIOErrorr9r rKsysexc_info)r%offsetwhencerMr,r,r-seeks (zGreenFileDescriptorIO.seekcCsdt|jt||j|jfS)Nz<%s at 0x%x fileno=%s mode=%r>)type__name__idrrr3r,r,r-__repr__szGreenFileDescriptorIO.__repr__)T)r)re __module__ __qualname__r"r#r<r5r@rr/r)r*r:r&propertyr=rEr$ staticmethodr?rPrUr]rQrcrgr,r,r,r-rs0  $     rc@s eZdZdS)GreenFileDescriptorIOWriteallN)rerhrir,r,r,r-rlsrlc@seZdZddZddZdS)GreenOpenDescriptorcCsp|rt|j||jd}|Sd}t|}|}t|||d}||_z|j|_W|St y7|`Y|Sw)N)r(F) is_fdr_fobjr(r _do_open_rawr&r@rAttributeError)r%fileior(rawr&r,r,r-rps   z GreenOpenDescriptor._do_open_rawcCs<||us ||s J|jturt|_|St|||}|Sr2)_raw_object_is_new __class__rrlr _make_atomic_write)r%resultrsr,r,r-rvs  z&GreenOpenDescriptor._make_atomic_writeN)rerhrirprvr,r,r,r-rms rmc@s$eZdZdZeZddZddZdS)FileObjectPosixa FileObjectPosix() A file-like object that operates on non-blocking files but provides a synchronous, cooperative interface. .. caution:: This object is only effective wrapping files that can be used meaningfully with :func:`select.select` such as sockets and pipes. In general, on most platforms, operations on regular files (e.g., ``open('a_file.txt')``) are considered non-blocking already, even though they can take some time to complete as data is copied to the kernel and flushed to disk: this time is relatively bounded compared to sockets or pipes, though. A :func:`~os.read` or :func:`~os.write` call on such a file will still effectively block for some small period of time. Therefore, wrapping this class around a regular file is unlikely to make IO gevent-friendly: reading or writing large amounts of data could still block the event loop. If you'll be working with regular files and doing IO in large chunks, you may consider using :class:`~gevent.fileobject.FileObjectThread` or :func:`~gevent.os.tp_read` and :func:`~gevent.os.tp_write` to bypass this concern. .. tip:: Although this object provides a :meth:`fileno` method and so can itself be passed to :func:`fcntl.fcntl`, setting the :data:`os.O_NONBLOCK` flag will have no effect (reads will still block the greenlet, although other greenlets can run). However, removing that flag *will cause this object to no longer be cooperative* (other greenlets will no longer run). You can use the internal ``fileio`` attribute of this object (a :class:`io.RawIOBase`) to perform non-blocking byte reads. Note, however, that once you begin directly using this attribute, the results from using methods of *this* object are undefined, especially in text mode. (See :issue:`222`.) .. versionchanged:: 1.1 Now uses the :mod:`io` package internally. Under Python 2, previously used the undocumented class :class:`socket._fileobject`. This provides better file-like semantics (and portability to Python 3). .. versionchanged:: 1.2a1 Document the ``fileio`` attribute for non-blocking reads. .. versionchanged:: 1.2a1 A bufsize of 0 in write mode is no longer forced to be 1. Instead, the underlying buffer is flushed after every write operation to simulate a bufsize of 0. In gevent 1.0, a bufsize of 0 was flushed when a newline was written, while in gevent 1.1 it was flushed when more than one byte was written. Note that this may have performance impacts. .. versionchanged:: 1.3a1 On Python 2, enabling universal newlines no longer forces unicode IO. .. versionchanged:: 1.5 The default value for *mode* was changed from ``rb`` to ``r``. This is consistent with :func:`open`, :func:`io.open`, and :class:`~.FileObjectThread`, which is the default ``FileObject`` on some platforms. .. versionchanged:: 1.5 Stop forcing buffering. Previously, given a ``buffering=0`` argument, *buffering* would be set to 1, and ``buffering=1`` would be forced to the default buffer size. This was a workaround for a long-standing concurrency issue. Now the *buffering* argument is interpreted as intended. cOs(t|i|}t||||_dSr2)rmr r opened_rawrr)r%rKkwargs descriptorr,r,r-rJs zFileObjectPosix.__init__cCs(z||jWd|_dSd|_wr2)r$rr)r%fobjr(r,r,r- _do_closePs zFileObjectPosix._do_closeN)rerhri__doc__rdefault_bufsizerr}r,r,r,r-rxs E rx) __future__rrr6r_r!rrrrrgevent._compatr gevent._fileobjectcommonr r r r gevent._hub_primitivesr gevent.hubr gevent.osrrrrrrlrmrxr,r,r,r-s6                  A#