[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r10567 - gnunet/src/datastore
From: |
gnunet |
Subject: |
[GNUnet-SVN] r10567 - gnunet/src/datastore |
Date: |
Fri, 12 Mar 2010 15:46:27 +0100 |
Author: grothoff
Date: 2010-03-12 15:46:26 +0100 (Fri, 12 Mar 2010)
New Revision: 10567
Modified:
gnunet/src/datastore/gnunet-service-datastore.c
Log:
keep until server done call
Modified: gnunet/src/datastore/gnunet-service-datastore.c
===================================================================
--- gnunet/src/datastore/gnunet-service-datastore.c 2010-03-12 14:35:42 UTC
(rev 10566)
+++ gnunet/src/datastore/gnunet-service-datastore.c 2010-03-12 14:46:26 UTC
(rev 10567)
@@ -454,9 +454,8 @@
if (tcc->tc != NULL)
tcc->tc (tcc->tc_cls, GNUNET_SYSERR);
if (GNUNET_YES == tcc->end)
- {
- GNUNET_SERVER_receive_done (tcc->client, GNUNET_SYSERR);
- }
+ GNUNET_SERVER_receive_done (tcc->client, GNUNET_SYSERR);
+ GNUNET_SERVER_client_drop (tcc->client);
GNUNET_free (tcc->msg);
GNUNET_free (tcc);
return 0;
@@ -476,6 +475,7 @@
"Response transmitted, more pending!\n");
#endif
}
+ GNUNET_SERVER_client_drop (tcc->client);
GNUNET_free (tcc->msg);
GNUNET_free (tcc);
return msize;
@@ -510,9 +510,9 @@
tcc->end = end;
if (NULL ==
(tcc->th = GNUNET_SERVER_notify_transmit_ready (client,
- ntohs(msg->size),
-
GNUNET_TIME_UNIT_FOREVER_REL,
- &transmit_callback,
+ ntohs(msg->size),
+
GNUNET_TIME_UNIT_FOREVER_REL,
+ &transmit_callback,
tcc)))
{
GNUNET_break (0);
@@ -530,6 +530,7 @@
GNUNET_free (tcc);
return;
}
+ GNUNET_SERVER_client_keep (client);
GNUNET_CONTAINER_DLL_insert (tcc_head,
tcc_tail,
tcc);
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r10567 - gnunet/src/datastore,
gnunet <=