Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #9982 from influxdata/bj-tsi-wal-flush-sync 

Flush/sync TSI1 WAL
pull/9996/head
Ben Johnson 2018-06-20 15:34:15 -06:00 committed by GitHub
parent 305dcd4097 fd5a2116d7
commit ccadb3799c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 35 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
tsdb/index/tsi1/log_file.go
View File

@ -299,6 +299,13 @@ func (f *LogFile) DeleteMeasurement(name []byte) error {
return err
}
f.execEntry(&e)
// Flush buffer & sync to disk.
if err := f.w.Flush(); err != nil {
return err
} else if err := f.file.Sync(); err != nil {
return err
}
return nil
}
@ -414,6 +421,13 @@ func (f *LogFile) DeleteTagKey(name, key []byte) error {
return err
}
f.execEntry(&e)
// Flush buffer & sync to disk.
if err := f.w.Flush(); err != nil {
return err
} else if err := f.file.Sync(); err != nil {
return err
}
return nil
}
@ -481,6 +495,13 @@ func (f *LogFile) DeleteTagValue(name, key, value []byte) error {
return err
}
f.execEntry(&e)
// Flush buffer & sync to disk.
if err := f.w.Flush(); err != nil {
return err
} else if err := f.file.Sync(); err != nil {
return err
}
return nil
}
@ -527,6 +548,13 @@ func (f *LogFile) AddSeriesList(seriesSet *tsdb.SeriesIDSet, names [][]byte, tag
f.execEntry(entry)
seriesSet.AddNoLock(entry.SeriesID)
}
// Flush buffer & sync to disk.
if err := f.w.Flush(); err != nil {
return err
} else if err := f.file.Sync(); err != nil {
return err
}
return nil
}
@ -540,6 +568,13 @@ func (f *LogFile) DeleteSeriesID(id uint64) error {
return err
}
f.execEntry(&e)
// Flush buffer & sync to disk.
if err := f.w.Flush(); err != nil {
return err
} else if err := f.file.Sync(); err != nil {
return err
}
return nil
}