liuxiaolong
2019-05-31 bde1bf71186ff1b0d7b1cbc01eeade7741d4a0c0
recv heartbeat and publish init
1个文件已修改
1 ■■■■ 已修改文件
server.go 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
server.go
@@ -149,6 +149,7 @@
    responses = NewStringSet()
    for {
        msg, err = d.sock.Recv()
        d.PublishMsg("Init")
        if err != nil {
            if err == mangos.ErrRecvTimeout {
                // Timeout means I can add the current responses to the SET