aboutsummaryrefslogtreecommitdiff
path: root/format/packfile/ingest/ingest.go
diff options
context:
space:
mode:
Diffstat (limited to 'format/packfile/ingest/ingest.go')
-rw-r--r--format/packfile/ingest/ingest.go68
1 files changed, 0 insertions, 68 deletions
diff --git a/format/packfile/ingest/ingest.go b/format/packfile/ingest/ingest.go
deleted file mode 100644
index be65ff5f..00000000
--- a/format/packfile/ingest/ingest.go
+++ /dev/null
@@ -1,68 +0,0 @@
-package ingest
-
-import (
- "fmt"
-)
-
-// ingest initializes transaction state and executes the ingest pipeline.
-func ingest(state *ingestState) (out Result, err error) {
- err = openTemporaryArtifacts(state)
- if err != nil {
- return Result{}, err
- }
-
- defer func() {
- _ = closeTemporaryArtifacts(state)
- if err != nil {
- rollbackTemporaryArtifacts(state)
- }
- }()
-
- err = streamPackAndScan(state)
- if err != nil {
- return Result{}, err
- }
-
- err = resolveAll(state)
- if err != nil {
- return Result{}, err
- }
-
- err = maybeFixThin(state)
- if err != nil {
- return Result{}, err
- }
-
- if state.thinFixed {
- err = resolveAll(state)
- if err != nil {
- return Result{}, err
- }
- }
-
- if len(state.unresolvedRefDeltas) > 0 {
- return Result{}, &ThinPackUnresolvedError{Count: len(state.unresolvedRefDeltas)}
- }
-
- err = verifyResolvedRecords(state)
- if err != nil {
- return Result{}, err
- }
-
- err = state.packFile.Sync()
- if err != nil {
- return Result{}, &DestinationWriteError{Op: fmt.Sprintf("sync pack: %v", err)}
- }
-
- err = writeIdx(state)
- if err != nil {
- return Result{}, err
- }
-
- err = writeRev(state)
- if err != nil {
- return Result{}, err
- }
-
- return finalizeArtifacts(state)
-}