1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
package containerd
import (
"context"
"fmt"
"github.com/containerd/containerd/v2/core/mount"
"github.com/containerd/log"
"github.com/docker/docker/container"
"github.com/docker/docker/pkg/stringid"
"github.com/moby/go-archive"
)
func (i *ImageService) Changes(ctx context.Context, ctr *container.Container) ([]archive.Change, error) {
rwl := ctr.RWLayer
if rwl == nil {
return nil, fmt.Errorf("RWLayer is unexpectedly nil for container %s", ctr.ID)
}
snapshotter := i.client.SnapshotService(ctr.Driver)
info, err := snapshotter.Stat(ctx, ctr.ID)
if err != nil {
return nil, err
}
id := stringid.GenerateRandomID()
parentViewKey := ctr.ID + "-parent-view-" + id
imageMounts, _ := snapshotter.View(ctx, parentViewKey, info.Parent)
defer func() {
if err := snapshotter.Remove(ctx, parentViewKey); err != nil {
log.G(ctx).WithError(err).Warn("error removing the parent view snapshot")
}
}()
containerRoot, err := rwl.Mount(ctr.GetMountLabel())
if err != nil {
return nil, err
}
defer func() {
if err := rwl.Unmount(); err != nil {
log.G(ctx).WithFields(log.Fields{"error": err, "container": ctr.ID}).Warn("Failed to unmount container RWLayer after export")
}
}()
var changes []archive.Change
err = mount.WithReadonlyTempMount(ctx, imageMounts, func(imageRoot string) error {
changes, err = archive.ChangesDirs(containerRoot, imageRoot)
return err
})
return changes, err
}
|
