PK �1�\� '�� �
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 �1�\�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 �1�\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 �1�\�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 �1�\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 �1�\���# #
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 �1�\��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 �1�\�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 �1�\���# #
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 �1�\�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 �1�\�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 �1�\�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 �1�\� ��� � 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 �1�\��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 �1�\��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 �1�\~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 �1�\)�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 �1�\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 �1�\[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 �1�\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 �1�\�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 �1�\�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 �1�\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 �1�\�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 �1�\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 �1�\.)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 �1�\ ��� 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 �1�\ⱈ�� � 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 �1�\���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 �1�\����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 �1�\��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 �1�\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 �1�\� ��� � 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 �1�\�'}&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 �1�\\�-� � 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 �1�\\�-� � 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 �1�\��^�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 �1�\���`� � 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 �1�\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 �1�\���$ $
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 �1�\[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 �1�\����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 �1�\)�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 �1�\.)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 �1�\�'}&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 �1�\�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 �1�\� '�� �
rpython.pynu ȯ�� PK �1�\�vt t READMEnu �[��� PK �1�\q�<�� �
� finger.pycnu �[��� PK �1�\�j{� �
q
echosvr.pynu ȯ�� PK �1�\Z6qA� � �
throughput.pycnu �[��� PK �1�\���# #
t broadcast.pyonu �[��� PK �1�\��FG� � � udpecho.pyonu �[��� PK �1�\�Hz� � �! ftp.pyonu �[��� PK �1�\���# #
�- broadcast.pycnu �[��� PK �1�\�U� � 0 telnet.pynu ȯ�� PK �1�\�Hz� � < ftp.pycnu �[��� PK �1�\�Se�� � �G rpython.pyonu �[��� PK �1�\� ��� � �K unicast.pyonu �[��� PK �1�\��C �M broadcast.pynu �[��� PK �1�\��c� � AO rpythond.pynu ȯ�� PK �1�\~h�D7& 7& 9T gopher.pynu ȯ�� PK �1�\)�a�� � �z radio.pycnu �[��� PK �1�\I��t� �
�| unixserver.pynu �[��� PK �1�\[g��y y �~ mcast.pycnu �[��� PK �1�\d�BT7 7 F� rpythond.pyonu �[��� PK �1�\�IA}� �
�� unixclient.pynu �[��� PK �1�\�Se�� � ލ rpython.pycnu �[��� PK �1�\d�BT7 7 � rpythond.pycnu �[��� PK �1�\�Yڎe e
b� telnet.pycnu �[��� PK �1�\q�<�� �
� finger.pyonu �[��� PK �1�\.)S; ; Ť echosvr.pyonu �[��� PK �1�\ ��� ;� radio.pynu �[��� PK �1�\ⱈ�� � �� mcast.pynu ȯ�� PK �1�\���l� �
p� unicast.pynu �[��� PK �1�\����S( S(
�� gopher.pycnu �[��� PK �1�\��FG� � � udpecho.pycnu �[��� PK �1�\u�a�� �
C� udpecho.pynu ȯ�� PK �1�\� ��� � 8� unicast.pycnu �[��� PK �1�\�'}&Q Q ;� unixserver.pyonu �[��� PK �1�\\�-� � �� unixclient.pyonu �[��� PK �1�\\�-� � �� unixclient.pycnu �[��� PK �1�\��^�X X �� ftp.pynu �[��� PK �1�\���`� � $ finger.pynu ȯ�� PK �1�\Z6qA� � H throughput.pyonu �[��� PK �1�\���$ $
/ throughput.pynu ȯ�� PK �1�\[g��y y � mcast.pyonu �[��� PK �1�\����S( S(
B" gopher.pyonu �[��� PK �1�\)�a�� � �J radio.pyonu �[��� PK �1�\.)S; ; �L echosvr.pycnu �[��� PK �1�\�'}&Q Q UP unixserver.pycnu �[��� PK �1�\�Yڎe e
�R telnet.pyonu �[��� PK . . i
�[
