diff options
author | Bart Polot <bart@net.in.tum.de> | 2015-10-02 03:37:20 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2015-10-02 03:37:20 +0000 |
commit | 137abaf6645f0a2cf0ff8eaaf49526796ca6adb2 (patch) | |
tree | 28fd9726bd0063e351ba27907275336d71df0f40 /src/cadet | |
parent | e2f70a2f9fa099e3ce0e7451028bea8c373522a6 (diff) | |
download | gnunet-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.c | 19 |
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 |