fix(usbdevice): close closed channel exception

Signed-off-by: Jack Yu <jack.yu@suse.com>

pkg/deviceplugins/usb_device_plugin.go

@@ -55,6 +55,7 @@ type USBDevicePlugin struct {
 	update       chan struct{}
 	deregistered chan struct{}
 	server       *grpc.Server
+	serverDone   chan struct{}
 	resourceName string
 	device       *PluginDevice
 	logger       *log.FilteredLogger
@@ -101,6 +102,10 @@ func (plugin *USBDevicePlugin) DeviceName() string {
 }
 
 func (plugin *USBDevicePlugin) stopDevicePlugin() error {
+	defer func() {
+		close(plugin.serverDone)
+	}()
+
 	// Give the device plugin one second to properly deregister
 	ticker := time.NewTicker(5 * time.Second)
 	defer ticker.Stop()
@@ -115,6 +120,7 @@ func (plugin *USBDevicePlugin) stopDevicePlugin() error {
 
 func (plugin *USBDevicePlugin) startDevicePlugin() error {
 	plugin.deregistered = make(chan struct{})
+	plugin.serverDone = make(chan struct{})
 
 	err := plugin.cleanup()
 	if err != nil {
@@ -294,6 +300,7 @@ func (plugin *USBDevicePlugin) ListAndWatch(_ *pluginapi.Empty, lws pluginapi.De
 	if err := sendUpdate(plugin.devicesToKubeVirtDevicePlugin()); err != nil {
 		return err
 	}
+
 	done := false
 	for !done {
 		select {
@@ -303,14 +310,18 @@ func (plugin *USBDevicePlugin) ListAndWatch(_ *pluginapi.Empty, lws pluginapi.De
 			}
 		case <-plugin.stop:
 			done = true
+		case <-plugin.serverDone:
+			done = true
 		}
 	}
 
 	if err := sendUpdate([]*pluginapi.Device{}); err != nil {
 		plugin.logger.Reason(err).Warningf("Failed to deregister device plugin %s",
 			plugin.resourceName)
 	}
+
 	close(plugin.deregistered)
+
 	return nil
 }