|
@@ -138,7 +138,7 @@ func (p *v2Pusher) pushV2Tag(tag string) error {
|
|
|
dgst, err := p.graph.GetDigest(layer.ID)
|
|
|
switch err {
|
|
|
case nil:
|
|
|
- _, err := p.repo.Blobs(nil).Stat(nil, dgst)
|
|
|
+ _, err := p.repo.Blobs(context.Background()).Stat(context.Background(), dgst)
|
|
|
switch err {
|
|
|
case nil:
|
|
|
exists = true
|
|
@@ -158,7 +158,7 @@ func (p *v2Pusher) pushV2Tag(tag string) error {
|
|
|
// if digest was empty or not saved, or if blob does not exist on the remote repository,
|
|
|
// then fetch it.
|
|
|
if !exists {
|
|
|
- if pushDigest, err := p.pushV2Image(p.repo.Blobs(nil), layer); err != nil {
|
|
|
+ if pushDigest, err := p.pushV2Image(p.repo.Blobs(context.Background()), layer); err != nil {
|
|
|
return err
|
|
|
} else if pushDigest != dgst {
|
|
|
// Cache new checksum
|
|
@@ -226,7 +226,7 @@ func (p *v2Pusher) pushV2Image(bs distribution.BlobService, img *image.Image) (d
|
|
|
|
|
|
// Send the layer
|
|
|
logrus.Debugf("rendered layer for %s of [%d] size", img.ID, size)
|
|
|
- layerUpload, err := bs.Create(nil)
|
|
|
+ layerUpload, err := bs.Create(context.Background())
|
|
|
if err != nil {
|
|
|
return "", err
|
|
|
}
|
|
@@ -250,7 +250,7 @@ func (p *v2Pusher) pushV2Image(bs distribution.BlobService, img *image.Image) (d
|
|
|
}
|
|
|
|
|
|
desc := distribution.Descriptor{Digest: dgst}
|
|
|
- if _, err := layerUpload.Commit(nil, desc); err != nil {
|
|
|
+ if _, err := layerUpload.Commit(context.Background(), desc); err != nil {
|
|
|
return "", err
|
|
|
}
|
|
|
|