senset/tunnel
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: senset:main
Branches Tags
senset:main
senset:v0.0.7
senset:v0.0.6
senset:v0.0.5
senset:v0.0.4
senset:v0.0.3
senset:v0.0.2
senset:v0.0.1
..
compare: senset:v0.0.4
Branches Tags
senset:main
senset:v0.0.7
senset:v0.0.6
senset:v0.0.5
senset:v0.0.4
senset:v0.0.3
senset:v0.0.2
senset:v0.0.1

No commits in common. "main" and "v0.0.4" have entirely different histories.
main ... v0.0.4

2 changed files with 20 additions and 18 deletions
Show Stats Expand all files Collapse all files

29
logger.go
View File

@ -22,17 +22,22 @@ type Logger interface {
type logger struct{}
func (l *logger) Trace(args ...interface{}) {}
func (l *logger) Tracef(format string, args ...interface{}) {}
func (l *logger) Debug(args ...interface{}) {}
func (l *logger) Debugf(format string, args ...interface{}) {}
func (l *logger) Info(args ...interface{}) {}
func (l *logger) Infof(format string, args ...interface{}) {}
func (l *logger) Error(args ...interface{}) {}
func (l *logger) Errorf(format string, args ...interface{}) {}
func (l *logger) Fatal(args ...interface{}) {}
func (l *logger) Fatalf(format string, args ...interface{}) {}
func (l *logger) Panic(args ...interface{}) {}
func (l *logger) Panicf(format string, args ...interface{}) {}
func (l *logger) Trace(args ...interface{})
func (l *logger) Tracef(format string, args ...interface{})
func (l *logger) Debug(args ...interface{})
func (l *logger) Debugf(format string, args ...interface{})
func (l *logger) Info(args ...interface{})
func (l *logger) Infof(format string, args ...interface{})
func (l *logger) Error(args ...interface{})
func (l *logger) Errorf(format string, args ...interface{})
func (l *logger) Fatal(args ...interface{})
func (l *logger) Fatalf(format string, args ...interface{})
func (l *logger) Panic(args ...interface{})
func (l *logger) Panicf(format string, args ...interface{})
var DefaultLogger = &logger{}

9
manager.go
View File

@ -25,7 +25,6 @@ func NewManager(tun io.ReadWriter) *Manager {
accept: make(chan *DataFrame, 1024),
newConnection: make(chan *Connection),
delConnection: make(chan *Connection),
closed: make(chan bool),
logger: DefaultLogger,
}
}
@ -48,11 +47,9 @@ func (m *Manager) Run() {
m.Connections[connection.ID] = connection
m.logger.Tracef("connection '%s' registered", connection.ID)
case connection := <-m.delConnection:
if !connection.closed {
connection.Close()
delete(m.Connections, connection.ID)
m.logger.Tracef("connection '%s' unregistered", connection.ID)
}
connection.Close()
delete(m.Connections, connection.ID)
m.logger.Tracef("connection '%s' unregistered", connection.ID)
case onReceiveQueue <- true:
go m.onReceive(onReceiveQueue)
}