diff options
author | Nathan S. Evans <evans@in.tum.de> | 2010-06-24 13:38:03 +0000 |
---|---|---|
committer | Nathan S. Evans <evans@in.tum.de> | 2010-06-24 13:38:03 +0000 |
commit | 586e529b1723ce9b17785b543f04171b7b2b6abd (patch) | |
tree | 86711f7e2430cd6f2e762a40f82559042580bbf7 /src/dv | |
parent | f7eba1c49884581a8da1057089714bc494ade59f (diff) | |
download | gnunet-586e529b1723ce9b17785b543f04171b7b2b6abd.tar.gz gnunet-586e529b1723ce9b17785b543f04171b7b2b6abd.zip |
plugin not receiving messages
Diffstat (limited to 'src/dv')
-rw-r--r-- | src/dv/gnunet-service-dv.c | 15 |
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 |
789 | if (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]; |