Close LRU by database path for deleted database/index

src/main/scala/com/cloudant/clouseau/ClouseauTypeFactory.scala

@@ -33,6 +33,7 @@ case class CleanupPathMsg(path: String)
 case class RenamePathMsg(dbName: String)
 case class CleanupDbMsg(dbName: String, activeSigs: List[String])
 case class DiskSizeMsg(path: String)
+case class CloseLRUByPathMsg(path: String)
 
 case class Group1Msg(query: String, field: String, refresh: Boolean, groupSort: Any, groupOffset: Int,
                      groupLimit: Int)
@@ -92,6 +93,8 @@ object ClouseauTypeFactory extends TypeFactory {
       Some(DeleteDocMsg(reader.readAs[String]))
     case ('disk_size, 2) =>
       Some(DiskSizeMsg(reader.readAs[String]))
+    case ('close_lru_by_path, 2) =>
+      Some(CloseLRUByPathMsg(reader.readAs[String]))
     case ('commit, 2) =>
       Some(CommitMsg(toLong(reader.readTerm)))
     case ('set_update_seq, 2) =>

src/main/scala/com/cloudant/clouseau/IndexManagerService.scala

@@ -76,6 +76,15 @@ class IndexManagerService(ctx: ServiceContext[ConfigurationArgs]) extends Servic
       }
     }
 
+    def closeByPath(path: String) {
+      pidToPath foreach {
+        kv =>
+          if (kv._2.startsWith(path)) {
+            logger.info("closing lru for " + path)
+            kv._1 ! ('close, 'closing)
+          }
+      }
+    }
   }
 
   val logger = Logger.getLogger("clouseau.main")
@@ -124,6 +133,9 @@ class IndexManagerService(ctx: ServiceContext[ConfigurationArgs]) extends Servic
     case 'close_lru =>
       lru.close()
       'ok
+    case CloseLRUByPathMsg(path: String) =>
+      lru.closeByPath(path)
+      'ok
     case 'version =>
       ('ok, getClass.getPackage.getImplementationVersion)
   }

src/main/scala/com/cloudant/clouseau/IndexService.scala

@@ -220,7 +220,9 @@ class IndexService(ctx: ServiceContext[IndexServiceArgs]) extends Service(ctx) w
       ctx.args.writer.rollback()
     } catch {
       case e: AlreadyClosedException => 'ignored
-      case e: IOException => warn("Error while closing writer", e)
+      case e: IOException =>
+        warn("Error while closing writer", e)
+        ctx.args.writer.close()
     } finally {
       super.exit(msg)
     }