Fix build when using build tag 'noresumabledigest'
Signed-off-by: Richard Scothern <richard.scothern@gmail.com>master
							parent
							
								
									af3f674323
								
							
						
					
					
						commit
						6f2f84996d
					
				| 
						 | 
				
			
			@ -4,6 +4,7 @@ import (
 | 
			
		|||
	"errors"
 | 
			
		||||
	"fmt"
 | 
			
		||||
	"io"
 | 
			
		||||
	"path"
 | 
			
		||||
	"time"
 | 
			
		||||
 | 
			
		||||
	"github.com/Sirupsen/logrus"
 | 
			
		||||
| 
						 | 
				
			
			@ -311,3 +312,35 @@ func (bw *blobWriter) moveBlob(ctx context.Context, desc distribution.Descriptor
 | 
			
		|||
 | 
			
		||||
	return bw.blobStore.driver.Move(ctx, bw.path, blobPath)
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// removeResources should clean up all resources associated with the upload
 | 
			
		||||
// instance. An error will be returned if the clean up cannot proceed. If the
 | 
			
		||||
// resources are already not present, no error will be returned.
 | 
			
		||||
func (bw *blobWriter) removeResources(ctx context.Context) error {
 | 
			
		||||
	dataPath, err := bw.blobStore.pm.path(uploadDataPathSpec{
 | 
			
		||||
		name: bw.blobStore.repository.Name(),
 | 
			
		||||
		id:   bw.id,
 | 
			
		||||
	})
 | 
			
		||||
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	// Resolve and delete the containing directory, which should include any
 | 
			
		||||
	// upload related files.
 | 
			
		||||
	dirPath := path.Dir(dataPath)
 | 
			
		||||
	if err := bw.blobStore.driver.Delete(ctx, dirPath); err != nil {
 | 
			
		||||
		switch err := err.(type) {
 | 
			
		||||
		case storagedriver.PathNotFoundError:
 | 
			
		||||
			break // already gone!
 | 
			
		||||
		default:
 | 
			
		||||
			// This should be uncommon enough such that returning an error
 | 
			
		||||
			// should be okay. At this point, the upload should be mostly
 | 
			
		||||
			// complete, but perhaps the backend became unaccessible.
 | 
			
		||||
			context.GetLogger(ctx).Errorf("unable to delete layer upload resources %q: %v", dirPath, err)
 | 
			
		||||
			return err
 | 
			
		||||
		}
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -100,38 +100,6 @@ func (bw *blobWriter) resumeDigestAt(ctx context.Context, offset int64) error {
 | 
			
		|||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// removeResources should clean up all resources associated with the upload
 | 
			
		||||
// instance. An error will be returned if the clean up cannot proceed. If the
 | 
			
		||||
// resources are already not present, no error will be returned.
 | 
			
		||||
func (bw *blobWriter) removeResources(ctx context.Context) error {
 | 
			
		||||
	dataPath, err := bw.blobStore.pm.path(uploadDataPathSpec{
 | 
			
		||||
		name: bw.blobStore.repository.Name(),
 | 
			
		||||
		id:   bw.id,
 | 
			
		||||
	})
 | 
			
		||||
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	// Resolve and delete the containing directory, which should include any
 | 
			
		||||
	// upload related files.
 | 
			
		||||
	dirPath := path.Dir(dataPath)
 | 
			
		||||
	if err := bw.blobStore.driver.Delete(ctx, dirPath); err != nil {
 | 
			
		||||
		switch err := err.(type) {
 | 
			
		||||
		case storagedriver.PathNotFoundError:
 | 
			
		||||
			break // already gone!
 | 
			
		||||
		default:
 | 
			
		||||
			// This should be uncommon enough such that returning an error
 | 
			
		||||
			// should be okay. At this point, the upload should be mostly
 | 
			
		||||
			// complete, but perhaps the backend became unaccessible.
 | 
			
		||||
			context.GetLogger(ctx).Errorf("unable to delete layer upload resources %q: %v", dirPath, err)
 | 
			
		||||
			return err
 | 
			
		||||
		}
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
type hashStateEntry struct {
 | 
			
		||||
	offset int64
 | 
			
		||||
	path   string
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue