diff options
author | Bart Polot <bart@net.in.tum.de> | 2015-06-10 12:08:17 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2015-06-10 12:08:17 +0000 |
commit | 3415ad933561b627814dbfc047587ca5b421e409 (patch) | |
tree | 12a4b488bb1cc05d4f41a4b640fde1cb6598b16e /src | |
parent | aefe7ee20e178f6c48e632c78f610dfd0a6cd62c (diff) | |
download | gnunet-3415ad933561b627814dbfc047587ca5b421e409.tar.gz gnunet-3415ad933561b627814dbfc047587ca5b421e409.zip |
- start poll after send
Diffstat (limited to 'src')
-rw-r--r-- | src/cadet/gnunet-service-cadet_connection.c | 8 |
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: |