diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2011-10-04 09:10:26 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2011-10-04 09:10:26 +0000 |
commit | d28be6b6fb0f67169f93d0c96fb513d67b298ce4 (patch) | |
tree | ba5eb229fe4f41c1d110466e2b13234d6252cad9 /src/transport/gnunet-service-transport_clients.c | |
parent | a73989c1d1334406bf9319f54eff34b987b985f8 (diff) | |
download | gnunet-d28be6b6fb0f67169f93d0c96fb513d67b298ce4.tar.gz gnunet-d28be6b6fb0f67169f93d0c96fb513d67b298ce4.zip |
fixing #17134
Diffstat (limited to 'src/transport/gnunet-service-transport_clients.c')
-rw-r--r-- | src/transport/gnunet-service-transport_clients.c | 32 |
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 | |||
181 | transmit_to_client_callback (void *cls, size_t size, void *buf) | 181 | transmit_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 | ||