X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fdb.cpp;h=6764f84ce54aad90d1e82df50c5862d243b270da;hb=9ffd4f03f314cc6e0254449593def95c9bc203d6;hp=39fd55776c40c9f094e84bfbbb4aed906b65fed6;hpb=9b7d691b4cc5db7dbfc18c82e86c1207fcac4722;p=nageru

diff --git a/futatabi/db.cpp b/futatabi/db.cpp
index 39fd557..6764f84 100644
--- a/futatabi/db.cpp
+++ b/futatabi/db.cpp
@@ -3,6 +3,7 @@
 #include "frame.pb.h"
 
 #include <string>
+#include <unordered_set>
 
 using namespace std;
 
@@ -11,20 +12,40 @@ DB::DB(const string &filename)
 	int ret = sqlite3_open(filename.c_str(), &db);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "%s: %s\n", filename.c_str(), sqlite3_errmsg(db));
-		exit(1);
+		abort();
+	}
+
+	// Set an effectively infinite timeout for waiting for write locks;
+	// if we get SQLITE_LOCKED, we just exit out, so this is much better.
+	ret = sqlite3_busy_timeout(db, 3600000);
+	if (ret != SQLITE_OK) {
+		fprintf(stderr, "sqlite3_busy_timeout: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
 	sqlite3_exec(db, R"(
 		CREATE TABLE IF NOT EXISTS state (state BLOB);
-	)", nullptr, nullptr, nullptr);  // Ignore errors.
+	)",
+	             nullptr, nullptr, nullptr);  // Ignore errors.
+
+	sqlite3_exec(db, "CREATE UNIQUE INDEX only_one_state ON state (1);", nullptr, nullptr, nullptr);  // Ignore errors.
+
+	sqlite3_exec(db, R"(
+		CREATE TABLE IF NOT EXISTS settings (settings BLOB);
+	)",
+	             nullptr, nullptr, nullptr);  // Ignore errors.
+
+	sqlite3_exec(db, "CREATE UNIQUE INDEX only_one_settings ON settings (1);", nullptr, nullptr, nullptr);  // Ignore errors.
 
 	sqlite3_exec(db, R"(
 		DROP TABLE file;
-	)", nullptr, nullptr, nullptr);  // Ignore errors.
+	)",
+	             nullptr, nullptr, nullptr);  // Ignore errors.
 
 	sqlite3_exec(db, R"(
 		DROP TABLE frame;
-	)", nullptr, nullptr, nullptr);  // Ignore errors.
+	)",
+	             nullptr, nullptr, nullptr);  // Ignore errors.
 
 	sqlite3_exec(db, R"(
 		CREATE TABLE IF NOT EXISTS filev2 (
@@ -33,7 +54,8 @@ DB::DB(const string &filename)
 			size BIGINT NOT NULL,
 			frames BLOB NOT NULL
 		);
-	)", nullptr, nullptr, nullptr);  // Ignore errors.
+	)",
+	             nullptr, nullptr, nullptr);  // Ignore errors.
 
 	sqlite3_exec(db, "PRAGMA journal_mode=WAL", nullptr, nullptr, nullptr);  // Ignore errors.
 	sqlite3_exec(db, "PRAGMA synchronous=NORMAL", nullptr, nullptr, nullptr);  // Ignore errors.
@@ -47,7 +69,7 @@ StateProto DB::get_state()
 	int ret = sqlite3_prepare_v2(db, "SELECT state FROM state", -1, &stmt, 0);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "SELECT prepare: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	ret = sqlite3_step(stmt);
@@ -55,17 +77,17 @@ StateProto DB::get_state()
 		bool ok = state.ParseFromArray(sqlite3_column_blob(stmt, 0), sqlite3_column_bytes(stmt, 0));
 		if (!ok) {
 			fprintf(stderr, "State in database is corrupted!\n");
-			exit(1);
+			abort();
 		}
 	} else if (ret != SQLITE_DONE) {
 		fprintf(stderr, "SELECT step: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	ret = sqlite3_finalize(stmt);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "SELECT finalize: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	return state;
@@ -79,40 +101,105 @@ void DB::store_state(const StateProto &state)
 	int ret = sqlite3_exec(db, "BEGIN", nullptr, nullptr, nullptr);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "BEGIN: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
-	ret = sqlite3_exec(db, "DELETE FROM state", nullptr, nullptr, nullptr);
+	sqlite3_stmt *stmt;
+	ret = sqlite3_prepare_v2(db, "REPLACE INTO state VALUES (?)", -1, &stmt, 0);
 	if (ret != SQLITE_OK) {
-		fprintf(stderr, "DELETE: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		fprintf(stderr, "REPLACE prepare: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+
+	sqlite3_bind_blob(stmt, 1, serialized.data(), serialized.size(), SQLITE_STATIC);
+
+	ret = sqlite3_step(stmt);
+	if (ret == SQLITE_ROW) {
+		fprintf(stderr, "REPLACE step: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+
+	ret = sqlite3_finalize(stmt);
+	if (ret != SQLITE_OK) {
+		fprintf(stderr, "REPLACE finalize: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
+	ret = sqlite3_exec(db, "COMMIT", nullptr, nullptr, nullptr);
+	if (ret != SQLITE_OK) {
+		fprintf(stderr, "COMMIT: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+}
+
+SettingsProto DB::get_settings()
+{
+	SettingsProto settings;
+
 	sqlite3_stmt *stmt;
-	ret = sqlite3_prepare_v2(db, "INSERT INTO state VALUES (?)", -1, &stmt, 0);
+	int ret = sqlite3_prepare_v2(db, "SELECT settings FROM settings", -1, &stmt, 0);
 	if (ret != SQLITE_OK) {
-		fprintf(stderr, "INSERT prepare: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		fprintf(stderr, "SELECT prepare: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+
+	ret = sqlite3_step(stmt);
+	if (ret == SQLITE_ROW) {
+		bool ok = settings.ParseFromArray(sqlite3_column_blob(stmt, 0), sqlite3_column_bytes(stmt, 0));
+		if (!ok) {
+			fprintf(stderr, "State in database is corrupted!\n");
+			abort();
+		}
+	} else if (ret != SQLITE_DONE) {
+		fprintf(stderr, "SELECT step: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+
+	ret = sqlite3_finalize(stmt);
+	if (ret != SQLITE_OK) {
+		fprintf(stderr, "SELECT finalize: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+
+	return settings;
+}
+
+void DB::store_settings(const SettingsProto &settings)
+{
+	string serialized;
+	settings.SerializeToString(&serialized);
+
+	int ret = sqlite3_exec(db, "BEGIN", nullptr, nullptr, nullptr);
+	if (ret != SQLITE_OK) {
+		fprintf(stderr, "BEGIN: %s\n", sqlite3_errmsg(db));
+		abort();
+	}
+
+	sqlite3_stmt *stmt;
+	ret = sqlite3_prepare_v2(db, "REPLACE INTO settings VALUES (?)", -1, &stmt, 0);
+	if (ret != SQLITE_OK) {
+		fprintf(stderr, "REPLACE prepare: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
 	sqlite3_bind_blob(stmt, 1, serialized.data(), serialized.size(), SQLITE_STATIC);
 
 	ret = sqlite3_step(stmt);
 	if (ret == SQLITE_ROW) {
-		fprintf(stderr, "INSERT step: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		fprintf(stderr, "REPLACE step: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
 	ret = sqlite3_finalize(stmt);
 	if (ret != SQLITE_OK) {
-		fprintf(stderr, "INSERT finalize: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		fprintf(stderr, "REPLACE finalize: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
 	ret = sqlite3_exec(db, "COMMIT", nullptr, nullptr, nullptr);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "COMMIT: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 }
 
@@ -124,7 +211,7 @@ vector<DB::FrameOnDiskAndStreamIdx> DB::load_frame_file(const string &filename,
 	int ret = sqlite3_prepare_v2(db, "SELECT frames FROM filev2 WHERE filename=? AND size=?", -1, &stmt, 0);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "SELECT prepare: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	sqlite3_bind_text(stmt, 1, filename.data(), filename.size(), SQLITE_STATIC);
@@ -135,17 +222,17 @@ vector<DB::FrameOnDiskAndStreamIdx> DB::load_frame_file(const string &filename,
 		bool ok = file_contents.ParseFromArray(sqlite3_column_blob(stmt, 0), sqlite3_column_bytes(stmt, 0));
 		if (!ok) {
 			fprintf(stderr, "Frame list in database is corrupted!\n");
-			exit(1);
+			abort();
 		}
 	} else if (ret != SQLITE_DONE) {
 		fprintf(stderr, "SELECT step: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	ret = sqlite3_finalize(stmt);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "SELECT finalize: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	vector<FrameOnDiskAndStreamIdx> frames;
@@ -169,32 +256,12 @@ void DB::store_frame_file(const string &filename, size_t size, const vector<Fram
 	int ret = sqlite3_exec(db, "BEGIN", nullptr, nullptr, nullptr);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "BEGIN: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	// Delete any existing instances with this filename.
 	sqlite3_stmt *stmt;
 
-	ret = sqlite3_prepare_v2(db, "DELETE FROM filev2 WHERE filename=?", -1, &stmt, 0);
-	if (ret != SQLITE_OK) {
-		fprintf(stderr, "DELETE prepare: %s\n", sqlite3_errmsg(db));
-		exit(1);
-	}
-
-	sqlite3_bind_text(stmt, 1, filename.data(), filename.size(), SQLITE_STATIC);
-
-	ret = sqlite3_step(stmt);
-	if (ret == SQLITE_ROW) {
-		fprintf(stderr, "DELETE step: %s\n", sqlite3_errmsg(db));
-		exit(1);
-	}
-
-	ret = sqlite3_finalize(stmt);
-	if (ret != SQLITE_OK) {
-		fprintf(stderr, "DELETE finalize: %s\n", sqlite3_errmsg(db));
-		exit(1);
-	}
-
 	// Create the protobuf blob for the new row.
 	FileContentsProto file_contents;
 	unordered_set<unsigned> seen_stream_idx;  // Usually only one.
@@ -220,10 +287,10 @@ void DB::store_frame_file(const string &filename, size_t size, const vector<Fram
 	file_contents.SerializeToString(&serialized);
 
 	// Insert the new row.
-	ret = sqlite3_prepare_v2(db, "INSERT INTO filev2 (filename, size, frames) VALUES (?, ?, ?)", -1, &stmt, 0);
+	ret = sqlite3_prepare_v2(db, "REPLACE INTO filev2 (filename, size, frames) VALUES (?, ?, ?)", -1, &stmt, 0);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "INSERT prepare: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	sqlite3_bind_text(stmt, 1, filename.data(), filename.size(), SQLITE_STATIC);
@@ -232,21 +299,21 @@ void DB::store_frame_file(const string &filename, size_t size, const vector<Fram
 
 	ret = sqlite3_step(stmt);
 	if (ret == SQLITE_ROW) {
-		fprintf(stderr, "INSERT step: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		fprintf(stderr, "REPLACE step: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
 	ret = sqlite3_finalize(stmt);
 	if (ret != SQLITE_OK) {
-		fprintf(stderr, "INSERT finalize: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		fprintf(stderr, "REPLACE finalize: %s\n", sqlite3_errmsg(db));
+		abort();
 	}
 
 	// Commit.
 	ret = sqlite3_exec(db, "COMMIT", nullptr, nullptr, nullptr);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "COMMIT: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 }
 
@@ -255,16 +322,17 @@ void DB::clean_unused_frame_files(const vector<string> &used_filenames)
 	int ret = sqlite3_exec(db, "BEGIN", nullptr, nullptr, nullptr);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "BEGIN: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	ret = sqlite3_exec(db, R"(
 		CREATE TEMPORARY TABLE used_filenames ( filename VARCHAR NOT NULL PRIMARY KEY )
-	)", nullptr, nullptr, nullptr);
+	)",
+	                   nullptr, nullptr, nullptr);
 
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "CREATE TEMPORARY TABLE: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	// Insert the new rows.
@@ -272,7 +340,7 @@ void DB::clean_unused_frame_files(const vector<string> &used_filenames)
 	ret = sqlite3_prepare_v2(db, "INSERT INTO used_filenames (filename) VALUES (?)", -1, &stmt, 0);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "INSERT prepare: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	for (const string &filename : used_filenames) {
@@ -281,44 +349,46 @@ void DB::clean_unused_frame_files(const vector<string> &used_filenames)
 		ret = sqlite3_step(stmt);
 		if (ret == SQLITE_ROW) {
 			fprintf(stderr, "INSERT step: %s\n", sqlite3_errmsg(db));
-			exit(1);
+			abort();
 		}
 
 		ret = sqlite3_reset(stmt);
 		if (ret == SQLITE_ROW) {
 			fprintf(stderr, "INSERT reset: %s\n", sqlite3_errmsg(db));
-			exit(1);
+			abort();
 		}
 	}
 
 	ret = sqlite3_finalize(stmt);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "INSERT finalize: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	ret = sqlite3_exec(db, R"(
 		DELETE FROM filev2 WHERE filename NOT IN ( SELECT filename FROM used_filenames )
-	)", nullptr, nullptr, nullptr);
+	)",
+	                   nullptr, nullptr, nullptr);
 
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "DELETE: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	ret = sqlite3_exec(db, R"(
 		DROP TABLE used_filenames
-	)", nullptr, nullptr, nullptr);
+	)",
+	                   nullptr, nullptr, nullptr);
 
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "DROP TABLE: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 
 	// Commit.
 	ret = sqlite3_exec(db, "COMMIT", nullptr, nullptr, nullptr);
 	if (ret != SQLITE_OK) {
 		fprintf(stderr, "COMMIT: %s\n", sqlite3_errmsg(db));
-		exit(1);
+		abort();
 	}
 }