[GNUnet-SVN] r22025 - gnunet/src/stream

[gnunet]

Author: harsha
Date: 2012-06-15 17:25:51 +0200 (Fri, 15 Jun 2012)
New Revision: 22025

Modified:
   gnunet/src/stream/stream_api.c
   gnunet/src/stream/test_stream_big.c
Log:
remvod verbose debugging in stream api; fixed warning in stream_big test case

Modified: gnunet/src/stream/stream_api.c
===================================================================
--- gnunet/src/stream/stream_api.c      2012-06-15 15:19:08 UTC (rev 22024)
+++ gnunet/src/stream/stream_api.c      2012-06-15 15:25:51 UTC (rev 22025)
@@ -471,22 +471,6 @@
 
 
 /**
- * Function to print the contents of an address location. Used only for 
debugging
- *
- * @param ptr the address location; Should be more than 5 bytes long
- */
-static void
-debug_print_contents (const void *ptr)
-{
-  /* const char *c; */
-  
-  /* c = ptr; */
-  /* LOG (GNUNET_ERROR_TYPE_DEBUG, */
-  /*      "--- contents: %u %u %u %u %u\n", c[0], c[1], c[2], c[3], c[4]); */
-}
-
-
-/**
  * Callback function for sending queued message
  *
  * @param cls closure the socket
@@ -846,7 +830,6 @@
            "%s: Placing DATA message with sequence %u in send queue\n",
            GNUNET_i2s (&socket->other_peer),
            ntohl (io_handle->messages[packet]->sequence_number));
-      debug_print_contents(&(io_handle->messages[packet][1]));
       copy_and_queue_message (socket,
                               &io_handle->messages[packet]->header,
                               NULL,
@@ -866,7 +849,6 @@
          "%s: Placing DATA message with sequence %u in send queue\n",
          GNUNET_i2s (&socket->other_peer),
          ntohl (io_handle->messages[packet]->sequence_number));
-    debug_print_contents(&(io_handle->messages[packet][1]));
     copy_and_queue_message (socket,
                             &io_handle->messages[packet]->header,
                             NULL,
@@ -928,7 +910,6 @@
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "%s: Calling read processor\n",
        GNUNET_i2s (&socket->other_peer));
-  debug_print_contents (socket->receive_buffer + socket->copy_offset);
   read_size = 
     socket->read_handle->proc (socket->read_handle->proc_cls,
                                socket->status,
@@ -1159,7 +1140,6 @@
       
     /* Copy Data to buffer */
     payload = &msg[1];
-    debug_print_contents(payload);
     GNUNET_assert (relative_offset + size <= socket->receive_buffer_size);
     memcpy (socket->receive_buffer + relative_offset,
             payload,

Modified: gnunet/src/stream/test_stream_big.c
===================================================================
--- gnunet/src/stream/test_stream_big.c 2012-06-15 15:19:08 UTC (rev 22024)
+++ gnunet/src/stream/test_stream_big.c 2012-06-15 15:25:51 UTC (rev 22025)
@@ -164,9 +164,9 @@
     }
   else
     {
-      LOG (GNUNET_ERROR_TYPE_DEBUG,
-           "Finished writing the data; waiting for the other peer to finish"
-           "reading");
+      LOG (GNUNET_ERROR_TYPE_DEBUG, "Writing successfully finished\n");
+      result = GNUNET_OK;
+      GNUNET_SCHEDULER_add_now (&do_shutdown, NULL);
     }
 }
 
@@ -271,8 +271,7 @@
   else 
   {
     /* Peer2 has completed reading*/
-    result = GNUNET_OK;
-    GNUNET_SCHEDULER_add_now (&do_shutdown, NULL);
+    LOG (GNUNET_ERROR_TYPE_DEBUG, "Reading finished successfully\n");
   } 
   return size;
 }