Add debug

experimental/manifest.go

@@ -69,7 +69,7 @@ func (m *manifestData) path() string {
 }
 
 func (m *manifestData) load(blobs blobsData) error {
-	logrus.Println("MANIFEST:", m.path(), ": loading...")
+	logrus.Infoln("MANIFEST:", m.path(), ": loading...")
 
 	data, err := currentStorage.Read(m.path(), blobs.etag(m.digest))
 	if err != nil {
@@ -88,7 +88,7 @@ func (m *manifestData) load(blobs blobsData) error {
 				if err != nil {
 					return err
 				}
-				logrus.Println("MANIFEST: list", m.path(), " references ", digest)
+				logrus.Infoln("MANIFEST: list", m.path(), " references ", digest)
 				m.manifests = append(m.manifests, digest)
 
 				path := filepath.Join("blobs", digest.scopedPath(), "data")

experimental/repository.go

@@ -59,6 +59,7 @@ func (r *repositoryData) markManifest(revision digest) error {
 	r.lock.Lock()
 	defer r.lock.Unlock()
 
+	logrus.Debugln("MANIFEST: marking ", revision)
 	r.manifests[revision]++
 	return nil
 }
@@ -182,6 +183,7 @@ func (r *repositoryData) mark(blobs blobsData) error {
 }
 
 func (r *repositoryData) sweep() error {
+    logrus.Debug("SWEEP: list of manifests", r.manifests)
 	for name, t := range r.tags {
 		err := t.sweep()
 		if err != nil {

experimental/tag.go

@@ -45,6 +45,7 @@ func (t *tagData) mark(blobs blobsData) error {
 
 func (t *tagData) sweep() error {
 	if !t.current.valid() {
+        logrus.Trace("TAG: deleting invalid current ", t.currentLinkPath())
 		err := deleteFile(t.currentLinkPath(), digestReferenceSize)
 		if err != nil {
 			return err
@@ -55,11 +56,13 @@ func (t *tagData) sweep() error {
 		if version == t.current {
 			continue
 		}
+
 		if t.repository.manifests[version] > 0 {
 			continue
 		}
 
 		if *deleteOldTagVersions {
+            logrus.Trace("TAG: deleting old version", version)
 			err := deleteFile(t.versionLinkPath(version), digestReferenceSize)
 			if err != nil {
 				return err