aboutsummaryrefslogtreecommitdiff
path: root/src/psycstore
diff options
context:
space:
mode:
authorGabor X Toth <*@tg-x.net>2016-10-12 16:41:40 +0000
committerGabor X Toth <*@tg-x.net>2016-10-12 16:41:40 +0000
commit172c9bbdfdd7054663efd59e85e415c7ddafe1be (patch)
tree060ecfd25c08f049d22d2d3f87c747f2d29f60d1 /src/psycstore
parent7dc9da1f79ef3a619df7c17fab139ad6c7b745bc (diff)
psycstore: fix limit
Diffstat (limited to 'src/psycstore')
-rw-r--r--src/psycstore/plugin_psycstore_mysql.c4
-rw-r--r--src/psycstore/plugin_psycstore_sqlite.c2
2 files changed, 5 insertions, 1 deletions
diff --git a/src/psycstore/plugin_psycstore_mysql.c b/src/psycstore/plugin_psycstore_mysql.c
index 010673341b..e847ffd07f 100644
--- a/src/psycstore/plugin_psycstore_mysql.c
+++ b/src/psycstore/plugin_psycstore_mysql.c
@@ -1222,6 +1222,10 @@ message_get (void *cls,
struct Plugin *plugin = cls;
struct GNUNET_MYSQL_StatementHandle *stmt = plugin->select_messages;
int ret;
+
+ if (0 == fragment_limit)
+ fragment_limit = UINT64_MAX;
+
struct GNUNET_MY_QueryParam params_select[] = {
GNUNET_MY_query_param_auto_from_type (channel_key),
GNUNET_MY_query_param_uint64 (&first_message_id),
diff --git a/src/psycstore/plugin_psycstore_sqlite.c b/src/psycstore/plugin_psycstore_sqlite.c
index 83ede6e41b..e6f7959717 100644
--- a/src/psycstore/plugin_psycstore_sqlite.c
+++ b/src/psycstore/plugin_psycstore_sqlite.c
@@ -1214,7 +1214,7 @@ message_get (void *cls,
|| SQLITE_OK != sqlite3_bind_int64 (stmt, 4,
(0 != fragment_limit)
? fragment_limit
- : -1))
+ : INT64_MAX))
{
LOG_SQLITE (plugin, GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"sqlite3_bind");