ó ÐH/\c@@sZddlmZddlZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd l m Z dd l mZdd l mZdd lmZdd lmZddlmZddlmZddlmZde fd„ƒYZdefd„ƒYZdefd„ƒYZdS(i(tabsolute_importN(tBufferedReader(tBufferedWriter(tBytesIO(tDEFAULT_BUFFER_SIZE(t RawIOBase(tUnsupportedOperation(treraise(tcancel_wait_ex(tFileObjectBase(tget_hub(t_read(t_write(tignored_errors(tmake_nonblockingtGreenFileDescriptorIOcB@s¤eZdZdZeZdZded„Z d„Z d„Z d„Z d„Z ed„ƒZd„Zd„Zd „Zd „Zd „Zd „Zd d„ZRS(trcC@s±tj|ƒ||_||_t|ƒd|k}d|k}tƒ|_|jjj}y:|rz||dƒ|_ n|r•||dƒ|_ nWn|j ƒ‚nXdS(NRtwii( Rt__init__t_closefdt_filenoRR thubtlooptiot _read_eventt _write_eventtclose(tselftfilenotmodetclosefdtreadabletwritablet io_watcher((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyR"s         cC@s |jdk S(N(RtNone(R((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRDscC@s |jdk S(N(RR"(R((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyR GscC@s\|jdkrUytj|jdtjƒWntk rHt|_qUXt|_n|jS(Ni( t _seekableR"tostlseekRtSEEK_CURtOSErrortFalsetTrue(R((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pytseekableJs   cC@s|jS(N(R(R((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRTscC@s|jS(N(t_closed(R((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pytclosedWscC@sz|j}|j}|j}d|_|_|_|dk rT|j|ttƒn|dk rv|j|ttƒndS(N(RRRR"t cancel_waitRR)(Rt read_eventt write_eventR((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyt__destroy_events[s     cC@sY|jr dS|jƒt|_|jƒ|j}|jrUd|_tj|ƒndS(N( R+tflushR)t&_GreenFileDescriptorIO__destroy_eventsRRR"R$R(RR((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRfs       cC@s‹|jdkrtdƒ‚nxftr†yt|j|ƒSWn2ttfk ro}|jdt krp‚qpnX|j j |jƒq!WdS(Ntreadi( RR"RR)R RtIOErrorR'targsR Rtwait(Rtntex((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyt__readzs  cC@sFtƒ}x0tr;|jtƒ}|s+Pn|j|ƒq W|jƒS(N(RR)t_GreenFileDescriptorIO__readRtwritetgetvalue(Rtrettdata((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pytreadall…s  cC@s†|jt|ƒƒ}t|ƒ}y|||*WnPtk r}ddl}t||jƒsh|‚n|jd|ƒ||*nX|S(Nitb(R:tlent TypeErrortarrayt isinstance(RR@R>R7terrRC((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pytreadintoŽs   cC@s‹|jdkrtdƒ‚nxftr†yt|j|ƒSWn2ttfk ro}|jdt krp‚qpnX|j j |jƒq!WdS(NR;i( RR"RR)R RR4R'R5R RR6(RR@R8((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyR;šs  icC@sjytj|j||ƒSWnItk r0‚n6tk re}ttt|jŒtjƒdƒnXdS(Ni( R$R%RR4R'RR5tsystexc_info(RtoffsettwhenceR8((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pytseek¥s  N(t__name__t __module__R"RRR(R+R#R)RRR R*RtpropertyR,R2RR:R?RFR;RK(((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRs""     tFlushingBufferedWritercB@seZd„ZRS(cC@s tj||ƒ}|jƒ|S(N(RR;R1(RR@R=((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyR;´s (RLRMR;(((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRO²stFileObjectPosixcB@s;eZdZejZdded„Zd„Zd„Z RS(sØ 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. .. note:: Random read/write (e.g., ``mode='rwb'``) is not supported. For that, use :class:`io.BufferedRWPair` around two instance of this class. .. 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. trbiÿÿÿÿc @st|tƒr|}d }n |jƒ}t|tƒsLtd|ƒ‚n|}|p[djddƒ}d|krÜt|_tt krÇd|krÇd|_ dd l ‰‡fd †}||_ n|jddƒ}n t |_|jddƒ}t|ƒd kr+|d kr+td |fƒ‚n||_|dksL|d krX|j}n|dkrmd }n|dkr‚t}n0|dks”t‚t}|jdkr²t}n||_t||d|ƒ|_||j|ƒ} tt|ƒj| |ƒd S(så :param fobj: Either an integer fileno, or an object supporting the usual :meth:`socket.fileno` method. The file *will* be put in non-blocking mode using :func:`gevent.os.make_nonblocking`. :keyword str mode: The manner of access to the file, one of "rb", "rU" or "wb" (where the "b" or "U" can be omitted). If "U" is part of the mode, universal newlines will be used. On Python 2, if 't' is not in the mode, this will result in returning byte (native) strings; putting 't' in the mode will return text strings. This may cause :exc:`UnicodeDecodeError` to be raised. :keyword int bufsize: If given, the size of the buffer to use. The default value means to use a platform-specific default Other values are interpreted as for the :mod:`io` package. Buffering is ignored in text mode. .. versionchanged:: 1.3a1 On Python 2, enabling universal newlines no longer forces unicode IO. .. 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. sfileno must be int: %rRQR@ttUttslatin-1iNc@s8ˆjjdƒr4ˆjˆƒ‡fd†ƒ}|SˆS(NR3c@s1ˆ||Ž}t|tƒs$t‚|jdƒS(Nslatin-1(RDtunicodetAssertionErrortencode(R5tkwargstresult(tm(s6lib/python2.7/site-packages/gevent/_fileobjectposix.pytwrapped(s(RLt startswithtwraps(RZR[(t functools(RZs6lib/python2.7/site-packages/gevent/_fileobjectposix.pyt wrap_method&sitrws%mode can only be [rb, rU, wb], not %rRRR(RDtintR"RRBtreplaceR)t _translatetbyteststrt_translate_encodingR^t _wrap_methodR(RAt ValueErrort _orig_bufsizetdefault_bufsizeRRVRROt_fobjRtfileiotsuperRPR( RtfobjRtbufsizeRRt orig_modeR_tIOFamilyt buffered_fobj((R^s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRòsF                cC@s5z|jƒ|jjƒWdd|_d|_XdS(N(RRlR"Rk(RRnR((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyt _do_closeZs   cC@s|jS(N(t_io(R((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyt__iter__ds( RLRMt__doc__RRRjR)RRsRu(((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyRPºs 3 h (t __future__RR$RGRRRRRRRtgevent._compatRtgevent._fileobjectcommonRR t gevent.hubR t gevent.osR R R RRRORP(((s6lib/python2.7/site-packages/gevent/_fileobjectposix.pyts(   œ