aboutsummaryrefslogtreecommitdiff
path: root/src/transport/gnunet-service-transport_clients.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/gnunet-service-transport_clients.c')
-rw-r--r--src/transport/gnunet-service-transport_clients.c28
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,