aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/plugin_peerstore_sqlite.c
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-05-16 12:54:18 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-05-16 12:54:18 +0000
commitaeaf5c97d7d115d99f30e86be66c622b7a6ebf4f (patch)
tree13e3f037af1fc84188b91e6054153714ad3f631a /src/peerstore/plugin_peerstore_sqlite.c
parent369811cfb47a51f240c7c4872e29c6eccd21fb0c (diff)
downloadgnunet-aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f.tar.gz
gnunet-aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f.zip
towards peerstore iterate
Diffstat (limited to 'src/peerstore/plugin_peerstore_sqlite.c')
-rw-r--r--src/peerstore/plugin_peerstore_sqlite.c12
1 files changed, 10 insertions, 2 deletions
diff --git a/src/peerstore/plugin_peerstore_sqlite.c b/src/peerstore/plugin_peerstore_sqlite.c
index c44914f43..c5eabac2d 100644
--- a/src/peerstore/plugin_peerstore_sqlite.c
+++ b/src/peerstore/plugin_peerstore_sqlite.c
@@ -116,7 +116,7 @@ peerstore_sqlite_iterate_records (void *cls,
116 const char *sub_system, 116 const char *sub_system,
117 const struct GNUNET_PeerIdentity *peer, 117 const struct GNUNET_PeerIdentity *peer,
118 const char *key, 118 const char *key,
119 GNUNET_PEERSTORE_RecordIterator iter, void *iter_cls) 119 GNUNET_PEERSTORE_Processor iter, void *iter_cls)
120{ 120{
121 struct Plugin *plugin = cls; 121 struct Plugin *plugin = cls;
122 sqlite3_stmt *stmt; 122 sqlite3_stmt *stmt;
@@ -127,6 +127,7 @@ peerstore_sqlite_iterate_records (void *cls,
127 const char *ret_key; 127 const char *ret_key;
128 const void *ret_value; 128 const void *ret_value;
129 size_t ret_value_size; 129 size_t ret_value_size;
130 struct GNUNET_TIME_Absolute ret_expiry;
130 131
131 if(NULL == peer && NULL == key) 132 if(NULL == peer && NULL == key)
132 { 133 {
@@ -170,8 +171,15 @@ peerstore_sqlite_iterate_records (void *cls,
170 ret_key = (const char *)sqlite3_column_text(stmt, 2); 171 ret_key = (const char *)sqlite3_column_text(stmt, 2);
171 ret_value = sqlite3_column_blob(stmt, 3); 172 ret_value = sqlite3_column_blob(stmt, 3);
172 ret_value_size = sqlite3_column_bytes(stmt, 3); 173 ret_value_size = sqlite3_column_bytes(stmt, 3);
174 ret_expiry.abs_value_us = (uint64_t)sqlite3_column_int64(stmt, 4);
173 if (NULL != iter) 175 if (NULL != iter)
174 iter (iter_cls, ret_sub_system, ret_peer, ret_key, ret_value, ret_value_size); 176 iter (iter_cls,
177 ret_sub_system,
178 ret_peer,
179 ret_key,
180 ret_value,
181 ret_value_size,
182 ret_expiry);
175 } 183 }
176 if (SQLITE_DONE != sret) 184 if (SQLITE_DONE != sret)
177 { 185 {