diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-04-15 11:14:55 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-04-15 11:14:55 +0000 |
commit | 7dd02c04e03327c3415f72261933476360e4b906 (patch) | |
tree | 420c750b4a18979c3ac9693cebb0dda2ba1f8b42 /src/datastore | |
parent | 20c70f2888f89ae14b4a1ca02dde2ac0ac5c9ed1 (diff) | |
download | gnunet-7dd02c04e03327c3415f72261933476360e4b906.tar.gz gnunet-7dd02c04e03327c3415f72261933476360e4b906.zip |
fix
Diffstat (limited to 'src/datastore')
-rw-r--r-- | src/datastore/plugin_datastore_mysql.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/datastore/plugin_datastore_mysql.c b/src/datastore/plugin_datastore_mysql.c index fdbb9d1b5..1658aa51a 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, | |||
946 | exp); | 946 | exp); |
947 | #endif | 947 | #endif |
948 | expiration.abs_value = exp; | 948 | expiration.abs_value = exp; |
949 | ret = nrc->dviter (nrc->dviter_cls, nrc, | 949 | ret = nrc->dviter (nrc->dviter_cls, (nrc->end_it == GNUNET_YES) ? NULL : nrc, |
950 | &key, | 950 | &key, |
951 | size, value, | 951 | size, value, |
952 | type, priority, anonymity, expiration, | 952 | type, priority, anonymity, expiration, |
@@ -1466,6 +1466,7 @@ replication_prepare (void *cls, | |||
1466 | { | 1466 | { |
1467 | struct Plugin *plugin = cls; | 1467 | struct Plugin *plugin = cls; |
1468 | 1468 | ||
1469 | nrc->end_it = GNUNET_YES; | ||
1469 | return prepared_statement_run_select (plugin, | 1470 | return prepared_statement_run_select (plugin, |
1470 | plugin->select_replication, | 1471 | plugin->select_replication, |
1471 | 7, nrc->rbind, | 1472 | 7, nrc->rbind, |
@@ -1521,6 +1522,7 @@ expiration_prepare (void *cls, | |||
1521 | 1522 | ||
1522 | if (NULL == nrc) | 1523 | if (NULL == nrc) |
1523 | return GNUNET_NO; | 1524 | return GNUNET_NO; |
1525 | nrc->end_it = GNUNET_YES; | ||
1524 | nt = (long long) nrc->now.abs_value; | 1526 | nt = (long long) nrc->now.abs_value; |
1525 | return prepared_statement_run_select | 1527 | return prepared_statement_run_select |
1526 | (plugin, | 1528 | (plugin, |