aboutsummaryrefslogtreecommitdiff
path: root/src/dv
diff options
context:
space:
mode:
authorNathan S. Evans <evans@in.tum.de>2010-06-24 13:38:03 +0000
committerNathan S. Evans <evans@in.tum.de>2010-06-24 13:38:03 +0000
commit586e529b1723ce9b17785b543f04171b7b2b6abd (patch)
tree86711f7e2430cd6f2e762a40f82559042580bbf7 /src/dv
parentf7eba1c49884581a8da1057089714bc494ade59f (diff)
downloadgnunet-586e529b1723ce9b17785b543f04171b7b2b6abd.tar.gz
gnunet-586e529b1723ce9b17785b543f04171b7b2b6abd.zip
plugin not receiving messages
Diffstat (limited to 'src/dv')
-rw-r--r--src/dv/gnunet-service-dv.c15
1 files changed, 8 insertions, 7 deletions
diff --git a/src/dv/gnunet-service-dv.c b/src/dv/gnunet-service-dv.c
index 81cf15453..45ae281f9 100644
--- a/src/dv/gnunet-service-dv.c
+++ b/src/dv/gnunet-service-dv.c
@@ -741,7 +741,7 @@ void send_to_plugin(const struct GNUNET_PeerIdentity * sender,
741{ 741{
742 struct GNUNET_DV_MessageReceived *received_msg; 742 struct GNUNET_DV_MessageReceived *received_msg;
743 struct PendingMessage *pending_message; 743 struct PendingMessage *pending_message;
744#if DEBUG_DV 744#if DEBUG_DV_MESSAGES
745 struct GNUNET_MessageHeader * packed_message_header; 745 struct GNUNET_MessageHeader * packed_message_header;
746 struct GNUNET_HELLO_Message *hello_msg; 746 struct GNUNET_HELLO_Message *hello_msg;
747 struct GNUNET_PeerIdentity hello_identity; 747 struct GNUNET_PeerIdentity hello_identity;
@@ -786,12 +786,13 @@ void send_to_plugin(const struct GNUNET_PeerIdentity * sender,
786 packed_msg_start = &packed_msg_start[sender_address_len]; 786 packed_msg_start = &packed_msg_start[sender_address_len];
787 memcpy(packed_msg_start, message, message_size); 787 memcpy(packed_msg_start, message, message_size);
788#if DEBUG_DV_MESSAGES 788#if DEBUG_DV_MESSAGES
789if (ntohs(packed_message_header->type) == GNUNET_MESSAGE_TYPE_HELLO) 789 packed_message_header = (struct GNUNET_MessageHeader *)packed_msg_start;
790 { 790 if (ntohs(packed_message_header->type) == GNUNET_MESSAGE_TYPE_HELLO)
791 hello_msg = (struct GNUNET_HELLO_Message *)packed_message_header; 791 {
792 GNUNET_assert(GNUNET_OK == GNUNET_HELLO_get_id(hello_msg, &hello_identity)); 792 hello_msg = (struct GNUNET_HELLO_Message *)packed_msg_start;
793 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "%s: send_to_plugin: Packed HELLO message is about peer %s\n", my_short_id, GNUNET_i2s(&hello_identity)); 793 GNUNET_assert(GNUNET_OK == GNUNET_HELLO_get_id(hello_msg, &hello_identity));
794 } 794 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "%s: send_to_plugin: Packed HELLO message is about peer %s\n", my_short_id, GNUNET_i2s(&hello_identity));
795 }
795#endif 796#endif
796 pending_message = GNUNET_malloc(sizeof(struct PendingMessage) + size); 797 pending_message = GNUNET_malloc(sizeof(struct PendingMessage) + size);
797 pending_message->msg = (struct GNUNET_MessageHeader *)&pending_message[1]; 798 pending_message->msg = (struct GNUNET_MessageHeader *)&pending_message[1];