| ... | ... |
@@ -168,6 +168,7 @@ func (devices *DeviceSetDM) saveMetadata() error {
|
| 168 | 168 |
} |
| 169 | 169 |
|
| 170 | 170 |
func (devices *DeviceSetDM) registerDevice(id int, hash string, size uint64) (*DevInfo, error) {
|
| 171 |
+ utils.Debugf("registerDevice(%v, %v)", id, hash)
|
|
| 171 | 172 |
info := &DevInfo{
|
| 172 | 173 |
Hash: hash, |
| 173 | 174 |
DeviceId: id, |
| ... | ... |
@@ -188,7 +189,7 @@ func (devices *DeviceSetDM) registerDevice(id int, hash string, size uint64) (*D |
| 188 | 188 |
} |
| 189 | 189 |
|
| 190 | 190 |
func (devices *DeviceSetDM) activateDeviceIfNeeded(hash string) error {
|
| 191 |
- utils.Debugf("activateDeviceIfNeeded()")
|
|
| 191 |
+ utils.Debugf("activateDeviceIfNeeded(%v)", hash)
|
|
| 192 | 192 |
info := devices.Devices[hash] |
| 193 | 193 |
if info == nil {
|
| 194 | 194 |
return fmt.Errorf("Unknown device %s", hash)
|
| ... | ... |
@@ -560,6 +561,7 @@ func (devices *DeviceSetDM) DeactivateDevice(hash string) error {
|
| 560 | 560 |
|
| 561 | 561 |
func (devices *DeviceSetDM) Shutdown() error {
|
| 562 | 562 |
devices.Lock() |
| 563 |
+ utils.Debugf("[devmapper] Shutting down DeviceSet: %s", devices.root)
|
|
| 563 | 564 |
defer devices.Unlock() |
| 564 | 565 |
|
| 565 | 566 |
if !devices.initialized {
|
| ... | ... |
@@ -570,6 +570,7 @@ func resumeDevice(name string) error {
|
| 570 | 570 |
} |
| 571 | 571 |
|
| 572 | 572 |
func createDevice(poolName string, deviceId int) error {
|
| 573 |
+ utils.Debugf("[devmapper] createDevice(poolName=%v, deviceId=%v)", poolName, deviceId)
|
|
| 573 | 574 |
task, err := createTask(DeviceTargetMsg, poolName) |
| 574 | 575 |
if task == nil {
|
| 575 | 576 |
return err |
| ... | ... |
@@ -106,6 +106,8 @@ func removeDev(name string) error {
|
| 106 | 106 |
} |
| 107 | 107 |
|
| 108 | 108 |
func cleanupDevMapper() error {
|
| 109 |
+ utils.Debugf("[devmapper cleanup] starting")
|
|
| 110 |
+ defer utils.Debugf("[devmapper cleanup] done")
|
|
| 109 | 111 |
filter := "docker-" + path.Base(unitTestStoreBase) |
| 110 | 112 |
utils.Debugf("Filtering out %s\n", filter)
|
| 111 | 113 |
// Unmount any leftover mounts from previous unit test runs |
| ... | ... |
@@ -30,19 +30,25 @@ type Fataler interface {
|
| 30 | 30 |
Fatal(args ...interface{})
|
| 31 | 31 |
} |
| 32 | 32 |
|
| 33 |
-func newTestRuntime() (*Runtime, error) {
|
|
| 33 |
+func newTestRuntime() (runtime *Runtime, err error) {
|
|
| 34 |
+ utils.Debugf("newTestRuntime start")
|
|
| 34 | 35 |
root, err := ioutil.TempDir("", "docker-test")
|
| 36 |
+ defer func() {
|
|
| 37 |
+ utils.Debugf("newTestRuntime: %s", root)
|
|
| 38 |
+ }() |
|
| 35 | 39 |
if err != nil {
|
| 36 | 40 |
return nil, err |
| 37 | 41 |
} |
| 38 | 42 |
if err := os.Remove(root); err != nil {
|
| 39 | 43 |
return nil, err |
| 40 | 44 |
} |
| 45 |
+ utils.Debugf("Copying %s to %s", unitTestStoreBase, root)
|
|
| 41 | 46 |
if err := utils.CopyDirectory(unitTestStoreBase, root); err != nil {
|
| 47 |
+ utils.Debugf("ERROR: Copying %s to %s returned %s", unitTestStoreBase, root, err)
|
|
| 42 | 48 |
return nil, err |
| 43 | 49 |
} |
| 44 | 50 |
|
| 45 |
- runtime, err := NewRuntimeFromDirectory(root, false) |
|
| 51 |
+ runtime, err = NewRuntimeFromDirectory(root, false) |
|
| 46 | 52 |
if err != nil {
|
| 47 | 53 |
return nil, err |
| 48 | 54 |
} |