return r
def dumplatin1(self):
return self.dump().translate(self.trl1)
- def dumphtml(self,color=1):
+ def dumphtml(self,color=1,force=False):
h=self.height
w=self.width
r=""
if i%w==w-1:
span+='\n'
r='<?xml version="1.0" encoding="ISO-8859-1"?><pre class="term">%s</pre>'%r
- if self.last_html==r:
+ if self.last_html==r and not force:
return '<?xml version="1.0"?><idem></idem>'
else:
self.last_html=r
return r
class Multiplex:
- def __init__(self,cmd=None):
- signal.signal(signal.SIGCHLD, signal.SIG_IGN)
- self.cmd=cmd
+ def __init__(self):
self.proc={}
self.lock=threading.RLock()
self.thread=threading.Thread(target=self.loop)
+ self.thread.daemon=True
self.alive=1
# synchronize methods
for name in ['create','fds','proc_read','proc_write','dump','die','run']:
orig=getattr(self,name)
setattr(self,name,SynchronizedMethod(self.lock,orig))
self.thread.start()
- def create(self,w=80,h=25):
+ def create(self,cmd,w=80,h=25):
pid,fd=pty.fork()
if pid==0:
try:
os.close(i)
except OSError:
pass
- if self.cmd:
- cmd=['/bin/sh','-c',self.cmd]
- elif os.getuid()==0:
- cmd=['/bin/login']
- else:
- sys.stdout.write("Login: ")
- login=sys.stdin.readline().strip()
- if re.match('^[0-9A-Za-z-_. ]+$',login):
- cmd=['ssh']
- cmd+=['-oPreferredAuthentications=keyboard-interactive,password']
- cmd+=['-oNoHostAuthenticationForLocalhost=yes']
- cmd+=['-oLogLevel=FATAL']
- cmd+=['-F/dev/null','-l',login,'localhost']
- else:
- os._exit(0)
env={}
env["COLUMNS"]=str(w)
env["LINES"]=str(h)
os.write(fd,s)
except (IOError,OSError):
self.proc_kill(fd)
- def dump(self,fd,color=1):
+ def dump(self,fd,color=1,force=False):
try:
- return self.proc[fd]['term'].dumphtml(color)
+ return self.proc[fd]['term'].dumphtml(color, force)
except KeyError:
return False
def loop(self):