Skip to content
Snippets Groups Projects
Commit f6ba8655 authored by Fernando Erd's avatar Fernando Erd :ok_hand:
Browse files

Test with queues

parent f36a01e2
Branches
No related tags found
No related merge requests found
......@@ -30,6 +30,7 @@ import socket
import threading
import sys
import binascii
import Queue
HOST = "127.0.0.1" # Endereco IP do Servidor
SEND_PORT = 5000 # Porta que o Servidor envia
......@@ -103,14 +104,16 @@ def client ():
dest = (HOST, SEND_PORT)
print 'Para sair digite exit\n'
protocolMessage = Protocol()
queueMessage = Queue.PriorityQueue()
protocolMessage.setDestiny()
protocolMessage.setPriority()
protocolMessage.setMessage()
protocolMessage.setSizeof()
protocolMessage.setCRC32()
msg = protocolMessage.getEmpacotar()
queueMessage.put ((int(protocolMessage.priority), msg))
while protocolMessage.msg <> 'exit':
udp.sendto (msg, dest)
#udp.sendto (msg, dest)
protocolMessage = Protocol()
protocolMessage.setDestiny()
protocolMessage.setPriority()
......@@ -118,6 +121,10 @@ def client ():
protocolMessage.setSizeof()
protocolMessage.setCRC32()
msg = protocolMessage.getEmpacotar()
queueMessage.put ((int(protocolMessage.priority), msg))
print queueMessage.get()
print queueMessage.get()
print queueMessage.get()
threadServer._Thread__stop()
udp.close()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment