github/rclone
1
Fork 0
mirror of https://github.com/rclone/rclone synced 2024-11-26 04:07:22 +01:00
Code Releases Activity

sftp: use atomic types

Browse Source
This commit is contained in:
Roberto Ricci 2023-08-18 16:33:10 +02:00 committed by Nick Craig-Wood
parent c624dd5c3a
commit 28ceb323ee
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/sftp/sftp.go
View File

@ -503,7 +503,7 @@ type Fs struct {
drain *time.Timer // used to drain the pool when we stop using the connections drain *time.Timer // used to drain the pool when we stop using the connections
pacer *fs.Pacer // pacer for operations pacer *fs.Pacer // pacer for operations
savedpswd string savedpswd string
sessions int32 // count in use sessions sessions atomic.Int32 // count in use sessions
} }
// Object is a remote SFTP file that has been stat'd (so it exists, but is not necessarily open for reading) // Object is a remote SFTP file that has been stat'd (so it exists, but is not necessarily open for reading)
@ -571,17 +571,17 @@ func (c *conn) closed() error {
// //
// Call removeSession() when done // Call removeSession() when done
func (f *Fs) addSession() { func (f *Fs) addSession() {
atomic.AddInt32(&f.sessions, 1) f.sessions.Add(1)
} }
// Show the ssh session is no longer in use // Show the ssh session is no longer in use
func (f *Fs) removeSession() { func (f *Fs) removeSession() {
atomic.AddInt32(&f.sessions, -1) f.sessions.Add(-1)
} }
// getSessions shows whether there are any sessions in use // getSessions shows whether there are any sessions in use
func (f *Fs) getSessions() int32 { func (f *Fs) getSessions() int32 {
return atomic.LoadInt32(&f.sessions) return f.sessions.Load()
} }
// Open a new connection to the SFTP server. // Open a new connection to the SFTP server.