aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_tcp.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r--src/transport/plugin_transport_tcp.c8
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 */