Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 32 additions & 5 deletions assignments/session01/echo_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,17 +4,31 @@

def client(msg, log_buffer=sys.stderr):
server_address = ('localhost', 10000)

# server_address = ('127.0.0.1', 10000)

# TODO: Replace the following line with your code which will instantiate
# a TCP socket with IPv4 Addressing, call the socket you make 'sock'
sock = None

# sock = None

sock = socket.socket(
socket.AF_INET,
socket.SOCK_STREAM,
socket.IPPROTO_IP)

print >>log_buffer, 'connecting to {0} port {1}'.format(*server_address)
# TODO: connect your socket to the server here.

sock.connect((server_address))

# this try/finally block exists purely to allow us to close the socket
# when we are finished with it
try:
print >>log_buffer, 'sending "{0}"'.format(msg)
# TODO: send your message to the server here.

sock.sendall(msg)

# TODO: the server should be sending you back your message as a series
# of 16-byte chunks. You will want to log them as you receive
Expand All @@ -24,13 +38,26 @@ def client(msg, log_buffer=sys.stderr):
#
# Make sure that you log each chunk you receive. Use the print
# statement below to do it. (The tests expect this log format)
chunk = ''
print >>log_buffer, 'received "{0}"'.format(chunk)

# chunk = ''

while True:

chunk = sock.recv(16)

print >>log_buffer, 'received "{0}"'.format(chunk)

if len(chunk) == 0:
break

finally:
# TODO: after you break out of the loop receiving echoed chunks from
# the server you will want to close your client socket.
print >>log_buffer, 'closing socket'


sock.close()

sys.exit(1)

if __name__ == '__main__':
if len(sys.argv) != 2:
Expand All @@ -39,4 +66,4 @@ def client(msg, log_buffer=sys.stderr):
sys.exit(1)

msg = sys.argv[1]
client(msg)
client(msg)
46 changes: 40 additions & 6 deletions assignments/session01/echo_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,16 +7,28 @@ def server(log_buffer=sys.stderr):
address = ('127.0.0.1', 10000)
# TODO: Replace the following line with your code which will instantiate
# a TCP socket with IPv4 Addressing, call the socket you make 'sock'
sock = None

# sock = None

sock = socket.socket(
socket.AF_INET,
socket.SOCK_STREAM,
socket.IPPROTO_IP)

# TODO: Set an option to allow the socket address to be reused immediately
# see the end of http://docs.python.org/2/library/socket.html

sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# log that we are building a server
print >>log_buffer, "making a server on {0}:{1}".format(*address)

# TODO: bind your new sock 'sock' to the address above and begin to listen
# for incoming connections

sock.bind((address))
sock.listen(1)

try:
# the outer loop controls the creation of new connection sockets. The
# server will handle each incoming connection one at a time.
Expand All @@ -28,7 +40,11 @@ def server(log_buffer=sys.stderr):
# the client so we can report it below. Replace the
# following line with your code. It is only here to prevent
# syntax errors
addr = ('bar', 'baz')

# addr = ('bar', 'baz')

conn, addr = sock.accept()

try:
print >>log_buffer, 'connection - {0}:{1}'.format(*addr)

Expand All @@ -41,29 +57,47 @@ def server(log_buffer=sys.stderr):
# following line with your code. It's only here as
# a placeholder to prevent an error in string
# formatting
data = ''

# data = ''

data = conn.recv(16)

print >>log_buffer, 'received "{0}"'.format(data)

# TODO: you will need to check here to see if any data was
# received. If so, send the data you got back to
# the client. If not, exit the inner loop and wait
# for a new connection from a client

if len(data) > 0:
conn.sendall(data)

else:
break


finally:
# TODO: When the inner loop exits, this 'finally' clause will
# be hit. Use that opportunity to close the socket you
# created above when a client connected. Replace the
# call to `pass` below, which is only there to prevent
# syntax problems
pass

# pass

conn.close()

except KeyboardInterrupt:
# TODO: Use the python KeyboardIntterupt exception as a signal to
# close the server socket and exit from the server function.
# Replace the call to `pass` below, which is only there to
# prevent syntax problems
pass

# pass

sock.close()


if __name__ == '__main__':
server()
sys.exit(0)
sys.exit(0)