|
@@ -180,6 +180,11 @@ func (c *Line) writePump() {
|
|
|
// 检查是否需要重新连接
|
|
// 检查是否需要重新连接
|
|
|
if c.autoReconnect && c.host != nil && c.state != Closed && c.state != Connected {
|
|
if c.autoReconnect && c.host != nil && c.state != Closed && c.state != Connected {
|
|
|
go func() {
|
|
go func() {
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ if err := recover(); err != nil {
|
|
|
|
|
+ log.Println(err)
|
|
|
|
|
+ }
|
|
|
|
|
+ }()
|
|
|
c.host.Errors++
|
|
c.host.Errors++
|
|
|
c.host.Updated = time.Now()
|
|
c.host.Updated = time.Now()
|
|
|
|
|
|