Skip to content

Commit 55cd225

Browse files
committed
dedup index IDs
1 parent 24249ab commit 55cd225

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

pkg/lmd/datastore.go

+6-2
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ func (d *DataStore) InsertItem(index int, row *DataRow) {
144144
switch len(d.Table.PrimaryKey) {
145145
case 0:
146146
case 1:
147-
id := row.GetID()
147+
id := dedup.S(row.GetID())
148148
d.Index[id] = row
149149
if d.Table.Name == TableHosts {
150150
idLower := dedup.S(strings.ToLower(id))
@@ -154,6 +154,8 @@ func (d *DataStore) InsertItem(index int, row *DataRow) {
154154
}
155155
case 2:
156156
id1, id2 := row.GetID2()
157+
id1 = dedup.S(id1)
158+
id2 = dedup.S(id2)
157159
if _, ok := d.Index2[id1]; !ok {
158160
d.Index2[id1] = make(map[string]*DataRow)
159161
}
@@ -169,7 +171,7 @@ func (d *DataStore) AddItem(row *DataRow) {
169171
switch len(d.Table.PrimaryKey) {
170172
case 0:
171173
case 1:
172-
id := row.GetID()
174+
id := dedup.S(row.GetID())
173175
d.Index[id] = row
174176
if d.Table.Name == TableHosts {
175177
idLower := dedup.S(strings.ToLower(id))
@@ -179,6 +181,8 @@ func (d *DataStore) AddItem(row *DataRow) {
179181
}
180182
case 2:
181183
id1, id2 := row.GetID2()
184+
id1 = dedup.S(id1)
185+
id2 = dedup.S(id2)
182186
if _, ok := d.Index2[id1]; !ok {
183187
d.Index2[id1] = make(map[string]*DataRow)
184188
}

0 commit comments

Comments
 (0)