diff --git a/internal/httpclient/client.go b/internal/httpclient/client.go index 68e11495d..dd1a1bd6b 100644 --- a/internal/httpclient/client.go +++ b/internal/httpclient/client.go @@ -19,7 +19,6 @@ package httpclient import ( "context" - "crypto/x509" "errors" "fmt" "io" @@ -266,15 +265,13 @@ func (c *Client) DoSigned(r *http.Request, sign SignFunc) (rsp *http.Response, e ) { // Non-retryable errors. return nil, err - } else if errorsv2.Assignable(err, - (*x509.CertificateInvalidError)(nil), - (*x509.HostnameError)(nil), - (*x509.UnknownAuthorityError)(nil), - ) { - // Non-retryable TLS errors. - return nil, err - } else if strings.Contains(err.Error(), "stopped after 10 redirects") { - // Don't bother if net/http returned after too many redirects + } else if errstr := err.Error(); // nocollapse + strings.Contains(errstr, "stopped after 10 redirects") || + strings.Contains(errstr, "tls: ") || + strings.Contains(errstr, "x509: ") { + // These error types aren't wrapped + // so we have to check the error string. + // All are unrecoverable! return nil, err } else if dnserr := (*net.DNSError)(nil); // nocollapse errors.As(err, &dnserr) && dnserr.IsNotFound { diff --git a/internal/transport/controller.go b/internal/transport/controller.go index e1271d202..23c51f35b 100644 --- a/internal/transport/controller.go +++ b/internal/transport/controller.go @@ -69,7 +69,7 @@ func NewController(state *state.State, federatingDB federatingdb.DB, clock pub.C client: client, trspCache: cache.New[string, *transport](0, 100, 0), userAgent: fmt.Sprintf("%s (+%s://%s) gotosocial/%s", applicationName, proto, host, version), - senders: runtime.GOMAXPROCS(0), // on batch delivery, only ever send GOMAXPROCS at a time. + senders: 2 * runtime.GOMAXPROCS(0), // on batch delivery, only ever send 2*GOMAXPROCS at a time. } return c