diff options
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r-- | src/transport/plugin_transport_tcp.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c index 877356c16..99da8bb17 100644 --- a/src/transport/plugin_transport_tcp.c +++ b/src/transport/plugin_transport_tcp.c | |||
@@ -849,7 +849,7 @@ do_transmit (void *cls, size_t size, void *buf) | |||
849 | { | 849 | { |
850 | GNUNET_CONTAINER_DLL_remove (hd, tl, pos); | 850 | GNUNET_CONTAINER_DLL_remove (hd, tl, pos); |
851 | if (pos->transmit_cont != NULL) | 851 | if (pos->transmit_cont != NULL) |
852 | pos->transmit_cont (pos->transmit_cont_cls, &pid, GNUNET_SYSERR); | 852 | pos->transmit_cont (pos->transmit_cont_cls, &pid, GNUNET_SYSERR, pos->message_size, 0); |
853 | GNUNET_free (pos); | 853 | GNUNET_free (pos); |
854 | } | 854 | } |
855 | GNUNET_STATISTICS_update (plugin->env->stats, | 855 | GNUNET_STATISTICS_update (plugin->env->stats, |
@@ -895,7 +895,7 @@ do_transmit (void *cls, size_t size, void *buf) | |||
895 | { | 895 | { |
896 | GNUNET_CONTAINER_DLL_remove (hd, tl, pos); | 896 | GNUNET_CONTAINER_DLL_remove (hd, tl, pos); |
897 | if (pos->transmit_cont != NULL) | 897 | if (pos->transmit_cont != NULL) |
898 | pos->transmit_cont (pos->transmit_cont_cls, &pid, GNUNET_OK); | 898 | pos->transmit_cont (pos->transmit_cont_cls, &pid, GNUNET_OK, pos->message_size, pos->message_size); /* FIXME: include TCP overhead */ |
899 | GNUNET_free (pos); | 899 | GNUNET_free (pos); |
900 | } | 900 | } |
901 | GNUNET_assert (hd == NULL); | 901 | GNUNET_assert (hd == NULL); |
@@ -999,7 +999,7 @@ disconnect_session (struct Session *session) | |||
999 | session->pending_messages_tail, pm); | 999 | session->pending_messages_tail, pm); |
1000 | if (NULL != pm->transmit_cont) | 1000 | if (NULL != pm->transmit_cont) |
1001 | pm->transmit_cont (pm->transmit_cont_cls, &session->target, | 1001 | pm->transmit_cont (pm->transmit_cont_cls, &session->target, |
1002 | GNUNET_SYSERR); | 1002 | GNUNET_SYSERR, pm->message_size, 0); |
1003 | GNUNET_free (pm); | 1003 | GNUNET_free (pm); |
1004 | } | 1004 | } |
1005 | if (session->receive_delay_task != GNUNET_SCHEDULER_NO_TASK) | 1005 | if (session->receive_delay_task != GNUNET_SCHEDULER_NO_TASK) |
@@ -1159,7 +1159,7 @@ tcp_plugin_send (void *cls, | |||
1159 | LOG (GNUNET_ERROR_TYPE_ERROR, | 1159 | LOG (GNUNET_ERROR_TYPE_ERROR, |
1160 | "Invalid session %p\n", session); | 1160 | "Invalid session %p\n", session); |
1161 | if (NULL != cont) | 1161 | if (NULL != cont) |
1162 | cont (cont_cls, &session->target, GNUNET_SYSERR); | 1162 | cont (cont_cls, &session->target, GNUNET_SYSERR, pm->message_size, 0); |
1163 | GNUNET_break (0); | 1163 | GNUNET_break (0); |
1164 | GNUNET_free (pm); | 1164 | GNUNET_free (pm); |
1165 | return GNUNET_SYSERR; /* session does not exist here */ | 1165 | return GNUNET_SYSERR; /* session does not exist here */ |