aboutsummaryrefslogtreecommitdiff
path: root/src/transport
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2011-10-04 09:10:26 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2011-10-04 09:10:26 +0000
commitd28be6b6fb0f67169f93d0c96fb513d67b298ce4 (patch)
treeba5eb229fe4f41c1d110466e2b13234d6252cad9 /src/transport
parenta73989c1d1334406bf9319f54eff34b987b985f8 (diff)
downloadgnunet-d28be6b6fb0f67169f93d0c96fb513d67b298ce4.tar.gz
gnunet-d28be6b6fb0f67169f93d0c96fb513d67b298ce4.zip
fixing #17134
Diffstat (limited to 'src/transport')
-rw-r--r--src/transport/gnunet-service-transport_clients.c32
1 files changed, 2 insertions, 30 deletions
diff --git a/src/transport/gnunet-service-transport_clients.c b/src/transport/gnunet-service-transport_clients.c
index 6e62ae5f4..23b72b48e 100644
--- a/src/transport/gnunet-service-transport_clients.c
+++ b/src/transport/gnunet-service-transport_clients.c
@@ -181,30 +181,12 @@ static size_t
181transmit_to_client_callback (void *cls, size_t size, void *buf) 181transmit_to_client_callback (void *cls, size_t size, void *buf)
182{ 182{
183 struct TransportClient *tc = cls; 183 struct TransportClient *tc = cls;
184 struct TransportClient *tmp;
185 struct ClientMessageQueueEntry *q; 184 struct ClientMessageQueueEntry *q;
186 const struct GNUNET_MessageHeader *msg; 185 const struct GNUNET_MessageHeader *msg;
187 char *cbuf; 186 char *cbuf;
188 uint16_t msize; 187 uint16_t msize;
189 size_t tsize; 188 size_t tsize;
190 189
191 tmp = clients_head;
192 while (tmp != NULL)
193 {
194 if (tc == tmp)
195 break;
196 tmp = tmp->next;
197 }
198
199 if (tc == NULL)
200 {
201#if DEBUG_TRANSPORT
202 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
203 "Transmission to client failed, client already disconnected.\n");
204#endif
205 return 0;
206 }
207
208 tc->th = NULL; 190 tc->th = NULL;
209 if (buf == NULL) 191 if (buf == NULL)
210 { 192 {
@@ -485,18 +467,8 @@ handle_send_transmit_continuation (void *cls, int success)
485 send_ok_msg.latency = 467 send_ok_msg.latency =
486 GNUNET_TIME_relative_hton (GNUNET_TIME_UNIT_FOREVER_REL); 468 GNUNET_TIME_relative_hton (GNUNET_TIME_UNIT_FOREVER_REL);
487 send_ok_msg.peer = stcc->target; 469 send_ok_msg.peer = stcc->target;
488 tc = lookup_client(stcc->client); 470 GST_clients_unicast (stcc->client, &send_ok_msg.header, GNUNET_NO);
489 if (tc != NULL) 471 GNUNET_SERVER_client_drop (stcc->client);
490 {
491#if DEBUG_TRANSPORT
492 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG | GNUNET_ERROR_TYPE_BULK,
493 "Sending `%s' to client %X\n",
494 "GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_OK",
495 tc);
496#endif
497 GST_clients_unicast (stcc->client, &send_ok_msg.header, GNUNET_NO);
498 GNUNET_SERVER_client_drop (stcc->client);
499 }
500 GNUNET_free (stcc); 472 GNUNET_free (stcc);
501} 473}
502 474