wip

Author: Luca Bianconi

arduino/cores/packagemanager/package_manager.go

@@ -95,8 +95,9 @@ func (pmb *Builder) BuildIntoExistingPackageManager(target *PackageManager) {
 	target.profile = pmb.profile
 	if target.discoveryManager != nil {
 		target.discoveryManager.Clear()
+	} else {
+		target.discoveryManager = pmb.discoveryManager
 	}
-	target.discoveryManager = pmb.discoveryManager
 	target.userAgent = pmb.userAgent
 }
 

arduino/discovery/discovery.go

@@ -379,6 +379,7 @@ func (disc *PluggableDiscovery) Quit() {
 	if _, err := disc.waitMessage(time.Second * 5); err != nil {
 		logrus.Errorf("Quitting discovery %s: %s", disc.id, err)
 	}
+	disc.stopSync()
 	disc.killProcess()
 }
 

arduino/discovery/discoverymanager/discoverymanager.go

@@ -65,9 +65,15 @@ func (dm *DiscoveryManager) Clear() {
 			logrus.Infof("Closed and removed discovery %s", d.GetID())
 		}
 	}
+	dm.discoveriesRunning = false
 	dm.discoveries = map[string]*discovery.PluggableDiscovery{}
 }
 
+// DiscoveryRunning returns boolean representing the running status of discoveries
+func (dm *DiscoveryManager) DiscoveryRunning() bool {
+	return dm.discoveriesRunning
+}
+
 // IDs returns the list of discoveries' ids in this DiscoveryManager
 func (dm *DiscoveryManager) IDs() []string {
 	ids := []string{}
@@ -194,12 +200,14 @@ func (dm *DiscoveryManager) startDiscovery(d *discovery.PluggableDiscovery) (dis
 		return fmt.Errorf("%s: %s", tr("starting discovery %s", d.GetID()), err)
 	}
 
-	go func() {
+	go func(d *discovery.PluggableDiscovery) {
 		// Transfer all incoming events from this discovery to the feed channel
 		for ev := range eventCh {
+			// here from discovery to discovery manager
 			dm.feed <- ev
 		}
-	}()
+		logrus.Info("Discovery event channel closed %s. Exiting goroutine.", d.GetID())
+	}(d)
 	return nil
 }
 

commands/instances.go

@@ -261,13 +261,23 @@ func Init(req *rpc.InitRequest, responseCallback func(r *rpc.InitResponse)) erro
 			},
 		})
 	}
-
+	var shouldStartDiscovery bool
 	{
 		// We need to rebuild the PackageManager currently in use by this instance
 		// in case this is not the first Init on this instances, that might happen
 		// after reinitializing an instance after installing or uninstalling a core.
 		// If this is not done the information of the uninstall core is kept in memory,
 		// even if it should not.
+
+		exp, release := instance.pm.NewExplorer()
+		// register whether the discoveries are running, if so we need to start them in
+		// for the previous watchers to keep receiving events
+		if exp.DiscoveryManager() != nil && exp.DiscoveryManager().DiscoveryRunning() {
+			shouldStartDiscovery = true
+		} else {
+			shouldStartDiscovery = false
+		}
+		release()
 		pmb, commitPackageManager := instance.pm.NewBuilder()
 
 		loadBuiltinTools := func() []error {
@@ -443,6 +453,9 @@ func Init(req *rpc.InitRequest, responseCallback func(r *rpc.InitResponse)) erro
 		responseError(s)
 	}
 
+	if shouldStartDiscovery {
+		pme.DiscoveryManager().Start()
+	}
 	// Refreshes the locale used, this will change the
 	// language of the CLI if the locale is different
 	// after started.