test

Signed-off-by: Jack Yu <[email protected]>

pkg/deviceplugins/usb_device_plugin.go

@@ -289,6 +289,11 @@ func (plugin *USBDevicePlugin) ListAndWatch(_ *pluginapi.Empty, lws pluginapi.De
 		response := pluginapi.ListAndWatchResponse{
 			Devices: devices,
 		}
+		fmt.Println("===================")
+		for _, device := range devices {
+			fmt.Printf("devices: %#v\n", *device)
+		}
+		fmt.Println("===================")
 		err := lws.Send(&response)
 		if err != nil {
 			plugin.logger.Reason(err).Warningf("Failed to send device plugin %s",
@@ -327,6 +332,9 @@ func (plugin *USBDevicePlugin) ListAndWatch(_ *pluginapi.Empty, lws pluginapi.De
 
 // Interface to allocate requested USBDevice, exported by ListAndWatch
 func (plugin *USBDevicePlugin) Allocate(_ context.Context, allocRequest *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error) {
+	fmt.Println("===================")
+	fmt.Printf("request: %#v\n", *allocRequest)
+	fmt.Println("===================")
 	allocResponse := new(pluginapi.AllocateResponse)
 	env := make(map[string]string)
 	for _, request := range allocRequest.ContainerRequests {
@@ -395,7 +403,7 @@ func NewUSBDevicePlugin(usb v1beta1.USBDevice) (*USBDevicePlugin, error) {
 		socketPath:   SocketPath(resourceID),
 		resourceName: usb.Status.ResourceName,
 		device: &PluginDevice{
-			ID:           usb.Name,
+			ID:           usb.Status.ResourceName,
 			DevicePath:   usb.Status.DevicePath,
 			Bus:          bus,
 			DeviceNumber: deviceNumber,