mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-07 06:53:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

More comments

Browse source
This commit is contained in:
Mark Haines 2017-02-15 10:47:04 +00:00
parent 29e0ff2651
commit 4759f0103d
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/github.com/matrix-org/dendrite/roomserver/input/state.go
View file

@ -191,16 +191,18 @@ func findDuplicateStateKeys(a []types.StateEntry) []types.StateEntry {
for i := 1; i < len(a); i++ { for i := 1; i < len(a); i++ {
// Check if the state key tuple matches the start of the block // Check if the state key tuple matches the start of the block
if a[j].StateKeyTuple != a[i].StateKeyTuple { if a[j].StateKeyTuple != a[i].StateKeyTuple {
// If the state key tuple is different then we've reached the end of a block of duplicates.
// Check if the size of the block is bigger than one. // Check if the size of the block is bigger than one.
// If the size is one then there was only a single entry with that state key tuple so we don't add it to the result
if j+1 != i { if j+1 != i {
// Add the block to the result. // Add the block to the result.
result = append(result, a[j:i]...) result = append(result, a[j:i]...)
} }
// Start a new block. // Start a new block for the next state key tuple.
j = i j = i
} }
} }
// Check if the last block had more than one event in it. // Check if the last block with the same state key tuple had more than one event in it.
if j+1 != len(a) { if j+1 != len(a) {
result = append(result, a[j:]...) result = append(result, a[j:]...)
} }