File tree Expand file tree Collapse file tree 1 file changed +0
-19
lines changed
Expand file tree Collapse file tree 1 file changed +0
-19
lines changed Original file line number Diff line number Diff line change @@ -435,25 +435,6 @@ func (cs *CommandService) receiveCallback(ctx context.Context) func() error {
435435 cs .subscribeChannel <- request
436436 }
437437 }
438- switch request .GetRequest ().(type ) {
439- case * mpi.ManagementPlaneRequest_ConfigApplyRequest :
440- cs .configApplyRequestQueueMutex .Lock ()
441- defer cs .configApplyRequestQueueMutex .Unlock ()
442-
443- instanceID := request .GetConfigApplyRequest ().GetOverview ().GetConfigVersion ().GetInstanceId ()
444- cs .configApplyRequestQueue [instanceID ] = append (cs .configApplyRequestQueue [instanceID ], request )
445- if len (cs .configApplyRequestQueue [instanceID ]) == 1 {
446- cs .subscribeChannel <- request
447- } else {
448- slog .DebugContext (
449- ctx ,
450- "Config apply request is already in progress, queuing new config apply request" ,
451- "request" , request ,
452- )
453- }
454- default :
455- cs .subscribeChannel <- request
456- }
457438
458439 return nil
459440 }
You can’t perform that action at this time.
0 commit comments