feat: discard the old configuration - 3

deepflowio · Jan 26, 2025 · 53024ae · 53024ae
1 parent 50abcea
commit 53024ae
Show file tree

Hide file tree

Showing 3 changed files with 107 additions and 946 deletions.
diff --git a/server/controller/grpc/synchronizer/service.go b/server/controller/grpc/synchronizer/service.go
@@ -17,7 +17,6 @@
 package synchronize
 
 import (
-	"strings"
 	"time"
 
 	api "github.com/deepflowio/deepflow/message/trident"
@@ -65,12 +64,7 @@ func (s *service) Sync(ctx context.Context, in *api.SyncRequest) (*api.SyncRespo
 }
 
 func (s *service) Push(r *api.SyncRequest, in api.Synchronizer_PushServer) error {
-	processName := r.GetProcessName()
-	if strings.HasPrefix(processName, "trident") || strings.HasPrefix(processName, "deepflow-agent") {
-		s.vTapEvent.Push(r, in)
-	} else {
-		s.tsdbEvent.Push(r, in)
-	}
+	s.tsdbEvent.Push(r, in)
 	return nil
 }
 

diff --git a/server/controller/trisolaris/services/grpc/synchronize/upgrade.go b/server/controller/trisolaris/services/grpc/synchronize/upgrade.go