[GNUnet-SVN] r34545 - in gnunet: po src/dht src/hostlist src/include

[gnunet]

Author: grothoff
Date: 2014-12-13 21:08:11 +0100 (Sat, 13 Dec 2014)
New Revision: 34545

Modified:
   gnunet/po/POTFILES.in
   gnunet/src/dht/gnunet-service-dht_neighbours.c
   gnunet/src/dht/gnunet-service-xdht_neighbours.c
   gnunet/src/hostlist/gnunet-daemon-hostlist_server.c
   gnunet/src/include/gnunet_core_service.h
Log:
-doxygen, one more statistic

Modified: gnunet/po/POTFILES.in
===================================================================
--- gnunet/po/POTFILES.in       2014-12-13 19:59:40 UTC (rev 34544)
+++ gnunet/po/POTFILES.in       2014-12-13 20:08:11 UTC (rev 34545)
@@ -58,6 +58,7 @@
 src/conversation/speaker.c
 src/core/core_api.c
 src/core/core_api_monitor_peers.c
+src/core/core_api_mq.c
 src/core/gnunet-core.c
 src/core/gnunet-service-core.c
 src/core/gnunet-service-core_clients.c
@@ -259,8 +260,12 @@
 src/revocation/gnunet-revocation.c
 src/revocation/gnunet-service-revocation.c
 src/revocation/revocation_api.c
+src/rps/gnunet-rps.c
+src/rps/gnunet-service-rps.c
+src/rps/rps_api.c
 src/scalarproduct/gnunet-scalarproduct.c
-src/scalarproduct/gnunet-service-scalarproduct.c
+src/scalarproduct/gnunet-service-scalarproduct_alice.c
+src/scalarproduct/gnunet-service-scalarproduct_bob.c
 src/scalarproduct/scalarproduct_api.c
 src/secretsharing/gnunet-secretsharing-profiler.c
 src/secretsharing/gnunet-service-secretsharing.c

Modified: gnunet/src/dht/gnunet-service-dht_neighbours.c
===================================================================
--- gnunet/src/dht/gnunet-service-dht_neighbours.c      2014-12-13 19:59:40 UTC 
(rev 34544)
+++ gnunet/src/dht/gnunet-service-dht_neighbours.c      2014-12-13 20:08:11 UTC 
(rev 34545)
@@ -24,7 +24,6 @@
  * @author Christian Grothoff
  * @author Nathan Evans
  */
-
 #include "platform.h"
 #include "gnunet_util_lib.h"
 #include "gnunet_block_lib.h"
@@ -789,6 +788,11 @@
   while ((NULL != (pending = peer->head)) &&
          (0 == GNUNET_TIME_absolute_get_remaining 
(pending->timeout).rel_value_us))
   {
+    GNUNET_STATISTICS_update (GDS_stats,
+                              gettext_noop
+                              ("# Messages dropped (CORE timeout)"),
+                              1,
+                              GNUNET_NO);
     peer->pending_count--;
     GNUNET_CONTAINER_DLL_remove (peer->head, peer->tail, pending);
     GNUNET_free (pending);

Modified: gnunet/src/dht/gnunet-service-xdht_neighbours.c
===================================================================
--- gnunet/src/dht/gnunet-service-xdht_neighbours.c     2014-12-13 19:59:40 UTC 
(rev 34544)
+++ gnunet/src/dht/gnunet-service-xdht_neighbours.c     2014-12-13 20:08:11 UTC 
(rev 34545)
@@ -979,11 +979,18 @@
   size_t msize;
 
   peer->th = NULL;
-  while ((NULL != (pending = peer->head)) &&
-         (0 == GNUNET_TIME_absolute_get_remaining 
(pending->timeout).rel_value_us))
+  while ( (NULL != (pending = peer->head)) &&
+          (0 == GNUNET_TIME_absolute_get_remaining 
(pending->timeout).rel_value_us) )
   {
+    GNUNET_STATISTICS_update (GDS_stats,
+                              gettext_noop
+                              ("# Messages dropped (CORE timeout)"),
+                              1,
+                              GNUNET_NO);
     peer->pending_count--;
-    GNUNET_CONTAINER_DLL_remove (peer->head, peer->tail, pending);
+    GNUNET_CONTAINER_DLL_remove (peer->head,
+                                 peer->tail,
+                                 pending);
     GNUNET_free (pending);
   }
   if (NULL == pending)
@@ -1009,7 +1016,8 @@
   {
     GNUNET_STATISTICS_update (GDS_stats,
                               gettext_noop
-                              ("# Bytes transmitted to other peers"), msize,
+                              ("# Bytes transmitted to other peers"),
+                              msize,
                               GNUNET_NO);
     memcpy (&cbuf[off], pending->msg, msize);
     off += msize;

Modified: gnunet/src/hostlist/gnunet-daemon-hostlist_server.c
===================================================================
--- gnunet/src/hostlist/gnunet-daemon-hostlist_server.c 2014-12-13 19:59:40 UTC 
(rev 34544)
+++ gnunet/src/hostlist/gnunet-daemon-hostlist_server.c 2014-12-13 20:08:11 UTC 
(rev 34545)
@@ -510,6 +510,8 @@
                     const struct GNUNET_PeerIdentity *peer)
 {
   /* nothing to do */
+  /* FIXME: this is wrong, need to CANCEL active
+     NTR! */
 }
 
 

Modified: gnunet/src/include/gnunet_core_service.h
===================================================================
--- gnunet/src/include/gnunet_core_service.h    2014-12-13 19:59:40 UTC (rev 
34544)
+++ gnunet/src/include/gnunet_core_service.h    2014-12-13 20:08:11 UTC (rev 
34545)
@@ -26,7 +26,6 @@
  * @defgroup core encrypted direct communication between peers
  * @{
  */
-
 #ifndef GNUNET_CORE_SERVICE_H
 #define GNUNET_CORE_SERVICE_H
 
@@ -245,7 +244,7 @@
  * established (and the client has been informed about this).  You may
  * have one request of this type pending for each connected peer at
  * any time.  If a peer disconnects, the application MUST call
- * #GNUNET_CORE_notify_transmit_ready_cancel on the respective
+ * #GNUNET_CORE_notify_transmit_ready_cancel() on the respective
  * transmission request, if one such request is pending.
  *
  * @param handle connection to core service
@@ -253,7 +252,7 @@
  * @param priority how important is the message?
  * @param maxdelay how long can the message wait? Only effective if @a cork is 
#GNUNET_YES
  * @param target who should receive the message, never NULL (can be this 
peer's identity for loopback)
- * @param notify_size how many bytes of buffer space does notify want?
+ * @param notify_size how many bytes of buffer space does @a notify want?
  * @param notify function to call when buffer space is available;
  *        will be called with NULL on timeout; clients MUST cancel
  *        all pending transmission requests DURING the disconnect
@@ -261,7 +260,7 @@
  * @param notify_cls closure for @a notify
  * @return non-NULL if the notify callback was queued,
  *         NULL if we can not even queue the request (request already pending);
- *         if NULL is returned, "notify" will NOT be called.
+ *         if NULL is returned, @a notify will NOT be called.
  */
 struct GNUNET_CORE_TransmitHandle *
 GNUNET_CORE_notify_transmit_ready (struct GNUNET_CORE_Handle *handle,