aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorBart Polot <bart@net.in.tum.de>2015-06-10 12:08:17 +0000
committerBart Polot <bart@net.in.tum.de>2015-06-10 12:08:17 +0000
commit3415ad933561b627814dbfc047587ca5b421e409 (patch)
tree12a4b488bb1cc05d4f41a4b640fde1cb6598b16e /src
parentaefe7ee20e178f6c48e632c78f610dfd0a6cd62c (diff)
downloadgnunet-3415ad933561b627814dbfc047587ca5b421e409.tar.gz
gnunet-3415ad933561b627814dbfc047587ca5b421e409.zip
- start poll after send
Diffstat (limited to 'src')
-rw-r--r--src/cadet/gnunet-service-cadet_connection.c8
1 files changed, 3 insertions, 5 deletions
diff --git a/src/cadet/gnunet-service-cadet_connection.c b/src/cadet/gnunet-service-cadet_connection.c
index 13afdb28f..91401f297 100644
--- a/src/cadet/gnunet-service-cadet_connection.c
+++ b/src/cadet/gnunet-service-cadet_connection.c
@@ -656,7 +656,9 @@ conn_message_sent (void *cls,
656 if (GNUNET_YES == sent) 656 if (GNUNET_YES == sent)
657 { 657 {
658 GNUNET_assert (NULL != q); 658 GNUNET_assert (NULL != q);
659 fc->last_pid_sent = pid; // FIXME 659 fc->last_pid_sent = pid;
660 if (GC_is_pid_bigger (fc->last_pid_sent + 1, fc->last_ack_recv))
661 GCC_start_poll (c, fwd);
660 GCC_send_ack (c, fwd, GNUNET_NO); 662 GCC_send_ack (c, fwd, GNUNET_NO);
661 connection_reset_timeout (c, fwd); 663 connection_reset_timeout (c, fwd);
662 } 664 }
@@ -3227,10 +3229,6 @@ GCC_send_prebuilt_message (const struct GNUNET_MessageHeader *message,
3227 { 3229 {
3228 LOG (GNUNET_ERROR_TYPE_DEBUG, " not droppable, Q_N stays the same\n"); 3230 LOG (GNUNET_ERROR_TYPE_DEBUG, " not droppable, Q_N stays the same\n");
3229 } 3231 }
3230 if (GC_is_pid_bigger (fc->last_pid_sent + 1, fc->last_ack_recv))
3231 {
3232 GCC_start_poll (c, fwd);
3233 }
3234 break; 3232 break;
3235 3233
3236 case GNUNET_MESSAGE_TYPE_CADET_KX: 3234 case GNUNET_MESSAGE_TYPE_CADET_KX: