Merge branch 'master' into feature/skip-non-commit-tags

Author: ajnavarro

.gitignore

@@ -20,6 +20,7 @@ _cgo_export.*
 _testmain.go
 
 main
+gitbase
 *.exe
 *.test
 *.prof

commit_trees.go

@@ -330,11 +330,13 @@ func (i *commitTreesRowIter) Close() error {
 		i.trees.Close()
 	}
 
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
 	if i.index != nil {
 		return i.index.Close()
 	}
 
-	i.repo.Close()
-
 	return nil
 }

commits.go

@@ -3,7 +3,6 @@ package gitbase
 import (
 	"io"
 
-	git "gopkg.in/src-d/go-git.v4"
 	"gopkg.in/src-d/go-mysql-server.v0/sql"
 
 	"gopkg.in/src-d/go-git.v4/plumbing"
@@ -409,10 +408,7 @@ func newCommitsKeyValueIter(
 		return nil, err
 	}
 
-	commits, err :=
-		repo.Log(&git.LogOptions{
-			All: true,
-		})
+	commits, err := newCommitIter(repo, false)
 	if err != nil {
 		return nil, err
 	}

gitbase

@@ -227,5 +227,8 @@ func (i *partitionedIndexKeyValueIter) Next() (sql.Partition, sql.IndexKeyValueI
 }
 
 func (i *partitionedIndexKeyValueIter) Close() error {
-	return i.partitions.Close()
+	if i.partitions != nil {
+		return i.partitions.Close()
+	}
+	return nil
 }

partition.go

@@ -370,12 +370,14 @@ func (i *refCommitsRowIter) Close() error {
 		i.refs.Close()
 	}
 
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
 	if i.index != nil {
 		return i.index.Close()
 	}
 
-	i.repo.Close()
-
 	return nil
 }
 
@@ -452,3 +454,9 @@ func (i *indexedCommitIter) Next() (*object.Commit, int, error) {
 		return c, frame.idx, nil
 	}
 }
+
+func (i *indexedCommitIter) Close() {
+	if i.repo != nil {
+		i.repo.Close()
+	}
+}

ref_commits.go

@@ -330,12 +330,14 @@ func (i *refRowIter) Close() error {
 		i.iter.Close()
 	}
 
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
 	if i.index != nil {
 		return i.index.Close()
 	}
 
-	i.repo.Close()
-
 	return nil
 }
 

references.go

@@ -151,5 +151,8 @@ func (i *repositoriesRowIter) Next() (sql.Row, error) {
 
 func (i *repositoriesRowIter) Close() error {
 	i.visited = true
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return nil
 }

repositories.go

@@ -56,7 +56,13 @@ func NewAllReposIter(filters sql.Expression) ReposIter {
 }
 
 func (i *squashReposIter) Repo() *Repository { return i.repo }
-func (i *squashReposIter) Close() error      { return nil }
+func (i *squashReposIter) Close() error {
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
+	return nil
+}
 func (i *squashReposIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
 	session, err := getSession(ctx)
 	if err != nil {
@@ -140,7 +146,13 @@ func NewAllRemotesIter(filters sql.Expression) RemotesIter {
 }
 
 func (i *squashRemoteIter) Remote() *Remote { return i.remote }
-func (i *squashRemoteIter) Close() error    { return nil }
+func (i *squashRemoteIter) Close() error {
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
+	return nil
+}
 func (i *squashRemoteIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
 	session, err := getSession(ctx)
 	if err != nil {
@@ -403,6 +415,9 @@ func (i *squashRefIter) Close() error {
 	if i.refs != nil {
 		i.refs.Close()
 	}
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return i.repos.Close()
 }
 func (i *squashRefIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
@@ -532,6 +547,10 @@ func NewIndexRefsIter(filters sql.Expression, index sql.IndexLookup) RefsIter {
 func (i *squashRefIndexIter) Repository() *Repository { return i.repo }
 func (i *squashRefIndexIter) Ref() *Ref               { return i.ref }
 func (i *squashRefIndexIter) Close() error {
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
 	return i.iter.Close()
 }
 func (i *squashRefIndexIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
@@ -792,8 +811,6 @@ func NewRemoteRefsIter(
 func (i *squashRemoteRefsIter) Repository() *Repository { return i.remotes.Repository() }
 func (i *squashRemoteRefsIter) Ref() *Ref               { return i.ref }
 func (i *squashRemoteRefsIter) Close() error {
-	i.Repository().Close()
-
 	if i.refs != nil {
 		i.refs.Close()
 	}
@@ -952,7 +969,9 @@ func (i *squashRefRefCommitsIter) Close() error {
 		i.refs.Close()
 	}
 
-	i.Repository().Close()
+	if i.commits != nil {
+		i.commits.Close()
+	}
 	return nil
 }
 func (i *squashRefRefCommitsIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
@@ -1225,7 +1244,9 @@ func (i *squashRefCommitsIndexIter) Schema() sql.Schema {
 	return RefCommitsSchema
 }
 func (i *squashRefCommitsIndexIter) Close() error {
-	i.repo.Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return i.iter.Close()
 }
 
@@ -1249,7 +1270,6 @@ func (i *squashRefCommitCommitsIter) Close() error {
 		i.refCommits.Close()
 	}
 
-	i.Repository().Close()
 	return nil
 }
 func (i *squashRefCommitCommitsIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
@@ -1320,8 +1340,10 @@ func (i *squashCommitsIter) Close() error {
 	if i.commits != nil {
 		i.commits.Close()
 	}
+	if i.repo != nil {
+		i.repo.Close()
+	}
 
-	i.repo.Close()
 	return nil
 }
 func (i *squashCommitsIter) New(ctx *sql.Context, repo *Repository) (ChainableIter, error) {
@@ -1495,7 +1517,10 @@ func (i *squashCommitsIndexIter) Schema() sql.Schema {
 	return CommitsSchema
 }
 func (i *squashCommitsIndexIter) Close() error {
-	i.repo.Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
 	return i.iter.Close()
 }
 
@@ -1522,8 +1547,6 @@ func (i *squashRepoCommitsIter) Close() error {
 		i.commits.Close()
 	}
 
-	i.Repository().Close()
-
 	if i.repos != nil {
 		return i.repos.Close()
 	}
@@ -1634,8 +1657,6 @@ func NewRefHEADCommitsIter(
 func (i *squashRefHeadCommitsIter) Repository() *Repository { return i.refs.Repository() }
 func (i *squashRefHeadCommitsIter) Commit() *object.Commit  { return i.commit }
 func (i *squashRefHeadCommitsIter) Close() error {
-	i.Repository().Close()
-
 	if i.refs != nil {
 		return i.refs.Close()
 	}
@@ -1828,7 +1849,10 @@ func (i *squashCommitTreesIndexIter) Schema() sql.Schema {
 	return CommitTreesSchema
 }
 func (i *squashCommitTreesIndexIter) Close() error {
-	i.repo.Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
+
 	return i.iter.Close()
 }
 
@@ -1860,6 +1884,9 @@ func NewCommitTreesIter(
 func (i *squashCommitTreesIter) Repository() *Repository { return i.commits.Repository() }
 func (i *squashCommitTreesIter) Tree() *object.Tree      { return i.tree }
 func (i *squashCommitTreesIter) Close() error {
+	if i.trees != nil {
+		i.trees.Close()
+	}
 	if i.commits != nil {
 		return i.commits.Close()
 	}
@@ -1976,8 +2003,6 @@ func (i *squashRepoTreeEntriesIter) Close() error {
 		i.trees.Close()
 	}
 
-	i.Repository().Close()
-
 	if i.repos != nil {
 		return i.repos.Close()
 	}
@@ -2106,8 +2131,6 @@ func NewCommitMainTreeIter(
 func (i *squashCommitMainTreeIter) Repository() *Repository { return i.commits.Repository() }
 func (i *squashCommitMainTreeIter) Tree() *object.Tree      { return i.tree }
 func (i *squashCommitMainTreeIter) Close() error {
-	i.Repository().Close()
-
 	if i.commits != nil {
 		return i.commits.Close()
 	}
@@ -2270,6 +2293,12 @@ func (i *commitTreeIter) Next() (*object.Tree, error) {
 	}
 }
 
+func (i *commitTreeIter) Close() {
+	if i.repo != nil {
+		i.repo.Close()
+	}
+}
+
 // TreeEntriesIter is a chainable iterator that operates on Tree Entries.
 type TreeEntriesIter interface {
 	ChainableIter
@@ -2300,7 +2329,9 @@ func NewAllTreeEntriesIter(filters sql.Expression) TreeEntriesIter {
 func (i *squashTreeEntriesIter) Repository() *Repository { return i.repo }
 func (i *squashTreeEntriesIter) TreeEntry() *TreeEntry   { return i.entry }
 func (i *squashTreeEntriesIter) Close() error {
-	i.Repository().Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
 
 	if i.trees != nil {
 		i.trees.Close()
@@ -2471,7 +2502,9 @@ func (i *squashTreeEntriesIndexIter) Schema() sql.Schema {
 	return TreeEntriesSchema
 }
 func (i *squashTreeEntriesIndexIter) Close() error {
-	i.Repository().Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return i.iter.Close()
 }
 
@@ -2503,8 +2536,6 @@ func NewTreeTreeEntriesIter(
 func (i *squashTreeTreeEntriesIter) Repository() *Repository { return i.trees.Repository() }
 func (i *squashTreeTreeEntriesIter) TreeEntry() *TreeEntry   { return i.entry }
 func (i *squashTreeTreeEntriesIter) Close() error {
-	i.Repository().Close()
-
 	if i.trees != nil {
 		return i.trees.Close()
 	}
@@ -2674,7 +2705,9 @@ func (i *squashCommitBlobsIndexIter) Schema() sql.Schema {
 	return CommitBlobsSchema
 }
 func (i *squashCommitBlobsIndexIter) Close() error {
-	i.Repository().Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return i.iter.Close()
 }
 
@@ -2712,8 +2745,6 @@ func (i *squashCommitBlobsIter) Close() error {
 		i.files.Close()
 	}
 
-	i.Repository().Close()
-
 	if i.commits != nil {
 		return i.commits.Close()
 	}
@@ -2844,8 +2875,6 @@ func (i *squashRepoBlobsIter) Close() error {
 		i.blobs.Close()
 	}
 
-	i.Repository().Close()
-
 	if i.repos != nil {
 		return i.repos.Close()
 	}
@@ -3230,7 +3259,6 @@ func (i *squashCommitFilesIter) Close() error {
 		i.files.Close()
 	}
 
-	i.Repository().Close()
 	return i.commits.Close()
 }
 func (i *squashCommitFilesIter) Schema() sql.Schema {
@@ -3338,7 +3366,9 @@ func (i *squashIndexCommitFilesIter) Row() sql.Row            { return i.row }
 func (i *squashIndexCommitFilesIter) Schema() sql.Schema      { return CommitFilesSchema }
 
 func (i *squashIndexCommitFilesIter) Close() error {
-	i.repo.Close()
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return i.iter.Close()
 }
 
@@ -3414,7 +3444,6 @@ func (i *squashCommitFileFilesIter) Schema() sql.Schema {
 	return append(i.files.Schema(), FilesSchema...)
 }
 func (i *squashCommitFileFilesIter) Close() error {
-	i.Repository().Close()
 	return i.files.Close()
 }
 

squash_iterator.go

@@ -239,9 +239,9 @@ func (i *treeEntriesRowIter) Close() error {
 	if i.iter != nil {
 		i.iter.Close()
 	}
-
-	i.repo.Close()
-
+	if i.repo != nil {
+		i.repo.Close()
+	}
 	return nil
 }