Add partitions to watcher upon restoring the core

up9inc · Oct 27, 2021 · f78726f · f78726f
1 parent 281bcb7
commit f78726f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -300,6 +300,9 @@ func restoreCore() {
 		paritition, err := os.OpenFile(partitionPath, os.O_CREATE|os.O_WRONLY, 0644)
 		check(err)
 		cs.partitions = append(cs.partitions, paritition)
+
+		err = watcher.Add(paritition.Name())
+		check(err)
 	}
 	cs.partitionIndex = csExport.PartitionIndex
 	cs.partitionSizeLimit = csExport.PartitionSizeLimit

diff --git a/todo.todo b/todo.todo
@@ -2,7 +2,7 @@
 - [x] Handle escapes in strings. Example: `"\"hello world\";v=\"42\", "`
 - [x] Add `limit` helper to the query language
 - [x] Stream metadata from server in `QUERY` mode to inform client about the progress
-- [] Add `-persistent` option and implement persistent storage
+- [x] Add `-persistent` option and implement persistent storage
 - [] Write a client library for Python
 - [] Implement mechanisms to reduce data redundancy
 - [] Improve the querying speed by tracking checksums of strings