Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/sugar/__pycache__/context.cpython-39.pyc
Ðазад
a a�ht# � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z dd l mZmZmZ dd lmZ dd lmZ d ad d� Ze�e� G dd� de e �ZdgZdS )zPython bindings for 0MQ.� N)�Lock)�WeakSet)�Context� )� constants)�AttributeSetter)�ENOTSUP�LINGER� ctx_opt_names��Socket)�ZMQErrorFc C s da d S )NT)�_exiting� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/sugar/context.py�_notice_atexit s r c s� e Zd ZdZdZdZe� ZdZdZ dZ d-� fdd� Z dd� Z d d � Z d d � Zd.d d�ZeZedd� �Zedd� �Zed/dd��Z� fdd�Zdd� Zdd� Zdd � Zd0d d �Zed d � �Zd!d"� Z d#d$� Z d%d&� Z d'd(� Z d)d*� Z d+d,� Z!� Z"S )1r z[Create a zmq Context A zmq Context creates sockets via its ``ctx.socket`` method. NFr c sF t t| �jf d|i|�� |�dd�r.d| _nd| _i | _t� | _d S )N� io_threads�shadowFT)�superr �__init__�get�_shadow�sockoptsr �_sockets)�selfr �kwargs�� __class__r r r & s zContext.__init__c C s t � | jsts| �� dS )zMdeleting a Context should terminate it, without trying non-threadsafe destroyN)�localsr r �term�r r r r �__del__/ s zContext.__del__c C s | S �Nr r r r r � __enter__8 s zContext.__enter__c O s | � � d S r" )r )r �argsr r r r �__exit__; s zContext.__exit__c C s | j �| j�S )z'Copying a Context creates a shadow copy)r r � underlying)r �memor r r �__copy__> s zContext.__copy__c C s ddl m} ||�}| |d�S )z�Shadow an existing libzmq context address is the integer address of the libzmq context or an FFI pointer to it. .. versionadded:: 14.1 r �� cast_int_addr�r )�zmq.utils.interopr* )�cls�addressr* r r r r D s zContext.shadowc C s4 ddl m} ddlm} |�|�}||�}| |d�S )z�Shadow an existing pyczmq context ctx is the FFI `zctx_t *` pointer .. versionadded:: 14.1 r )�zctxr) r+ )Zpyczmqr/ r, r* r& )r- �ctxr/ r* r& r. r r r � shadow_pyczmqQ s zContext.shadow_pyczmqc C s� | j du s | jt�� ks | j jr|| j�F | j du sH| jt�� ksH| j jr^| |d�| _ t�� | _W d � n1 sr0 Y | j S )a Returns a global Context instance. Most single-threaded applications have a single, global Context. Use this method instead of passing around Context instances throughout your code. A common pattern for classes that depend on Contexts is to use a default argument to enable programs with multiple Contexts but not require the argument for simpler applications:: class MyClass(object): def __init__(self, context=None): self.context = context or Context.instance() .. versionchanged:: 18.1 When called in a subprocess after forking, a new global instance is created instead of inheriting a Context that won't work from the parent process. N)r )� _instance� _instance_pid�os�getpid�closed�_instance_lock)r- r r r r �instancea s � ��� �� (zContext.instancec s t t| ��� S )aL Close or terminate the context. Context termination is performed in the following steps: - Any blocking operations currently in progress on sockets open within context shall raise :class:`zmq.ContextTerminated`. With the exception of socket.close(), any further operations on sockets open within this context shall raise :class:`zmq.ContextTerminated`. - After interrupting all blocking calls, term shall block until the following conditions are satisfied: - All sockets open within context have been closed. - For each socket within context, all messages sent on the socket have either been physically transferred to a network peer, or the socket's linger period set with the zmq.LINGER socket option has expired. For further details regarding socket linger behaviour refer to libzmq documentation for ZMQ_LINGER. This can be called to close the context by hand. If this is not called, the context will automatically be closed when it is garbage collected. )r r r r r r r r � s z Context.termc C s$ t | j�}tfD ]}|�|� q|S r" )�dirr r �extend)r �keysZ collectionr r r �__dir__� s � zContext.__dir__c C s | j �|� d S r" )r �add�r �socketr r r � _add_socket� s zContext._add_socketc C s | j r| j �|� d S r" )r �discardr> r r r � _rm_socket� s zContext._rm_socketc C sT | j r dS | j}t� | _|D ]*}|r |j s |dur>|�t|� |�� q | �� dS )a� Close all sockets associated with this context and then terminate the context. .. warning:: destroy involves calling ``zmq_close()``, which is **NOT** threadsafe. If there are active sockets in other threads, this must not be called. Parameters ---------- linger : int, optional If specified, set LINGER on sockets prior to closing them. N)r6 r r � setsockoptr �closer )r ZlingerZsockets�sr r r �destroy� s zContext.destroyc C s t S r" r r r r r � _socket_class� s zContext._socket_classc K sh | j rtt��| j| |fi |��}| j�� D ],\}}z|�||� W q, tyV Y q,0 q,| �|� |S )a] Create a Socket associated with this Context. Parameters ---------- socket_type : int The socket type, which can be any of the 0MQ socket types: REQ, REP, PUB, SUB, PAIR, DEALER, ROUTER, PULL, PUSH, etc. kwargs: will be passed to the __init__ method of the socket class. )r6 r r rG r �itemsrC r@ )r � socket_typer rE �opt�valuer r r r? � s zContext.socketc C s || j |< dS )zkset default socket options for new sockets created by this Context .. versionadded:: 13.0 N�r )r rJ rK r r r rC � s zContext.setsockoptc C s | j | S )zkget default socket options for new sockets created by this Context .. versionadded:: 13.0 rL )r rJ r r r � getsockopt� s zContext.getsockoptc C s$ |t jv r| �||�S || j|< dS )z"set default sockopts as attributesN)r r �setr )r �namerJ rK r r r � _set_attr_opt� s zContext._set_attr_optc C s6 |t jv r| �|�S || jvr(t|��n | j| S dS )z"get default sockopts as attributesN)r r r r �AttributeError)r rO rJ r r r � _get_attr_opt s zContext._get_attr_optc C sV |� � }ztt|�}W n ty4 td| ��Y n 0 || jvrJt|��n| j|= dS )z%delete default sockopts as attributeszno such socket option: %sN)�upper�getattrr rQ r )r �keyrJ r r r � __delattr__ s zContext.__delattr__)r )N)r )N)#�__name__� __module__� __qualname__�__doc__r r2 r r7 r3 r r r r! r# r% r( � __deepcopy__� classmethodr r1 r8 r r< r@ rB rF �propertyrG r? rC rM rP rR rV � __classcell__r r r r r s@ $ r )rZ �atexitr4 � threadingr �weakrefr Z zmq.backendr Z ContextBase� r Z attrsettrr r r r r? r Z zmq.errorr r r �register�__all__r r r r �<module> s"
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка