From 51117c142f3e315f3085761cee3aeee21b93a445 Mon Sep 17 00:00:00 2001
From: Sree Harsha Totakura <totakura@in.tum.de>
Date: Thu, 8 Mar 2012 13:23:49 +0000
Subject: [PATCH] more assertions

---
 src/stream/stream_api.c        |  4 ++--
 src/stream/test_stream_local.c | 27 +++++++++++++++++++++++++--
 2 files changed, 27 insertions(+), 4 deletions(-)

diff --git a/src/stream/stream_api.c b/src/stream/stream_api.c
index d694d43bb..19a2d918d 100644
--- a/src/stream/stream_api.c
+++ b/src/stream/stream_api.c
@@ -1989,8 +1989,8 @@ mesh_peer_connect_callback (void *cls,
   
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "%s: Target peer %s connected\n", 
-              GNUNET_i2s (&socket->our_id),
-              GNUNET_i2s (peer));
+              GNUNET_i2s (&(socket->our_id)),
+              GNUNET_i2s (&(socket->other_peer)));
   
   /* Set state to INIT */
   socket->state = STATE_INIT;
diff --git a/src/stream/test_stream_local.c b/src/stream/test_stream_local.c
index 9cf608164..927194e3f 100644
--- a/src/stream/test_stream_local.c
+++ b/src/stream/test_stream_local.c
@@ -59,6 +59,11 @@ struct PeerData
    */
   struct GNUNET_STREAM_IOReadHandle *io_read_handle;
 
+  /**
+   * Our Peer id
+   */
+  struct GNUNET_PeerIdentity our_id;
+
   /**
    * Bytes the peer has written
    */
@@ -240,7 +245,10 @@ stream_open_cb (void *cls,
 {
   struct PeerData *peer;
 
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stream established from peer1\n");
+  GNUNET_assert (socket == peer1.socket);
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "%s: Stream established from peer1\n",
+              GNUNET_i2s (&peer1.our_id));
   peer = (struct PeerData *) cls;
   peer->bytes_wrote = 0;
   GNUNET_assert (socket == peer1.socket);
@@ -356,7 +364,9 @@ stream_listen_cb (void *cls,
   GNUNET_assert (socket != peer1.socket);
 
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-              "Peer connected: %s\n", GNUNET_i2s(initiator));
+              "%s: Peer connected: %s\n",
+              GNUNET_i2s (&peer2.our_id),
+              GNUNET_i2s(initiator));
 
   peer2.socket = socket;
   read_task = GNUNET_SCHEDULER_add_now (&stream_read, (void *) socket);
@@ -390,6 +400,19 @@ peergroup_ready (void *cls, const char *emsg)
   d2 = GNUNET_TESTING_daemon_get (pg, 1);
   GNUNET_assert (NULL != d2);
 
+  GNUNET_TESTING_get_peer_identity (d1->cfg,
+                                    &peer1.our_id);
+  GNUNET_TESTING_get_peer_identity (d2->cfg,
+                                    &peer2.our_id);
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "%s : %s\n",
+              GNUNET_i2s (&peer1.our_id),
+              GNUNET_i2s (&d1->id));
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "%s : %s\n",
+              GNUNET_i2s (&peer2.our_id),
+              GNUNET_i2s (&d2->id));
+
   peer2_listen_socket = GNUNET_STREAM_listen (d2->cfg,
                                               10, /* App port */
                                               &stream_listen_cb,
-- 
2.25.1