Bump version to 1.4.4

As importing a transaction requires blockchain lock, all the network threads
can be used up blocking for that lock, especially if Synchronizer is active.

So we simply discard incoming TRANSACTION messages if we can't immediately
obtain the blockchain lock. Some other peer will probably attempt to
send the transaction soon again anyway.

Plus we swap transaction lists after connection handshake.

pom.xml

@@ -3,7 +3,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>org.qortal</groupId>
 	<artifactId>qortal</artifactId>
-	<version>1.4.3</version>
+	<version>1.4.4</version>
 	<packaging>jar</packaging>
 	<properties>
 		<skipTests>true</skipTests>

src/main/java/org/qortal/controller/Controller.java

@@ -143,7 +143,6 @@ public class Controller extends Thread {
 	private ExecutorService callbackExecutor = Executors.newFixedThreadPool(3);
 	private volatile boolean notifyGroupMembershipChange = false;
 
-	private static final int BLOCK_CACHE_SIZE = 10; // To cover typical Synchronizer request + a few spare
 	/** Latest blocks on our chain. Note: tail/last is the latest block. */
 	private final Deque<BlockData> latestBlocks = new LinkedList<>();
 
@@ -152,7 +151,7 @@ public class Controller extends Thread {
 	private final LinkedHashMap<ByteArray, BlockMessage> blockMessageCache = new LinkedHashMap<>() {
 		@Override
 		protected boolean removeEldestEntry(Map.Entry<ByteArray, BlockMessage> eldest) {
-			return this.size() > BLOCK_CACHE_SIZE;
+			return this.size() > Settings.getInstance().getBlockCacheSize();
 		}
 	};
 
@@ -319,11 +318,12 @@ public class Controller extends Thread {
 		// Set initial chain height/tip
 		try (final Repository repository = RepositoryManager.getRepository()) {
 			BlockData blockData = repository.getBlockRepository().getLastBlock();
+			int blockCacheSize = Settings.getInstance().getBlockCacheSize();
 
 			synchronized (this.latestBlocks) {
 				this.latestBlocks.clear();
 
-				for (int i = 0; i < BLOCK_CACHE_SIZE && blockData != null; ++i) {
+				for (int i = 0; i < blockCacheSize && blockData != null; ++i) {
 					this.latestBlocks.addFirst(blockData);
 					blockData = repository.getBlockRepository().fromHeight(blockData.getHeight() - 1);
 				}
@@ -933,6 +933,7 @@ public class Controller extends Thread {
 	public void onNewBlock(BlockData latestBlockData) {
 		// Protective copy
 		BlockData blockDataCopy = new BlockData(latestBlockData);
+		int blockCacheSize = Settings.getInstance().getBlockCacheSize();
 
 		synchronized (this.latestBlocks) {
 			BlockData cachedChainTip = this.latestBlocks.peekLast();
@@ -942,7 +943,7 @@ public class Controller extends Thread {
 				this.latestBlocks.addLast(latestBlockData);
 
 				// Trim if necessary
-				if (this.latestBlocks.size() >= BLOCK_CACHE_SIZE)
+				if (this.latestBlocks.size() >= blockCacheSize)
 					this.latestBlocks.pollFirst();
 			} else {
 				if (cachedChainTip != null)
@@ -1151,6 +1152,7 @@ public class Controller extends Thread {
 		ByteArray signatureAsByteArray = new ByteArray(signature);
 
 		BlockMessage cachedBlockMessage = this.blockMessageCache.get(signatureAsByteArray);
+		int blockCacheSize = Settings.getInstance().getBlockCacheSize();
 
 		// Check cached latest block message
 		if (cachedBlockMessage != null) {
@@ -1193,7 +1195,7 @@ public class Controller extends Thread {
 				peer.disconnect("failed to send block");
 
 			// If request is for a recent block, cache it
-			if (getChainHeight() - blockData.getHeight() <= BLOCK_CACHE_SIZE) {
+			if (getChainHeight() - blockData.getHeight() <= blockCacheSize) {
 				this.stats.getBlockMessageStats.cacheFills.incrementAndGet();
 
 				this.blockMessageCache.put(new ByteArray(blockData.getSignature()), blockMessage);
@@ -1207,6 +1209,18 @@ public class Controller extends Thread {
 		TransactionMessage transactionMessage = (TransactionMessage) message;
 		TransactionData transactionData = transactionMessage.getTransactionData();
 
+		/*
+		 *  If we can't obtain blockchain lock immediately,
+		 *  e.g. Synchronizer is active, or another transaction is taking a while to validate,
+		 *  then we're using up a network thread for ages and clogging things up
+		 *  so bail out early
+		 */
+		ReentrantLock blockchainLock = Controller.getInstance().getBlockchainLock();
+		if (!blockchainLock.tryLock()) {
+			LOGGER.trace(() -> String.format("Too busy to import %s transaction %s from peer %s", transactionData.getType().name(), Base58.encode(transactionData.getSignature()), peer));
+			return;
+		}
+
 		try (final Repository repository = RepositoryManager.getRepository()) {
 			Transaction transaction = Transaction.fromData(repository, transactionData);
 
@@ -1236,6 +1250,8 @@ public class Controller extends Thread {
 			LOGGER.debug(() -> String.format("Imported %s transaction %s from peer %s", transactionData.getType().name(), Base58.encode(transactionData.getSignature()), peer));
 		} catch (DataException e) {
 			LOGGER.error(String.format("Repository issue while processing transaction %s from peer %s", Base58.encode(transactionData.getSignature()), peer), e);
+		} finally {
+			blockchainLock.unlock();
 		}
 	}
 

src/main/java/org/qortal/controller/tradebot/BitcoinACCTv1TradeBot.java

@@ -386,7 +386,7 @@ public class BitcoinACCTv1TradeBot implements AcctTradeBot {
 
 				// If it has been over 24 hours since we last updated this trade-bot entry then assume AT is never coming back
 				// and so wipe the trade-bot entry
-				if (tradeBotData.getTimestamp() + MAX_AT_CONFIRMATION_PERIOD > NTP.getTime()) {
+				if (tradeBotData.getTimestamp() + MAX_AT_CONFIRMATION_PERIOD < NTP.getTime()) {
 					LOGGER.info(() -> String.format("AT %s has been gone for too long - deleting trade-bot entry", tradeBotData.getAtAddress()));
 					repository.getCrossChainRepository().delete(tradeBotData.getTradePrivateKey());
 					repository.saveChanges();

src/main/java/org/qortal/controller/tradebot/LitecoinACCTv1TradeBot.java

@@ -384,7 +384,7 @@ public class LitecoinACCTv1TradeBot implements AcctTradeBot {
 
 				// If it has been over 24 hours since we last updated this trade-bot entry then assume AT is never coming back
 				// and so wipe the trade-bot entry
-				if (tradeBotData.getTimestamp() + MAX_AT_CONFIRMATION_PERIOD > NTP.getTime()) {
+				if (tradeBotData.getTimestamp() + MAX_AT_CONFIRMATION_PERIOD < NTP.getTime()) {
 					LOGGER.info(() -> String.format("AT %s has been gone for too long - deleting trade-bot entry", tradeBotData.getAtAddress()));
 					repository.getCrossChainRepository().delete(tradeBotData.getTradePrivateKey());
 					repository.saveChanges();

src/main/java/org/qortal/repository/hsqldb/HSQLDBRepository.java

@@ -931,6 +931,8 @@ public class HSQLDBRepository implements Repository {
 
 	/** Logs other HSQLDB sessions then returns passed exception */
 	public SQLException examineException(SQLException e) {
+		// TODO: could log at DEBUG for deadlocks by checking RepositoryManager.isDeadlockRelated(e)?
+
 		LOGGER.error(() -> String.format("[Session %d] HSQLDB error: %s", this.sessionId, e.getMessage()), e);
 
 		logStatements();

src/main/java/org/qortal/repository/hsqldb/HSQLDBRepositoryFactory.java

@@ -14,11 +14,11 @@ import org.hsqldb.jdbc.HSQLDBPool;
 import org.qortal.repository.DataException;
 import org.qortal.repository.Repository;
 import org.qortal.repository.RepositoryFactory;
+import org.qortal.settings.Settings;
 
 public class HSQLDBRepositoryFactory implements RepositoryFactory {
 
 	private static final Logger LOGGER = LogManager.getLogger(HSQLDBRepositoryFactory.class);
-	private static final int POOL_SIZE = 100;
 
 	/** Log getConnection() calls that take longer than this. (ms) */
 	private static final long SLOW_CONNECTION_THRESHOLD = 1000L;
@@ -57,7 +57,7 @@ public class HSQLDBRepositoryFactory implements RepositoryFactory {
 			HSQLDBRepository.attemptRecovery(connectionUrl);
 		}
 
-		this.connectionPool = new HSQLDBPool(POOL_SIZE);
+		this.connectionPool = new HSQLDBPool(Settings.getInstance().getRepositoryConnectionPoolSize());
 		this.connectionPool.setUrl(this.connectionUrl);
 
 		Properties properties = new Properties();

src/main/java/org/qortal/settings/Settings.java

@@ -89,6 +89,8 @@ public class Settings {
 	private long repositoryCheckpointInterval = 60 * 60 * 1000L; // 1 hour (ms) default
 	/** Whether to show a notification when we perform repository 'checkpoint'. */
 	private boolean showCheckpointNotification = false;
+	/* How many blocks to cache locally. Defaulted to 10, which covers a typical Synchronizer request + a few spare */
+	private int blockCacheSize = 10;
 
 	/** How long to keep old, full, AT state data (ms). */
 	private long atStatesMaxLifetime = 2 * 7 * 24 * 60 * 60 * 1000L; // milliseconds
@@ -134,6 +136,8 @@ public class Settings {
 	private Long slowQueryThreshold = null;
 	/** Repository storage path. */
 	private String repositoryPath = "db";
+	/** Repository connection pool size. Needs to be a bit bigger than maxNetworkThreadPoolSize */
+	private int repositoryConnectionPoolSize = 100;
 
 	// Auto-update sources
 	private String[] autoUpdateRepos = new String[] {
@@ -361,6 +365,10 @@ public class Settings {
 		return this.maxTransactionTimestampFuture;
 	}
 
+	public int getBlockCacheSize() {
+		return this.blockCacheSize;
+	}
+
 	public boolean isTestNet() {
 		return this.isTestNet;
 	}
@@ -424,6 +432,10 @@ public class Settings {
 		return this.repositoryPath;
 	}
 
+	public int getRepositoryConnectionPoolSize() {
+		return this.repositoryConnectionPoolSize;
+	}
+
 	public boolean isAutoUpdateEnabled() {
 		return this.autoUpdateEnabled;
 	}

src/main/resources/i18n/ApiError_it.properties

@@ -0,0 +1,72 @@
+#Generated by ResourceBundle Editor (http://essiembre.github.io/eclipse-rbe/)
+# Keys are from api.ApiError enum
+# Italian translation by Pabs 2021
+
+# La modifica della lingua dell'UI è fatta nel file Settings.json
+#
+# "localeLang": "it",
+# Si prega ricordare la virgola alla fine, se questo comando non è sull'ultima riga
+
+ADDRESS_UNKNOWN = indirizzo account sconosciuto
+
+BLOCKCHAIN_NEEDS_SYNC = blockchain deve prima sincronizzarsi
+
+# Blocks
+BLOCK_UNKNOWN = blocco sconosciuto
+
+BTC_BALANCE_ISSUE = saldo Bitcoin insufficiente
+
+BTC_NETWORK_ISSUE = Bitcoin/ElectrumX problema di rete
+
+BTC_TOO_SOON = troppo presto per trasmettere transazione Bitcoin (tempo di blocco / tempo di blocco mediano)
+
+CANNOT_MINT = l'account non può coniare
+
+GROUP_UNKNOWN = gruppo sconosciuto
+
+INVALID_ADDRESS = indirizzo non valido
+
+# Assets
+INVALID_ASSET_ID = identificazione risorsa non valida
+
+INVALID_CRITERIA = criteri di ricerca non validi
+
+INVALID_DATA = dati non validi
+
+INVALID_HEIGHT = altezza blocco non valida
+
+INVALID_NETWORK_ADDRESS = indirizzo di rete non valido
+
+INVALID_ORDER_ID = identificazione di ordine di risorsa non valida
+
+INVALID_PRIVATE_KEY = chiave privata non valida
+
+INVALID_PUBLIC_KEY = chiave pubblica non valida
+
+INVALID_REFERENCE = riferimento non valido
+
+# Validation
+INVALID_SIGNATURE = firma non valida
+
+JSON = Impossibile analizzare il messaggio JSON
+
+NAME_UNKNOWN = nome sconosciuto
+
+NON_PRODUCTION = questa chiamata API non è consentita per i sistemi di produzione
+
+NO_TIME_SYNC = nessuna sincronizzazione dell'orologio ancora
+
+ORDER_UNKNOWN = identificazione di ordine di risorsa sconosciuta
+
+PUBLIC_KEY_NOT_FOUND = chiave pubblica non trovata
+
+REPOSITORY_ISSUE = errore del repositorio
+
+# This one is special in that caller expected to pass two additional strings, hence the two %s
+TRANSACTION_INVALID = transazione non valida: %s (%s)
+
+TRANSACTION_UNKNOWN = transazione sconosciuta
+
+TRANSFORMATION_ERROR = non è stato possibile trasformare JSON in transazione
+
+UNAUTHORIZED = Chiamata API non autorizzata

src/main/resources/i18n/SysTray_it.properties

@@ -0,0 +1,46 @@
+#Generated by ResourceBundle Editor (http://essiembre.github.io/eclipse-rbe/)
+# SysTray pop-up menu
+# Italian translation by Pabs 2021
+
+APPLYING_UPDATE_AND_RESTARTING = Applicando aggiornamento automatico e riavviando...
+
+AUTO_UPDATE = Aggiornamento automatico
+
+BLOCK_HEIGHT = altezza
+
+CHECK_TIME_ACCURACY = Controlla la precisione dell'ora
+
+CONNECTING = Collegando
+
+CONNECTION = connessione
+
+CONNECTIONS = connessioni
+
+CREATING_BACKUP_OF_DB_FILES = Creazione di backup dei file di database...
+
+DB_BACKUP = Backup del database
+
+DB_CHECKPOINT = Punto di controllo del database
+
+EXIT = Uscita
+
+MINTING_DISABLED = NON coniando
+
+MINTING_ENABLED = \u2714 Coniando
+
+# Nagging about lack of NTP time sync
+NTP_NAG_CAPTION = L'orologio del computer è impreciso!
+
+NTP_NAG_TEXT_UNIX = Installare servizio NTP per ottenere un orologio preciso.
+
+NTP_NAG_TEXT_WINDOWS = Seleziona "Sincronizza orologio" dal menu per correggere.
+
+OPEN_UI = Apri UI
+
+PERFORMING_DB_CHECKPOINT = Salvataggio delle modifiche al database non salvate...
+
+SYNCHRONIZE_CLOCK = Sincronizza orologio
+
+SYNCHRONIZING_BLOCKCHAIN = Sincronizzando
+
+SYNCHRONIZING_CLOCK = Sincronizzando orologio

src/main/resources/i18n/TransactionValidity_it.properties

@@ -0,0 +1,185 @@
+# Italian translation by Pabs 2021
+
+ACCOUNT_ALREADY_EXISTS = l'account gia esiste
+
+ACCOUNT_CANNOT_REWARD_SHARE = l'account non può fare la condivisione di ricompensa
+
+ALREADY_GROUP_ADMIN = è già amministratore del gruppo
+
+ALREADY_GROUP_MEMBER = è già membro del gruppo
+
+ALREADY_VOTED_FOR_THAT_OPTION = già votato per questa opzione
+
+ASSET_ALREADY_EXISTS = risorsa già esistente
+
+ASSET_DOES_NOT_EXIST = risorsa non esistente
+
+ASSET_DOES_NOT_MATCH_AT = l'asset non corrisponde all'asset di AT
+
+ASSET_NOT_SPENDABLE = la risorsa non è spendibile
+
+AT_ALREADY_EXISTS = AT gia esiste
+
+AT_IS_FINISHED = AT ha finito
+
+AT_UNKNOWN = AT sconosciuto
+
+BANNED_FROM_GROUP = divietato dal gruppo
+
+BAN_EXISTS = il divieto esiste già
+
+BAN_UNKNOWN = divieto sconosciuto
+
+BUYER_ALREADY_OWNER = l'acquirente è già proprietario
+
+CHAT = Le transazioni CHAT non sono mai valide per l'inclusione nei blocchi
+
+CLOCK_NOT_SYNCED = orologio non sincronizzato
+
+DUPLICATE_OPTION = opzione duplicata
+
+GROUP_ALREADY_EXISTS = gruppo già esistente
+
+GROUP_APPROVAL_DECIDED = approvazione di gruppo già decisa
+
+GROUP_APPROVAL_NOT_REQUIRED = approvazione di gruppo non richiesto
+
+GROUP_DOES_NOT_EXIST = gruppo non esiste
+
+GROUP_ID_MISMATCH = identificazione di gruppo non corrispondente
+
+GROUP_OWNER_CANNOT_LEAVE = il proprietario del gruppo non può lasciare il gruppo
+
+HAVE_EQUALS_WANT = la risorsa avere è uguale a la risorsa volere
+
+INCORRECT_NONCE = PoW nonce sbagliato
+
+INSUFFICIENT_FEE = tariffa insufficiente
+
+INVALID_ADDRESS = indirizzo non valido
+
+INVALID_AMOUNT = importo non valido
+
+INVALID_ASSET_OWNER = proprietario della risorsa non valido
+
+INVALID_AT_TRANSACTION = transazione AT non valida
+
+INVALID_AT_TYPE_LENGTH = lunghezza di "tipo" AT non valida
+
+INVALID_CREATION_BYTES = byte di creazione non validi
+
+INVALID_DATA_LENGTH = lunghezza di dati non valida
+
+INVALID_DESCRIPTION_LENGTH = lunghezza della descrizione non valida
+
+INVALID_GROUP_APPROVAL_THRESHOLD = soglia di approvazione del gruppo non valida
+
+INVALID_GROUP_BLOCK_DELAY = ritardo del blocco di approvazione del gruppo non valido
+
+INVALID_GROUP_ID = identificazione di gruppo non valida
+
+INVALID_GROUP_OWNER = proprietario di gruppo non valido
+
+INVALID_LIFETIME = durata della vita non valida
+
+INVALID_NAME_LENGTH = lunghezza del nome non valida
+
+INVALID_NAME_OWNER = proprietario del nome non valido
+
+INVALID_OPTIONS_COUNT = conteggio di opzioni non validi
+
+INVALID_OPTION_LENGTH = lunghezza di opzioni non valida
+
+INVALID_ORDER_CREATOR = creatore dell'ordine non valido
+
+INVALID_PAYMENTS_COUNT = conteggio pagamenti non validi
+
+INVALID_PUBLIC_KEY = chiave pubblica non valida
+
+INVALID_QUANTITY = quantità non valida
+
+INVALID_REFERENCE = riferimento non valido
+
+INVALID_RETURN = ritorno non valido
+
+INVALID_REWARD_SHARE_PERCENT = percentuale condivisione di ricompensa non valida
+
+INVALID_SELLER = venditore non valido
+
+INVALID_TAGS_LENGTH = lunghezza dei "tag" non valida
+
+INVALID_TX_GROUP_ID = identificazione di gruppo di transazioni non valida
+
+INVALID_VALUE_LENGTH = lunghezza "valore" non valida
+
+INVITE_UNKNOWN = invito di gruppo sconosciuto
+
+JOIN_REQUEST_EXISTS = la richiesta di iscrizione al gruppo già esiste
+
+MAXIMUM_REWARD_SHARES =  numero massimo di condivisione di ricompensa raggiunto per l'account
+
+MISSING_CREATOR = creatore mancante
+
+MULTIPLE_NAMES_FORBIDDEN = è vietata la registrazione di multipli nomi per account
+
+NAME_ALREADY_FOR_SALE = nome già in vendita
+
+NAME_ALREADY_REGISTERED = nome già registrato
+
+NAME_DOES_NOT_EXIST = il nome non esiste
+
+NAME_NOT_FOR_SALE = il nome non è in vendita
+
+NAME_NOT_NORMALIZED = il nome non è in forma "normalizzata" Unicode
+
+NEGATIVE_AMOUNT = importo non valido / negativo
+
+NEGATIVE_FEE = tariffa non valida / negativa
+
+NEGATIVE_PRICE = prezzo non valido / negativo
+
+NOT_GROUP_ADMIN = l'account non è un amministratore di gruppo
+
+NOT_GROUP_MEMBER = l'account non è un membro del gruppo
+
+NOT_MINTING_ACCOUNT = l'account non può coniare
+
+NOT_YET_RELEASED = funzione non ancora rilasciata
+
+NO_BALANCE = equilibrio insufficiente
+
+NO_BLOCKCHAIN_LOCK = nodo di blockchain attualmente occupato
+
+NO_FLAG_PERMISSION = l'account non dispone di questa autorizzazione
+
+OK = OK
+
+ORDER_ALREADY_CLOSED = l'ordine di scambio di risorsa è già chiuso
+
+ORDER_DOES_NOT_EXIST =  l'ordine di scambio di risorsa non esiste
+
+POLL_ALREADY_EXISTS = il sondaggio già esiste
+
+POLL_DOES_NOT_EXIST = il sondaggio non esiste
+
+POLL_OPTION_DOES_NOT_EXIST = le opzioni di sondaggio non esistono
+
+PUBLIC_KEY_UNKNOWN = chiave pubblica sconosciuta
+
+REWARD_SHARE_UNKNOWN = condivisione di ricompensa sconosciuta
+
+SELF_SHARE_EXISTS = condivisione di sé (condivisione di ricompensa) già esiste
+
+TIMESTAMP_TOO_NEW = timestamp troppo nuovo
+
+TIMESTAMP_TOO_OLD = timestamp troppo vecchio
+
+TOO_MANY_UNCONFIRMED = l'account ha troppe transazioni non confermate in sospeso
+
+TRANSACTION_ALREADY_CONFIRMED = la transazione è già confermata
+
+TRANSACTION_ALREADY_EXISTS = la transazione già esiste
+
+TRANSACTION_UNKNOWN = transazione sconosciuta
+
+TX_GROUP_ID_MISMATCH = identificazione di gruppo della transazione non corrisponde