aboutsummaryrefslogtreecommitdiff
path: root/src/datastore/plugin_datastore_mysql.c
diff options
context:
space:
mode:
authorgrothoff <grothoff@140774ce-b5e7-0310-ab8b-a85725594a96>2011-04-15 11:14:55 +0000
committergrothoff <grothoff@140774ce-b5e7-0310-ab8b-a85725594a96>2011-04-15 11:14:55 +0000
commit83b92e2383e027b44b91f2a084e074a8ef473e77 (patch)
tree420c750b4a18979c3ac9693cebb0dda2ba1f8b42 /src/datastore/plugin_datastore_mysql.c
parentce5e9026da0f01b8460b0da1da26c99099ca1b89 (diff)
fix
git-svn-id: https://gnunet.org/svn/gnunet@14984 140774ce-b5e7-0310-ab8b-a85725594a96
Diffstat (limited to 'src/datastore/plugin_datastore_mysql.c')
-rw-r--r--src/datastore/plugin_datastore_mysql.c4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/datastore/plugin_datastore_mysql.c b/src/datastore/plugin_datastore_mysql.c
index fdbb9d1b58..1658aa51a2 100644
--- a/src/datastore/plugin_datastore_mysql.c
+++ b/src/datastore/plugin_datastore_mysql.c
@@ -946,7 +946,7 @@ mysql_next_request_cont (void *next_cls,
exp);
#endif
expiration.abs_value = exp;
- ret = nrc->dviter (nrc->dviter_cls, nrc,
+ ret = nrc->dviter (nrc->dviter_cls, (nrc->end_it == GNUNET_YES) ? NULL : nrc,
&key,
size, value,
type, priority, anonymity, expiration,
@@ -1466,6 +1466,7 @@ replication_prepare (void *cls,
{
struct Plugin *plugin = cls;
+ nrc->end_it = GNUNET_YES;
return prepared_statement_run_select (plugin,
plugin->select_replication,
7, nrc->rbind,
@@ -1521,6 +1522,7 @@ expiration_prepare (void *cls,
if (NULL == nrc)
return GNUNET_NO;
+ nrc->end_it = GNUNET_YES;
nt = (long long) nrc->now.abs_value;
return prepared_statement_run_select
(plugin,