diff options
Diffstat (limited to 'src/transport/gnunet-service-transport_clients.c')
-rw-r--r-- | src/transport/gnunet-service-transport_clients.c | 28 |
1 files changed, 18 insertions, 10 deletions
diff --git a/src/transport/gnunet-service-transport_clients.c b/src/transport/gnunet-service-transport_clients.c index db863ae65..87bc0699b 100644 --- a/src/transport/gnunet-service-transport_clients.c +++ b/src/transport/gnunet-service-transport_clients.c | |||
@@ -747,7 +747,8 @@ clients_handle_send (void *cls, | |||
747 | { | 747 | { |
748 | /* client asked for transmission before 'START' */ | 748 | /* client asked for transmission before 'START' */ |
749 | GNUNET_break (0); | 749 | GNUNET_break (0); |
750 | GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); | 750 | GNUNET_SERVER_receive_done (client, |
751 | GNUNET_SYSERR); | ||
751 | return; | 752 | return; |
752 | } | 753 | } |
753 | 754 | ||
@@ -756,7 +757,8 @@ clients_handle_send (void *cls, | |||
756 | sizeof (struct OutboundMessage) + sizeof (struct GNUNET_MessageHeader)) | 757 | sizeof (struct OutboundMessage) + sizeof (struct GNUNET_MessageHeader)) |
757 | { | 758 | { |
758 | GNUNET_break (0); | 759 | GNUNET_break (0); |
759 | GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); | 760 | GNUNET_SERVER_receive_done (client, |
761 | GNUNET_SYSERR); | ||
760 | return; | 762 | return; |
761 | } | 763 | } |
762 | obm = (const struct OutboundMessage *) message; | 764 | obm = (const struct OutboundMessage *) message; |
@@ -765,7 +767,8 @@ clients_handle_send (void *cls, | |||
765 | if (msize < sizeof (struct GNUNET_MessageHeader)) | 767 | if (msize < sizeof (struct GNUNET_MessageHeader)) |
766 | { | 768 | { |
767 | GNUNET_break (0); | 769 | GNUNET_break (0); |
768 | GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); | 770 | GNUNET_SERVER_receive_done (client, |
771 | GNUNET_SYSERR); | ||
769 | return; | 772 | return; |
770 | } | 773 | } |
771 | 774 | ||
@@ -779,23 +782,27 @@ clients_handle_send (void *cls, | |||
779 | gettext_noop | 782 | gettext_noop |
780 | ("# bytes payload dropped (other peer was not connected)"), | 783 | ("# bytes payload dropped (other peer was not connected)"), |
781 | msize, GNUNET_NO); | 784 | msize, GNUNET_NO); |
782 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 785 | GNUNET_SERVER_receive_done (client, |
786 | GNUNET_OK); | ||
783 | return; | 787 | return; |
784 | } | 788 | } |
785 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 789 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
786 | "Received `%s' request from client with target `%4s' and first message of type %u and total size %u\n", | 790 | "Received SEND request for `%s' and first message of type %u and total size %u\n", |
787 | "SEND", | ||
788 | GNUNET_i2s (&obm->peer), | 791 | GNUNET_i2s (&obm->peer), |
789 | ntohs (obmm->type), | 792 | ntohs (obmm->type), |
790 | msize); | 793 | msize); |
791 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 794 | GNUNET_SERVER_receive_done (client, |
795 | GNUNET_OK); | ||
792 | stcc = GNUNET_new (struct SendTransmitContinuationContext); | 796 | stcc = GNUNET_new (struct SendTransmitContinuationContext); |
793 | stcc->target = obm->peer; | 797 | stcc->target = obm->peer; |
794 | stcc->client = client; | 798 | stcc->client = client; |
795 | GNUNET_SERVER_client_keep (client); | 799 | GNUNET_SERVER_client_keep (client); |
796 | GST_manipulation_send (&obm->peer, obmm, msize, | 800 | GST_manipulation_send (&obm->peer, |
801 | obmm, | ||
802 | msize, | ||
797 | GNUNET_TIME_relative_ntoh (obm->timeout), | 803 | GNUNET_TIME_relative_ntoh (obm->timeout), |
798 | &handle_send_transmit_continuation, stcc); | 804 | &handle_send_transmit_continuation, |
805 | stcc); | ||
799 | } | 806 | } |
800 | 807 | ||
801 | 808 | ||
@@ -824,7 +831,8 @@ clients_handle_request_connect (void *cls, | |||
824 | sizeof (struct GNUNET_PeerIdentity))) | 831 | sizeof (struct GNUNET_PeerIdentity))) |
825 | { | 832 | { |
826 | GNUNET_break (0); | 833 | GNUNET_break (0); |
827 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 834 | GNUNET_SERVER_receive_done (client, |
835 | GNUNET_OK); | ||
828 | return; | 836 | return; |
829 | } | 837 | } |
830 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 838 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |