Skip to content

Commit 179d988

Browse files
committed
fix redis.Dial panic bug, and no auto Close after call Subscriber
1 parent 6d1f4b3 commit 179d988

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

push.go

+5-5
Original file line numberDiff line numberDiff line change
@@ -84,11 +84,11 @@ func Subscribe(ws *websocket.Conn) {
8484

8585
defer recoverFunc()
8686
// cleanup on server side
87-
defer func() {
88-
if err := ws.Close(); err != nil {
89-
Log.Printf("wc.Close() failed (%s)", err.Error())
90-
}
91-
}()
87+
//defer func() {
88+
// if err := ws.Close(); err != nil {
89+
// Log.Printf("wc.Close() failed (%s)", err.Error())
90+
// }
91+
//}()
9292
// set read deadline
9393
err := ws.SetReadDeadline(time.Now().Add(time.Duration(Conf.LongpollingTimeout) * time.Second))
9494
if err != nil {

redis.go

-1
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ func InitRedis() {
2727
c, err := redis.Dial(Conf.RedisNetwork, Conf.RedisAddr)
2828
if err != nil {
2929
Log.Printf("redis.Dial(\"%s\", \"%s\") failed (%s)", Conf.RedisNetwork, Conf.RedisAddr, err.Error())
30-
panic(err)
3130
}
3231
return c, err
3332
},

0 commit comments

Comments
 (0)