o ‡e(2ã@s.ddlmZddlmZddlZddlZddlmZddlmZddlmZddlm Z ddlm Z dd l m Z dd l mZdd l mZdd l mZdd l mZddlmZddlmZddlmZddlmZddlmZddlmZGdd„de ƒZGdd„deeƒZGdd„deƒZGdd„deƒZdS)é)Ú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@s¬eZdZdZdZdZdZdZd%dd„Zdd„Z dd „Z d d „Z d d „Z dd„Z edd„ƒZdd„Zdd„Zedd„ƒZdd„Zdd„Zdd„Zdd„Zd&d!d"„Zd#d$„ZdS)'ÚGreenFileDescriptorIONFTcCsˆt |¡||_||_||_|j|_t|ƒ|j}|j }t ƒ|_ |j j j }z|r.||dƒ|_|r9||dƒ|_WdSWdS| ¡‚)Néé)rÚ__init__Ú_closefdÚ_filenoÚnameZ fileio_modeÚmoderZcan_readZ can_writerÚhubÚloopÚioÚ _read_watcherÚ_write_watcherÚclose)ÚselfÚfilenoZopen_descriptorÚclosefdÚreadableÚwritableZ io_watcher©r'úGD:\Projects\ConvertPro\env\Lib\site-packages\gevent/_fileobjectposix.pyr)s&   ÿzGreenFileDescriptorIO.__init__cCs,t|jddƒ}z | ¡W| ¡S| ¡w)NÚrF)rrÚisattyr!)r"Úfr'r'r(r*MszGreenFileDescriptorIO.isattycCó |jduS©N)r©r"r'r'r(r%Uó zGreenFileDescriptorIO.readablecCr,r-)r r.r'r'r(r&Xr/zGreenFileDescriptorIO.writablecCsJ|jdur"z t |jdtj¡Wntyd|_Y|jSwd|_|jS)NrFT)Ú _seekableÚosÚlseekrÚSEEK_CURÚOSErrorr.r'r'r(Úseekable[s  üzGreenFileDescriptorIO.seekablecCó|jSr-)rr.r'r'r(r#eszGreenFileDescriptorIO.filenocCr6r-)Ú_closedr.r'r'r(ÚclosedhszGreenFileDescriptorIO.closedcCsH|j}|j}|j}d|_|_|_| ||ft|j|j|j|j¡dSr-) rr rZcancel_waits_close_and_thenr Ú$_GreenFileDescriptorIO__finish_closerrÚ _keep_alive)r"Z read_eventZ write_eventrr'r'r(Z__destroy_eventslsúz&GreenFileDescriptorIO.__destroy_eventsc CsB|jrdS| ¡d|_z | ¡Wd|_|_dSd|_|_w)NT)r7ÚflushÚ&_GreenFileDescriptorIO__destroy_eventsrr:r.r'r'r(r!{s zGreenFileDescriptorIO.closec CsBz|rt |¡Wt|dƒr| ¡dSdSt|dƒr | ¡ww)Nr!)r1r!Úhasattr)r$r#Ú keep_aliver'r'r(Z__finish_close‡s €  ÿ ÿz$GreenFileDescriptorIO.__finish_closec Cól|jdur tdƒ‚ zt|j|ƒWSty+}z|jdtvr!‚WYd}~nd}~wwt|jdd|jƒq )NÚreadrr) rrrrr4Úargsrrr)r"ÚnÚexr'r'r(Ú__read—ó  ÿ€ÿúzGreenFileDescriptorIO.__readcCsHtƒ} z| t¡}Wn tyd}Ynw|s | ¡S| |¡qr-)rÚ_GreenFileDescriptorIO__readrr ÚwriteÚgetvalue)r"ÚretÚdatar'r'r(Úreadall¢s ü ÿözGreenFileDescriptorIO.readallc Cs|| t|ƒ¡}t|ƒ}z ||d|…<W|Sty=}zddl}t||jƒs(|‚| d|¡|d|…<WYd}~|Sd}~ww)Nrób)rFÚlenÚ TypeErrorÚarrayÚ isinstance)r"ÚbrJrBÚerrrOr'r'r(Úreadinto±sû €ûzGreenFileDescriptorIO.readintoc Cr?)NrGTr) r rrrr4rArrr)r"rQrCr'r'r(rG½rEzGreenFileDescriptorIO.writerc Csbz t |j||¡WSty‚ty0}zttt|jŽt ¡dƒWYd}~dSd}~ww)Nr) r1r2rÚIOErrorr4r rAÚsysÚexc_info)r"ÚoffsetÚwhencerCr'r'r(ÚseekÈs (€ûzGreenFileDescriptorIO.seekcCsdt|ƒjt|ƒ|j|jfS)Nz<%s at 0x%x fileno=%s mode=%r>)ÚtypeÚ__name__Úidrrr.r'r'r(Ú__repr__ÔsÿzGreenFileDescriptorIO.__repr__)T)r)r[Ú __module__Ú __qualname__rr r7r0r:rr*r%r&r5r#Úpropertyr8r<r!Ú staticmethodr9rFrKrSrGrYr]r'r'r'r(rs0  $     rc@s eZdZdS)ÚGreenFileDescriptorIOWriteallN)r[r^r_r'r'r'r(rbÚsrbc@seZdZdd„Zdd„ZdS)ÚGreenOpenDescriptorcCsp| ¡rt|j||jd}|Sd}t |¡}| ¡}t|||d}||_z|j|_W|St y7|`Y|Sw)N)r$F) Zis_fdrZ_fobjr$r Ú _do_open_rawr#r:rÚAttributeError)r"Úfileior$Úrawr#r'r'r(rdásô   þþz GreenOpenDescriptor._do_open_rawcCs<||us | |¡s J‚|jturt|_|St |||¡}|Sr-)Z_raw_object_is_newÚ __class__rrbr Ú_make_atomic_write)r"Úresultrgr'r'r(riös  ÿz&GreenOpenDescriptor._make_atomic_writeN)r[r^r_rdrir'r'r'r(rcßs rcc@s$eZdZdZeZdd„Zdd„ZdS)Ú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 ||¡| ¡|_dSr-)rcr rZ opened_rawrf)r"rAÚkwargsZ descriptorr'r'r(rJs zFileObjectPosix.__init__cCs(z| ¡|j ¡Wd|_dSd|_wr-)r!rf)r"Zfobjr$r'r'r(Ú _do_closePs zFileObjectPosix._do_closeN)r[r^r_Ú__doc__rZdefault_bufsizerrmr'r'r'r(rks E rk)Ú __future__rrr1rUrrrrrrZgevent._compatr Zgevent._fileobjectcommonr r r r Zgevent._hub_primitivesrZ gevent.hubrZ gevent.osrrrrrrbrcrkr'r'r'r(Ús6                  Aÿ#