diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2014-01-07 09:31:13 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2014-01-07 09:31:13 +0000 |
commit | 0da95dcf912658ec3e4385c8969f43f666c0e27d (patch) | |
tree | e74aaff37bac682e04d71e8a1b57067573ebdeed /src/testbed/generate-underlay-topology.c | |
parent | 3116afe785564607b30d1ba973c7345853e327f0 (diff) | |
download | gnunet-0da95dcf912658ec3e4385c8969f43f666c0e27d.tar.gz gnunet-0da95dcf912658ec3e4385c8969f43f666c0e27d.zip |
- use asynchronous to speedup sqlite db writes
Diffstat (limited to 'src/testbed/generate-underlay-topology.c')
-rw-r--r-- | src/testbed/generate-underlay-topology.c | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/src/testbed/generate-underlay-topology.c b/src/testbed/generate-underlay-topology.c index 4299795a5..985c8e32e 100644 --- a/src/testbed/generate-underlay-topology.c +++ b/src/testbed/generate-underlay-topology.c | |||
@@ -149,24 +149,21 @@ setup_db (const char *dbfile) | |||
149 | " ?3," | 149 | " ?3," |
150 | " ?4," | 150 | " ?4," |
151 | " ?5);"; | 151 | " ?5);"; |
152 | struct sqlite3_stmt *stmt_create; | ||
153 | int ret; | 152 | int ret; |
154 | 153 | ||
155 | stmt_create = NULL; | ||
156 | if (SQLITE_OK != (ret = sqlite3_open (dbfile, &db))) | 154 | if (SQLITE_OK != (ret = sqlite3_open (dbfile, &db))) |
157 | { | 155 | { |
158 | LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_open"); | 156 | LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_open"); |
159 | goto err_ret; | 157 | goto err_ret; |
160 | } | 158 | } |
161 | if (SQLITE_OK != (ret = sqlite3_prepare_v2 (db, query_create, -1, | 159 | if (0 != sqlite3_exec (db, query_create, NULL, NULL, NULL)) |
162 | &stmt_create, NULL))) | ||
163 | { | 160 | { |
164 | LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_prepare_v2"); | 161 | LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_exec"); |
165 | goto err_ret; | 162 | goto err_ret; |
166 | } | 163 | } |
167 | if (SQLITE_DONE != sqlite3_step (stmt_create)) | 164 | if (0 != sqlite3_exec (db, "PRAGMA synchronous = 0;", NULL, NULL, NULL)) |
168 | { | 165 | { |
169 | LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_step"); | 166 | LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_exec"); |
170 | goto err_ret; | 167 | goto err_ret; |
171 | } | 168 | } |
172 | if (SQLITE_OK != (ret = sqlite3_prepare_v2 (db, query_insert, -1, | 169 | if (SQLITE_OK != (ret = sqlite3_prepare_v2 (db, query_insert, -1, |
@@ -177,8 +174,6 @@ setup_db (const char *dbfile) | |||
177 | } | 174 | } |
178 | 175 | ||
179 | err_ret: | 176 | err_ret: |
180 | if (NULL != stmt_create) | ||
181 | sqlite3_finalize (stmt_create); | ||
182 | return (SQLITE_OK != ret) ? GNUNET_SYSERR : GNUNET_OK; | 177 | return (SQLITE_OK != ret) ? GNUNET_SYSERR : GNUNET_OK; |
183 | } | 178 | } |
184 | 179 | ||