TheCloud/ssh-chat
1
0
Fork 0
mirror of https://github.com/shazow/ssh-chat.git synced 2025-09-22 10:50:18 -04:00
Code Issues Packages Projects Releases Wiki Activity

Added keepalive feature to keep clients connected

Browse Source
This commit is contained in:
James Mills 2016-07-09 18:03:28 -07:00
parent 838f58e648
commit e5b344f4eb
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6
1 changed files with 29 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
sshd/net.go
View File

@ -2,6 +2,7 @@ package sshd
import (
"net"
"time"
"github.com/shazow/rateio"
"golang.org/x/crypto/ssh"
@ -24,7 +25,7 @@ func ListenSSH(laddr string, config *ssh.ServerConfig) (*SSHListener, error) {
return &l, nil
}
func (l *SSHListener) handleConn(conn net.Conn) (*Terminal, error) {
func (l *SSHListener) handleConn(conn net.Conn, stop <-chan bool) (*Terminal, error) {
if l.RateLimit != nil {
// TODO: Configurable Limiter?
conn = ReadLimitConn(conn, l.RateLimit())
@ -38,11 +39,17 @@ func (l *SSHListener) handleConn(conn net.Conn) (*Terminal, error) {
// FIXME: Disconnect if too many faulty requests? (Avoid DoS.)
go ssh.DiscardRequests(requests)
return NewSession(sshConn, channels)
terminal, err := NewSession(sshConn, channels)
if err != nil {
return nil, err
}
go KeepAlive(terminal, 2, stop)
return terminal, err
}
// Accept incoming connections as terminal requests and yield them
func (l *SSHListener) ServeTerminal() <-chan *Terminal {
stop := make(chan bool)
ch := make(chan *Terminal)
go func() {
@ -59,7 +66,7 @@ func (l *SSHListener) ServeTerminal() <-chan *Terminal {
// Goroutineify to resume accepting sockets early
go func() {
term, err := l.handleConn(conn)
term, err := l.handleConn(conn, stop)
if err != nil {
logger.Printf("Failed to handshake: %v", err)
return
@ -71,3 +78,22 @@ func (l *SSHListener) ServeTerminal() <-chan *Terminal {
return ch
}
// KeepAlive Setup a new keepalive goroutine
func KeepAlive(t *Terminal, interval time.Duration, stop <-chan bool) {
// this sends keepalive packets every 2 seconds
// there's no useful response from these, so we can just abort if there's an error
tick := time.NewTicker(interval * time.Second)
defer tick.Stop()
for {
select {
case <-tick.C:
_, err := t.Channel.SendRequest("keepalive", true, nil)
if err != nil {
return
}
case <-stop:
return
}
}
}