[SOLVED] CS python #!/usr/bin/python3

#!/usr/bin/python3
import cse303
import threading
import subprocess

# Configure constants and users
cse303.indentation = 80
cse303.verbose = cse303.check_args_verbose()
alice = cse303.UserConfig(alice, alice_is_awesome)
fakealice = cse303.UserConfig(alice, not_alice_password)
bob = cse303.UserConfig(bob, bob_is_the_best)
filet1 = server/responses.h
filet2 = common/crypto.h
filet3 = server/server.cc
filet4 = common/pool.cc
fileb1 = solutions/file.o
fileb2 = solutions/err.o
fileb3 = solutions/bytevec.o
fileb4 = solutions/net.o
allfile = allfile
makefiles = [Makefile, p2.pool.mk, p2.nopool.mk]
num_iters = 1024

# Create objects with server and client configuration
server = cse303.ServerConfig(./obj64/server.exe, 9999, rsa, company.dir, 4, 2, 1, 67108864, 67108864, 8192, 4)
client = cse303.ClientConfig(./obj64/client.exe, localhost, 9999, localhost.pub)

# Check if we should use solution server and/or client
cse303.override_exe(server, client)

# Set up a clean slate before getting started
cse303.line()
print(Getting ready to run tests)
cse303.line()
cse303.makeclean() # make clean
cse303.clean_common_files(server, client) # .pub, .pri, .dir files
cse303.killprocs()
cse303.build(makefiles)
cse303.leftmsg(Copying files with solution pool into place)
cse303.copyfile(obj64/server.p2.nopool.exe, obj64/server.exe)
cse303.copyfile(obj64/client.p2.nopool.exe, obj64/client.exe)
cse303.okmsg()

# Note: Buckets < Threads, so we should get collisions…print()cse303.line()print(“Test: Races: Remember that this test isn’t enough to prove correctness”)cse303.line()cse303.leftmsg(“Creating temporary files…”)for i in range(num_iters):key = “k”+str(i)file = key + “.dat”cse303.build_file(file, 64)cse303.okmsg()server.pid = cse303.do_cmd_a(“Starting server:”, [“Listening on port “+server.port+” using (key/data) = (rsa, “+server.dirfile+”)”,”Generating RSA keys as (“+server.keyfile+”.pub, “+server.keyfile+”.pri)”,”File not found: ” + server.dirfile], server.launchcmd())cse303.waitfor(2)cse303.do_cmd(“Registering a user”, “OK”, client.reg(alice), server)cse303.after(server.pid) # need an extra cleanup to handle the KEY that was sent by first REGcse303.waitfor(2)# Concurrent insertion:procs = []cse303.leftmsg(“Launching ” + str(num_iters) + ” insertions”)for i in range(num_iters):key = “k”+str(i)file = key + “.dat”s = subprocess.Popen(client.kvI(alice, key, file), stdout=subprocess.PIPE)procs.append(s)cse303.okmsg()cse303.leftmsg(“Waiting on ” + str(num_iters) + ” completions”)errs = []for i in range(num_iters):res = procs[i].stdout.readline().rstrip().decode(“utf-8”)if res != “OK”:errs.append(i)procs[i].wait()cse303.after(server.pid)cse303.okmsg()if len(errs) > 0:
print(Errors encountered for the following iterations:)
for e in errs:
print( + str(e))

# Concurrent get:
procs = []
cse303.leftmsg(Launching + str(num_iters) + gets)
for i in range(num_iters):
key = k+str(i)
file = key + .dat
s = subprocess.Popen(client.kvG(alice, key), stdout=subprocess.PIPE)
procs.append(s)
cse303.okmsg()

cse303.leftmsg(Waiting on + str(num_iters) + completions)
errs = []
for i in range(num_iters):
res = procs[i].stdout.readline().rstrip().decode(utf-8)
if res != OK:
errs.append(i)
procs[i].wait()
cse303.after(server.pid)
cse303.okmsg()

if len(errs) > 0:
print(Errors encountered for the following iterations:)
for e in errs:
print( + str(e))

# Do the comparisons sequentially
for i in range(num_iters):
key = k+str(i)
file = key + .dat
cse303.check_file_result(file, key)
cse303.delfile(file)

# Concurrent get:
procs = []
cse303.leftmsg(Launching + str(num_iters) + deletions)
for i in range(num_iters):
key = k+str(i)
file = key + .dat
s = subprocess.Popen(client.kvD(alice, key), stdout=subprocess.PIPE)
procs.append(s)
cse303.okmsg()

cse303.leftmsg(Waiting on + str(num_iters) + completions)
errs = []
for i in range(num_iters):
res = procs[i].stdout.readline().rstrip().decode(utf-8)
if res != OK:
errs.append(i)
procs[i].wait()
cse303.after(server.pid)
cse303.okmsg()

if len(errs) > 0:
print(Errors encountered for the following iterations:)
for e in errs:
print( + str(e))

cse303.do_cmd(Shutting down, OK, client.bye(alice), server)
cse303.await_server(Waiting for server to shut down., Server terminated, server)
cse303.clean_common_files(server, client)

print()