Skip to content

Commit 61c5adc

Browse files
committed
Addressing review comments
1 parent 0f10286 commit 61c5adc

File tree

2 files changed

+14
-10
lines changed

2 files changed

+14
-10
lines changed

index/scorch/scorch.go

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ type Scorch struct {
7575
merges chan *segmentMerge
7676
introducerNotifier chan *epochWatcher
7777
persisterNotifier chan *epochWatcher
78-
loadedBolt bool
7978
rootBolt *bolt.DB
8079
asyncTasks sync.WaitGroup
8180

@@ -124,7 +123,6 @@ func NewScorch(storeName string,
124123
forceMergeRequestCh: make(chan *mergerCtrl, 1),
125124
segPlugin: defaultSegmentPlugin,
126125
copyScheduled: map[string]int{},
127-
loadedBolt: false,
128126
}
129127

130128
forcedSegmentType, forcedSegmentVersion, err := configForceSegmentTypeVersion(config)
@@ -220,7 +218,7 @@ func (s *Scorch) fireAsyncError(err error) {
220218
}
221219

222220
func (s *Scorch) Open() error {
223-
if !s.loadedBolt {
221+
if s.rootBolt == nil {
224222
err := s.openBolt()
225223
if err != nil {
226224
return err
@@ -376,6 +374,7 @@ func (s *Scorch) Close() (err error) {
376374
}
377375
}
378376
s.root = nil
377+
s.rootBolt = nil
379378
s.rootLock.Unlock()
380379
}
381380

@@ -960,15 +959,13 @@ func (s *Scorch) UpdateFields(fieldInfo map[string]*index.UpdateFieldInfo, mappi
960959
}
961960

962961
func (s *Scorch) OpenMeta() error {
963-
if s.loadedBolt {
964-
return nil
962+
if s.rootBolt == nil {
963+
err := s.openBolt()
964+
if err != nil {
965+
return err
966+
}
965967
}
966968

967-
err := s.openBolt()
968-
if err != nil {
969-
return err
970-
}
971-
s.loadedBolt = true
972969
return nil
973970
}
974971

index_update.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,13 @@ func compareMappings(ori, upd *mapping.IndexMappingImpl) error {
153153
return fmt.Errorf("default datetime parser cannot be changed if index dynamic is true")
154154
}
155155

156+
if ori.ScoringModel != upd.ScoringModel {
157+
if ori.ScoringModel != "" && ori.ScoringModel != "tf-idf" && ori.ScoringModel != "bm25" ||
158+
upd.ScoringModel != "" && upd.ScoringModel != "tf-idf" && upd.ScoringModel != "bm25" {
159+
return fmt.Errorf("scoring model can only be changed between \"\", tf-idf and bm25")
160+
}
161+
}
162+
156163
return nil
157164
}
158165

0 commit comments

Comments
 (0)