|
@@ -1128,6 +1128,11 @@ func (devices *DeviceSet) deleteDevice(info *DevInfo) error {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ if err := devices.openTransaction(info.Hash, info.DeviceId); err != nil {
|
|
|
+ log.Debugf("Error opening transaction hash = %s deviceId = %d", "", info.DeviceId)
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
if err := devicemapper.DeleteDevice(devices.getPoolDevName(), info.DeviceId); err != nil {
|
|
|
log.Debugf("Error deleting device: %s", err)
|
|
|
return err
|
|
@@ -1137,6 +1142,10 @@ func (devices *DeviceSet) deleteDevice(info *DevInfo) error {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
+ if err := devices.closeTransaction(); err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
devices.markDeviceIdFree(info.DeviceId)
|
|
|
|
|
|
return nil
|