From cac832abee3e0f4fbca7fdce2cc4b17a9f2c77a3 Mon Sep 17 00:00:00 2001
From: Fernando Erd <fce15@inf.ufpr.br>
Date: Mon, 7 Nov 2016 23:15:16 -0200
Subject: [PATCH] ACK ADD
---
Canguru/tentandop.py | 18 ++++++++++++++++--
1 file changed, 16 insertions(+), 2 deletions(-)
diff --git a/Canguru/tentandop.py b/Canguru/tentandop.py
index d3e66ff..7cbdf31 100755
--- a/Canguru/tentandop.py
+++ b/Canguru/tentandop.py
@@ -4,7 +4,7 @@
###############################################################################################
#Marca - 1 Byte Marca inicio de transmissao, inicio de msg fim de msg
-#Tipo - 0 Token, 1 - Msg
+#Tipo - 0 Token, 1 - Msg, 2 - ACK, 3 - NACK
#Destino - pode variar de 1 a 4
#Origem - pode variar de 1 a 4
#Prioridade - pode variar de 0 a 7
@@ -173,16 +173,30 @@ def server ():
while True:
msg, cliente = udp.recvfrom(1024)
protocolDescompactMessage.setDesempacota(msg)
-
+
+ #A msg foi enviada com sucesso
+ if (msg[1] == '2' and int(MACHINE_ID) == int(protocolDescompactMessage.destiny)):
+ print 'A MENSAGEM FOI ENVIADA COM SUCESSO'
+ #A msg e pra mim
if (msg[1] == '1' and int(MACHINE_ID) == int(protocolDescompactMessage.destiny)):
print '\n' + protocolDescompactMessage.origin + ' Escreveu: ' + protocolDescompactMessage.msg
+
+ #envia ack
+ protocolDescompactMessage.type = str(2)
+ protocolDescompactMessage.destiny = protocolDescompactMessage.origin
+ msg = protocolDescompactMessage.getEmpacotar()
+ udp.sendto (msg, dest)
+
+ #A msg n e pra mim
elif (msg[1] == '1'):
udp.sendto (msg, dest)
+ #Recebi o token
if (protocolDescompactMessage.type == '0' and TOKEN == 0):
print 'RECEBI O TOKEN'
TOKEN = 1
StartTime = time.time()
+
udp.close()
--
GitLab