Merge pull request #90 from libgit2/unchanify

Remove usage of channels for `ForEach`
This commit is contained in:
Carlos Martín Nieto 2014-05-07 15:12:00 +02:00
commit f5e1252d6e
3 changed files with 89 additions and 49 deletions

42
odb.go
View File

@ -84,30 +84,40 @@ func (v *Odb) Read(oid *Oid) (obj *OdbObject, err error) {
return obj, nil return obj, nil
} }
type OdbForEachCallback func(id *Oid) error
type foreachData struct {
callback OdbForEachCallback
err error
}
//export odbForEachCb //export odbForEachCb
func odbForEachCb(id *C.git_oid, payload unsafe.Pointer) int { func odbForEachCb(id *C.git_oid, payload unsafe.Pointer) int {
ch := *(*chan *Oid)(payload) data := (*foreachData)(payload)
oid := newOidFromC(id)
// Because the channel is unbuffered, we never read our own data. If ch is err := data.callback(newOidFromC(id))
// readable, the user has sent something on it, which means we should if err != nil {
// abort. data.err = err
select { return C.GIT_EUSER
case ch <- oid:
case <-ch:
return -1
} }
return 0 return 0
} }
func (v *Odb) forEachWrap(ch chan *Oid) { func (v *Odb) ForEach(callback OdbForEachCallback) error {
C._go_git_odb_foreach(v.ptr, unsafe.Pointer(&ch)) data := foreachData {
close(ch) callback: callback,
err: nil,
} }
func (v *Odb) ForEach() chan *Oid { ret := C._go_git_odb_foreach(v.ptr, unsafe.Pointer(&data))
ch := make(chan *Oid, 0) if ret == C.GIT_EUSER {
go v.forEachWrap(ch) return data.err
return ch } else if ret < 0 {
return MakeGitError(ret)
}
return nil
} }
// Hash determines the object-ID (sha1) of a data buffer. // Hash determines the object-ID (sha1) of a data buffer.

View File

@ -3,6 +3,7 @@ package git
import ( import (
"io" "io"
"os" "os"
"errors"
"testing" "testing"
) )
@ -48,7 +49,7 @@ parent 66e1c476199ebcd3e304659992233132c5a52c6c
author John Doe <john@doe.com> 1390682018 +0000 author John Doe <john@doe.com> 1390682018 +0000
committer John Doe <john@doe.com> 1390682018 +0000 committer John Doe <john@doe.com> 1390682018 +0000
Initial commit.`; Initial commit.`
oid, error := odb.Hash([]byte(str), ObjectCommit) oid, error := odb.Hash([]byte(str), ObjectCommit)
checkFatal(t, error) checkFatal(t, error)
@ -60,3 +61,36 @@ Initial commit.`;
t.Fatal("Hash and write Oids are different") t.Fatal("Hash and write Oids are different")
} }
} }
func TestOdbForeach(t *testing.T) {
repo := createTestRepo(t)
defer os.RemoveAll(repo.Workdir())
_, _ = seedTestRepo(t, repo)
odb, err := repo.Odb()
checkFatal(t, err)
expect := 3
count := 0
err = odb.ForEach(func(id *Oid) error {
count++
return nil
})
checkFatal(t, err)
if count != expect {
t.Fatalf("Expected %v objects, got %v")
}
expect = 1
count = 0
to_return := errors.New("not really an error")
err = odb.ForEach(func(id *Oid) error {
count++
return to_return
})
if err != to_return {
t.Fatalf("Odb.ForEach() did not return the expected error, got %v", err)
}
}

View File

@ -94,55 +94,51 @@ func (pb *Packbuilder) WriteToFile(name string, mode os.FileMode) error {
} }
func (pb *Packbuilder) Write(w io.Writer) error { func (pb *Packbuilder) Write(w io.Writer) error {
ch, stop := pb.ForEach() return pb.ForEach(func(slice []byte) error {
for slice := range ch {
_, err := w.Write(slice) _, err := w.Write(slice)
if err != nil {
close(stop)
return err return err
} })
}
return nil
} }
func (pb *Packbuilder) Written() uint32 { func (pb *Packbuilder) Written() uint32 {
return uint32(C.git_packbuilder_written(pb.ptr)) return uint32(C.git_packbuilder_written(pb.ptr))
} }
type PackbuilderForeachCallback func([]byte) error
type packbuilderCbData struct { type packbuilderCbData struct {
ch chan<- []byte callback PackbuilderForeachCallback
stop <-chan bool err error
} }
//export packbuilderForEachCb //export packbuilderForEachCb
func packbuilderForEachCb(buf unsafe.Pointer, size C.size_t, payload unsafe.Pointer) int { func packbuilderForEachCb(buf unsafe.Pointer, size C.size_t, payload unsafe.Pointer) int {
data := (*packbuilderCbData)(payload) data := (*packbuilderCbData)(payload)
ch := data.ch
stop := data.stop
slice := C.GoBytes(buf, C.int(size)) slice := C.GoBytes(buf, C.int(size))
select {
case <- stop: err := data.callback(slice)
return -1 if err != nil {
case ch <- slice: data.err = err
return C.GIT_EUSER
} }
return 0 return 0
} }
func (pb *Packbuilder) forEachWrap(data *packbuilderCbData) { // ForEach repeatedly calls the callback with new packfile data until
C._go_git_packbuilder_foreach(pb.ptr, unsafe.Pointer(data)) // there is no more data or the callback returns an error
close(data.ch) func (pb *Packbuilder) ForEach(callback PackbuilderForeachCallback) error {
data := packbuilderCbData{
callback: callback,
err: nil,
} }
// Foreach sends the packfile as slices through the "data" channel. If err := C._go_git_packbuilder_foreach(pb.ptr, unsafe.Pointer(&data))
// you want to stop the pack-building process (e.g. there's an error if err == C.GIT_EUSER {
// writing to the output), close or write a value into the "stop" return data.err
// channel. }
func (pb *Packbuilder) ForEach() (<-chan []byte, chan<- bool) { if err < 0 {
ch := make(chan []byte) return MakeGitError(err)
stop := make(chan bool) }
data := packbuilderCbData{ch, stop}
go pb.forEachWrap(&data) return nil
return ch, stop
} }