rdelaage
/
restic
mirror of https://github.com/restic/restic.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use connection pointer directly in putConnection 

Setting *pc back to nil is too easily defeated to be useful.
This is more concise and prevents pointer from getting heap-allocated.
This commit is contained in:
Aneesh Nireshwalia 2023-02-05 07:41:58 -07:00
parent a3e9be1656
commit c9dba2cdd7
2 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/backend/smb/conpool.go
View File

@ -188,12 +188,7 @@ func (b *Backend) getConnection(ctx context.Context, share string) (c *conn, err
}
// Return a SMB connection to the pool
//
// It nils the pointed to connection out so it can't be reused
func (b *Backend) putConnection(pc **conn) {
c := *pc
*pc = nil
func (b *Backend) putConnection(c *conn) {
var nopErr error
if c.smbShare != nil {
// stat the current directory

16
internal/backend/smb/smb.go
View File

@ -93,7 +93,7 @@ func open(ctx context.Context, cfg Config) (*Backend, error) {
if err != nil {
return nil, err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
stat, err := cn.smbShare.Stat(l.Filename(restic.Handle{Type: restic.ConfigFile}))
m := backend.DeriveModesFromFileInfo(stat, err)
@ -124,7 +124,7 @@ func Create(ctx context.Context, cfg Config) (*Backend, error) {
if err != nil {
return b, err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
// test if config file already exists
_, err = cn.smbShare.Lstat(b.Filename(restic.Handle{Type: restic.ConfigFile}))
@ -200,7 +200,7 @@ func (b *Backend) Save(ctx context.Context, h restic.Handle, rd restic.RewindRea
if err != nil {
return err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
// create new file
f, err := cn.smbShare.OpenFile(tmpFilename, os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0600)
@ -297,7 +297,7 @@ func (b *Backend) openReader(ctx context.Context, h restic.Handle, length int, o
if err != nil {
return nil, err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
b.sem.GetToken()
f, err := cn.smbShare.Open(b.Filename(h))
@ -338,7 +338,7 @@ func (b *Backend) Stat(ctx context.Context, h restic.Handle) (restic.FileInfo, e
if err != nil {
return restic.FileInfo{}, err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
fi, err := cn.smbShare.Stat(b.Filename(h))
if err != nil {
@ -360,7 +360,7 @@ func (b *Backend) Remove(ctx context.Context, h restic.Handle) error {
if err != nil {
return err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
// reset read-only flag
err = cn.smbShare.Chmod(fn, 0666)
@ -380,7 +380,7 @@ func (b *Backend) List(ctx context.Context, t restic.FileType, fn func(restic.Fi
if err != nil {
return err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
basedir, subdirs := b.Basedir(t)
if subdirs {
@ -480,7 +480,7 @@ func (b *Backend) Delete(ctx context.Context) error {
if err != nil {
return err
}
defer b.putConnection(&cn)
defer b.putConnection(cn)
return cn.smbShare.RemoveAll(b.Location())
}