fix type issue

1 files changed, 13 insertions, 5 deletions

diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c
index d10a74e36..592dcd849 100644
--- a/src/transport/gnunet-service-transport_neighbours.c
+++ b/src/transport/gnunet-service-transport_neighbours.c
@@ -924,7 +924,6 @@ free_neighbour (struct NeighbourMapEntry *n, int keep_sessions)
   GNUNET_free (n);
 }
 
-
 /**
  * Transmit a message using the current session of the given
  * neighbour.
@@ -946,17 +945,20 @@ send_with_session (struct NeighbourMapEntry *n,
                    void *cont_cls)
 {
   struct GNUNET_TRANSPORT_PluginFunctions *papi;
+  ssize_t send_phys;
 
   GNUNET_assert (n->primary_address.session != NULL);
   if ( ( (NULL == (papi = GST_plugins_find (n->primary_address.address->transport_name))) ||
-         (-1 == papi->send (papi->cls,
+         (-1 ==  (send_phys = papi->send (papi->cls,
                             n->primary_address.session,
                             msgbuf, msgbuf_size,
                             priority,
                             timeout,
-                            cont, cont_cls))) &&
+                            cont, cont_cls)))) &&
        (NULL != cont) )
     cont (cont_cls, &n->id, GNUNET_SYSERR);
+  if (-1 != send_phys)
+    GST_clients_communicate_bytes_used (&n->id, send_phys);
   GNUNET_break (NULL != papi);
 }
 
@@ -1520,6 +1522,7 @@ send_session_connect (struct NeighbourAddress *na)
 {
   struct GNUNET_TRANSPORT_PluginFunctions *papi;
   struct SessionConnectMessage connect_msg;
+  ssize_t send_phys;
   
   if (NULL == (papi = GST_plugins_find (na->address->transport_name)))  
   {
@@ -1538,12 +1541,14 @@ send_session_connect (struct NeighbourAddress *na)
   connect_msg.header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_CONNECT);
   connect_msg.reserved = htonl (0);
   connect_msg.timestamp = GNUNET_TIME_absolute_hton (na->connect_timestamp);
-  (void) papi->send (papi->cls,
+  send_phys = papi->send (papi->cls,
                      na->session,
                      (const char *) &connect_msg, sizeof (struct SessionConnectMessage),
                      UINT_MAX,
                      GNUNET_TIME_UNIT_FOREVER_REL,
                      NULL, NULL);
+  if (-1 != send_phys)
+    GST_clients_communicate_bytes_used (&na->address->peer, send_phys);
 }
 
 
@@ -1561,6 +1566,7 @@ send_session_connect_ack_message (const struct GNUNET_HELLO_Address *address,
 {
   struct GNUNET_TRANSPORT_PluginFunctions *papi;
   struct SessionConnectMessage connect_msg;
+  ssize_t send_phys;
   
   if (NULL == (papi = GST_plugins_find (address->transport_name)))  
   {
@@ -1578,12 +1584,14 @@ send_session_connect_ack_message (const struct GNUNET_HELLO_Address *address,
   connect_msg.header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_CONNECT_ACK);
   connect_msg.reserved = htonl (0);
   connect_msg.timestamp = GNUNET_TIME_absolute_hton (timestamp);
-  (void) papi->send (papi->cls,
+  send_phys = papi->send (papi->cls,
                      session,
                      (const char *) &connect_msg, sizeof (struct SessionConnectMessage),
                      UINT_MAX,
                      GNUNET_TIME_UNIT_FOREVER_REL,
                      NULL, NULL);
+  if (-1 != send_phys)
+    GST_clients_communicate_bytes_used (&address->peer, send_phys);
 }