diff options
| author | Till <2353100+S7evinK@users.noreply.github.com> | 2023-11-09 08:43:27 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-11-09 08:43:27 +0100 |
| commit | 7863a405a5f41acd2e40b40ec288eebe781eac1a (patch) | |
| tree | 1d94d328f0981ca1b9c77d828c242f474e54147c /cmd/dendrite-demo-pinecone | |
| parent | 699f5ca8c1f73ff7e4b70f0f9273ffcb1c195cdc (diff) | |
Use `IsBlacklistedOrBackingOff` to determine if we should try to fetch devices (#3254)
Use `IsBlacklistedOrBackingOff` from the federation API to check if we
should fetch devices.
To reduce back pressure, we now only queue retrying servers if there's
space in the channel.
Diffstat (limited to 'cmd/dendrite-demo-pinecone')
| -rw-r--r-- | cmd/dendrite-demo-pinecone/monolith/monolith.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cmd/dendrite-demo-pinecone/monolith/monolith.go b/cmd/dendrite-demo-pinecone/monolith/monolith.go index 5222d0b8..d9f44b5c 100644 --- a/cmd/dendrite-demo-pinecone/monolith/monolith.go +++ b/cmd/dendrite-demo-pinecone/monolith/monolith.go @@ -145,7 +145,7 @@ func (p *P2PMonolith) SetupDendrite( ) rsAPI.SetFederationAPI(fsAPI, keyRing) - userAPI := userapi.NewInternalAPI(processCtx, cfg, cm, &natsInstance, rsAPI, federation, enableMetrics) + userAPI := userapi.NewInternalAPI(processCtx, cfg, cm, &natsInstance, rsAPI, federation, enableMetrics, fsAPI.IsBlacklistedOrBackingOff) asAPI := appservice.NewInternalAPI(processCtx, cfg, &natsInstance, userAPI, rsAPI) |