diff options
| author | Guido van Rossum <guido@python.org> | 1992-08-10 10:48:14 (GMT) |
|---|---|---|
| committer | Guido van Rossum <guido@python.org> | 1992-08-10 10:48:14 (GMT) |
| commit | 260cc1a85715ff856ff656b9b5f63722af6094d2 (patch) | |
| tree | 8315586241f7856f2b29f3f939d05b83da02e19a /Demo/threads/telnet.py | |
| parent | 814d7cd4921f6202a2b8f45fd5e86b725675ce83 (diff) | |
| download | cpython-260cc1a85715ff856ff656b9b5f63722af6094d2.zip cpython-260cc1a85715ff856ff656b9b5f63722af6094d2.tar.gz cpython-260cc1a85715ff856ff656b9b5f63722af6094d2.tar.bz2 | |
Initial revision
Diffstat (limited to 'Demo/threads/telnet.py')
| -rw-r--r-- | Demo/threads/telnet.py | 110 |
1 files changed, 110 insertions, 0 deletions
diff --git a/Demo/threads/telnet.py b/Demo/threads/telnet.py new file mode 100644 index 0000000..e5101eb --- /dev/null +++ b/Demo/threads/telnet.py @@ -0,0 +1,110 @@ +# Minimal interface to the Internet telnet protocol. +# +# *** modified to use threads *** +# +# It refuses all telnet options and does not recognize any of the other +# telnet commands, but can still be used to connect in line-by-line mode. +# It's also useful to play with a number of other services, +# like time, finger, smtp and even ftp. +# +# Usage: telnet host [port] +# +# The port may be a service name or a decimal port number; +# it defaults to 'telnet'. + + +import sys, os, time +from socket import * +import thread + +BUFSIZE = 8*1024 + +# Telnet protocol characters + +IAC = chr(255) # Interpret as command +DONT = chr(254) +DO = chr(253) +WONT = chr(252) +WILL = chr(251) + +def main(): + host = sys.argv[1] + try: + hostaddr = gethostbyname(host) + except error: + sys.stderr.write(sys.argv[1] + ': bad host name\n') + sys.exit(2) + # + if len(sys.argv) > 2: + servname = sys.argv[2] + else: + servname = 'telnet' + # + if '0' <= servname[:1] <= '9': + port = eval(servname) + else: + try: + port = getservbyname(servname, 'tcp') + except error: + sys.stderr.write(servname + ': bad tcp service name\n') + sys.exit(2) + # + s = socket(AF_INET, SOCK_STREAM) + # + try: + s.connect(host, port) + except error, msg: + sys.stderr.write('connect failed: ' + `msg` + '\n') + sys.exit(1) + # + thread.start_new(child, (s,)) + parent(s) + +def parent(s): + # read socket, write stdout + iac = 0 # Interpret next char as command + opt = '' # Interpret next char as option + while 1: + data, dummy = s.recvfrom(BUFSIZE) + if not data: + # EOF -- exit + sys.stderr.write( '(Closed by remote host)\n') + thread.exit_prog(1) + cleandata = '' + for c in data: + if opt: + print ord(c) + print '(replying: ' + `opt+c` + ')' + s.send(opt + c) + opt = '' + elif iac: + iac = 0 + if c == IAC: + cleandata = cleandata + c + elif c in (DO, DONT): + if c == DO: print '(DO)', + else: print '(DONT)', + opt = IAC + WONT + elif c in (WILL, WONT): + if c == WILL: print '(WILL)', + else: print '(WONT)', + opt = IAC + DONT + else: + print '(command)', ord(c) + elif c == IAC: + iac = 1 + print '(IAC)', + else: + cleandata = cleandata + c + sys.stdout.write(cleandata) + sys.stdout.flush() +## print 'Out:', `cleandata` + +def child(s): + # read stdin, write socket + while 1: + line = sys.stdin.readline() +## print 'Got:', `line` + s.send(line) + +main() |