Disable event notifications

k8snetworkplumbingwg · Jun 20, 2024 · 444b8ae · 444b8ae
1 parent 401ddd8
commit 444b8ae
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 13 deletions.
diff --git a/pkg/daemon/daemon/gpsd.go b/pkg/daemon/daemon/gpsd.go
@@ -131,7 +131,7 @@ func (g *GPSD) CmdStop() {
 		}
 	}
 	if g.subscriber != nil {
-		g.unRegisterSubscriber()
+		//g.unRegisterSubscriber()
 	}
 	<-g.exitCh // waiting for all child routines to exit; we could add timeout to avoid waiting
 	g.monitorCancel()
@@ -151,14 +151,14 @@ func (g *GPSD) CmdInit() {
 func (g *GPSD) CmdRun(stdoutToSocket bool) {
 	defer func() {
 		if g.subscriber != nil {
-			g.unRegisterSubscriber()
+			//g.unRegisterSubscriber()
 		}
 	}()
 	// clean up
 	if g.subscriber != nil {
-		g.unRegisterSubscriber()
+		//g.unRegisterSubscriber()
 	}
-	g.subscriber = &GPSDSubscriber{source: event.MONITORING, gpsd: g, id: string(event.GNSS)}
+	//g.subscriber = &GPSDSubscriber{source: event.MONITORING, gpsd: g, id: string(event.GNSS)}
 	//g.registerSubscriber()
 	processStatus(g.name, g.messageTag, PtpProcessUp)
 	for {

diff --git a/pkg/daemon/dpll/dpll.go b/pkg/daemon/dpll/dpll.go
@@ -270,9 +270,9 @@ func (d *DpllConfig) CmdRun(stdToSocket bool) {
 
 func (d *DpllConfig) unRegisterAll() {
 	// register to event notification from other processes
-	for _, s := range d.subscriber {
-		event.StateRegisterer.Unregister(s)
-	}
+	//for _, s := range d.subscriber {
+	//	event.StateRegisterer.Unregister(s)
+	//}
 }
 
 // NewDpll ... create new DPLL process
@@ -588,16 +588,16 @@ func (d *DpllConfig) MonitorProcess(processCfg config.ProcessConfig) {
 }
 
 func (d *DpllConfig) unRegisterAllSubscriber() {
-	for _, s := range d.subscriber {
-		event.StateRegisterer.Unregister(s)
-	}
+	//for _, s := range d.subscriber {
+	//	event.StateRegisterer.Unregister(s)
+	//}
 	d.subscriber = []*DpllSubscriber{}
 }
 
 func (d *DpllConfig) registerAllSubscriber() {
-	for _, s := range d.subscriber {
-		event.StateRegisterer.Register(s)
-	}
+	//for _, s := range d.subscriber {
+	//	event.StateRegisterer.Register(s)
+	//}
 }
 
 // MonitorDpll monitors DPLL on the discovered API, if any