9*bLdZddlZddlZddlmZddlmZmZmZddl m Z e eddZ dZ d Zd ZeZd Zd ZGd dZy)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 N)partial)ERROR_CHECKERSFD_PAIR SIGNATURES)load_ctypes_library O_CLOEXECicNt}|j|||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)libcflagsfdss 1/usr/lib/python3/dist-packages/pyudev/_os/pipe.py _pipe2_ctypesr-s+ )CJJsE q63q6>ctj}|tjzdk7r!|D]}t|tj|tzdk7r|D]}t |t|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)r rfile_descriptors r_pipe2_by_piper;sh '')C r}}!" ?O  > ? yA" 4O  3 4 JrcttdrtjS tdtt }t|drt t|StS#t$r tcYSwxYw)zf Find the appropriate implementation for ``pipe2``. Return a function implementing ``pipe2``.r r ) hasattrrr rrrrrr ImportError)r s r_get_pipe2_implementationrQsa r7xx"6:~F,3D',BGM4 ( HV  s0AAA+*A+ctj|tjd}tj|tj||zy)zwSet a flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. rN)fcntlF_GETFDF_SETFDfdflagr s rrrd2 KKEMM1 -E KKEMM54<0rctj|tjd}tj|tj||zy)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"s rrrnr%rc,eZdZdZedZdZdZy)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()`. cZttjtz\}}|||S)zLOpen and return a new :class:`Pipe`. The pipe uses non-blocking IO.)_PIPE2rrr)clssourcesinks ropenz Pipe.opens( bmmi78 64  rcttj|dd|_tj|dd|_y)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_fds r__init__z Pipe.__init__s, ii 43 IIgtQ/ rc |jj|jjy#|jjwxYw)zCloses both sides of the pipe.N)r.closer/)r5s rr:z Pipe.closes4  KK    IIOO DIIOO s 7AN)__name__ __module__ __qualname____doc__ classmethodr0r8r:rrr*r*xs%!!0rr*)r>rr functoolsrpyudev._ctypeslib.libcrrrpyudev._ctypeslib.utilsrgetattrrrrrr,rrr*r@rrrEs^"   GF7 B Y /  ,  # $11  r