From 6f1d1e00a7c615209cf6b25e314d033bda3b5d09 Mon Sep 17 00:00:00 2001 From: Máximo Cuadros Date: Sat, 10 Sep 2016 01:48:43 +0200 Subject: storage: filesystem ref storage, and not not exists file handling --- remote.go | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) (limited to 'remote.go') diff --git a/remote.go b/remote.go index bfa7bc9..c654422 100644 --- a/remote.go +++ b/remote.go @@ -161,9 +161,20 @@ func (r *Remote) buildRequest( } func (r *Remote) updateObjectStorage(reader io.Reader) error { - stream := packfile.NewScannerFromReader(reader) + s := r.s.ObjectStorage() + if sw, ok := s.(core.ObjectStorageWrite); ok { + w, err := sw.Writer() + if err != nil { + return err + } + + defer w.Close() + _, err = io.Copy(w, reader) + return err + } - d := packfile.NewDecoder(stream, r.s.ObjectStorage()) + stream := packfile.NewScannerFromReader(reader) + d := packfile.NewDecoder(stream, s) _, err := d.Decode() return err } -- cgit