TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-04 07:40:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
GoEdgeLab
2024-04-18 08:47:05 +08:00
parent b885516254
commit 64dd4feb44
1 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
internal/nodes/http_request_reverse_proxy.go
View File

@@ -315,7 +315,7 @@ func (this *HTTPRequest) doOriginRequest(failedOriginIds []int64, failedLnNodeId
if requestErr != nil { if requestErr != nil {
// 客户端取消请求，则不提示 // 客户端取消请求，则不提示
var httpErr *url.Error var httpErr *url.Error
ok := errors.As(requestErr, &httpErr) var ok = errors.As(requestErr, &httpErr)
if !ok { if !ok {
if isHTTPOrigin { if isHTTPOrigin {
SharedOriginStateManager.Fail(origin, requestHost, this.reverseProxy, func() { SharedOriginStateManager.Fail(origin, requestHost, this.reverseProxy, func() {
@@ -361,18 +361,16 @@ func (this *HTTPRequest) doOriginRequest(failedOriginIds []int64, failedLnNodeId
} else { } else {
// 是否为客户端方面的错误 // 是否为客户端方面的错误
var isClientError = false var isClientError = false
if ok { if errors.Is(httpErr, context.Canceled) {
if errors.Is(httpErr, context.Canceled) { // 如果是服务器端主动关闭，则无需提示
// 如果是服务器端主动关闭，则无需提示 if this.isConnClosed() {
if this.isConnClosed() { this.disableLog = true
this.disableLog = true return
return
}
isClientError = true
this.addError(errors.New(httpErr.Op + " " + httpErr.URL + ": client closed the connection"))
this.writer.WriteHeader(499) // 仿照nginx
} }
isClientError = true
this.addError(errors.New(httpErr.Op + " " + httpErr.URL + ": client closed the connection"))
this.writer.WriteHeader(499) // 仿照nginx
} }
if !isClientError { if !isClientError {