diff options
| author | grothoff <grothoff@140774ce-b5e7-0310-ab8b-a85725594a96> | 2011-07-18 07:43:18 +0000 |
|---|---|---|
| committer | grothoff <grothoff@140774ce-b5e7-0310-ab8b-a85725594a96> | 2011-07-18 07:43:18 +0000 |
| commit | d49bf45d41990d917436a4332ec19cf2492213fb (patch) | |
| tree | 748e6f52399ac38884296df4d1e437b787b5347e /src/datastore/plugin_datastore_sqlite.c | |
| parent | e4fe76f826ff947f817e1205f93628b8dd374ce6 (diff) | |
checkret
git-svn-id: https://gnunet.org/svn/gnunet@16070 140774ce-b5e7-0310-ab8b-a85725594a96
Diffstat (limited to 'src/datastore/plugin_datastore_sqlite.c')
| -rw-r--r-- | src/datastore/plugin_datastore_sqlite.c | 41 |
1 files changed, 36 insertions, 5 deletions
diff --git a/src/datastore/plugin_datastore_sqlite.c b/src/datastore/plugin_datastore_sqlite.c index 7c7c49468a..3d2a1bb068 100644 --- a/src/datastore/plugin_datastore_sqlite.c +++ b/src/datastore/plugin_datastore_sqlite.c @@ -418,7 +418,16 @@ static int 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 @@ sqlite_plugin_update (void *cls, 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 @@ sqlite_plugin_get_replication (void *cls, 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 | |