diff options
author | Christian Grothoff <christian@grothoff.org> | 2017-01-20 20:39:51 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2017-01-20 20:39:51 +0100 |
commit | f52fc4b001758430bb911759c755d0f06d3eb693 (patch) | |
tree | 185370e26928136dfb2786843d06ed0a90f3ffd5 /src/cadet/cadet_api.c | |
parent | 6a828bdf078d44531cc8e7de70a88e9b6f438da9 (diff) | |
download | gnunet-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.c | 8 |
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)); |