1 # vi: encoding=utf-8 ts=8 sts=4 sw=4 et
6 from common import fileexists
11 def __init__(self, sock, authorized):
12 sock.setblocking(False)
14 self.authorized=authorized
15 self.fileno=sock.fileno
23 def handleinput(self):
26 newdata = self.sock.recv(8192)
33 self.data = self.data + newdata
48 lst.append(privlistener)
49 lst.append(publistener)
50 inlst,outlst,errlst = select.select(lst, [], [], 0.1)
53 def createlistener(path):
57 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
60 if path==ftpio.pubsock:
69 privlistener=createlistener(ftpio.privsock)
70 publistener=createlistener(ftpio.pubsock)