Only return 500 on /send if a database error occurs (#1503)
parent
2bd0449c5b
commit
4df7e345bb
|
@ -16,6 +16,7 @@ package routing
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"database/sql"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
@ -234,18 +235,11 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
|
||||||
// we should stop processing the transaction, and returns false if it
|
// we should stop processing the transaction, and returns false if it
|
||||||
// is just some less serious error about a specific event.
|
// is just some less serious error about a specific event.
|
||||||
func isProcessingErrorFatal(err error) bool {
|
func isProcessingErrorFatal(err error) bool {
|
||||||
switch err.(type) {
|
|
||||||
case roomNotFoundError:
|
|
||||||
case *gomatrixserverlib.NotAllowed:
|
|
||||||
case missingPrevEventsError:
|
|
||||||
default:
|
|
||||||
switch err {
|
switch err {
|
||||||
case context.Canceled:
|
case sql.ErrConnDone:
|
||||||
case context.DeadlineExceeded:
|
case sql.ErrTxDone:
|
||||||
default:
|
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
}
|
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue