octoleo/restic
2
2
Fork 0
mirror of https://github.com/octoleo/restic.git synced 2024-11-02 19:49:44 +00:00
Code Issues Releases Wiki Activity

rest backend: Remove indirection on http.Client

Browse Source
This commit is contained in:
Alexander Neumann 2016-02-21 17:06:35 +01:00
parent 921c2f6069
commit 7087efaa79
1 changed files with 7 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/restic/backend/rest/rest.go
View File

@ -48,7 +48,7 @@ func restPath(url *url.URL, h backend.Handle) string {
type restBackend struct { type restBackend struct {
url *url.URL url *url.URL
connChan chan struct{} connChan chan struct{}
client *http.Client client http.Client
} }
// Open opens the REST backend with the given config. // Open opens the REST backend with the given config.
@ -60,7 +60,7 @@ func Open(cfg Config) (backend.Backend, error) {
tr := &http.Transport{} tr := &http.Transport{}
client := http.Client{Transport: tr} client := http.Client{Transport: tr}
return &restBackend{url: cfg.URL, connChan: connChan, client: &client}, nil return &restBackend{url: cfg.URL, connChan: connChan, client: client}, nil
} }
// Location returns this backend's location (the server's URL). // Location returns this backend's location (the server's URL).
@ -80,10 +80,8 @@ func (b *restBackend) Load(h backend.Handle, p []byte, off int64) (n int, err er
return 0, err return 0, err
} }
req.Header.Add("Range", fmt.Sprintf("bytes=%d-%d", off, off+int64(len(p)))) req.Header.Add("Range", fmt.Sprintf("bytes=%d-%d", off, off+int64(len(p))))
client := *b.client
<-b.connChan <-b.connChan
resp, err := client.Do(req) resp, err := b.client.Do(req)
b.connChan <- struct{}{} b.connChan <- struct{}{}
if resp != nil { if resp != nil {
@ -112,10 +110,8 @@ func (b *restBackend) Save(h backend.Handle, p []byte) (err error) {
return err return err
} }
client := *b.client
<-b.connChan <-b.connChan
resp, err := client.Post(restPath(b.url, h), "binary/octet-stream", bytes.NewReader(p)) resp, err := b.client.Post(restPath(b.url, h), "binary/octet-stream", bytes.NewReader(p))
b.connChan <- struct{}{} b.connChan <- struct{}{}
if resp != nil { if resp != nil {
@ -145,9 +141,8 @@ func (b *restBackend) Stat(h backend.Handle) (backend.BlobInfo, error) {
return backend.BlobInfo{}, err return backend.BlobInfo{}, err
} }
client := *b.client
<-b.connChan <-b.connChan
resp, err := client.Head(restPath(b.url, h)) resp, err := b.client.Head(restPath(b.url, h))
b.connChan <- struct{}{} b.connChan <- struct{}{}
if err != nil { if err != nil {
return backend.BlobInfo{}, err return backend.BlobInfo{}, err
@ -193,10 +188,8 @@ func (b *restBackend) Remove(t backend.Type, name string) error {
if err != nil { if err != nil {
return err return err
} }
client := *b.client
<-b.connChan <-b.connChan
resp, err := client.Do(req) resp, err := b.client.Do(req)
b.connChan <- struct{}{} b.connChan <- struct{}{}
if err != nil { if err != nil {
@ -221,9 +214,8 @@ func (b *restBackend) List(t backend.Type, done <-chan struct{}) <-chan string {
url += "/" url += "/"
} }
client := *b.client
<-b.connChan <-b.connChan
resp, err := client.Get(url) resp, err := b.client.Get(url)
b.connChan <- struct{}{} b.connChan <- struct{}{}
if resp != nil { if resp != nil {