-
Notifications
You must be signed in to change notification settings - Fork 0
/
GoodputDownloadRate.py
89 lines (73 loc) · 3.11 KB
/
GoodputDownloadRate.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
# UploadGoodputRate.py
# Billy Kihei (c) 2021
# Intelligent Mobile Device Lab @ Kennesaw State University
# Part of the 5Gtoolkit for testing commercial 5G networks.
# This app measures the Layer 7 one-way Goodput from the phone to the UDP relay server.
# The phone will send a message to the relay server asking to prepare for a one-way stream of bytes from the phone.
# The phone will stream the bytes according to the users desires.
# The relay server will report the statistics.
# The intended use is to run this app in Termux.
# Provide the size of each message, and the duration of the test in seconds.
# Statistics will be returned to you.
# 1. Open Termux.
# 2. Download the 5gtoolkit git repo.
# 3. Edit the config.json file so that relay server ip and port are correct.
# 4. python UploadGoodputRate.py <size of packets in bytes> <duration of measurement in seconds>
import socket
import sys
import signal
import time
import json
import random
import string
f = open('config.json',)
conf = json.load(f)
f.close()
packetSizeInBytes_String = sys.argv[1]
packetSizeInBytes = int(packetSizeInBytes_String)
durationOfTestInSeconds_String = sys.argv[2]
durationOfTestInSeconds = int(durationOfTestInSeconds_String)
totalBytesSent = 0
server_addr = (conf["relay_server"]["ip"], conf["relay_server"]["port"])
server_halt_addr = (conf["relay_server"]["ip"], conf["relay_server"]["halt_port"])
udpClientSock= socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
def signal_handler(sig, frame):
udpClientSock.sendto(str("0").encode(), server_halt_addr)
data = udpClientSock.recvfrom(1024)
if data[0] == "1":
udpClientSock.close()
print('\n')
sys.exit(0)
else:
udpClientSock.close()
print('ERROR Could Not Stop Server \n')
sys.exit(0)
signal.signal(signal.SIGINT, signal_handler)
print('Sending UGR Request to Relay Server...')
udpClientSock.sendto(str.encode("UGR:"+packetSizeInBytes_String), server_addr)
respFromServer = udpClientSock.recvfrom(65507)
print('Server ready.')
print('Measurement in progress...')
totalPacketsSent = 0
t = time.time()
while (time.time() - t) <= durationOfTestInSeconds:
s = ''.join(random.choice(string.digits) for _ in range(packetSizeInBytes))
udpClientSock.sendto(s.encode(), server_addr)
totalPacketsSent += 1
print("Done. Awaiting Stats From Relay Server...")
udpClientSock.sendto(str.encode("done"), server_addr)
respFromServer = udpClientSock.recvfrom(1024)
stats = json.loads(respFromServer[0].decode())
udpClientSock.close()
print("Stats Received.")
totalBytesRecvd = stats["totalBytesRecvd"]
numberOfPackets = stats["numberOfPackets"]
goodput = totalBytesRecvd/durationOfTestInSeconds
numberOfPackets = totalBytesRecvd/packetSizeInBytes
packetReceptionRate = (numberOfPackets/totalPacketsSent)*100
print("Phone Uploaded: " + str(totalPacketsSent) + " packets")
print("Goodput (raw): %s bytes" % (goodput))
print("Goodput (Megabitsps): %s " % ((goodput*8)/(1e6)))
print("Goodput (MegaBytesps): %s " % ((goodput)/(1e6)))
print("Number of Packets Received by Server: " + str(numberOfPackets))
print("Packet Reception Rate: " + str(packetReceptionRate) + "%")