ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-31 00:24:59 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

ENT-6677: When you clear the cache via the command line it now also updates node_named_identities table. (#7075)

Browse Source
This commit is contained in:
Adel El-Beik 2022-02-18 15:04:35 +00:00 committed by GitHub
parent b008f5f42a
commit 20d2e2b3eb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/src/main/kotlin/net/corda/node/internal/AbstractNode.kt
View File

@ -455,7 +455,7 @@ abstract class AbstractNode<S>(val configuration: NodeConfiguration,
} }
} }
fun clearNetworkMapCache() { open fun clearNetworkMapCache() {
Node.printBasicNodeInfo("Clearing network map cache entries") Node.printBasicNodeInfo("Clearing network map cache entries")
log.info("Starting clearing of network map cache entries...") log.info("Starting clearing of network map cache entries...")
startDatabase() startDatabase()

5
node/src/main/kotlin/net/corda/node/internal/Node.kt
View File

@ -564,6 +564,11 @@ open class Node(configuration: NodeConfiguration,
return super.generateAndSaveNodeInfo() return super.generateAndSaveNodeInfo()
} }
override fun clearNetworkMapCache() {
initialiseSerialization()
super.clearNetworkMapCache()
}
override fun runDatabaseMigrationScripts( override fun runDatabaseMigrationScripts(
updateCoreSchemas: Boolean, updateCoreSchemas: Boolean,
updateAppSchemas: Boolean, updateAppSchemas: Boolean,

5
node/src/main/kotlin/net/corda/node/services/network/PersistentNetworkMapCache.kt
View File

@ -455,7 +455,10 @@ open class PersistentNetworkMapCache(cacheFactory: NamedCacheFactory,
database.transaction { database.transaction {
val result = getAllNodeInfos(session) val result = getAllNodeInfos(session)
logger.debug { "Number of node infos to be cleared: ${result.size}" } logger.debug { "Number of node infos to be cleared: ${result.size}" }
for (nodeInfo in result) session.remove(nodeInfo) for (nodeInfo in result) {
session.remove(nodeInfo)
archiveNamedIdentity(session, nodeInfo.toNodeInfo())
}
} }
} }