scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add unprotectedSaveAvailableShards() method

Browse source
This commit is contained in:
Travis Turner 2018-10-17 17:33:13 -05:00
parent 03e68aaa69
commit 9cd0782ef1
No known key found for this signature in database
GPG key ID: 7F08008DFD9314C9
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
field.go
View file

@ -269,9 +269,13 @@ func (f *Field) loadAvailableShards() error {
// saveAvailableShards writes remoteAvailableShards data for the field.
func (f *Field) saveAvailableShards() error {
// Open or create file.
f.mu.Lock()
defer f.mu.Unlock()
return f.unprotectedSaveAvailableShards()
}
func (f *Field) unprotectedSaveAvailableShards() error {
// Open or create file.
path := filepath.Join(f.path, ".available.shards")
file, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0666)
@ -294,8 +298,8 @@ func (f *Field) saveAvailableShards() error {
//
// NOTE: This can be overridden on the next sync so all nodes should be updated.
func (f *Field) RemoveAvailableShard(v uint64) error {
f.mu.RLock()
defer f.mu.RUnlock()
f.mu.Lock()
defer f.mu.Unlock()
b := f.remoteAvailableShards.Clone()
if _, err := b.Remove(v); err != nil {
@ -303,7 +307,7 @@ func (f *Field) RemoveAvailableShard(v uint64) error {
}
f.remoteAvailableShards = b
return f.saveAvailableShards()
return f.unprotectedSaveAvailableShards()
}
// Type returns the field type.