���ѧۧݧ�ӧ�� �ާ֧ߧ֧էا֧� - ���֧էѧܧ�ڧ��ӧѧ�� - /home/ukubnwwtacc0unt/chapelbellstudios.com/uploads/cover/sockets.zip
���ѧ٧ѧ�
PK *�\� ��� � unicast.pyonu �[��� � ��^c @ s� d Z d d l Z d d l Z d d l Te e e � Z e j d � x= e e j � � d Z e j e d e f � e j d � qG Wd S( iP� i����N( t *t i s i ( R i ( t MYPORTt syst timet sockett AF_INETt SOCK_DGRAMt st bindt reprt datat sendtot sleep( ( ( s, /usr/lib64/python2.7/Demo/sockets/unicast.pyt <module> s PK *�\)�a�� � radio.pyonu �[��� � ��^c @ s� d Z d d l Z d d l Te e e � Z e j d e f � xF e j d d � \ Z Z e j j e e � d � e j j e � qA Wd S( iP� i����N( t *t i� i s ( t MYPORTt syst sockett AF_INETt SOCK_DGRAMt st bindt recvfromt datat wherefromt stderrt writet reprt stdout( ( ( s* /usr/lib64/python2.7/Demo/sockets/radio.pyt <module> s PK *�\�'}&Q Q unixserver.pyonu �[��� � ��^c @ s� d d l Z d d l Td Z e e e � Z e j e � d e j � d GHe j d � e j � \ Z Z x0 e r� e j d � Z e s� Pn e j e � qm We j � e j e � d S( i����N( t *s unix-sockets Sock name is: [t ]i i ( t ost sockett FILEt AF_UNIXt SOCK_STREAMt st bindt getsocknamet listent acceptt connt addrt Truet recvt datat sendt closet unlink( ( ( s/ /usr/lib64/python2.7/Demo/sockets/unixserver.pyt <module> s PK *�\���l� � unicast.pynu �[��� # Send UDP broadcast packets MYPORT = 50000 import sys, time from socket import * s = socket(AF_INET, SOCK_DGRAM) s.bind(('', 0)) while 1: data = repr(time.time()) + '\n' s.sendto(data, ('', MYPORT)) time.sleep(2) PK *�\\�-� � unixclient.pyonu �[��� � ��^c @ se d d l Td Z e e e � Z e j e � e j d � e j d � Z e j � d Ge e � GHd S( i����( t *s unix-sockets Hello, worldi t ReceivedN( t sockett FILEt AF_UNIXt SOCK_STREAMt st connectt sendt recvt datat closet repr( ( ( s/ /usr/lib64/python2.7/Demo/sockets/unixclient.pyt <module> s PK *�\�U� � telnet.pynu ȯ�� #! /usr/bin/python2.7 # Minimal interface to the Internet telnet protocol. # # 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, posix, time from socket import * BUFSIZE = 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: ' + repr(msg) + '\n') sys.exit(1) # pid = posix.fork() # if pid == 0: # child -- read stdin, write socket while 1: line = sys.stdin.readline() s.send(line) else: # parent -- read socket, write stdout iac = 0 # Interpret next char as command opt = '' # Interpret next char as option while 1: data = s.recv(BUFSIZE) if not data: # EOF; kill child and exit sys.stderr.write( '(Closed by remote host)\n') posix.kill(pid, 9) sys.exit(1) cleandata = '' for c in data: if opt: print ord(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() try: main() except KeyboardInterrupt: pass PK *�\� '�� � rpython.pynu ȯ�� #! /usr/bin/python2.7 # Remote python client. # Execute Python commands remotely and send output back. import sys import string from socket import * PORT = 4127 BUFSIZE = 1024 def main(): if len(sys.argv) < 3: print "usage: rpython host command" sys.exit(2) host = sys.argv[1] port = PORT i = string.find(host, ':') if i >= 0: port = string.atoi(port[i+1:]) host = host[:i] command = string.join(sys.argv[2:]) s = socket(AF_INET, SOCK_STREAM) s.connect((host, port)) s.send(command) s.shutdown(1) reply = '' while 1: data = s.recv(BUFSIZE) if not data: break reply = reply + data print reply, main() PK *�\[g��y y mcast.pyonu �[��� � A fc @ s} d Z d Z d Z d Z d d l Z d d l Z d d l Z d d l Z d � Z d � Z d � Z e d k ry e � n d S( i� s 225.0.0.250s' ff15:7079:7468:6f6e:6465:6d6f:6d63:6173i i����Nc C sM d t j d k r t n t } d t j d k r? t | � n t | � d S( Ns -6i s -s( t syst argvt MYGROUP_6t MYGROUP_4t sendert receiver( t group( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyt main s c C s� t j | d � d } t j | d t j � } t j d t � } | d t j k rp | j t j t j | � n | j t j t j | � xK t r� t t j � � } | j | d | d d t f � t j d � q� Wd S( Ni s @is i i ( t sockett getaddrinfot Nonet SOCK_DGRAMt structt packt MYTTLt AF_INETt setsockoptt IPPROTO_IPt IP_MULTICAST_TTLt IPPROTO_IPV6t IPV6_MULTICAST_HOPSt Truet reprt timet sendtot MYPORTt sleep( R t addrinfot st ttl_bint data( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyR s "c C sP t j | d � d } t j | d t j � } | j t j t j d � | j d t f � t j | d | d d � } | d t j k r� | t j d t j � } | j t j t j | � n/ | t j d d � } | j t j t j | � xY t rK| j d � \ } } x | d d k r.| d } qWt | � d t | � GHq� Wd S( Ni i t i s =Is @Ii� i����s s ( R R R R R t SOL_SOCKETt SO_REUSEADDRt bindR t inet_ptonR R R t INADDR_ANYR t IP_ADD_MEMBERSHIPR t IPV6_JOIN_GROUPR t recvfromt strR ( R R R t group_bint mreqR R ( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyR 1 s t __main__( R R R R R R R R R R R t __name__( ( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyt <module> s PK *�\��FG� � udpecho.pyonu �[��� � A fc @ sQ d d l Z d d l Td Z d Z d � Z d � Z d � Z d � Z e � d S( i����N( t *iP� i i c C sd t t j � d k r t � n t j d d k r< t � n$ t j d d k rY t � n t � d S( Ni i s -ss -c( t lent syst argvt usaget servert client( ( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyt main s c C s' t j t _ d GHd GHt j d � d S( Ns, Usage: udpecho -s [port] (server)s, or: udpecho -c host [port] <file (client)i ( R t stderrt stdoutt exit( ( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyR s c C s� t t j � d k r+ t t j d � } n t } t t t � } | j d | f � d GHx8 | j t � \ } } d | | f GH| j | | � q[ Wd S( Ni t s udp echo server readys server received %r from %r( R R R t evalt ECHO_PORTt sockett AF_INETt SOCK_DGRAMt bindt recvfromt BUFSIZEt sendto( t portt st datat addr( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyR s c C s� t t j � d k r t � n t j d } t t j � d k rW t t j d � } n t } | | f } t t t � } | j d � d GHxQ t j j � } | s� Pn | j | | � | j t � \ } } d | | f GHq� Wd S( Ni i R i s$ udp echo client ready, reading stdins client received %r from %r( R i ( R R R R R R R R R R t stdint readlineR R R ( t hostR R R t lineR t fromaddr( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyR + s" iW� ( R R R R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyt <module> s PK *�\���$ $ throughput.pynu ȯ�� #! /usr/bin/python2.7 # Test network throughput. # # Usage: # 1) on host_A: throughput -s [port] # start a server # 2) on host_B: throughput -c count host_A [port] # start a client # # The server will service multiple clients until it is killed. # # The client performs one transfer of count*BUFSIZE bytes and # measures the time it takes (roundtrip!). import sys, time from socket import * MY_PORT = 50000 + 42 BUFSIZE = 1024 def main(): if len(sys.argv) < 2: usage() if sys.argv[1] == '-s': server() elif sys.argv[1] == '-c': client() else: usage() def usage(): sys.stdout = sys.stderr print 'Usage: (on host_A) throughput -s [port]' print 'and then: (on host_B) throughput -c count host_A [port]' sys.exit(2) def server(): if len(sys.argv) > 2: port = eval(sys.argv[2]) else: port = MY_PORT s = socket(AF_INET, SOCK_STREAM) s.bind(('', port)) s.listen(1) print 'Server ready...' while 1: conn, (host, remoteport) = s.accept() while 1: data = conn.recv(BUFSIZE) if not data: break del data conn.send('OK\n') conn.close() print 'Done with', host, 'port', remoteport def client(): if len(sys.argv) < 4: usage() count = int(eval(sys.argv[2])) host = sys.argv[3] if len(sys.argv) > 4: port = eval(sys.argv[4]) else: port = MY_PORT testdata = 'x' * (BUFSIZE-1) + '\n' t1 = time.time() s = socket(AF_INET, SOCK_STREAM) t2 = time.time() s.connect((host, port)) t3 = time.time() i = 0 while i < count: i = i+1 s.send(testdata) s.shutdown(1) # Send EOF t4 = time.time() data = s.recv(BUFSIZE) t5 = time.time() print data print 'Raw timers:', t1, t2, t3, t4, t5 print 'Intervals:', t2-t1, t3-t2, t4-t3, t5-t4 print 'Total:', t5-t1 print 'Throughput:', round((BUFSIZE*count*0.001) / (t5-t1), 3), print 'K/sec.' main() PK *�\��C broadcast.pynu �[��� # Send UDP broadcast packets MYPORT = 50000 import sys, time from socket import * s = socket(AF_INET, SOCK_DGRAM) s.bind(('', 0)) s.setsockopt(SOL_SOCKET, SO_BROADCAST, 1) while 1: data = repr(time.time()) + '\n' s.sendto(data, ('<broadcast>', MYPORT)) time.sleep(2) PK *�\[g��y y mcast.pycnu �[��� � A fc @ s} d Z d Z d Z d Z d d l Z d d l Z d d l Z d d l Z d � Z d � Z d � Z e d k ry e � n d S( i� s 225.0.0.250s' ff15:7079:7468:6f6e:6465:6d6f:6d63:6173i i����Nc C sM d t j d k r t n t } d t j d k r? t | � n t | � d S( Ns -6i s -s( t syst argvt MYGROUP_6t MYGROUP_4t sendert receiver( t group( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyt main s c C s� t j | d � d } t j | d t j � } t j d t � } | d t j k rp | j t j t j | � n | j t j t j | � xK t r� t t j � � } | j | d | d d t f � t j d � q� Wd S( Ni s @is i i ( t sockett getaddrinfot Nonet SOCK_DGRAMt structt packt MYTTLt AF_INETt setsockoptt IPPROTO_IPt IP_MULTICAST_TTLt IPPROTO_IPV6t IPV6_MULTICAST_HOPSt Truet reprt timet sendtot MYPORTt sleep( R t addrinfot st ttl_bint data( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyR s "c C sP t j | d � d } t j | d t j � } | j t j t j d � | j d t f � t j | d | d d � } | d t j k r� | t j d t j � } | j t j t j | � n/ | t j d d � } | j t j t j | � xY t rK| j d � \ } } x | d d k r.| d } qWt | � d t | � GHq� Wd S( Ni i t i s =Is @Ii� i����s s ( R R R R R t SOL_SOCKETt SO_REUSEADDRt bindR t inet_ptonR R R t INADDR_ANYR t IP_ADD_MEMBERSHIPR t IPV6_JOIN_GROUPR t recvfromt strR ( R R R t group_bint mreqR R ( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyR 1 s t __main__( R R R R R R R R R R R t __name__( ( ( s* /usr/lib64/python2.7/Demo/sockets/mcast.pyt <module> s PK *�\��^�X X ftp.pynu �[��� # A simple FTP client. # # The information to write this program was gathered from RFC 959, # but this is not a complete implementation! Yet it shows how a simple # FTP client can be built, and you are welcome to extend it to suit # it to your needs... # # How it works (assuming you've read the RFC): # # User commands are passed uninterpreted to the server. However, the # user never needs to send a PORT command. Rather, the client opens a # port right away and sends the appropriate PORT command to the server. # When a response code 150 is received, this port is used to receive # the data (which is written to stdout in this version), and when the # data is exhausted, a new port is opened and a corresponding PORT # command sent. In order to avoid errors when reusing ports quickly # (and because there is no s.getsockname() method in Python yet) we # cycle through a number of ports in the 50000 range. import sys, posix, string from socket import * BUFSIZE = 1024 # Default port numbers used by the FTP protocol. # FTP_PORT = 21 FTP_DATA_PORT = FTP_PORT - 1 # Change the data port to something not needing root permissions. # FTP_DATA_PORT = FTP_DATA_PORT + 50000 # Main program (called at the end of this file). # def main(): hostname = sys.argv[1] control(hostname) # Control process (user interface and user protocol interpreter). # def control(hostname): # # Create control connection # s = socket(AF_INET, SOCK_STREAM) s.connect((hostname, FTP_PORT)) f = s.makefile('r') # Reading the replies is easier from a file... # # Control loop # r = None while 1: code = getreply(f) if code in ('221', 'EOF'): break if code == '150': getdata(r) code = getreply(f) r = None if not r: r = newdataport(s, f) cmd = getcommand() if not cmd: break s.send(cmd + '\r\n') # Create a new data port and send a PORT command to the server for it. # (Cycle through a number of ports to avoid problems with reusing # a port within a short time.) # nextport = 0 # def newdataport(s, f): global nextport port = nextport + FTP_DATA_PORT nextport = (nextport+1) % 16 r = socket(AF_INET, SOCK_STREAM) r.bind((gethostbyname(gethostname()), port)) r.listen(1) sendportcmd(s, f, port) return r # Send an appropriate port command. # def sendportcmd(s, f, port): hostname = gethostname() hostaddr = gethostbyname(hostname) hbytes = string.splitfields(hostaddr, '.') pbytes = [repr(port//256), repr(port%256)] bytes = hbytes + pbytes cmd = 'PORT ' + string.joinfields(bytes, ',') s.send(cmd + '\r\n') code = getreply(f) # Process an ftp reply and return the 3-digit reply code (as a string). # The reply should be a line of text starting with a 3-digit number. # If the 4th char is '-', it is a multi-line reply and is # terminate by a line starting with the same 3-digit number. # Any text while receiving the reply is echoed to the file. # def getreply(f): line = f.readline() if not line: return 'EOF' print line, code = line[:3] if line[3:4] == '-': while 1: line = f.readline() if not line: break # Really an error print line, if line[:3] == code and line[3:4] != '-': break return code # Get the data from the data connection. # def getdata(r): print '(accepting data connection)' conn, host = r.accept() print '(data connection accepted)' while 1: data = conn.recv(BUFSIZE) if not data: break sys.stdout.write(data) print '(end of data connection)' # Get a command from the user. # def getcommand(): try: while 1: line = raw_input('ftp.py> ') if line: return line except EOFError: return '' # Call the main program. # main() PK *�\�j{� � echosvr.pynu ȯ�� #! /usr/bin/python2.7 # Python implementation of an 'echo' tcp server: echo all data it receives. # # This is the simplest possible server, servicing a single request only. import sys from socket import * # The standard echo port isn't very useful, it requires root permissions! # ECHO_PORT = 7 ECHO_PORT = 50000 + 7 BUFSIZE = 1024 def main(): if len(sys.argv) > 1: port = int(eval(sys.argv[1])) else: port = ECHO_PORT s = socket(AF_INET, SOCK_STREAM) s.bind(('', port)) s.listen(1) conn, (remotehost, remoteport) = s.accept() print 'connected by', remotehost, remoteport while 1: data = conn.recv(BUFSIZE) if not data: break conn.send(data) main() PK *�\.)S; ; echosvr.pyonu �[��� � A fc @ s6 d d l Z d d l Td Z d Z d � Z e � d S( i����N( t *iP� i i c C s� t t j � d k r1 t t t j d � � } n t } t t t � } | j d | f � | j d � | j � \ } \ } } d G| G| GHx* | j t � } | s� Pn | j | � q� Wd S( Ni t s connected by( t lent syst argvt intt evalt ECHO_PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt send( t portt st connt remotehostt remoteportt data( ( s, /usr/lib64/python2.7/Demo/sockets/echosvr.pyt main s iW� ( R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/sockets/echosvr.pyt <module> s PK *�\�Yڎe e telnet.pyonu �[��� � A fc @ s� d d l Z d d l Z d d l Z d d l Td Z e d � Z e d � Z e d � Z e d � Z e d � Z d � Z y e � Wn e k r� n Xd S( i����N( t *i i� i� i� i� i� c C s! t j d } y t | � } Wn9 t k rX t j j t j d d � t j d � n Xt t j � d k r~ t j d } n d } d | d k o� d k n r� t | � } nH y t | d � } Wn2 t k r� t j j | d � t j d � n Xt t t � } y | j | | f � Wn> t k ra} t j j d t | � d � t j d � n Xt j � } | d k r�x�t j j � } | j | � q}Wn}d } d } xn| j t � } | s�t j j d � t j | d � t j d � n d } x� | D]� } | r2t | � GH| j | | � d } q| r�d } | t k rW| | } q�| t t f k r�| t k r|d Gn d Gt t } q�| t t f k r�| t k r�d Gn d Gt t } q�d Gt | � GHq| t k r�d } d Gq| | } qWt j j | � t j j � q�Wd S( Ni s : bad host name i t telnett 0t 9t tcps : bad tcp service name s connect failed: s i t s (Closed by remote host) i s (DO)s (DONT)s (WILL)s (WONT)s (command)s (IAC)( t syst argvt gethostbynamet errort stderrt writet exitt lent evalt getservbynamet sockett AF_INETt SOCK_STREAMt connectt reprt posixt forkt stdint readlinet sendt recvt BUFSIZEt killt ordt IACt DOt DONTt WONTt WILLt stdoutt flush( t hostt hostaddrt servnamet portt st msgt pidt linet iact optt datat cleandatat c( ( s+ /usr/lib64/python2.7/Demo/sockets/telnet.pyt main s| ( R R t timeR R t chrR R R R! R" R2 t KeyboardInterrupt( ( ( s+ /usr/lib64/python2.7/Demo/sockets/telnet.pyt <module> s $ M PK *�\q�<�� � finger.pyonu �[��� � A fc @ sE d d l Z d d l Z d d l Td Z d � Z d � Z e � d S( i����N( t *iO c C st t t t � } | j | t f � | j | d � x- | j d � } | sO Pn t j j | � q6 Wt j j � d S( Ns i ( t sockett AF_INETt SOCK_STREAMt connectt FINGER_PORTt sendt recvt syst stdoutt writet flush( t hostt argst st buf( ( s+ /usr/lib64/python2.7/Demo/sockets/finger.pyt finger s c C s� d } d } xO | t t j � k r] t j | d d k r] | t j | d } | d } q Wt j | } | s} d g } n x^ | D]V } d | k r� t j | d � } | | d } | | } n d } t | | | � q� Wd S( Nt i t -t t @( t lenR t argvt stringt indexR ( t optionst iR t argt atR ( ( s+ /usr/lib64/python2.7/Demo/sockets/finger.pyt main% s / ( R R R R R R ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/finger.pyt <module> s PK *�\�vt t READMEnu �[��� This directory contains some demonstrations of the socket module: broadcast.py Broadcast the time to radio.py. echosvr.py About the simplest TCP server possible. finger.py Client for the 'finger' protocol. ftp.py A very simple ftp client. gopher.py A simple gopher client. mcast.py IPv4/v6 multicast example radio.py Receive time broadcasts from broadcast.py. telnet.py Client for the 'telnet' protocol. throughput.py Client and server to measure TCP throughput. unixclient.py Unix socket example, client side unixserver.py Unix socket example, server side udpecho.py Client and server for the UDP echo protocol. PK *�\.)S; ; echosvr.pycnu �[��� � A fc @ s6 d d l Z d d l Td Z d Z d � Z e � d S( i����N( t *iP� i i c C s� t t j � d k r1 t t t j d � � } n t } t t t � } | j d | f � | j d � | j � \ } \ } } d G| G| GHx* | j t � } | s� Pn | j | � q� Wd S( Ni t s connected by( t lent syst argvt intt evalt ECHO_PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt send( t portt st connt remotehostt remoteportt data( ( s, /usr/lib64/python2.7/Demo/sockets/echosvr.pyt main s iW� ( R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/sockets/echosvr.pyt <module> s PK *�\~h�D7& 7& gopher.pynu ȯ�� #! /usr/bin/python2.7 # A simple gopher client. # # Usage: gopher [ [selector] host [port] ] import string import sys import os import socket # Default selector, host and port DEF_SELECTOR = '' DEF_HOST = 'gopher.micro.umn.edu' DEF_PORT = 70 # Recognized file types T_TEXTFILE = '0' T_MENU = '1' T_CSO = '2' T_ERROR = '3' T_BINHEX = '4' T_DOS = '5' T_UUENCODE = '6' T_SEARCH = '7' T_TELNET = '8' T_BINARY = '9' T_REDUNDANT = '+' T_SOUND = 's' # Dictionary mapping types to strings typename = {'0': '<TEXT>', '1': '<DIR>', '2': '<CSO>', '3': '<ERROR>', \ '4': '<BINHEX>', '5': '<DOS>', '6': '<UUENCODE>', '7': '<SEARCH>', \ '8': '<TELNET>', '9': '<BINARY>', '+': '<REDUNDANT>', 's': '<SOUND>'} # Oft-used characters and strings CRLF = '\r\n' TAB = '\t' # Open a TCP connection to a given host and port def open_socket(host, port): if not port: port = DEF_PORT elif type(port) == type(''): port = string.atoi(port) s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect((host, port)) return s # Send a selector to a given host and port, return a file with the reply def send_request(selector, host, port): s = open_socket(host, port) s.send(selector + CRLF) s.shutdown(1) return s.makefile('r') # Get a menu in the form of a list of entries def get_menu(selector, host, port): f = send_request(selector, host, port) list = [] while 1: line = f.readline() if not line: print '(Unexpected EOF from server)' break if line[-2:] == CRLF: line = line[:-2] elif line[-1:] in CRLF: line = line[:-1] if line == '.': break if not line: print '(Empty line from server)' continue typechar = line[0] parts = string.splitfields(line[1:], TAB) if len(parts) < 4: print '(Bad line from server: %r)' % (line,) continue if len(parts) > 4: print '(Extra info from server: %r)' % (parts[4:],) parts.insert(0, typechar) list.append(parts) f.close() return list # Get a text file as a list of lines, with trailing CRLF stripped def get_textfile(selector, host, port): list = [] get_alt_textfile(selector, host, port, list.append) return list # Get a text file and pass each line to a function, with trailing CRLF stripped def get_alt_textfile(selector, host, port, func): f = send_request(selector, host, port) while 1: line = f.readline() if not line: print '(Unexpected EOF from server)' break if line[-2:] == CRLF: line = line[:-2] elif line[-1:] in CRLF: line = line[:-1] if line == '.': break if line[:2] == '..': line = line[1:] func(line) f.close() # Get a binary file as one solid data block def get_binary(selector, host, port): f = send_request(selector, host, port) data = f.read() f.close() return data # Get a binary file and pass each block to a function def get_alt_binary(selector, host, port, func, blocksize): f = send_request(selector, host, port) while 1: data = f.read(blocksize) if not data: break func(data) # A *very* simple interactive browser # Browser main command, has default arguments def browser(*args): selector = DEF_SELECTOR host = DEF_HOST port = DEF_PORT n = len(args) if n > 0 and args[0]: selector = args[0] if n > 1 and args[1]: host = args[1] if n > 2 and args[2]: port = args[2] if n > 3: raise RuntimeError, 'too many args' try: browse_menu(selector, host, port) except socket.error, msg: print 'Socket error:', msg sys.exit(1) except KeyboardInterrupt: print '\n[Goodbye]' # Browse a menu def browse_menu(selector, host, port): list = get_menu(selector, host, port) while 1: print '----- MENU -----' print 'Selector:', repr(selector) print 'Host:', host, ' Port:', port print for i in range(len(list)): item = list[i] typechar, description = item[0], item[1] print string.rjust(repr(i+1), 3) + ':', description, if typename.has_key(typechar): print typename[typechar] else: print '<TYPE=' + repr(typechar) + '>' print while 1: try: str = raw_input('Choice [CR == up a level]: ') except EOFError: print return if not str: return try: choice = string.atoi(str) except string.atoi_error: print 'Choice must be a number; try again:' continue if not 0 < choice <= len(list): print 'Choice out of range; try again:' continue break item = list[choice-1] typechar = item[0] [i_selector, i_host, i_port] = item[2:5] if typebrowser.has_key(typechar): browserfunc = typebrowser[typechar] try: browserfunc(i_selector, i_host, i_port) except (IOError, socket.error): print '***', sys.exc_type, ':', sys.exc_value else: print 'Unsupported object type' # Browse a text file def browse_textfile(selector, host, port): x = None try: p = os.popen('${PAGER-more}', 'w') x = SaveLines(p) get_alt_textfile(selector, host, port, x.writeln) except IOError, msg: print 'IOError:', msg if x: x.close() f = open_savefile() if not f: return x = SaveLines(f) try: get_alt_textfile(selector, host, port, x.writeln) print 'Done.' except IOError, msg: print 'IOError:', msg x.close() # Browse a search index def browse_search(selector, host, port): while 1: print '----- SEARCH -----' print 'Selector:', repr(selector) print 'Host:', host, ' Port:', port print try: query = raw_input('Query [CR == up a level]: ') except EOFError: print break query = string.strip(query) if not query: break if '\t' in query: print 'Sorry, queries cannot contain tabs' continue browse_menu(selector + TAB + query, host, port) # "Browse" telnet-based information, i.e. open a telnet session def browse_telnet(selector, host, port): if selector: print 'Log in as', repr(selector) if type(port) <> type(''): port = repr(port) sts = os.system('set -x; exec telnet ' + host + ' ' + port) if sts: print 'Exit status:', sts # "Browse" a binary file, i.e. save it to a file def browse_binary(selector, host, port): f = open_savefile() if not f: return x = SaveWithProgress(f) get_alt_binary(selector, host, port, x.write, 8*1024) x.close() # "Browse" a sound file, i.e. play it or save it def browse_sound(selector, host, port): browse_binary(selector, host, port) # Dictionary mapping types to browser functions typebrowser = {'0': browse_textfile, '1': browse_menu, \ '4': browse_binary, '5': browse_binary, '6': browse_textfile, \ '7': browse_search, \ '8': browse_telnet, '9': browse_binary, 's': browse_sound} # Class used to save lines, appending a newline to each line class SaveLines: def __init__(self, f): self.f = f def writeln(self, line): self.f.write(line + '\n') def close(self): sts = self.f.close() if sts: print 'Exit status:', sts # Class used to save data while showing progress class SaveWithProgress: def __init__(self, f): self.f = f def write(self, data): sys.stdout.write('#') sys.stdout.flush() self.f.write(data) def close(self): print sts = self.f.close() if sts: print 'Exit status:', sts # Ask for and open a save file, or return None if not to save def open_savefile(): try: savefile = raw_input( \ 'Save as file [CR == don\'t save; |pipeline or ~user/... OK]: ') except EOFError: print return None savefile = string.strip(savefile) if not savefile: return None if savefile[0] == '|': cmd = string.strip(savefile[1:]) try: p = os.popen(cmd, 'w') except IOError, msg: print repr(cmd), ':', msg return None print 'Piping through', repr(cmd), '...' return p if savefile[0] == '~': savefile = os.path.expanduser(savefile) try: f = open(savefile, 'w') except IOError, msg: print repr(savefile), ':', msg return None print 'Saving to', repr(savefile), '...' return f # Test program def test(): if sys.argv[4:]: print 'usage: gopher [ [selector] host [port] ]' sys.exit(2) elif sys.argv[3:]: browser(sys.argv[1], sys.argv[2], sys.argv[3]) elif sys.argv[2:]: try: port = string.atoi(sys.argv[2]) selector = '' host = sys.argv[1] except string.atoi_error: selector = sys.argv[1] host = sys.argv[2] port = '' browser(selector, host, port) elif sys.argv[1:]: browser('', sys.argv[1]) else: browser() # Call the test program as a main program test() PK *�\�Se�� � rpython.pyonu �[��� � A fc @ sB d d l Z d d l Z d d l Td Z d Z d � Z e � d S( i����N( t *i i c C s t t j � d k r* d GHt j d � n t j d } t } t j | d � } | d k r t j | | d � } | | } n t j t j d � } t t t � } | j | | f � | j | � | j d � d } x' | j t � } | s� Pn | | } q� W| Gd S( Ni s usage: rpython host commandi i t :i t ( t lent syst argvt exitt PORTt stringt findt atoit joint sockett AF_INETt SOCK_STREAMt connectt sendt shutdownt recvt BUFSIZE( t hostt portt it commandt st replyt data( ( s, /usr/lib64/python2.7/Demo/sockets/rpython.pyt main s* ( R R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/sockets/rpython.pyt <module> s PK *�\I��t� � unixserver.pynu �[��� # Echo server demo using Unix sockets (handles one connection only) # Piet van Oostrum import os from socket import * FILE = 'unix-socket' s = socket(AF_UNIX, SOCK_STREAM) s.bind(FILE) print 'Sock name is: ['+s.getsockname()+']' # Wait for a connection s.listen(1) conn, addr = s.accept() while True: data = conn.recv(1024) if not data: break conn.send(data) conn.close() os.unlink(FILE) PK *�\���# # broadcast.pycnu �[��� � ��^c @ s� d Z d d l Z d d l Z d d l Te e e � Z e j d � e j e e d � x= e e j � � d Z e j e d e f � e j d � qZ Wd S( iP� i����N( t *t i i s s <broadcast>i ( R i ( t MYPORTt syst timet sockett AF_INETt SOCK_DGRAMt st bindt setsockoptt SOL_SOCKETt SO_BROADCASTt reprt datat sendtot sleep( ( ( s. /usr/lib64/python2.7/Demo/sockets/broadcast.pyt <module> s PK *�\�IA}� � unixclient.pynu �[��� # Echo client demo using Unix sockets # Piet van Oostrum from socket import * FILE = 'unix-socket' s = socket(AF_UNIX, SOCK_STREAM) s.connect(FILE) s.send('Hello, world') data = s.recv(1024) s.close() print 'Received', repr(data) PK *�\)�a�� � radio.pycnu �[��� � ��^c @ s� d Z d d l Z d d l Te e e � Z e j d e f � xF e j d d � \ Z Z e j j e e � d � e j j e � qA Wd S( iP� i����N( t *t i� i s ( t MYPORTt syst sockett AF_INETt SOCK_DGRAMt st bindt recvfromt datat wherefromt stderrt writet reprt stdout( ( ( s* /usr/lib64/python2.7/Demo/sockets/radio.pyt <module> s PK *�\� ��� � unicast.pycnu �[��� � ��^c @ s� d Z d d l Z d d l Z d d l Te e e � Z e j d � x= e e j � � d Z e j e d e f � e j d � qG Wd S( iP� i����N( t *t i s i ( R i ( t MYPORTt syst timet sockett AF_INETt SOCK_DGRAMt st bindt reprt datat sendtot sleep( ( ( s, /usr/lib64/python2.7/Demo/sockets/unicast.pyt <module> s PK *�\���# # broadcast.pyonu �[��� � ��^c @ s� d Z d d l Z d d l Z d d l Te e e � Z e j d � e j e e d � x= e e j � � d Z e j e d e f � e j d � qZ Wd S( iP� i����N( t *t i i s s <broadcast>i ( R i ( t MYPORTt syst timet sockett AF_INETt SOCK_DGRAMt st bindt setsockoptt SOL_SOCKETt SO_BROADCASTt reprt datat sendtot sleep( ( ( s. /usr/lib64/python2.7/Demo/sockets/broadcast.pyt <module> s PK *�\��c� � rpythond.pynu ȯ�� #! /usr/bin/python2.7 # Remote python server. # Execute Python commands remotely and send output back. # WARNING: This version has a gaping security hole -- it accepts requests # from any host on the Internet! import sys from socket import * import StringIO import traceback PORT = 4127 BUFSIZE = 1024 def main(): if len(sys.argv) > 1: port = int(eval(sys.argv[1])) else: port = PORT s = socket(AF_INET, SOCK_STREAM) s.bind(('', port)) s.listen(1) while 1: conn, (remotehost, remoteport) = s.accept() print 'connected by', remotehost, remoteport request = '' while 1: data = conn.recv(BUFSIZE) if not data: break request = request + data reply = execute(request) conn.send(reply) conn.close() def execute(request): stdout = sys.stdout stderr = sys.stderr sys.stdout = sys.stderr = fakefile = StringIO.StringIO() try: try: exec request in {}, {} except: print traceback.print_exc(100) finally: sys.stderr = stderr sys.stdout = stdout return fakefile.getvalue() main() PK *�\�Hz� � ftp.pyonu �[��� � ��^c @ s� d d l Z d d l Z d d l Z d d l Td Z d Z e d Z e d Z d � Z d � Z d a d � Z d � Z d � Z d � Z d � Z e � d S( i����N( t *i i i iP� c C s t j d } t | � d S( Ni ( t syst argvt control( t hostname( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyt main' s c C s� t t t � } | j | t f � | j d � } d } x� t | � } | d k rV Pn | d k r� t | � t | � } d } n | s� t | | � } n t � } | s� Pn | j | d � q: Wd S( Nt rt 221t EOFt 150s ( R R ( t sockett AF_INETt SOCK_STREAMt connectt FTP_PORTt makefilet Nonet getreplyt getdatat newdataportt getcommandt send( R t st fR t codet cmd( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR . s$ i c C sd t t } t d d a t t t � } | j t t � � | f � | j d � t | | | � | S( Ni i ( t nextportt FTP_DATA_PORTR R R t bindt gethostbynamet gethostnamet listent sendportcmd( R R t portR ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR M s c C s� t � } t | � } t j | d � } t | d � t | d � g } | | } d t j | d � } | j | d � t | � } d S( Nt .i s PORT t ,s ( R R t stringt splitfieldst reprt joinfieldsR R ( R R R! R t hostaddrt hbytest pbytest bytesR R ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR Z s c C s� | j � } | s d S| G| d } | d d !d k r� xH | j � } | sP Pn | G| d | k r: | d d !d k r: Pq: q: Wn | S( NR i i t -( t readline( R t lineR ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR k s # c C sU d GH| j � \ } } d GHx- | j t � } | s8 Pn t j j | � q Wd GHd S( Ns (accepting data connection)s (data connection accepted)s (end of data connection)( t acceptt recvt BUFSIZER t stdoutt write( R t connt hostt data( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR { s c C s: y! x t d � } | r | Sq WWn t k r5 d SXd S( Ns ftp.py> t ( t raw_inputt EOFError( R. ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR � s ( R t posixR$ R R1 R R R R R R R R R R ( ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyt <module> s $ PK *�\d�BT7 7 rpythond.pyonu �[��� � A fc @ sW d d l Z d d l Td d l Z d d l Z d Z d Z d � Z d � Z e � d S( i����N( t *i i c C s� t t j � d k r1 t t t j d � � } n t } t t t � } | j d | f � | j d � x| | j � \ } \ } } d G| G| GHd } x' | j t � } | s� Pn | | } q� Wt | � } | j | � | j � qi Wd S( Ni t s connected by( t lent syst argvt intt evalt PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt executet sendt close( t portt st connt remotehostt remoteportt requestt datat reply( ( s- /usr/lib64/python2.7/Demo/sockets/rpythond.pyt main s$ c B sv e j } e j } e j � e _ e _ } z* y | i i UWn He j d � n XWd | e _ | e _ X| j � S( Nid ( R t stdoutt stderrt StringIOt tracebackt print_exct getvalue( R R R t fakefile( ( s- /usr/lib64/python2.7/Demo/sockets/rpythond.pyR % s ( R R R R R R R R ( ( ( s- /usr/lib64/python2.7/Demo/sockets/rpythond.pyt <module> s PK *�\����S( S( gopher.pycnu �[��� � A fc @ s� d d l Z d d l Z d d l Z d d l Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z i d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6Z d Z d Z d � Z d � Z d! � Z d" � Z d# � Z d$ � Z d% � Z d& � Z d' � Z d( � Z d) � Z d* � Z! d+ � Z" d, � Z# i e d 6e d 6e" d 6e" d 6e d 6e d 6e! d 6e" d 6e# d 6Z$ d- d3 d. � � YZ% d/ d4 d0 � � YZ& d1 � Z' d2 � Z( e( � d S(5 i����Nt s gopher.micro.umn.eduiF t 0t 1t 2t 3t 4t 5t 6t 7t 8t 9t +t ss <TEXT>s <DIR>s <CSO>s <ERROR>s <BINHEX>s <DOS>s <UUENCODE>s <SEARCH>s <TELNET>s <BINARY>s <REDUNDANT>s <SOUND>s s c C sh | s t } n* t | � t d � k r9 t j | � } n t j t j t j � } | j | | f � | S( NR ( t DEF_PORTt typet stringt atoit sockett AF_INETt SOCK_STREAMt connect( t hostt portR ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt open_socket) s c C s: t | | � } | j | t � | j d � | j d � S( Ni t r( R t sendt CRLFt shutdownt makefile( t selectorR R R ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt send_request3 s c C s) t | | | � } g } x | j � } | s6 d GHPn | d t k rS | d } n | d t k rp | d } n | d k r� Pn | s� d GHq n | d } t j | d t � } t | � d k r� d | f GHq n t | � d k r� d | d f GHn | j d | � | j | � q W| j � | S( Ns (Unexpected EOF from server)i����i����t .s (Empty line from server)i i i s (Bad line from server: %r)s (Extra info from server: %r)( R t readlineR R t splitfieldst TABt lent insertt appendt close( R R R t ft listt linet typechart parts( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_menu: s6 c C s g } t | | | | j � | S( N( t get_alt_textfileR% ( R R R R( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_textfileX s c C s� t | | | � } x� | j � } | s0 d GHPn | d t k rM | d } n | d t k rj | d } n | d k rz Pn | d d k r� | d } n | | � q W| j � d S( Ns (Unexpected EOF from server)i����i����R i s ..i ( R R R R& ( R R R t funcR' R) ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR- ^ s c C s, t | | | � } | j � } | j � | S( N( R t readR& ( R R R R' t data( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_binaryq s c C s@ t | | | � } x' | j | � } | s. Pn | | � q Wd S( N( R R0 ( R R R R/ t blocksizeR' R1 ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_alt_binaryx s c G s� t } t } t } t | � } | d k rA | d rA | d } n | d k rd | d rd | d } n | d k r� | d r� | d } n | d k r� t d � n y t | | | � WnA t j k r� } d G| GHt j d � n t k r� d GHn Xd S( Ni i i i s too many argss Socket error:s [Goodbye]( t DEF_SELECTORt DEF_HOSTR R# t RuntimeErrort browse_menuR t errort syst exitt KeyboardInterrupt( t argsR R R t nt msg( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browser� s& c C s� t | | | � } x�d GHd Gt | � GHd G| Gd G| GHHx� t t | � � D]u } | | } | d | d } } t j t | d � d � d G| Gt j | � r� t | GHqN d t | � d GHqN WHx� y t d � } Wn t k r� Hd SX| s� d Sy t j | � } Wn t j k r,d GHq� n Xd | k oJt | � k n sZd GHq� n Pq� W| | d } | d } | d d !\ } } } t j | � r�t | } y | | | | � Wq�t t j f k r�d Gt j Gd Gt j GHq�Xq d GHq Wd S( Ns ----- MENU -----s Selector:s Host:s Port:i i i t :s <TYPE=t >s Choice [CR == up a level]: s# Choice must be a number; try again:s Choice out of range; try again:i i s ***s Unsupported object type( R, t reprt rangeR# R t rjustt typenamet has_keyt raw_inputt EOFErrorR t atoi_errort typebrowsert IOErrorR R9 R: t exc_typet exc_value( R R R R( t it itemR* t descriptiont strt choicet i_selectort i_hostt i_portt browserfunc( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR8 � sR " " c C s� d } y8 t j d d � } t | � } t | | | | j � Wn t k r\ } d G| GHn X| rp | j � n t � } | s� d St | � } y t | | | | j � d GHWn t k r� } d G| GHn X| j � d S( Ns ${PAGER-more}t ws IOError:s Done.( t Nonet ost popent SaveLinesR- t writelnRL R& t open_savefile( R R R t xt pR? R' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_textfile� s& c C s� x� d GHd Gt | � GHd G| Gd G| GHHy t d � } Wn t k rN HPn Xt j | � } | sh Pn d | k r d GHq n t | t | | | � q Wd S( Ns ----- SEARCH -----s Selector:s Host:s Port:s Query [CR == up a level]: s s" Sorry, queries cannot contain tabs( RC RH RI R t stripR8 R" ( R R R t query( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_search� s" c C sp | r d Gt | � GHn t | � t d � k r? t | � } n t j d | d | � } | rl d G| GHn d S( Ns Log in asR s set -x; exec telnet t s Exit status:( RC R RZ t system( R R R t sts( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_telnet� s c C sF t � } | s d St | � } t | | | | j d � | j � d S( Ni i i ( R^ t SaveWithProgressR4 t writeR& ( R R R R' R_ ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_binary� s c C s t | | | � d S( N( Rk ( R R R ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_sound s R\ c B s# e Z d � Z d � Z d � Z RS( c C s | | _ d S( N( R' ( t selfR' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt __init__ s c C s | j j | d � d S( Ns ( R' Rj ( Rm R) ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR] s c C s% | j j � } | r! d G| GHn d S( Ns Exit status:( R' R& ( Rm Rg ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR& s ( t __name__t __module__Rn R] R& ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR\ s Ri c B s# e Z d � Z d � Z d � Z RS( c C s | | _ d S( N( R' ( Rm R' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyRn s c C s1 t j j d � t j j � | j j | � d S( Nt #( R: t stdoutRj t flushR' ( Rm R1 ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyRj s c C s& H| j j � } | r" d G| GHn d S( Ns Exit status:( R' R& ( Rm Rg ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR& s ( Ro Rp Rn Rj R& ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyRi s c C s2 y t d � } Wn t k r% Hd SXt j | � } | s? d S| d d k r� t j | d � } y t j | d � } Wn' t k r� } t | � Gd G| GHd SXd Gt | � Gd GH| S| d d k r� t j j | � } n y t | d � } Wn' t k r} t | � Gd G| GHd SXd Gt | � Gd GH| S( Ns< Save as file [CR == don't save; |pipeline or ~user/... OK]: i t |i RX RA s Piping throughs ...t ~s Saving to( RH RI RY R Rb RZ R[ RL RC t patht expandusert open( t savefilet cmdR` R? R' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR^ ' s6 c C s t j d r" d GHt j d � n� t j d rW t t j d t j d t j d � n� t j d r� y- t j t j d � } d } t j d } Wn4 t j k r� t j d } t j d } d } n Xt | | | � n+ t j d r� t d t j d � n t � d S( Ni s( usage: gopher [ [selector] host [port] ]i i i R ( R: t argvR; R@ R R RJ ( R R R ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt testE s$ ( ( ( () R R: RZ R R5 R6 R t T_TEXTFILEt T_MENUt T_CSOt T_ERRORt T_BINHEXt T_DOSt T_UUENCODEt T_SEARCHt T_TELNETt T_BINARYt T_REDUNDANTt T_SOUNDRF R R" R R R, R. R- R2 R4 R@ R8 Ra Rd Rh Rk Rl RK R\ Ri R^ R| ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt <module> s\ . PK *�\�Hz� � ftp.pycnu �[��� � ��^c @ s� d d l Z d d l Z d d l Z d d l Td Z d Z e d Z e d Z d � Z d � Z d a d � Z d � Z d � Z d � Z d � Z e � d S( i����N( t *i i i iP� c C s t j d } t | � d S( Ni ( t syst argvt control( t hostname( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyt main' s c C s� t t t � } | j | t f � | j d � } d } x� t | � } | d k rV Pn | d k r� t | � t | � } d } n | s� t | | � } n t � } | s� Pn | j | d � q: Wd S( Nt rt 221t EOFt 150s ( R R ( t sockett AF_INETt SOCK_STREAMt connectt FTP_PORTt makefilet Nonet getreplyt getdatat newdataportt getcommandt send( R t st fR t codet cmd( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR . s$ i c C sd t t } t d d a t t t � } | j t t � � | f � | j d � t | | | � | S( Ni i ( t nextportt FTP_DATA_PORTR R R t bindt gethostbynamet gethostnamet listent sendportcmd( R R t portR ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR M s c C s� t � } t | � } t j | d � } t | d � t | d � g } | | } d t j | d � } | j | d � t | � } d S( Nt .i s PORT t ,s ( R R t stringt splitfieldst reprt joinfieldsR R ( R R R! R t hostaddrt hbytest pbytest bytesR R ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR Z s c C s� | j � } | s d S| G| d } | d d !d k r� xH | j � } | sP Pn | G| d | k r: | d d !d k r: Pq: q: Wn | S( NR i i t -( t readline( R t lineR ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR k s # c C sU d GH| j � \ } } d GHx- | j t � } | s8 Pn t j j | � q Wd GHd S( Ns (accepting data connection)s (data connection accepted)s (end of data connection)( t acceptt recvt BUFSIZER t stdoutt write( R t connt hostt data( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR { s c C s: y! x t d � } | r | Sq WWn t k r5 d SXd S( Ns ftp.py> t ( t raw_inputt EOFError( R. ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyR � s ( R t posixR$ R R1 R R R R R R R R R R ( ( ( s( /usr/lib64/python2.7/Demo/sockets/ftp.pyt <module> s $ PK *�\�Se�� � rpython.pycnu �[��� � A fc @ sB d d l Z d d l Z d d l Td Z d Z d � Z e � d S( i����N( t *i i c C s t t j � d k r* d GHt j d � n t j d } t } t j | d � } | d k r t j | | d � } | | } n t j t j d � } t t t � } | j | | f � | j | � | j d � d } x' | j t � } | s� Pn | | } q� W| Gd S( Ni s usage: rpython host commandi i t :i t ( t lent syst argvt exitt PORTt stringt findt atoit joint sockett AF_INETt SOCK_STREAMt connectt sendt shutdownt recvt BUFSIZE( t hostt portt it commandt st replyt data( ( s, /usr/lib64/python2.7/Demo/sockets/rpython.pyt main s* ( R R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/sockets/rpython.pyt <module> s PK *�\��FG� � udpecho.pycnu �[��� � A fc @ sQ d d l Z d d l Td Z d Z d � Z d � Z d � Z d � Z e � d S( i����N( t *iP� i i c C sd t t j � d k r t � n t j d d k r< t � n$ t j d d k rY t � n t � d S( Ni i s -ss -c( t lent syst argvt usaget servert client( ( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyt main s c C s' t j t _ d GHd GHt j d � d S( Ns, Usage: udpecho -s [port] (server)s, or: udpecho -c host [port] <file (client)i ( R t stderrt stdoutt exit( ( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyR s c C s� t t j � d k r+ t t j d � } n t } t t t � } | j d | f � d GHx8 | j t � \ } } d | | f GH| j | | � q[ Wd S( Ni t s udp echo server readys server received %r from %r( R R R t evalt ECHO_PORTt sockett AF_INETt SOCK_DGRAMt bindt recvfromt BUFSIZEt sendto( t portt st datat addr( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyR s c C s� t t j � d k r t � n t j d } t t j � d k rW t t j d � } n t } | | f } t t t � } | j d � d GHxQ t j j � } | s� Pn | j | | � | j t � \ } } d | | f GHq� Wd S( Ni i R i s$ udp echo client ready, reading stdins client received %r from %r( R i ( R R R R R R R R R R t stdint readlineR R R ( t hostR R R t lineR t fromaddr( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyR + s" iW� ( R R R R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/sockets/udpecho.pyt <module> s PK *�\\�-� � unixclient.pycnu �[��� � ��^c @ se d d l Td Z e e e � Z e j e � e j d � e j d � Z e j � d Ge e � GHd S( i����( t *s unix-sockets Hello, worldi t ReceivedN( t sockett FILEt AF_UNIXt SOCK_STREAMt st connectt sendt recvt datat closet repr( ( ( s/ /usr/lib64/python2.7/Demo/sockets/unixclient.pyt <module> s PK *�\�'}&Q Q unixserver.pycnu �[��� � ��^c @ s� d d l Z d d l Td Z e e e � Z e j e � d e j � d GHe j d � e j � \ Z Z x0 e r� e j d � Z e s� Pn e j e � qm We j � e j e � d S( i����N( t *s unix-sockets Sock name is: [t ]i i ( t ost sockett FILEt AF_UNIXt SOCK_STREAMt st bindt getsocknamet listent acceptt connt addrt Truet recvt datat sendt closet unlink( ( ( s/ /usr/lib64/python2.7/Demo/sockets/unixserver.pyt <module> s PK *�\Z6qA� � throughput.pyonu �[��� � A fc @ s] d d l Z d d l Z d d l Td Z d Z d � Z d � Z d � Z d � Z e � d S( i����N( t *iP� i* i c C sd t t j � d k r t � n t j d d k r< t � n$ t j d d k rY t � n t � d S( Ni i s -ss -c( t lent syst argvt usaget servert client( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyt main s c C s' t j t _ d GHd GHt j d � d S( Ns* Usage: (on host_A) throughput -s [port]s7 and then: (on host_B) throughput -c count host_A [port]i ( R t stderrt stdoutt exit( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR " s c C s� t t j � d k r+ t t j d � } n t } t t t � } | j d | f � | j d � d GHxg | j � \ } \ } } x | j t � } | s� Pn ~ q� W| j d � | j � d G| Gd G| GHqh Wd S( Ni t i s Server ready...s OK s Done witht port( R R R t evalt MY_PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt sendt close( R t st connt hostt remoteportt data( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR ) s" c C s� t t j � d k r t � n t t t j d � � } t j d } t t j � d k rp t t j d � } n t } d t d d } t j � } t t t � } t j � } | j | | f � t j � } d } x' | | k r� | d } | j | � q� W| j d � t j � } | j t � } t j � } | GHd G| G| G| G| G| GHd G| | G| | G| | G| | GHd G| | GHd Gt t | d | | d � Gd GHd S( Ni i i t xi s i s Raw timers:s Intervals:s Total:s Throughput:g����MbP?s K/sec.( R R R R t intR R R t timeR R R t connectR t shutdownR t round( t countR R t testdatat t1R t t2t t3t it t4R t t5( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR > s6 % !iz� ( R R R R R R R R R ( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyt <module> s PK *�\���`� � finger.pynu ȯ�� #! /usr/bin/python2.7 # Python interface to the Internet finger daemon. # # Usage: finger [options] [user][@host] ... # # If no host is given, the finger daemon on the local host is contacted. # Options are passed uninterpreted to the finger daemon! import sys, string from socket import * # Hardcode the number of the finger port here. # It's not likely to change soon... # FINGER_PORT = 79 # Function to do one remote finger invocation. # Output goes directly to stdout (although this can be changed). # def finger(host, args): s = socket(AF_INET, SOCK_STREAM) s.connect((host, FINGER_PORT)) s.send(args + '\n') while 1: buf = s.recv(1024) if not buf: break sys.stdout.write(buf) sys.stdout.flush() # Main function: argument parsing. # def main(): options = '' i = 1 while i < len(sys.argv) and sys.argv[i][:1] == '-': options = options + sys.argv[i] + ' ' i = i+1 args = sys.argv[i:] if not args: args = [''] for arg in args: if '@' in arg: at = string.index(arg, '@') host = arg[at+1:] arg = arg[:at] else: host = '' finger(host, options + arg) # Call the main function. # main() PK *�\Z6qA� � throughput.pycnu �[��� � A fc @ s] d d l Z d d l Z d d l Td Z d Z d � Z d � Z d � Z d � Z e � d S( i����N( t *iP� i* i c C sd t t j � d k r t � n t j d d k r< t � n$ t j d d k rY t � n t � d S( Ni i s -ss -c( t lent syst argvt usaget servert client( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyt main s c C s' t j t _ d GHd GHt j d � d S( Ns* Usage: (on host_A) throughput -s [port]s7 and then: (on host_B) throughput -c count host_A [port]i ( R t stderrt stdoutt exit( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR " s c C s� t t j � d k r+ t t j d � } n t } t t t � } | j d | f � | j d � d GHxg | j � \ } \ } } x | j t � } | s� Pn ~ q� W| j d � | j � d G| Gd G| GHqh Wd S( Ni t i s Server ready...s OK s Done witht port( R R R t evalt MY_PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt sendt close( R t st connt hostt remoteportt data( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR ) s" c C s� t t j � d k r t � n t t t j d � � } t j d } t t j � d k rp t t j d � } n t } d t d d } t j � } t t t � } t j � } | j | | f � t j � } d } x' | | k r� | d } | j | � q� W| j d � t j � } | j t � } t j � } | GHd G| G| G| G| G| GHd G| | G| | G| | G| | GHd G| | GHd Gt t | d | | d � Gd GHd S( Ni i i t xi s i s Raw timers:s Intervals:s Total:s Throughput:g����MbP?s K/sec.( R R R R t intR R R t timeR R R t connectR t shutdownR t round( t countR R t testdatat t1R t t2t t3t it t4R t t5( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR > s6 % !iz� ( R R R R R R R R R ( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyt <module> s PK *�\�Yڎe e telnet.pycnu �[��� � A fc @ s� d d l Z d d l Z d d l Z d d l Td Z e d � Z e d � Z e d � Z e d � Z e d � Z d � Z y e � Wn e k r� n Xd S( i����N( t *i i� i� i� i� i� c C s! t j d } y t | � } Wn9 t k rX t j j t j d d � t j d � n Xt t j � d k r~ t j d } n d } d | d k o� d k n r� t | � } nH y t | d � } Wn2 t k r� t j j | d � t j d � n Xt t t � } y | j | | f � Wn> t k ra} t j j d t | � d � t j d � n Xt j � } | d k r�x�t j j � } | j | � q}Wn}d } d } xn| j t � } | s�t j j d � t j | d � t j d � n d } x� | D]� } | r2t | � GH| j | | � d } q| r�d } | t k rW| | } q�| t t f k r�| t k r|d Gn d Gt t } q�| t t f k r�| t k r�d Gn d Gt t } q�d Gt | � GHq| t k r�d } d Gq| | } qWt j j | � t j j � q�Wd S( Ni s : bad host name i t telnett 0t 9t tcps : bad tcp service name s connect failed: s i t s (Closed by remote host) i s (DO)s (DONT)s (WILL)s (WONT)s (command)s (IAC)( t syst argvt gethostbynamet errort stderrt writet exitt lent evalt getservbynamet sockett AF_INETt SOCK_STREAMt connectt reprt posixt forkt stdint readlinet sendt recvt BUFSIZEt killt ordt IACt DOt DONTt WONTt WILLt stdoutt flush( t hostt hostaddrt servnamet portt st msgt pidt linet iact optt datat cleandatat c( ( s+ /usr/lib64/python2.7/Demo/sockets/telnet.pyt main s| ( R R t timeR R t chrR R R R! R" R2 t KeyboardInterrupt( ( ( s+ /usr/lib64/python2.7/Demo/sockets/telnet.pyt <module> s $ M PK *�\ ��� radio.pynu �[��� # Receive UDP packets transmitted by a broadcasting service MYPORT = 50000 import sys from socket import * s = socket(AF_INET, SOCK_DGRAM) s.bind(('', MYPORT)) while 1: data, wherefrom = s.recvfrom(1500, 0) sys.stderr.write(repr(wherefrom) + '\n') sys.stdout.write(data) PK *�\q�<�� � finger.pycnu �[��� � A fc @ sE d d l Z d d l Z d d l Td Z d � Z d � Z e � d S( i����N( t *iO c C st t t t � } | j | t f � | j | d � x- | j d � } | sO Pn t j j | � q6 Wt j j � d S( Ns i ( t sockett AF_INETt SOCK_STREAMt connectt FINGER_PORTt sendt recvt syst stdoutt writet flush( t hostt argst st buf( ( s+ /usr/lib64/python2.7/Demo/sockets/finger.pyt finger s c C s� d } d } xO | t t j � k r] t j | d d k r] | t j | d } | d } q Wt j | } | s} d g } n x^ | D]V } d | k r� t j | d � } | | d } | | } n d } t | | | � q� Wd S( Nt i t -t t @( t lenR t argvt stringt indexR ( t optionst iR t argt atR ( ( s+ /usr/lib64/python2.7/Demo/sockets/finger.pyt main% s / ( R R R R R R ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/finger.pyt <module> s PK *�\u�a�� � udpecho.pynu ȯ�� #! /usr/bin/python2.7 # Client and server for udp (datagram) echo. # # Usage: udpecho -s [port] (to start a server) # or: udpecho -c host [port] <file (client) import sys from socket import * ECHO_PORT = 50000 + 7 BUFSIZE = 1024 def main(): if len(sys.argv) < 2: usage() if sys.argv[1] == '-s': server() elif sys.argv[1] == '-c': client() else: usage() def usage(): sys.stdout = sys.stderr print 'Usage: udpecho -s [port] (server)' print 'or: udpecho -c host [port] <file (client)' sys.exit(2) def server(): if len(sys.argv) > 2: port = eval(sys.argv[2]) else: port = ECHO_PORT s = socket(AF_INET, SOCK_DGRAM) s.bind(('', port)) print 'udp echo server ready' while 1: data, addr = s.recvfrom(BUFSIZE) print 'server received %r from %r' % (data, addr) s.sendto(data, addr) def client(): if len(sys.argv) < 3: usage() host = sys.argv[2] if len(sys.argv) > 3: port = eval(sys.argv[3]) else: port = ECHO_PORT addr = host, port s = socket(AF_INET, SOCK_DGRAM) s.bind(('', 0)) print 'udp echo client ready, reading stdin' while 1: line = sys.stdin.readline() if not line: break s.sendto(line, addr) data, fromaddr = s.recvfrom(BUFSIZE) print 'client received %r from %r' % (data, fromaddr) main() PK *�\ⱈ�� � mcast.pynu ȯ�� #! /usr/bin/python2.7 # # Send/receive UDP multicast packets. # Requires that your OS kernel supports IP multicast. # # Usage: # mcast -s (sender, IPv4) # mcast -s -6 (sender, IPv6) # mcast (receivers, IPv4) # mcast -6 (receivers, IPv6) MYPORT = 8123 MYGROUP_4 = '225.0.0.250' MYGROUP_6 = 'ff15:7079:7468:6f6e:6465:6d6f:6d63:6173' MYTTL = 1 # Increase to reach other networks import time import struct import socket import sys def main(): group = MYGROUP_6 if "-6" in sys.argv[1:] else MYGROUP_4 if "-s" in sys.argv[1:]: sender(group) else: receiver(group) def sender(group): addrinfo = socket.getaddrinfo(group, None)[0] s = socket.socket(addrinfo[0], socket.SOCK_DGRAM) # Set Time-to-live (optional) ttl_bin = struct.pack('@i', MYTTL) if addrinfo[0] == socket.AF_INET: # IPv4 s.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, ttl_bin) else: s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, ttl_bin) while True: data = repr(time.time()) s.sendto(data + '\0', (addrinfo[4][0], MYPORT)) time.sleep(1) def receiver(group): # Look up multicast group address in name server and find out IP version addrinfo = socket.getaddrinfo(group, None)[0] # Create a socket s = socket.socket(addrinfo[0], socket.SOCK_DGRAM) # Allow multiple copies of this program on one machine # (not strictly needed) s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # Bind it to the port s.bind(('', MYPORT)) group_bin = socket.inet_pton(addrinfo[0], addrinfo[4][0]) # Join group if addrinfo[0] == socket.AF_INET: # IPv4 mreq = group_bin + struct.pack('=I', socket.INADDR_ANY) s.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) else: mreq = group_bin + struct.pack('@I', 0) s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq) # Loop, printing any data we receive while True: data, sender = s.recvfrom(1500) while data[-1:] == '\0': data = data[:-1] # Strip trailing \0's print (str(sender) + ' ' + repr(data)) if __name__ == '__main__': main() PK *�\d�BT7 7 rpythond.pycnu �[��� � A fc @ sW d d l Z d d l Td d l Z d d l Z d Z d Z d � Z d � Z e � d S( i����N( t *i i c C s� t t j � d k r1 t t t j d � � } n t } t t t � } | j d | f � | j d � x| | j � \ } \ } } d G| G| GHd } x' | j t � } | s� Pn | | } q� Wt | � } | j | � | j � qi Wd S( Ni t s connected by( t lent syst argvt intt evalt PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt executet sendt close( t portt st connt remotehostt remoteportt requestt datat reply( ( s- /usr/lib64/python2.7/Demo/sockets/rpythond.pyt main s$ c B sv e j } e j } e j � e _ e _ } z* y | i i UWn He j d � n XWd | e _ | e _ X| j � S( Nid ( R t stdoutt stderrt StringIOt tracebackt print_exct getvalue( R R R t fakefile( ( s- /usr/lib64/python2.7/Demo/sockets/rpythond.pyR % s ( R R R R R R R R ( ( ( s- /usr/lib64/python2.7/Demo/sockets/rpythond.pyt <module> s PK *�\����S( S( gopher.pyonu �[��� � A fc @ s� d d l Z d d l Z d d l Z d d l Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z i d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6Z d Z d Z d � Z d � Z d! � Z d" � Z d# � Z d$ � Z d% � Z d& � Z d' � Z d( � Z d) � Z d* � Z! d+ � Z" d, � Z# i e d 6e d 6e" d 6e" d 6e d 6e d 6e! d 6e" d 6e# d 6Z$ d- d3 d. � � YZ% d/ d4 d0 � � YZ& d1 � Z' d2 � Z( e( � d S(5 i����Nt s gopher.micro.umn.eduiF t 0t 1t 2t 3t 4t 5t 6t 7t 8t 9t +t ss <TEXT>s <DIR>s <CSO>s <ERROR>s <BINHEX>s <DOS>s <UUENCODE>s <SEARCH>s <TELNET>s <BINARY>s <REDUNDANT>s <SOUND>s s c C sh | s t } n* t | � t d � k r9 t j | � } n t j t j t j � } | j | | f � | S( NR ( t DEF_PORTt typet stringt atoit sockett AF_INETt SOCK_STREAMt connect( t hostt portR ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt open_socket) s c C s: t | | � } | j | t � | j d � | j d � S( Ni t r( R t sendt CRLFt shutdownt makefile( t selectorR R R ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt send_request3 s c C s) t | | | � } g } x | j � } | s6 d GHPn | d t k rS | d } n | d t k rp | d } n | d k r� Pn | s� d GHq n | d } t j | d t � } t | � d k r� d | f GHq n t | � d k r� d | d f GHn | j d | � | j | � q W| j � | S( Ns (Unexpected EOF from server)i����i����t .s (Empty line from server)i i i s (Bad line from server: %r)s (Extra info from server: %r)( R t readlineR R t splitfieldst TABt lent insertt appendt close( R R R t ft listt linet typechart parts( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_menu: s6 c C s g } t | | | | j � | S( N( t get_alt_textfileR% ( R R R R( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_textfileX s c C s� t | | | � } x� | j � } | s0 d GHPn | d t k rM | d } n | d t k rj | d } n | d k rz Pn | d d k r� | d } n | | � q W| j � d S( Ns (Unexpected EOF from server)i����i����R i s ..i ( R R R R& ( R R R t funcR' R) ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR- ^ s c C s, t | | | � } | j � } | j � | S( N( R t readR& ( R R R R' t data( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_binaryq s c C s@ t | | | � } x' | j | � } | s. Pn | | � q Wd S( N( R R0 ( R R R R/ t blocksizeR' R1 ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt get_alt_binaryx s c G s� t } t } t } t | � } | d k rA | d rA | d } n | d k rd | d rd | d } n | d k r� | d r� | d } n | d k r� t d � n y t | | | � WnA t j k r� } d G| GHt j d � n t k r� d GHn Xd S( Ni i i i s too many argss Socket error:s [Goodbye]( t DEF_SELECTORt DEF_HOSTR R# t RuntimeErrort browse_menuR t errort syst exitt KeyboardInterrupt( t argsR R R t nt msg( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browser� s& c C s� t | | | � } x�d GHd Gt | � GHd G| Gd G| GHHx� t t | � � D]u } | | } | d | d } } t j t | d � d � d G| Gt j | � r� t | GHqN d t | � d GHqN WHx� y t d � } Wn t k r� Hd SX| s� d Sy t j | � } Wn t j k r,d GHq� n Xd | k oJt | � k n sZd GHq� n Pq� W| | d } | d } | d d !\ } } } t j | � r�t | } y | | | | � Wq�t t j f k r�d Gt j Gd Gt j GHq�Xq d GHq Wd S( Ns ----- MENU -----s Selector:s Host:s Port:i i i t :s <TYPE=t >s Choice [CR == up a level]: s# Choice must be a number; try again:s Choice out of range; try again:i i s ***s Unsupported object type( R, t reprt rangeR# R t rjustt typenamet has_keyt raw_inputt EOFErrorR t atoi_errort typebrowsert IOErrorR R9 R: t exc_typet exc_value( R R R R( t it itemR* t descriptiont strt choicet i_selectort i_hostt i_portt browserfunc( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR8 � sR " " c C s� d } y8 t j d d � } t | � } t | | | | j � Wn t k r\ } d G| GHn X| rp | j � n t � } | s� d St | � } y t | | | | j � d GHWn t k r� } d G| GHn X| j � d S( Ns ${PAGER-more}t ws IOError:s Done.( t Nonet ost popent SaveLinesR- t writelnRL R& t open_savefile( R R R t xt pR? R' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_textfile� s& c C s� x� d GHd Gt | � GHd G| Gd G| GHHy t d � } Wn t k rN HPn Xt j | � } | sh Pn d | k r d GHq n t | t | | | � q Wd S( Ns ----- SEARCH -----s Selector:s Host:s Port:s Query [CR == up a level]: s s" Sorry, queries cannot contain tabs( RC RH RI R t stripR8 R" ( R R R t query( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_search� s" c C sp | r d Gt | � GHn t | � t d � k r? t | � } n t j d | d | � } | rl d G| GHn d S( Ns Log in asR s set -x; exec telnet t s Exit status:( RC R RZ t system( R R R t sts( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_telnet� s c C sF t � } | s d St | � } t | | | | j d � | j � d S( Ni i i ( R^ t SaveWithProgressR4 t writeR& ( R R R R' R_ ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_binary� s c C s t | | | � d S( N( Rk ( R R R ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt browse_sound s R\ c B s# e Z d � Z d � Z d � Z RS( c C s | | _ d S( N( R' ( t selfR' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt __init__ s c C s | j j | d � d S( Ns ( R' Rj ( Rm R) ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR] s c C s% | j j � } | r! d G| GHn d S( Ns Exit status:( R' R& ( Rm Rg ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR& s ( t __name__t __module__Rn R] R& ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR\ s Ri c B s# e Z d � Z d � Z d � Z RS( c C s | | _ d S( N( R' ( Rm R' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyRn s c C s1 t j j d � t j j � | j j | � d S( Nt #( R: t stdoutRj t flushR' ( Rm R1 ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyRj s c C s& H| j j � } | r" d G| GHn d S( Ns Exit status:( R' R& ( Rm Rg ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR& s ( Ro Rp Rn Rj R& ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyRi s c C s2 y t d � } Wn t k r% Hd SXt j | � } | s? d S| d d k r� t j | d � } y t j | d � } Wn' t k r� } t | � Gd G| GHd SXd Gt | � Gd GH| S| d d k r� t j j | � } n y t | d � } Wn' t k r} t | � Gd G| GHd SXd Gt | � Gd GH| S( Ns< Save as file [CR == don't save; |pipeline or ~user/... OK]: i t |i RX RA s Piping throughs ...t ~s Saving to( RH RI RY R Rb RZ R[ RL RC t patht expandusert open( t savefilet cmdR` R? R' ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyR^ ' s6 c C s t j d r" d GHt j d � n� t j d rW t t j d t j d t j d � n� t j d r� y- t j t j d � } d } t j d } Wn4 t j k r� t j d } t j d } d } n Xt | | | � n+ t j d r� t d t j d � n t � d S( Ni s( usage: gopher [ [selector] host [port] ]i i i R ( R: t argvR; R@ R R RJ ( R R R ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt testE s$ ( ( ( () R R: RZ R R5 R6 R t T_TEXTFILEt T_MENUt T_CSOt T_ERRORt T_BINHEXt T_DOSt T_UUENCODEt T_SEARCHt T_TELNETt T_BINARYt T_REDUNDANTt T_SOUNDRF R R" R R R, R. R- R2 R4 R@ R8 Ra Rd Rh Rk Rl RK R\ Ri R^ R| ( ( ( s+ /usr/lib64/python2.7/Demo/sockets/gopher.pyt <module> s\ . PK *�\� ��� � unicast.pyonu �[��� PK *�\)�a�� � radio.pyonu �[��� PK *�\�'}&Q Q unixserver.pyonu �[��� PK *�\���l� � � unicast.pynu �[��� PK *�\\�-� � � unixclient.pyonu �[��� PK *�\�U� � � telnet.pynu ȯ�� PK *�\� '�� � � rpython.pynu ȯ�� PK *�\[g��y y � mcast.pyonu �[��� PK *�\��FG� � W! udpecho.pyonu �[��� PK *�\���$ $ }) throughput.pynu ȯ�� PK *�\��C �1 broadcast.pynu �[��� PK *�\[g��y y 53 mcast.pycnu �[��� PK *�\��^�X X �; ftp.pynu �[��� PK *�\�j{� � uK echosvr.pynu ȯ�� PK *�\.)S; ; �N echosvr.pyonu �[��� PK *�\�Yڎe e R telnet.pyonu �[��� PK *�\q�<�� � �Z finger.pyonu �[��� PK *�\�vt t j_ READMEnu �[��� PK *�\.)S; ; b echosvr.pycnu �[��� PK *�\~h�D7& 7& �e gopher.pynu ȯ�� PK *�\�Se�� � �� rpython.pyonu �[��� PK *�\I��t� � � unixserver.pynu �[��� PK *�\���# # � broadcast.pycnu �[��� PK *�\�IA}� � F� unixclient.pynu �[��� PK *�\)�a�� � k� radio.pycnu �[��� PK *�\� ��� � {� unicast.pycnu �[��� PK *�\���# # ~� broadcast.pyonu �[��� PK *�\��c� � ޛ rpythond.pynu ȯ�� PK *�\�Hz� � ֠ ftp.pyonu �[��� PK *�\d�BT7 7 �� rpythond.pyonu �[��� PK *�\����S( S( � gopher.pycnu �[��� PK *�\�Hz� � �� ftp.pycnu �[��� PK *�\�Se�� � X� rpython.pycnu �[��� PK *�\��FG� � i� udpecho.pycnu �[��� PK *�\\�-� � �� unixclient.pycnu �[��� PK *�\�'}&Q Q u� unixserver.pycnu �[��� PK *�\Z6qA� � � throughput.pyonu �[��� PK *�\���`� � � finger.pynu ȯ�� PK *�\Z6qA� � throughput.pycnu �[��� PK *�\�Yڎe e � telnet.pycnu �[��� PK *�\ ��� � radio.pynu �[��� PK *�\q�<�� � � finger.pycnu �[��� PK *�\u�a�� � � udpecho.pynu ȯ�� PK *�\ⱈ�� � �$ mcast.pynu ȯ�� PK *�\d�BT7 7 �- rpythond.pycnu �[��� PK *�\����S( S( �2 gopher.pyonu �[��� PK . . i �[
| ver. 1.4 |
Github
|
.
| PHP 8.1.34 | ���֧ߧ֧�ѧ�ڧ� ����ѧߧڧ��: 0.2 |
proxy
|
phpinfo
|
���ѧ����ۧܧ�