aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorBart Polot <bart@net.in.tum.de>2014-04-01 00:16:40 +0000
committerBart Polot <bart@net.in.tum.de>2014-04-01 00:16:40 +0000
commit9b7d6aa783283757767e2de8127d28676de0ad28 (patch)
tree037dd57ef27ee536129b5c4d110d17e41985842d /src
parent811205e0b9484d1bbb6555e2b077ae7d334b0cf2 (diff)
downloadgnunet-9b7d6aa783283757767e2de8127d28676de0ad28.tar.gz
gnunet-9b7d6aa783283757767e2de8127d28676de0ad28.zip
- fix queue priority
Diffstat (limited to 'src')
-rw-r--r--src/mesh/gnunet-service-mesh_peer.c6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mesh/gnunet-service-mesh_peer.c b/src/mesh/gnunet-service-mesh_peer.c
index 842c5bea7..1265230d7 100644
--- a/src/mesh/gnunet-service-mesh_peer.c
+++ b/src/mesh/gnunet-service-mesh_peer.c
@@ -776,10 +776,7 @@ queue_is_sendable (struct MeshPeerQueue *q)
776 GNUNET_break (0); 776 GNUNET_break (0);
777 } 777 }
778 778
779 if (GNUNET_MESSAGE_TYPE_MESH_CONNECTION_BROKEN != q->type) 779 return GMC_is_sendable (q->c, q->fwd);
780 return GMC_is_sendable (q->c, q->fwd);
781
782 return GNUNET_NO;
783} 780}
784 781
785 782
@@ -797,6 +794,7 @@ peer_get_first_message (const struct MeshPeer *peer)
797 794
798 for (q = peer->queue_head; NULL != q; q = q->next) 795 for (q = peer->queue_head; NULL != q; q = q->next)
799 { 796 {
797 LOG (GNUNET_ERROR_TYPE_DEBUG, "Checking %p towards %s\n", q, GMC_2s (q->c));
800 if (queue_is_sendable (q)) 798 if (queue_is_sendable (q))
801 return q; 799 return q;
802 } 800 }