Commit 8f2ddfa7 authored by alexstocks's avatar alexstocks

session.go:(Session)RunEventLoop -> session.go:(Session)run

parent 41ca4a94
......@@ -11,6 +11,11 @@
## develop history ##
---
- 2016/10/21
> 1 session.go:(Session)RunEventLoop -> session.go:(Session)run
>
> 2 version: 0.4.05
- 2016/10/14
> 1 add conn.go:(gettyWSConn)handlePing
>
......
......@@ -233,7 +233,8 @@ func (this *Client) connect() {
}
err = this.newSession(session)
if err == nil {
session.RunEventLoop()
// session.RunEventLoop()
session.run()
this.Lock()
this.sessionMap[session] = empty{}
this.Unlock()
......
......@@ -122,7 +122,8 @@ func (this *Server) RunEventloop(newSession NewSessionCallback) {
continue
}
delay = 0
client.RunEventLoop()
// client.RunEventLoop()
client.run()
}
}()
}
......@@ -179,7 +180,8 @@ func (this *wsHandler) serveWSRequest(w http.ResponseWriter, r *http.Request) {
if session.maxMsgLen > 0 {
conn.SetReadLimit(int64(session.maxMsgLen))
}
session.RunEventLoop()
// session.RunEventLoop()
session.run()
}
// RunWSEventLoop serve websocket client request
......
......@@ -381,7 +381,8 @@ func (this *Session) WriteBytesArray(pkgs ...[]byte) error {
return this.iConn.write(arr)
}
func (this *Session) RunEventLoop() {
// func (this *Session) RunEventLoop() {
func (this *Session) run() {
if this.rQ == nil || this.wQ == nil {
errStr := fmt.Sprintf("Session{name:%s, rQ:%#v, wQ:%#v}",
this.name, this.rQ, this.wQ)
......
......@@ -10,9 +10,9 @@
package getty
const (
Version = "0.4.04"
DATE = "2016/10/14"
Version = "0.4.05"
DATE = "2016/10/21"
GETTY_MAJOR = 0
GETTY_MINOR = 4
GETTY_BUILD = 4
GETTY_BUILD = 5
)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment