o U˟iC2@s:ddlmZddlmZddlZddlZddlmZddlmZddlmZddlm Z ddlm Z dd l m Z dd l mZdd l mZdd l mZdd l mZddlmZddlmZddlmZddlmZddlmZddlmZddlmZGddde 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)_close)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-_/var/www/apps/myagent/mysuperagent/venv/lib/python3.10/site-packages/gevent/_fileobjectposix.pyr*s&   zGreenFileDescriptorIO.__init__cCs,t|jdd}z |W|S|w)NrF)rrisattyr%)r&fr-r-r.r0NszGreenFileDescriptorIO.isattycC |jduSN)r#r&r-r-r.r*V zGreenFileDescriptorIO.readablecCr2r3)r$r4r-r-r.r+Yr5zGreenFileDescriptorIO.writablecCsJ|jdur"z t|jdtjWntyd|_Y|jSwd|_|jS)NrFT) _seekableoslseekrSEEK_CUROSErrorr4r-r-r.seekable\s  zGreenFileDescriptorIO.seekablecC|jSr3)rr4r-r-r.r'fszGreenFileDescriptorIO.filenocCr<r3)_closedr4r-r-r.closediszGreenFileDescriptorIO.closedcCsH|j}|j}|j}d|_|_|_|||ft|j|j|j|jdSr3) r#r$r cancel_waits_close_and_thenr $_GreenFileDescriptorIO__finish_closerr _keep_alive)r& read_event write_eventr r-r-r.__destroy_eventsmsz&GreenFileDescriptorIO.__destroy_eventsc CsB|jrdS|d|_z |Wd|_|_dSd|_|_w)NT)r=flush&_GreenFileDescriptorIO__destroy_eventsrrAr4r-r-r.r%|s zGreenFileDescriptorIO.closec Cs@z|rt|Wt|dr|dSdSt|dr|ww)Nr%)rhasattrr%)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#rrrr:argsrrr )r&nexr-r-r.__read  zGreenFileDescriptorIO.__readcCsHt} z|t}Wn tyd}Ynw|s |S||qr3)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)rQlen TypeErrorarray isinstance)r&brUrMerrrZr-r-r.readintos zGreenFileDescriptorIO.readintoc CrJ)NrRTr) r$rrrr:rLrrr )r&r\rNr-r-r.rRrPzGreenFileDescriptorIO.writerc Csbz t|j||WStyty0}zttt|jtdWYd}~dSd}~ww)Nr) r7r8rIOErrorr:r rLsysexc_info)r&offsetwhencerNr-r-r.seeks (zGreenFileDescriptorIO.seekcCsdt|jt||j|jfS)Nz<%s at 0x%x fileno=%s mode=%r>)type__name__idrrr4r-r-r.__repr__szGreenFileDescriptorIO.__repr__)T)r)rf __module__ __qualname__r#r$r=r6rArr0r*r+r;r'propertyr>rFr% staticmethodr@rQrVr^rRrdrhr-r-r-r.rs0  $     rc@s eZdZdS)GreenFileDescriptorIOWriteallN)rfrirjr-r-r-r.rmsrmc@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'rArAttributeError)r&fileior)rawr'r-r-r.rqs   z GreenOpenDescriptor._do_open_rawcCs<||us ||s J|jturt|_|St|||}|Sr3)_raw_object_is_new __class__rrmr _make_atomic_write)r&resultrtr-r-r.rws  z&GreenOpenDescriptor._make_atomic_writeN)rfrirjrqrwr-r-r-r.rns rnc@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||||_dSr3)rnr r opened_rawrs)r&rLkwargs descriptorr-r-r.rKs zFileObjectPosix.__init__cCs(z||jWd|_dSd|_wr3)r%rs)r&fobjr)r-r-r. _do_closeQs zFileObjectPosix._do_closeN)rfrirj__doc__rdefault_bufsizerr~r-r-r-r.rys E ry) __future__rrr7r`r"rrrrrgevent._compatr gevent._fileobjectcommonr r r r gevent._hub_primitivesr gevent.hubr gevent.osrrrrrrrmrnryr-r-r-r.s8                   A#