o 8g+^@sdZddlmZddlmZddlmZddlmZddlZddlZddlm Z ddl m Z dd l m Z dd l m Z dd lmZeed d ZddZddZddZeZddZddZGdddeZdS)a# pyudev._os.pipe =============== Fallback implementations for pipe. 1. pipe2 from python os module 2. pipe2 from libc 3. pipe from python os module The Pipe class wraps the chosen implementation. .. moduleauthor:: Sebastian Wiesner )absolute_import)division)print_function)unicode_literalsN)partial)ERROR_CHECKERS)FD_PAIR) SIGNATURES)load_ctypes_library O_CLOEXECicCs"t}||||d|dfS)zA ``pipe2`` implementation using ``pipe2`` from ctypes. ``libc`` is a :class:`ctypes.CDLL` object for libc. ``flags`` is an integer providing the flags to ``pipe2``. Return a pair of file descriptors ``(r, w)``. r)rpipe2)libcflagsfdsr1/usr/lib/python3/dist-packages/pyudev/_os/pipe.py _pipe2_ctypes2s rcCsPt}|tj@dkr|D]}t|tjq |t@dkr&|D]}t|tq|S)zA ``pipe2`` implementation using :func:`os.pipe`. ``flags`` is an integer providing the flags to ``pipe2``. .. warning:: This implementation is not atomic! Return a pair of file descriptors ``(r, w)``. r)ospipe O_NONBLOCKset_fd_status_flagr set_fd_flag)rrfdrrr_pipe2_by_pipe@s   rcCsPttdrtjSztdtt}t|drtt|WStWSt y'tYSw)z]Find the appropriate implementation for ``pipe2``. Return a function implementing ``pipe2``.r r) hasattrrr r r rrrr ImportError)rrrr_get_pipe2_implementationVs   rcC(t|tjd}t|tj||BdS)zwSet a flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. rN)fcntlF_GETFDF_SETFDrflagrrrrrhrcCr)z~Set a status flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. rN)rF_GETFLF_SETFLr"rrrrrr$rc@s,eZdZdZeddZddZddZdS) PipezA unix pipe. A pipe object provides two file objects: :attr:`source` is a readable file object, and :attr:`sink` a writeable. Bytes written to :attr:`sink` appear at :attr:`source`. Open a pipe with :meth:`open()`. cCsttjtB\}}|||S)zLOpen and return a new :class:`Pipe`. The pipe uses non-blocking IO.)_PIPE2rrr )clssourcesinkrrropens z Pipe.opencCs$t|dd|_t|dd|_dS)zCreate a new pipe object from the given file descriptors. ``source_fd`` is a file descriptor for the readable side of the pipe, ``sink_fd`` is a file descriptor for the writeable side.rbrwbN)rfdopenr*r+)self source_fdsink_fdrrr__init__sz Pipe.__init__cCs(z |jW|jdS|jw)zCloses both sides of the pipe.N)r*closer+)r0rrrr4s z Pipe.closeN)__name__ __module__ __qualname____doc__ classmethodr,r3r4rrrrr'|s   r')r8 __future__rrrrrr functoolsrpyudev._ctypeslib.libcrrr pyudev._ctypeslib.utilsr getattrr rrrr(rrobjectr'rrrrs(