diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-05-16 12:54:18 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-05-16 12:54:18 +0000 |
commit | aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f (patch) | |
tree | 13e3f037af1fc84188b91e6054153714ad3f631a /src/peerstore/plugin_peerstore_sqlite.c | |
parent | 369811cfb47a51f240c7c4872e29c6eccd21fb0c (diff) | |
download | gnunet-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.c | 12 |
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 | { |