diff --git a/internal/nodes/http_request_oss.go b/internal/nodes/http_request_oss.go index 8271941..b65b2c4 100644 --- a/internal/nodes/http_request_oss.go +++ b/internal/nodes/http_request_oss.go @@ -9,7 +9,7 @@ import ( "net/http" ) -func (this *HTTPRequest) doOSSOrigin(origin *serverconfigs.OriginConfig) (*http.Response, error) { +func (this *HTTPRequest) doOSSOrigin(origin *serverconfigs.OriginConfig) (resp *http.Response, goNext bool, err error) { // stub return nil, errors.New("not implemented") } diff --git a/internal/nodes/http_request_reverse_proxy.go b/internal/nodes/http_request_reverse_proxy.go index 46b7bd0..cc59b6b 100644 --- a/internal/nodes/http_request_reverse_proxy.go +++ b/internal/nodes/http_request_reverse_proxy.go @@ -271,8 +271,9 @@ func (this *HTTPRequest) doOriginRequest(failedOriginIds []int64, failedLnNodeId // 开始请求 resp, requestErr = client.Do(this.RawReq) } else if origin.OSS != nil { // OSS源站 - resp, requestErr = this.doOSSOrigin(origin) - if requestErr == nil && resp == nil { + var goNext bool + resp, goNext, requestErr = this.doOSSOrigin(origin) + if (requestErr == nil && resp == nil) || !goNext { return } } else {