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
21 def handleinput(self):
23 newdata=self.sock.recv(8192)
28 self.data=self.data+newdata
42 lst.append(privlistener)
43 lst.append(publistener)
44 inlst,outlst,errlst = select.select(lst, [], [], 0.1)
47 def createlistener(path):
51 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
54 if path==ftpio.pubsock:
63 privlistener=createlistener(ftpio.privsock)
64 publistener=createlistener(ftpio.pubsock)