|
@@ -106,6 +106,10 @@ func listSyFiles(dir string) (ret []string) {
|
|
|
|
|
|
func (box *Box) Unindex() {
|
|
func (box *Box) Unindex() {
|
|
task.AppendTask(task.DatabaseIndex, unindex, box.ID)
|
|
task.AppendTask(task.DatabaseIndex, unindex, box.ID)
|
|
|
|
+ go func() {
|
|
|
|
+ sql.WaitForWritingDatabase()
|
|
|
|
+ ResetVirtualBlockRefCache()
|
|
|
|
+ }()
|
|
}
|
|
}
|
|
|
|
|
|
func unindex(boxID string) {
|
|
func unindex(boxID string) {
|
|
@@ -118,6 +122,10 @@ func (box *Box) Index() {
|
|
task.AppendTask(task.DatabaseIndexRef, removeBoxRefs, box.ID)
|
|
task.AppendTask(task.DatabaseIndexRef, removeBoxRefs, box.ID)
|
|
task.AppendTask(task.DatabaseIndex, index, box.ID)
|
|
task.AppendTask(task.DatabaseIndex, index, box.ID)
|
|
task.AppendTask(task.DatabaseIndexRef, IndexRefs)
|
|
task.AppendTask(task.DatabaseIndexRef, IndexRefs)
|
|
|
|
+ go func() {
|
|
|
|
+ sql.WaitForWritingDatabase()
|
|
|
|
+ ResetVirtualBlockRefCache()
|
|
|
|
+ }()
|
|
}
|
|
}
|
|
|
|
|
|
func removeBoxRefs(boxID string) {
|
|
func removeBoxRefs(boxID string) {
|
|
@@ -281,8 +289,6 @@ func IndexRefs() {
|
|
}
|
|
}
|
|
logging.LogInfof("resolved refs [%d] in [%dms]", size, time.Now().Sub(start).Milliseconds())
|
|
logging.LogInfof("resolved refs [%d] in [%dms]", size, time.Now().Sub(start).Milliseconds())
|
|
util.PushStatusBar(fmt.Sprintf(Conf.Language(55), i))
|
|
util.PushStatusBar(fmt.Sprintf(Conf.Language(55), i))
|
|
-
|
|
|
|
- ResetVirtualBlockRefCache()
|
|
|
|
}
|
|
}
|
|
|
|
|
|
var indexEmbedBlockLock = sync.Mutex{}
|
|
var indexEmbedBlockLock = sync.Mutex{}
|