Method preparePackDataContent

repo/content/content_manager_lock_free.go:126–176

(ctx context.Context, mp format.MutableParameters, pp *pendingPackInfo)

}

func (sm *SharedManager) preparePackDataContent(ctx context.Context, mp format.MutableParameters, pp *pendingPackInfo) (index.Builder, error) {
	packFileIndex := index.Builder{}
	haveContent := false

	for _, info := range pp.currentPackItems {
		if info.PackBlobID == pp.packBlobID {
			haveContent = true

			contentlog.Log3(ctx, sm.log, "add-to-pack",
				contentparam.ContentID("cid", info.ContentID),
				logparam.UInt32("len", info.PackedLength),
				logparam.Bool("del", info.Deleted))
		} else {
			contentlog.Log4(ctx, sm.log, "move-to-pack",
				contentparam.ContentID("cid", info.ContentID),
				blobparam.BlobID("sourcePack", info.PackBlobID),
				logparam.UInt32("len", info.PackedLength),
				logparam.Bool("del", info.Deleted))
		}

		packFileIndex.Add(info)
	}

	if len(packFileIndex) == 0 {
		return nil, nil
	}

	if !haveContent {
		// we wrote pack preamble but no actual content, revert it
		pp.currentPackData.Reset()
		return packFileIndex, nil
	}

	if pp.finalized {
		return packFileIndex, nil
	}

	pp.finalized = true

	if sm.paddingUnit > 0 {
		if missing := sm.paddingUnit - (pp.currentPackData.Length() % sm.paddingUnit); missing > 0 {
			if err := writeRandomBytesToBuffer(pp.currentPackData, missing); err != nil {
				return nil, errors.Wrap(err, "unable to prepare content postamble")
			}
		}
	}

	err := sm.appendPackFileIndexRecoveryData(mp, packFileIndex, pp.currentPackData)

	return packFileIndex, err
}

func getPackedContentIV(output []byte, contentID ID) []byte {
	h := contentID.Hash()