← Back
Editing: ioloop.cpython-311.pyc
� mc�c� � � � U d Z ddlZddlZddlmZ ddlZddlmZ ddlmZ e ej d� � s e d e edd � � z � � �n# e $ r d dl mZ d dlmZ Y nw xY wej Z G d � d e� � Zd � Zde_ eed< dej v rd dlmZ n8ej Z ej � � eur ej � � Z ej � � eu� G d� de� � ZeZ d� Zdej v r d dlm Z mZmZ dS dS )z�tornado IOLoop API with zmq compatibility This module is deprecated in pyzmq 17. To use zmq with tornado, eventloop integration is no longer required and tornado itself should be used. � N)�Any)�ioloop)�gen_log�configurable_defaultzTornado too old: %s�version�unknown� c �0 � � e Zd ZdZd� fd� Zd� Zd� Z� xZS )�DelayedCallbackz�Schedules the given callback to be called once. The callback is called once, after callback_time milliseconds. `start` must be called after the DelayedCallback is created. The timeout is calculated from when `start` is called. Nc � �� t j dt � � t |d� � }t � � � |||� � d S )NzDDelayedCallback is deprecated. Use loop.add_timeout instead.g����MbP?)�warnings�warn�DeprecationWarning�max�super�__init__)�self�callback� callback_time�io_loop� __class__s ��6/usr/lib/python3/dist-packages/zmq/eventloop/ioloop.pyr zDelayedCallback.__init__+ sR �� �� � )� � � � � �M�4�0�0� � ������=�'�:�:�:�:�:� c � � d| _ d| _ t j � � | j dz z | _ | j � | j | j � � dS )zStarts the timer.Tg @�@N)�_running� _firstrun�timer � _next_timeoutr � add_timeout�_run�r s r �startzDelayedCallback.start5 sN � � �� � ��� !�Y�[�[�4�+=��+F� F��� � � � ��!3�T�Y�?�?�?�?�?r c � � | j sd S d| _ | � � � d S # t $ r t j dd�� � Y d S w xY w)NFzError in delayed callbackT)�exc_info)r r � Exceptionr �errorr! s r r zDelayedCallback._run< sm � ��}� � �F� �� � F� �M�M�O�O�O�O�O��� F� F� F� �M�5�� E� E� E� E� E� E� E� F���s �( � A � A �N)�__name__� __module__� __qualname__�__doc__r r" r � __classcell__�r s @r r r ! so �� � � � � �� �;� ;� ;� ;� ;� ;�@� @� @�F� F� F� F� F� F� Fr r c �r � t j rd S dt _ t j dt d�� � d S )NTzlzmq.eventloop.ioloop is deprecated in pyzmq 17. pyzmq now works with default tornado and asyncio eventloops.� )� stacklevel)� _deprecated�calledr r r � r r r1 r1 F sI � ��� ��� �K�� �M� H��� � � � � � r F�_IOLoopz .minitornado.)� ZMQIOLoopc �N � � e Zd ZdZ� fd�Zed� � � Zed� � � Z� xZS )r5 z�DEPRECATED: No longer needed as of pyzmq-17 PyZMQ tornado integration now works with the default :mod:`tornado.ioloop.IOLoop`. c �` �� t � � t � � � � � S r' )r1 r r )r �args�kwargsr s �r r zZMQIOLoop.__init__d s" �� �� � � ��w�w� � �!�!�!r c � � t j � | � � t � � t j j |i |��}|S )a Returns a global `IOLoop` instance. Most applications have a single, global `IOLoop` running on the main thread. Use this method to get this instance from another thread. To get the current thread's `IOLoop`, use `current()`. )r �IOLoop� configurer1 �instance��clsr8 r9 �loops r r= zZMQIOLoop.instancei s? � � � � � ��$�$�$�� � � ��}�%�t�6�v�6�6��� r c � � t j � | � � t � � t j j |i |��}|S )u& Returns the current thread’s IOLoop.)r r; r< r1 �currentr> s r rB zZMQIOLoop.currentx s? � � � � � ��$�$�$�� � � ��}�$�d�5�f�5�5��� r ) r( r) r* r+ r � classmethodr= rB r, r- s @r r5 r5 ^ sx �� � � � � �� � "� "� "� "� "� � � � �[� � �� � �[�� � � � r r5 c �j � t � � t j � t � � dS )zRDEPRECATED pyzmq 17 no longer needs any special integration for tornado. N)r1 r r; r< r5 r3 r r �installrE � s) � � �M�M�M� �M���I�&�&�&�&�&r )r; r5 rE )r+ r r �typingr �tornador � tornado.logr �hasattrr; � ImportError�getattr� minitornado�minitornado.log�PeriodicCallbackr r1 r2 �__annotations__r( r5 r4 r rE r3 r r �<module>rP s= ��� � � � � � � ���� � � � � � � )��N�N�N� � � � � � �#�#�#�#�#�#� �7�6�=�"8� 9� 9� ��k� !�G�G�G�Y� �$J�$J� J� � � � �� � )� )� )�#�#�#�#�#�#�(�(�(�(�(�(�(�(�)���� �*� �"F� "F� "F� "F� "F�&� "F� "F� "F�J � � � � � � � � � ��f�o�%�%�1�1�1�1�1�1�1��m�G� &�'� &� (� (�� 7� 7�.�'�.�0�0�� '�'� &� (� (�� 7� 7�"� "� "� "� "�� "� "� "�L ��'� '� '� �f�o�%�%�7�7�7�7�7�7�7�7�7�7�7�7� &�%s �:A �A"�!A"
Save File
Cancel