hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2024-12-26 15:08:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Simplify

Browse source
This commit is contained in:
Neil Alexander 2021-06-22 11:24:27 +01:00
parent 1607b8ef78
commit f6b68b4c4b
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
federationapi/routing/send.go
View file

@ -483,14 +483,12 @@ func (t *txnReq) getServers(ctx context.Context, roomID string, eventOrigin goma
return t.servers return t.servers
} }
dedupe := map[gomatrixserverlib.ServerName]struct{}{} dedupe := map[gomatrixserverlib.ServerName]struct{}{}
count := 1
t.servers = []gomatrixserverlib.ServerName{t.Origin} // transaction origin t.servers = []gomatrixserverlib.ServerName{t.Origin} // transaction origin
dedupe[t.Origin] = struct{}{} dedupe[t.Origin] = struct{}{}
if eventOrigin != "" { if eventOrigin != "" {
if _, ok := dedupe[eventOrigin]; !ok { if _, ok := dedupe[eventOrigin]; !ok {
t.servers = append(t.servers, eventOrigin) // event origin, if specified t.servers = append(t.servers, eventOrigin) // event origin, if specified
dedupe[eventOrigin] = struct{}{} dedupe[eventOrigin] = struct{}{}
count++
} }
} }
serverReq := &api.QueryServerJoinedToRoomRequest{ serverReq := &api.QueryServerJoinedToRoomRequest{
@ -502,8 +500,7 @@ func (t *txnReq) getServers(ctx context.Context, roomID string, eventOrigin goma
if _, ok := dedupe[server]; !ok { if _, ok := dedupe[server]; !ok {
t.servers = append(t.servers, server) t.servers = append(t.servers, server)
dedupe[server] = struct{}{} dedupe[server] = struct{}{}
count++ if len(t.servers) == 10 {
if count == 10 {
break break
} }
} }