[ETCM-52] Upgrade RocksDB

Author: kapke

build.sbt

@@ -7,14 +7,11 @@ val commonSettings = Seq(
   testOptions in Test += Tests.Argument(TestFrameworks.ScalaTest, "-l", "EthashMinerSpec") // miner tests disabled by default
 )
 
-// Resolver for rocksDb
-resolvers += "rocksDb" at "https://dl.bintray.com/ethereum/maven/"
-
 val dep = {
   val akkaVersion = "2.6.9"
   val akkaHttpVersion = "10.2.0"
   val circeVersion = "0.9.3"
-  val rocksDb = "5.9.2"
+  val rocksDb = "6.11.4"
 
   Seq(
     "com.typesafe.akka" %% "akka-actor" % akkaVersion,
@@ -27,7 +24,7 @@ val dep = {
     "de.heikoseeberger" %% "akka-http-json4s" % "1.34.0",
     "com.typesafe.akka" %% "akka-http-testkit" % akkaHttpVersion % "it,test",
     "io.suzaku" %% "boopickle" % "1.3.0",
-    "org.ethereum" % "rocksdbjni" % rocksDb,
+    "org.rocksdb" % "rocksdbjni" % rocksDb,
     "org.scalatest" %% "scalatest" % "3.0.5" % "it,test",
     "org.scalamock" %% "scalamock-scalatest-support" % "3.6.0" % "test",
     "org.scalacheck" %% "scalacheck" % "1.14.0" % "it,test",
@@ -122,7 +119,6 @@ unmanagedResourceDirectories in Compile += baseDirectory.value / "src" / "main"
 scalastyleSources in Test ++= {(unmanagedSourceDirectories in Integration).value}
 
 // Packaging
-enablePlugins(JavaAppPackaging)
 mainClass in Compile := Some("io.iohk.ethereum.App")
 discoveredMainClasses in Compile := Seq("io.iohk.ethereum.mallet.main.Mallet")
 // Requires the 'ant-javafx.jar' that comes with Oracle JDK

src/main/scala/io/iohk/ethereum/db/dataSource/RocksDbDataSource.scala

@@ -83,7 +83,7 @@ class RocksDbDataSource(
     try {
       withResources(new WriteOptions()){ writeOptions =>
         withResources(new WriteBatch()){ batch =>
-          toRemove.foreach{ key => batch.remove(handles(namespace), key.toArray) }
+          toRemove.foreach{ key => batch.delete(handles(namespace), key.toArray) }
           toUpsert.foreach{ case (k, v) => batch.put(handles(namespace), k.toArray, v.toArray) }
 
           db.write(writeOptions, batch)
@@ -115,7 +115,7 @@ class RocksDbDataSource(
     try {
       withResources(new WriteOptions()){ writeOptions =>
         withResources(new WriteBatch()){ batch =>
-          toRemove.foreach{ key => batch.remove(key) }
+          toRemove.foreach{ key => batch.delete(key) }
           toUpsert.foreach{ case (k, v) => batch.put(k, v) }
 
           db.write(writeOptions, batch)
@@ -193,10 +193,10 @@ class RocksDbDataSource(
 
       val tableCfg = new BlockBasedTableConfig()
         .setBlockSize(blockSize)
-        .setBlockCacheSize(blockCacheSize)
+        .setBlockCache(new ClockCache(blockCacheSize))
         .setCacheIndexAndFilterBlocks(true)
         .setPinL0FilterAndIndexBlocksInCache(true)
-        .setFilter(new BloomFilter(10, false))
+        .setFilterPolicy(new BloomFilter(10, false))
 
       val options = new Options()
         .setCreateIfMissing(createIfMissing)
@@ -253,10 +253,10 @@ object RocksDbDataSource {
 
       val tableCfg = new BlockBasedTableConfig()
         .setBlockSize(blockSize)
-        .setBlockCacheSize(blockCacheSize)
+        .setBlockCache(new ClockCache(blockCacheSize))
         .setCacheIndexAndFilterBlocks(true)
         .setPinL0FilterAndIndexBlocksInCache(true)
-        .setFilter(new BloomFilter(10, false))
+        .setFilterPolicy(new BloomFilter(10, false))
 
       val options = new DBOptions()
         .setCreateIfMissing(createIfMissing)