mirror of
https://github.com/1f349/dendrite.git
synced 2024-11-25 13:11:37 +00:00
Backoff for 401s (#1410)
* Backoff for 401s * Human-readable retry_after in logs
This commit is contained in:
parent
726ad6ce2e
commit
668a722ee0
@ -30,7 +30,7 @@ type FederationClientError struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (e *FederationClientError) Error() string {
|
func (e *FederationClientError) Error() string {
|
||||||
return fmt.Sprintf("%s - (retry_after=%d, blacklisted=%v)", e.Err, e.RetryAfter, e.Blacklisted)
|
return fmt.Sprintf("%s - (retry_after=%s, blacklisted=%v)", e.Err, e.RetryAfter.String(), e.Blacklisted)
|
||||||
}
|
}
|
||||||
|
|
||||||
// FederationSenderInternalAPI is used to query information from the federation sender.
|
// FederationSenderInternalAPI is used to query information from the federation sender.
|
||||||
|
@ -70,7 +70,10 @@ func failBlacklistableError(err error, stats *statistics.ServerStatistics) (unti
|
|||||||
if !ok {
|
if !ok {
|
||||||
return stats.Failure()
|
return stats.Failure()
|
||||||
}
|
}
|
||||||
if mxerr.Code >= 500 && mxerr.Code < 600 {
|
if mxerr.Code == 401 { // invalid signature in X-Matrix header
|
||||||
|
return stats.Failure()
|
||||||
|
}
|
||||||
|
if mxerr.Code >= 500 && mxerr.Code < 600 { // internal server errors
|
||||||
return stats.Failure()
|
return stats.Failure()
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
|
Loading…
Reference in New Issue
Block a user