TP4

Question 1

Complete the Proxy.py code:
def producer(queue, baseURL, movieName, track_num):
manifest_url = ________________________________________
response = requests.get(____________)
manifest = ____________

track_num = int(track_num)

# Process the manifest
offsets = [ ]
i = 0
num_fragments = 50
current_track = 0
current_segment = 0

Answer 1

def producer(queue, baseURL, movieName, track_num):
manifest_url = baseURL + ‘/’ + movieName + ‘/manifest.txt’
response = requests.get(manifest_url)
manifest = response.content.decode()

track_num = int(track_num)

# Process the manifest
offsets = [ ]
i = 0
num_fragments = 50
current_track = 0
current_segment = 0

Question 2

Complete the Proxy.py code:
for j in range(____________________):
segment_url = baseURL + ‘/’ + movieName + ‘/’ + track
headers = {__________________________________________________________}
response = requests.get(__________,____________)
for chunk in response.iter_content(__________):
queue.put(_________)

Answer 2

for j in range(num_fragments):
segment_url = baseURL + ‘/’ + movieName + ‘/’ + track
headers = {“Range”: “bytes=” + str(offsets[j][0]) + “-“ + str(offsets[j][1])}
response = requests.get(segment_url, headers=headers)
for chunk in response.iter_content(CHUNK_SIZE):
queue.put(chunk)

Question 3

Complete the Proxy.py code:
def consumer(queue, player_socket):
while True:
segment = queue.get()
player_socket._________(_________)
if segment == b’’:
break

Answer 3

def consumer(queue, player_socket):
while True:
segment = queue.get()
player_socket.sendall(segment)
if segment == b’’:
break

Question 4

Complete the Proxy.py code:
producer_thread = threading.Thread(target=_________, args=(______, ________, _________, _____))
consumer_thread = threading.Thread(target=_________, args=(_____, _________))
producer_thread._______()
consumer_thread.______()

producer_thread.\_\_\_\_\_()
consumer_thread.\_\_\_\_\_\_()

Answer 4

producer_thread = threading.Thread(target=producer, args=(queue, baseURL, movieName, track))
consumer_thread = threading.Thread(target=consumer, args=(queue, player_socket))
producer_thread.start()
consumer_thread.start()

producer_thread.join()
consumer_thread.join()

Question 5

what’s the server function?

Answer 5

it is a standard http server that contains movies to be played.

Question 6

what’s the proxy function?

Answer 6

Has two parts each executed by a thread; the two threads share a queue or buffer.
o Thread producer: gets segments from the content server using a TCP socket TC and
the HTTP protocol and puts them in the queue.
o Thread consumer: gets segments from the queue and writes its content to socket TP

Question 7

what’s the client function?

Answer 7

shows the movie. Receives the byte stream through a socket TP

Question 8

which http command do we use in this project?

Answer 8

GET HTTP