lower () != 'yes' : # Custom address list specified, and EPICS_CA_AUTO_ADDR_LIST=NO auto_addr_list = else : # No addresses configured or EPICS_CA_AUTO_ADDR_LIST=YES if netifaces is not None : auto_addr_list = else : auto_addr_list = return list ( set ( addresses + auto_addr_list )) def get_client_address_list ( *, protocol = Protocol. auto () class Protocol ( str, _SimpleReprEnum ): PVAccess = 'PVA' ChannelAccess = 'CA' def server_env_key ( self ) -> str : """The environment variable key used for server settings.""" return _AUTO_ADDR_LIST' ] if addresses and auto_addr_list. auto () class ConversionDirection ( _SimpleReprEnum ): FROM_WIRE = enum. auto () # Special old 'sentinel' for needing more data NEED_DATA = enum. auto () SEND_CREATE_CHAN_RESPONSE = enum. auto () AWAIT_CREATE_CHAN_RESPONSE = enum. auto () class States ( _SimpleReprEnum ): SEND_SEARCH_REQUEST = enum. auto () class Direction ( _SimpleReprEnum ): RESPONSE = enum. name class Role ( _SimpleReprEnum ): CLIENT = enum. Enum ): def _repr_ ( self ): return self.
# It also defines some custom Exceptions. getLogger ( _name_ ) # This module defines sentinels used in the state machine and elsewhere, such # as NEED_DATA, CLIENT, SERVER, AWAITING_SEARCH_RESPONSE, etc.
ARRSYNC NAME WINDOWS
_version import get_versions _version_ = get_versions () try : import fcntl import termios except ImportError : fcntl = None termios = None # fcntl is unavailale on windows try : import netifaces except ImportError : netifaces = None _all_ = ( # noqa F822 'adapt_old_callback_signature', 'apply_arr_filter', 'ChannelFilter', 'get_environment_variables', 'get_address_list', 'get_local_address', 'get_beacon_address_list', 'get_client_address_list', 'get_server_address_list', 'get_netifaces_addresses', 'ensure_bytes', 'random_ports', 'bcast_socket', 'buffer_list_slice', 'incremental_buffer_list_slice', 'send_all', 'async_send_all', 'parse_record_field', 'parse_channel_filter', 'batch_requests', 'CaprotoError', 'Protocol', 'ProtocolError', 'LocalProtocolError', 'RemoteProtocolError', 'CaprotoTimeoutError', 'CaprotoKeyError', 'CaprotoAttributeError', 'CaprotoNotImplementedError', 'CaprotoValueError', 'CaprotoTypeError', 'CaprotoConversionError', 'CaprotoRuntimeError', 'CaprotoNetworkError', 'ErrorResponseReceived', 'SendAllRetry', 'RecordModifiers', 'RecordModifier', 'RecordAndField', 'ThreadsafeCounter', '_version_', # sentinels dynamically defined and added to globals() below 'CLIENT', 'SERVER', 'RESPONSE', 'REQUEST', 'NEED_DATA', 'SEND_SEARCH_REQUEST', 'AWAIT_SEARCH_RESPONSE', 'SEND_SEARCH_RESPONSE', 'SEND_VERSION_REQUEST', 'AWAIT_VERSION_RESPONSE', 'SEND_VERSION_RESPONSE', 'SEND_CREATE_CHAN_REQUEST', 'AWAIT_CREATE_CHAN_RESPONSE', 'SEND_CREATE_CHAN_RESPONSE', 'CONNECTED', 'MUST_CLOSE', 'CLOSED', 'IDLE', 'FAILED', 'DISCONNECTED' ) logger = logging. import argparse import array import collections import enum import functools import inspect import ipaddress import json import logging import os import random import socket import struct import sys import threading import typing import weakref from collections import namedtuple from contextlib import contextmanager from warnings import warn from.
# This module includes all exceptions raised by caproto, sentinel objects used # throughout the package (see detailed comment below), various network-related # helper functions, and other miscellaneous utilities.
0 kommentar(er)
