commons_go/websocket_fasthttp
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2017-11-27 20:48:10 +09:00
parent 4eaa31788d
commit 83feb109dc
3 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server.go
View File

@ -19,11 +19,11 @@ type Server interface {
Context() ServerContext Context() ServerContext
} }
func New(sh ServerHandler) Server { func New(serverCTX ServerContext, sh ServerHandler) Server {
s := &server{ s := &server{
sh: sh, sh: sh,
} }
s.ctx = NewServerContext(nil) s.ctx = serverCTX
return s return s
} }
@ -42,6 +42,9 @@ type server struct {
} }
func (s *server) Start() error { func (s *server) Start() error {
if nil == s.ctx {
logging.Logger().Panic("Server: server context must be specified.")
}
if nil == s.sh { if nil == s.sh {
logging.Logger().Panic("Server: server handler must be specified.") logging.Logger().Panic("Server: server handler must be specified.")
} }

2
socket.go
View File

@ -156,7 +156,7 @@ func newSocket(serverCTX ServerContext, id string, conn *websocket.Conn, sh Sock
if 0 < sh.GetReadTimeout() { if 0 < sh.GetReadTimeout() {
s.SetReadDeadline(time.Now().Add(sh.GetReadTimeout() * time.Second)) s.SetReadDeadline(time.Now().Add(sh.GetReadTimeout() * time.Second))
} }
s.ctx = NewSocketContext(serverCTX) s.ctx = newSocketContext(serverCTX)
return s return s
} }

2
socket_context.go
View File

@ -9,7 +9,7 @@ type SocketContext interface {
ServerContext() ServerContext ServerContext() ServerContext
} }
func NewSocketContext(serverCTX ServerContext) SocketContext { func newSocketContext(serverCTX ServerContext) SocketContext {
sCTX := &socketContext{} sCTX := &socketContext{}
sCTX.Context = cuc.NewContext(serverCTX) sCTX.Context = cuc.NewContext(serverCTX)
sCTX.serverCTX = serverCTX sCTX.serverCTX = serverCTX