aboutsummaryrefslogtreecommitdiff
path: root/src/cadet
diff options
context:
space:
mode:
authorBart Polot <bart@net.in.tum.de>2015-10-02 03:37:20 +0000
committerBart Polot <bart@net.in.tum.de>2015-10-02 03:37:20 +0000
commit137abaf6645f0a2cf0ff8eaaf49526796ca6adb2 (patch)
tree28fd9726bd0063e351ba27907275336d71df0f40 /src/cadet
parente2f70a2f9fa099e3ce0e7451028bea8c373522a6 (diff)
downloadgnunet-137abaf6645f0a2cf0ff8eaaf49526796ca6adb2.tar.gz
gnunet-137abaf6645f0a2cf0ff8eaaf49526796ca6adb2.zip
- don't call core if there is no traffic
Diffstat (limited to 'src/cadet')
-rw-r--r--src/cadet/gnunet-service-cadet_peer.c19
1 files changed, 13 insertions, 6 deletions
diff --git a/src/cadet/gnunet-service-cadet_peer.c b/src/cadet/gnunet-service-cadet_peer.c
index f95c3aecf..e7da408c5 100644
--- a/src/cadet/gnunet-service-cadet_peer.c
+++ b/src/cadet/gnunet-service-cadet_peer.c
@@ -1170,15 +1170,22 @@ queue_send (void *cls, size_t size, void *buf)
1170 if (GNUNET_NO == in_shutdown) 1170 if (GNUNET_NO == in_shutdown)
1171 { 1171 {
1172 queue = peer_get_first_message (peer); 1172 queue = peer_get_first_message (peer);
1173 if (NULL == queue)
1174 {
1175 peer->core_transmit = NULL;
1176 peer->tmt_time.abs_value_us = 0;
1177 GCC_check_connections ();
1178 return;
1179 }
1173 dst_id = GNUNET_PEER_resolve2 (peer->id); 1180 dst_id = GNUNET_PEER_resolve2 (peer->id);
1174 peer->core_transmit = 1181 peer->core_transmit =
1175 GNUNET_CORE_notify_transmit_ready (core_handle, 1182 GNUNET_CORE_notify_transmit_ready (core_handle,
1176 GNUNET_NO, get_priority (queue), 1183 GNUNET_NO, get_priority (queue),
1177 GNUNET_TIME_UNIT_FOREVER_REL, 1184 GNUNET_TIME_UNIT_FOREVER_REL,
1178 dst_id, 1185 dst_id,
1179 get_core_size (queue->size), 1186 get_core_size (queue->size),
1180 &queue_send, 1187 &queue_send,
1181 peer); 1188 peer);
1182 peer->tmt_time = GNUNET_TIME_absolute_get (); 1189 peer->tmt_time = GNUNET_TIME_absolute_get ();
1183 } 1190 }
1184 else 1191 else