scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 09:05:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

flush bytes instead of roaring

Browse source
This commit is contained in:
Kuba Podgórski 2021-05-10 19:20:34 +02:00
parent 252fadf6a0
commit 17f89f1bf6
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
field.go
View file

@ -15,6 +15,7 @@
package pilosa
import (
"bytes"
"context"
"encoding/json"
"fmt"
@ -609,9 +610,14 @@ func (f *Field) protectedRemoteAvailableShards() *roaring.Bitmap {
func (f *Field) flushAvailableShards(ctx context.Context) {
shards := f.protectedRemoteAvailableShards()
err := f.holder.sharder.SetShards(ctx, f.index, f.name, shards)
if err != nil {
var buf bytes.Buffer
if _, err := shards.WriteTo(&buf); err != nil {
f.holder.Logger.Errorf("writting available shards: %v", err)
return
}
if err := f.holder.sharder.SetShards(ctx, f.index, f.name, buf.Bytes()); err != nil {
f.holder.Logger.Errorf("setting available shards: %v", err)
}
}