Commit a1ed13b0 authored by qiuqunfeng's avatar qiuqunfeng
Browse files

Update WAF service mode update to set listener mode

- Add direct mode assignment to listener specification
- Ensure listener mode is updated during concurrent processing
- Simplify mode update logic in UpdateMode method
parent 1d95943f
...@@ -294,6 +294,7 @@ func (s *wafService) UpdateMode(ctx context.Context, req *UpdateModeReq) (*WafSe ...@@ -294,6 +294,7 @@ func (s *wafService) UpdateMode(ctx context.Context, req *UpdateModeReq) (*WafSe
for _, listener := range listenerList.Items { for _, listener := range listenerList.Items {
wg.Add(1) wg.Add(1)
listener := listener // Create new variable for goroutine listener := listener // Create new variable for goroutine
listener.Spec.Mode = string(req.Mode)
go func() { go func() {
defer wg.Done() defer wg.Done()
log.Info().Msgf("update WAF service mode: %v", listener.Name) log.Info().Msgf("update WAF service mode: %v", listener.Name)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment