From f6ba865551a50cf214eb8519e25967922a843115 Mon Sep 17 00:00:00 2001
From: Fernando Erd <fce15@inf.ufpr.br>
Date: Fri, 4 Nov 2016 23:51:39 -0200
Subject: [PATCH] Test with queues
---
Canguru/CanguruChat.py | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/Canguru/CanguruChat.py b/Canguru/CanguruChat.py
index 97f7628..2fc5f92 100755
--- a/Canguru/CanguruChat.py
+++ b/Canguru/CanguruChat.py
@@ -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()
--
GitLab