simplify setup of the server

This commit is contained in:
Marten Seemann
2019-07-07 08:37:36 +07:00
parent 6eb72f712d
commit 3724f91f33

View File

@@ -154,25 +154,21 @@ func listen(conn net.PacketConn, tlsConf *tls.Config, config *Config) (*server,
if err != nil { if err != nil {
return nil, err return nil, err
} }
tokenGenerator, err := handshake.NewTokenGenerator()
if err != nil {
return nil, err
}
s := &server{ s := &server{
conn: conn, conn: conn,
tlsConf: tlsConf, tlsConf: tlsConf,
config: config, config: config,
tokenGenerator: tokenGenerator,
sessionHandler: sessionHandler, sessionHandler: sessionHandler,
sessionQueue: make(chan Session), sessionQueue: make(chan Session),
errorChan: make(chan struct{}), errorChan: make(chan struct{}),
newSession: newSession, newSession: newSession,
logger: utils.DefaultLogger.WithPrefix("server"), logger: utils.DefaultLogger.WithPrefix("server"),
} }
if err := s.setup(); err != nil {
return nil, err
}
sessionHandler.SetServer(s)
s.logger.Debugf("Listening for %s connections on %s", conn.LocalAddr().Network(), conn.LocalAddr().String())
return s, nil
}
func (s *server) setup() error {
s.sessionRunner = &runner{ s.sessionRunner = &runner{
packetHandlerManager: s.sessionHandler, packetHandlerManager: s.sessionHandler,
onHandshakeCompleteImpl: func(sess Session) { onHandshakeCompleteImpl: func(sess Session) {
@@ -188,12 +184,9 @@ func (s *server) setup() error {
}() }()
}, },
} }
tokenGenerator, err := handshake.NewTokenGenerator() sessionHandler.SetServer(s)
if err != nil { s.logger.Debugf("Listening for %s connections on %s", conn.LocalAddr().Network(), conn.LocalAddr().String())
return err return s, nil
}
s.tokenGenerator = tokenGenerator
return nil
} }
var defaultAcceptToken = func(clientAddr net.Addr, token *Token) bool { var defaultAcceptToken = func(clientAddr net.Addr, token *Token) bool {