/usr/lib/python3/dist-packages/SocketMap.py is in python3-srs 1.0.3-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 | # Copyright (c) 2004-2010 Business Management Systems. All rights reserved.
#
# This program is free software; you can redistribute it and/or modify
# it under the same terms as Python itself.
#
# Base class for sendmail socket servers
try:
import socketserver
except:
import SocketServer as socketserver
class MapError(Exception):
def __init__(self,code,reason):
self.code = code
self.reason = reason
class Handler(socketserver.StreamRequestHandler):
def write(self,s):
"write netstring to socket"
self.wfile.write('%d:%s,' % (len(s),s))
self.log(s)
def _readlen(self,maxlen=8):
"read netstring length from socket"
n = ""
file = self.rfile
ch = file.read(1)
while ch != ":":
if not ch:
raise EOFError
if not ch in "0123456789":
raise ValueError
if len(n) >= maxlen:
raise OverflowError
n += ch
ch = file.read(1)
return int(n)
def read(self, maxlen=None):
"Read a netstring from the socket, and return the extracted netstring."
n = self._readlen()
if maxlen and n > maxlen:
raise OverflowError
file = self.rfile
s = file.read(n)
ch = file.read(1)
if ch == ',':
return s
if ch == "":
raise EOFError
raise ValueError
def handle(self):
#self.log("connect")
while True:
try:
line = self.read()
self.log(line)
args = line.split(' ',1)
map = args.pop(0).replace('-','_')
meth = getattr(self, '_handle_' + map, None)
if not map:
raise ValueError("Unrecognized map: %s" % map)
res = meth(*args)
self.write('OK ' + res)
except EOFError:
#self.log("Ending connection")
return
except MapError as x:
if code in ('PERM','TIMEOUT','NOTFOUND','OK','TEMP'):
self.write("%s %s"%(x.code,x.reason))
else:
self.write("%s %s %s"%('PERM',x.code,x.reason))
except LookupError as x:
self.write("NOTFOUND")
except Exception as x:
#print x
self.write("TEMP %s"%x)
# PERM,TIMEOUT
# Application should subclass SocketMap.Daemon, and define
# a _handler_map_name method for each sendmail socket map handled
# by this server. The socket is a unix domain socket which must match
# the socket defined in sendmail.cf.
#
# Socket maps in sendmail.cf look like this:
# Kmy_map socket local:/tmp/sockd
class Daemon(object):
def __init__(self,socket,handlerfactory):
self.socket = socket
try:
os.unlink(socket)
except: pass
self.server = socketserver.ThreadingUnixStreamServer(socket,handlerfactory)
self.server.daemon = self
def run(self):
self.server.serve_forever()
|