aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/cadet_api.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2017-01-20 20:39:51 +0100
committerChristian Grothoff <christian@grothoff.org>2017-01-20 20:39:51 +0100
commitf52fc4b001758430bb911759c755d0f06d3eb693 (patch)
tree185370e26928136dfb2786843d06ed0a90f3ffd5 /src/cadet/cadet_api.c
parent6a828bdf078d44531cc8e7de70a88e9b6f438da9 (diff)
downloadgnunet-f52fc4b001758430bb911759c755d0f06d3eb693.tar.gz
gnunet-f52fc4b001758430bb911759c755d0f06d3eb693.zip
working on channel passing data to clients
Diffstat (limited to 'src/cadet/cadet_api.c')
-rw-r--r--src/cadet/cadet_api.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/cadet/cadet_api.c b/src/cadet/cadet_api.c
index 8f1274d63..5dcf43e46 100644
--- a/src/cadet/cadet_api.c
+++ b/src/cadet/cadet_api.c
@@ -569,7 +569,7 @@ request_data (void *cls)
569 env = GNUNET_MQ_msg_extra (msg, 569 env = GNUNET_MQ_msg_extra (msg,
570 th->size, 570 th->size,
571 GNUNET_MESSAGE_TYPE_CADET_LOCAL_DATA); 571 GNUNET_MESSAGE_TYPE_CADET_LOCAL_DATA);
572 msg->id = th->channel->chid; 572 msg->channel_id = th->channel->chid;
573 osize = th->notify (th->notify_cls, 573 osize = th->notify (th->notify_cls,
574 th->size, 574 th->size,
575 &msg[1]); 575 &msg[1]);
@@ -697,7 +697,7 @@ check_local_data (void *cls,
697 } 697 }
698 698
699 ch = retrieve_channel (h, 699 ch = retrieve_channel (h,
700 message->id); 700 message->channel_id);
701 if (NULL == ch) 701 if (NULL == ch)
702 { 702 {
703 GNUNET_break_op (0); 703 GNUNET_break_op (0);
@@ -727,7 +727,7 @@ handle_local_data (void *cls,
727 727
728 LOG (GNUNET_ERROR_TYPE_DEBUG, 728 LOG (GNUNET_ERROR_TYPE_DEBUG,
729 "Got a data message!\n"); 729 "Got a data message!\n");
730 ch = retrieve_channel (h, message->id); 730 ch = retrieve_channel (h, message->channel_id);
731 GNUNET_assert (NULL != ch); 731 GNUNET_assert (NULL != ch);
732 732
733 payload = (struct GNUNET_MessageHeader *) &message[1]; 733 payload = (struct GNUNET_MessageHeader *) &message[1];
@@ -735,7 +735,7 @@ handle_local_data (void *cls,
735 GC_f2s (ntohl (ch->chid.channel_of_client) >= 735 GC_f2s (ntohl (ch->chid.channel_of_client) >=
736 GNUNET_CADET_LOCAL_CHANNEL_ID_CLI), 736 GNUNET_CADET_LOCAL_CHANNEL_ID_CLI),
737 GNUNET_i2s (GNUNET_PEER_resolve2 (ch->peer)), 737 GNUNET_i2s (GNUNET_PEER_resolve2 (ch->peer)),
738 ntohl (message->id.channel_of_client)); 738 ntohl (message->channel_id.channel_of_client));
739 739
740 type = ntohs (payload->type); 740 type = ntohs (payload->type);
741 LOG (GNUNET_ERROR_TYPE_DEBUG, " payload type %s\n", GC_m2s (type)); 741 LOG (GNUNET_ERROR_TYPE_DEBUG, " payload type %s\n", GC_m2s (type));