github/containerd
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Merge pull request #5283 from alakesh/check-out-of-space

Browse Source 
devmapper: log pool status when mkfs fails
This commit is contained in:
Phil Estes 2021-04-12 20:37:13 -04:00 committed by GitHub
commit b7c8136901
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
snapshots/devmapper/dmsetup/dmsetup.go
View File

@ -274,10 +274,11 @@ func Version() (string, error) {
// DeviceStatus represents devmapper device status information // DeviceStatus represents devmapper device status information
type DeviceStatus struct { type DeviceStatus struct {
Offset int64 RawOutput string
Length int64 Offset int64
Target string Length int64
Params []string Target string
Params []string
} }
// Status provides status information for devmapper device // Status provides status information for devmapper device
@ -291,6 +292,7 @@ func Status(deviceName string) (*DeviceStatus, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
status.RawOutput = output
// Status output format: // Status output format:
// Offset (int64) // Offset (int64)

7
snapshots/devmapper/snapshotter.go
View File

@ -366,8 +366,13 @@ func (s *Snapshotter) createSnapshot(ctx context.Context, kind snapshots.Kind, k
} }
if err := mkfs(ctx, dmsetup.GetFullDevicePath(deviceName)); err != nil { if err := mkfs(ctx, dmsetup.GetFullDevicePath(deviceName)); err != nil {
status, sErr := dmsetup.Status(s.pool.poolName)
if sErr != nil {
multierror.Append(err, sErr)
}
// Rollback thin device creation if mkfs failed // Rollback thin device creation if mkfs failed
log.G(ctx).WithError(err).Errorf("failed to initialize thin device %q for snapshot %s", deviceName, snap.ID) log.G(ctx).WithError(err).Errorf("failed to initialize thin device %q for snapshot %s pool status %s", deviceName, snap.ID, status.RawOutput)
return nil, multierror.Append(err, return nil, multierror.Append(err,
s.pool.RemoveDevice(ctx, deviceName)) s.pool.RemoveDevice(ctx, deviceName))
} }