Fix race conditions and improve lifecycle safety #150
@@ -73,10 +73,14 @@ func (l *lifecycle) User() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (l *lifecycle) SetChannel(channel ssh.Channel) {
|
func (l *lifecycle) SetChannel(channel ssh.Channel) {
|
||||||
|
l.mu.Lock()
|
||||||
|
defer l.mu.Unlock()
|
||||||
l.channel = channel
|
l.channel = channel
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *lifecycle) Channel() ssh.Channel {
|
func (l *lifecycle) Channel() ssh.Channel {
|
||||||
|
l.mu.Lock()
|
||||||
|
defer l.mu.Unlock()
|
||||||
return l.channel
|
return l.channel
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user