diff options
author | Gabor X Toth <*@tg-x.net> | 2016-10-12 16:41:40 +0000 |
---|---|---|
committer | Gabor X Toth <*@tg-x.net> | 2016-10-12 16:41:40 +0000 |
commit | 172c9bbdfdd7054663efd59e85e415c7ddafe1be (patch) | |
tree | 060ecfd25c08f049d22d2d3f87c747f2d29f60d1 | |
parent | 7dc9da1f79ef3a619df7c17fab139ad6c7b745bc (diff) | |
download | gnunet-172c9bbdfdd7054663efd59e85e415c7ddafe1be.tar.gz gnunet-172c9bbdfdd7054663efd59e85e415c7ddafe1be.zip |
psycstore: fix limit
-rw-r--r-- | src/psycstore/plugin_psycstore_mysql.c | 4 | ||||
-rw-r--r-- | src/psycstore/plugin_psycstore_sqlite.c | 2 |
2 files changed, 5 insertions, 1 deletions
diff --git a/src/psycstore/plugin_psycstore_mysql.c b/src/psycstore/plugin_psycstore_mysql.c index 010673341..e847ffd07 100644 --- a/src/psycstore/plugin_psycstore_mysql.c +++ b/src/psycstore/plugin_psycstore_mysql.c | |||
@@ -1222,6 +1222,10 @@ message_get (void *cls, | |||
1222 | struct Plugin *plugin = cls; | 1222 | struct Plugin *plugin = cls; |
1223 | struct GNUNET_MYSQL_StatementHandle *stmt = plugin->select_messages; | 1223 | struct GNUNET_MYSQL_StatementHandle *stmt = plugin->select_messages; |
1224 | int ret; | 1224 | int ret; |
1225 | |||
1226 | if (0 == fragment_limit) | ||
1227 | fragment_limit = UINT64_MAX; | ||
1228 | |||
1225 | struct GNUNET_MY_QueryParam params_select[] = { | 1229 | struct GNUNET_MY_QueryParam params_select[] = { |
1226 | GNUNET_MY_query_param_auto_from_type (channel_key), | 1230 | GNUNET_MY_query_param_auto_from_type (channel_key), |
1227 | GNUNET_MY_query_param_uint64 (&first_message_id), | 1231 | 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 83ede6e41..e6f795971 100644 --- a/src/psycstore/plugin_psycstore_sqlite.c +++ b/src/psycstore/plugin_psycstore_sqlite.c | |||
@@ -1214,7 +1214,7 @@ message_get (void *cls, | |||
1214 | || SQLITE_OK != sqlite3_bind_int64 (stmt, 4, | 1214 | || SQLITE_OK != sqlite3_bind_int64 (stmt, 4, |
1215 | (0 != fragment_limit) | 1215 | (0 != fragment_limit) |
1216 | ? fragment_limit | 1216 | ? fragment_limit |
1217 | : -1)) | 1217 | : INT64_MAX)) |
1218 | { | 1218 | { |
1219 | LOG_SQLITE (plugin, GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK, | 1219 | LOG_SQLITE (plugin, GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK, |
1220 | "sqlite3_bind"); | 1220 | "sqlite3_bind"); |