From 68065ad8c5267a82c9d3e024a98e1adb3c3bdfd0 Mon Sep 17 00:00:00 2001 From: Damyan Ivanov Date: Tue, 20 Apr 2021 22:57:56 +0300 Subject: [PATCH] drop unused async db queue classes --- .../net/ktnx/mobileledger/async/DbOpItem.java | 35 ---------- .../ktnx/mobileledger/async/DbOpQueue.java | 47 ------------- .../ktnx/mobileledger/async/DbOpRunner.java | 69 ------------------- 3 files changed, 151 deletions(-) delete mode 100644 app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java delete mode 100644 app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java delete mode 100644 app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java deleted file mode 100644 index 2b0b61fd..00000000 --- a/app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java +++ /dev/null @@ -1,35 +0,0 @@ -/* - * Copyright © 2020 Damyan Ivanov. - * This file is part of MoLe. - * MoLe is free software: you can distribute it and/or modify it - * under the term of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your opinion), any later version. - * - * MoLe is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License terms for details. - * - * You should have received a copy of the GNU General Public License - * along with MoLe. If not, see . - */ - -package net.ktnx.mobileledger.async; - -class DbOpItem { - final String sql; - final Object[] params; - final Runnable onReady; - public DbOpItem(String sql, Object[] params, Runnable onReady) { - this.sql = sql; - this.params = params; - this.onReady = onReady; - } - public DbOpItem(String sql, Object[] params) { - this(sql, params, null); - } - public DbOpItem(String sql) { - this(sql, null, null); - } -} diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java deleted file mode 100644 index 081bbeee..00000000 --- a/app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java +++ /dev/null @@ -1,47 +0,0 @@ -/* - * Copyright © 2020 Damyan Ivanov. - * This file is part of MoLe. - * MoLe is free software: you can distribute it and/or modify it - * under the term of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your opinion), any later version. - * - * MoLe is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License terms for details. - * - * You should have received a copy of the GNU General Public License - * along with MoLe. If not, see . - */ - -package net.ktnx.mobileledger.async; - -import java.util.concurrent.BlockingQueue; -import java.util.concurrent.LinkedBlockingQueue; - -import static net.ktnx.mobileledger.utils.Logger.debug; - -public class DbOpQueue { - static private final BlockingQueue queue = new LinkedBlockingQueue<>(); - static private DbOpRunner runner; - synchronized static public void init() { - if (runner != null) - return; - debug("opQueue", "Starting runner thread"); - runner = new DbOpRunner(queue); - runner.start(); - } - static public void done() { - runner.interrupt(); - } - public static void add(String sql, Object[] params) {add(sql, params, null);} - public static void add(String sql, Object[] params, Runnable onReady) { - init(); - debug("opQueue", "Adding " + sql); - queue.add(new DbOpItem(sql, params, onReady)); - } - static void add(String sql) { - queue.add(new DbOpItem(sql)); - } -} diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java deleted file mode 100644 index f8ea5775..00000000 --- a/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java +++ /dev/null @@ -1,69 +0,0 @@ -/* - * Copyright © 2020 Damyan Ivanov. - * This file is part of MoLe. - * MoLe is free software: you can distribute it and/or modify it - * under the term of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your opinion), any later version. - * - * MoLe is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License terms for details. - * - * You should have received a copy of the GNU General Public License - * along with MoLe. If not, see . - */ - -package net.ktnx.mobileledger.async; - -import android.database.sqlite.SQLiteDatabase; - -import net.ktnx.mobileledger.App; -import net.ktnx.mobileledger.BuildConfig; - -import java.util.concurrent.BlockingQueue; - -import static net.ktnx.mobileledger.utils.Logger.debug; - -class DbOpRunner extends Thread { - private final BlockingQueue queue; - public DbOpRunner(BlockingQueue queue) { - this.queue = queue; - } - @Override - public void run() { - while (!interrupted()) { - try { - DbOpItem item = queue.take(); - debug("opQRunner", "Got " + item.sql); - { - SQLiteDatabase db = App.getDatabase(); - if (BuildConfig.DEBUG) { - StringBuilder b = new StringBuilder("Executing "); - b.append(item.sql); - if (item.params.length > 0) { - boolean first = true; - b.append(" ["); - for (Object p : item.params) { - if (first) - first = false; - else - b.append(", "); - b.append(p.toString()); - } - b.append("]"); - } - debug("opQRunner", b.toString()); - } - db.execSQL(item.sql, item.params); - } - if (item.onReady != null) - item.onReady.run(); - } - catch (InterruptedException e) { - break; - } - } - } -} -- 2.39.2