/usr/lib/python2.7/dist-packages/Pyro4/configuration.py is in python2-pyro4 4.63-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 | """
Configuration settings.
Pyro - Python Remote Objects. Copyright by Irmen de Jong (irmen@razorvine.net).
"""
# Env vars used at package import time (see __init__.py):
# PYRO_LOGLEVEL (enable Pyro log config and set level)
# PYRO_LOGFILE (the name of the logfile if you don't like the default)
from __future__ import print_function
import os
import platform
import pickle
import socket
from Pyro4 import constants
class Configuration(object):
__slots__ = ("HOST", "NS_HOST", "NS_PORT", "NS_BCPORT", "NS_BCHOST", "NS_AUTOCLEAN",
"COMPRESSION", "SERVERTYPE", "COMMTIMEOUT", "POLLTIMEOUT", "ONEWAY_THREADED",
"DETAILED_TRACEBACK", "SOCK_REUSE", "SOCK_NODELAY", "PREFER_IP_VERSION",
"THREADPOOL_SIZE", "THREADPOOL_SIZE_MIN", "AUTOPROXY", "PICKLE_PROTOCOL_VERSION",
"BROADCAST_ADDRS", "NATHOST", "NATPORT", "MAX_MESSAGE_SIZE",
"FLAME_ENABLED", "SERIALIZER", "SERIALIZERS_ACCEPTED", "LOGWIRE",
"METADATA", "REQUIRE_EXPOSE", "USE_MSG_WAITALL", "JSON_MODULE",
"MAX_RETRIES", "DILL_PROTOCOL_VERSION", "ITER_STREAMING", "ITER_STREAM_LIFETIME",
"ITER_STREAM_LINGER", "SSL", "SSL_REQUIRECLIENTCERT", "SSL_CACERTS",
"SSL_SERVERCERT", "SSL_SERVERKEY", "SSL_SERVERKEYPASSWD",
"SSL_CLIENTCERT", "SSL_CLIENTKEY", "SSL_CLIENTKEYPASSWD")
def __init__(self):
self.reset()
def reset(self, useenvironment=True):
"""
Set default config items.
If useenvironment is False, won't read environment variables settings (useful if you can't trust your env).
"""
self.HOST = "localhost" # don't expose us to the outside world by default
self.NS_HOST = self.HOST
self.NS_PORT = 9090 # tcp
self.NS_BCPORT = 9091 # udp
self.NS_BCHOST = None
self.NS_AUTOCLEAN = 0.0
self.NATHOST = None
self.NATPORT = 0
self.COMPRESSION = False
self.SERVERTYPE = "thread"
self.COMMTIMEOUT = 0.0
self.POLLTIMEOUT = 2.0 # seconds
self.SOCK_REUSE = True # so_reuseaddr on server sockets?
self.SOCK_NODELAY = False # tcp_nodelay on socket?
self.ONEWAY_THREADED = True # oneway calls run in their own thread
self.DETAILED_TRACEBACK = False
self.THREADPOOL_SIZE = 40
self.THREADPOOL_SIZE_MIN = 4
self.AUTOPROXY = True
self.MAX_MESSAGE_SIZE = 0 # 0 = unlimited
self.BROADCAST_ADDRS = "<broadcast>, 0.0.0.0" # comma separated list of broadcast addresses
self.FLAME_ENABLED = False
self.PREFER_IP_VERSION = 4 # 4, 6 or 0 (let OS choose according to RFC 3484)
self.SERIALIZER = "serpent"
self.SERIALIZERS_ACCEPTED = "serpent,marshal,json" # these are the 'safe' serializers that are always available
self.LOGWIRE = False # log wire-level messages
self.PICKLE_PROTOCOL_VERSION = pickle.HIGHEST_PROTOCOL
try:
import dill
self.DILL_PROTOCOL_VERSION = dill.HIGHEST_PROTOCOL # Highest protocol
except ImportError:
self.DILL_PROTOCOL_VERSION = -1
self.METADATA = True # get metadata from server on proxy connect
self.REQUIRE_EXPOSE = True # require @expose to make members remotely accessible (if False, everything is accessible)
self.USE_MSG_WAITALL = hasattr(socket, "MSG_WAITALL") and platform.system() != "Windows" # waitall is not reliable on windows
self.JSON_MODULE = "json"
self.MAX_RETRIES = 0
self.ITER_STREAMING = True
self.ITER_STREAM_LIFETIME = 0.0
self.ITER_STREAM_LINGER = 30.0
self.SSL = False
self.SSL_SERVERCERT = ""
self.SSL_SERVERKEY = ""
self.SSL_SERVERKEYPASSWD = ""
self.SSL_REQUIRECLIENTCERT = False
self.SSL_CLIENTCERT = ""
self.SSL_CLIENTKEY = ""
self.SSL_CLIENTKEYPASSWD = ""
self.SSL_CACERTS = ""
if useenvironment:
# process environment variables
PREFIX = "PYRO_"
for symbol in self.__slots__:
if PREFIX + symbol in os.environ:
value = getattr(self, symbol)
envvalue = os.environ[PREFIX + symbol]
if value is not None:
valuetype = type(value)
if valuetype is bool:
# booleans are special
envvalue = envvalue.lower()
if envvalue in ("0", "off", "no", "false"):
envvalue = False
elif envvalue in ("1", "yes", "on", "true"):
envvalue = True
else:
raise ValueError("invalid boolean value: %s%s=%s" % (PREFIX, symbol, envvalue))
else:
envvalue = valuetype(envvalue) # just cast the value to the appropriate type
setattr(self, symbol, envvalue)
self.SERIALIZERS_ACCEPTED = set(self.SERIALIZERS_ACCEPTED.split(','))
def asDict(self):
"""returns the current config as a regular dictionary"""
result = {}
for item in self.__slots__:
result[item] = getattr(self, item)
return result
def parseAddressesString(self, addresses):
"""
Parses the addresses string which contains one or more ip addresses separated by a comma.
Returns a sequence of these addresses. '' is replaced by the empty string.
"""
result = []
for addr in addresses.split(','):
addr = addr.strip()
if addr == "''":
addr = ""
result.append(addr)
return result
def dump(self):
# easy config diagnostics
if hasattr(platform, "python_implementation"):
implementation = platform.python_implementation()
else:
implementation = "???"
config = self.asDict()
config["LOGFILE"] = os.environ.get("PYRO_LOGFILE")
config["LOGLEVEL"] = os.environ.get("PYRO_LOGLEVEL")
result = ["Pyro version: %s" % constants.VERSION,
"Loaded from: %s" % os.path.dirname(__file__),
"Python version: %s %s (%s, %s)" % (implementation, platform.python_version(), platform.system(), os.name),
"Protocol version: %d" % constants.PROTOCOL_VERSION,
"Currently active configuration settings:"]
for n, v in sorted(config.items()):
result.append("%s = %s" % (n, v))
return "\n".join(result)
config = Configuration()
# entrypoint from script
def main():
print(config.dump())
if __name__ == "__main__":
main()
|