}
if (! ( (pc == 0) && (-1 != (int) ft) && (va_arg (ap, int) == -1) ) )
{
- GNUNET_break (0);
+ GNUNET_assert (0);
return GNUNET_SYSERR;
}
if (mysql_stmt_bind_param (s->statement, qbind))
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,
struct NextRequestClosure *nrc)
{
struct Plugin *plugin = cls;
- unsigned long long nt;
- nt = (unsigned long long) nrc->now.abs_value;
+ nrc->end_it = GNUNET_YES;
return prepared_statement_run_select (plugin,
plugin->select_replication,
- 6, nrc->rbind,
+ 7, nrc->rbind,
&return_ok, NULL,
- MYSQL_TYPE_LONGLONG, &nt, GNUNET_YES,
-1);
}
if (NULL == nrc)
return GNUNET_NO;
+ nrc->end_it = GNUNET_YES;
nt = (long long) nrc->now.abs_value;
return prepared_statement_run_select
(plugin,