File: //lib64/python3.6/site-packages/zmq/eventloop/minitornado/platform/__pycache__/posix.cpython-36.pyc
3
VS�_2 � @ s^ d Z ddlmZmZmZmZ ddlZddlZddlm Z dd� Z
dd � Z G d
d � d e j �Z dS ) z9Posix implementations of platform-specific functionality.� )�absolute_import�division�print_function�with_statementN� )� interfacec C s( t j | t j�}t j | t j|t jB � d S )N)�fcntlZF_GETFDZF_SETFDZ
FD_CLOEXEC)�fd�flags� r � /usr/lib64/python3.6/posix.py�set_close_exec s r
c C s( t j | t j�}t j | t j|tjB � d S )N)r ZF_GETFLZF_SETFL�os�
O_NONBLOCK)r r
r r r �_set_nonblocking s r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�Wakerc C sP t j� \}}t|� t|� t|� t|� t j|dd�| _t j|dd�| _d S )N�rbr �wb)r �piper r
�fdopen�reader�writer)�self�r�wr r r �__init__& s zWaker.__init__c C s
| j j� S )N)r �fileno)r r r r r / s z Waker.filenoc C s
| j j� S )N)r r )r r r r � write_fileno2 s zWaker.write_filenoc C s* y| j jd� W n tk
r$ Y nX d S )N� x)r �write�IOError)r r r r �wake5 s z
Waker.wakec C s4 yx| j j� }|sP qW W n tk
r. Y nX d S )N)r �readr )r �resultr r r �consume; s
z
Waker.consumec C s | j j� | jj� d S )N)r �closer )r r r r r% D s
z Waker.closeN) �__name__�
__module__� __qualname__r r r r! r$ r% r r r r r % s r )
�__doc__Z
__future__r r r r r r � r r
r r r r r r �<module> s