[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r16070 - gnunet/src/datastore
From: |
gnunet |
Subject: |
[GNUnet-SVN] r16070 - gnunet/src/datastore |
Date: |
Mon, 18 Jul 2011 09:43:19 +0200 |
Author: grothoff
Date: 2011-07-18 09:43:18 +0200 (Mon, 18 Jul 2011)
New Revision: 16070
Modified:
gnunet/src/datastore/plugin_datastore_sqlite.c
Log:
checkret
Modified: gnunet/src/datastore/plugin_datastore_sqlite.c
===================================================================
--- gnunet/src/datastore/plugin_datastore_sqlite.c 2011-07-18 07:16:28 UTC
(rev 16069)
+++ gnunet/src/datastore/plugin_datastore_sqlite.c 2011-07-18 07:43:18 UTC
(rev 16070)
@@ -418,7 +418,16 @@
delete_by_rowid (struct Plugin* plugin,
unsigned long long rid)
{
- sqlite3_bind_int64 (plugin->delRow, 1, rid);
+ if (SQLITE_OK !=
+ sqlite3_bind_int64 (plugin->delRow, 1, rid))
+ {
+ LOG_SQLITE (plugin, NULL,
+ GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"sqlite3_bind_XXXX");
+ if (SQLITE_OK != sqlite3_reset (plugin->delRow))
+ LOG_SQLITE (plugin, NULL,
+ GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"sqlite3_reset");
+ return GNUNET_SYSERR;
+ }
if (SQLITE_DONE != sqlite3_step (plugin->delRow))
{
LOG_SQLITE (plugin, NULL,
@@ -585,9 +594,21 @@
struct Plugin *plugin = cls;
int n;
- sqlite3_bind_int (plugin->updPrio, 1, delta);
- sqlite3_bind_int64 (plugin->updPrio, 2, expire.abs_value);
- sqlite3_bind_int64 (plugin->updPrio, 3, uid);
+ if ( (SQLITE_OK !=
+ sqlite3_bind_int (plugin->updPrio, 1, delta)) ||
+ (SQLITE_OK !=
+ sqlite3_bind_int64 (plugin->updPrio, 2, expire.abs_value)) ||
+ (SQLITE_OK !=
+ sqlite3_bind_int64 (plugin->updPrio, 3, uid)) )
+ {
+ LOG_SQLITE (plugin, msg,
+ GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"sqlite3_bind_XXXX");
+ if (SQLITE_OK != sqlite3_reset (plugin->updPrio))
+ LOG_SQLITE (plugin, NULL,
+ GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"sqlite3_reset");
+ return GNUNET_SYSERR;
+
+ }
n = sqlite3_step (plugin->updPrio);
if (SQLITE_OK != sqlite3_reset (plugin->updPrio))
LOG_SQLITE (plugin, NULL,
@@ -989,7 +1010,17 @@
execute_get (plugin, plugin->selRepl, &repl_proc, &rc);
if (GNUNET_YES == rc.have_uid)
{
- sqlite3_bind_int64 (plugin->updRepl, 1, rc.uid);
+ if (SQLITE_OK !=
+ sqlite3_bind_int64 (plugin->updRepl, 1, rc.uid))
+ {
+ LOG_SQLITE (plugin, NULL,
+ GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"sqlite3_bind_XXXX");
+ if (SQLITE_OK != sqlite3_reset (plugin->updRepl))
+ LOG_SQLITE (plugin, NULL,
+ GNUNET_ERROR_TYPE_ERROR |
+ GNUNET_ERROR_TYPE_BULK, "sqlite3_reset");
+ return;
+ }
if (SQLITE_DONE != sqlite3_step (plugin->updRepl))
LOG_SQLITE (plugin, NULL,
GNUNET_ERROR_TYPE_ERROR |
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r16070 - gnunet/src/datastore,
gnunet <=