[proxy]防止后端服务器当前请求数小于0

iwind · iwind · commit 81fbe2d4f76f · 2019-12-01T14:39:40.000+08:00
diff --git a/teaconfigs/backend.go b/teaconfigs/backend.go
@@ -223,6 +223,9 @@ func (this *BackendConfig) DecreaseConn() int32 {
 	if this.nextBackend != nil {
 		return this.nextBackend.DecreaseConn()
 	}
+	if this.CurrentConns == 0 {
+		return 0
+	}
 	return atomic.AddInt32(&this.CurrentConns, -1)
 }
 
@@ -447,7 +450,7 @@ func (this *BackendConfig) CloneState(oldBackend *BackendConfig) {
 	this.IsDown = oldBackend.IsDown
 	this.DownTime = oldBackend.DownTime
 	this.CurrentFails = oldBackend.CurrentFails
-	this.CurrentConns = oldBackend.CurrentConns
+	atomic.StoreInt32(&this.CurrentConns, oldBackend.CurrentConns)
 }
 
 // 获取唯一ID

Original file line number	Diff line number	Diff line change
`@@ -223,6 +223,9 @@ func (this *BackendConfig) DecreaseConn() int32 {`
`223`	`223`	`if this.nextBackend != nil {`
`224`	`224`	`return this.nextBackend.DecreaseConn()`
`225`	`225`	`}`
	`226`	`+ if this.CurrentConns == 0 {`
	`227`	`+ return 0`
	`228`	`+ }`
`226`	`229`	`return atomic.AddInt32(&this.CurrentConns, -1)`
`227`	`230`	`}`
`228`	`231`
`@@ -447,7 +450,7 @@ func (this BackendConfig) CloneState(oldBackend BackendConfig) {`
`447`	`450`	`this.IsDown = oldBackend.IsDown`
`448`	`451`	`this.DownTime = oldBackend.DownTime`
`449`	`452`	`this.CurrentFails = oldBackend.CurrentFails`
`450`		`- this.CurrentConns = oldBackend.CurrentConns`
	`453`	`+ atomic.StoreInt32(&this.CurrentConns, oldBackend.CurrentConns)`
`451`	`454`	`}`
`452`	`455`
`453`	`456`	`// 获取唯一ID`