|
|
@@ -66,7 +66,7 @@ func (r *QuotePublish) onDisconnected() {
|
|
|
}
|
|
|
global.M2A_LOG.Error("行情发布服务连接已断开，将会尝试重新连接行情发布服务", zap.Any("host", global.M2A_CONFIG.System.QuotePublishAddr))
|
|
|
|
|
|
- close(r.closeCh)
|
|
|
+ // close(r.closeCh)
|
|
|
r.setStatus(-1)
|
|
|
go func() {
|
|
|
r.connQuotePublish()
|
|
|
@@ -78,7 +78,7 @@ func (r *QuotePublish) onDisconnected() {
|
|
|
func (r *QuotePublish) readQuote() {
|
|
|
for {
|
|
|
// Set a deadline for reading messages
|
|
|
- r.conn.SetReadDeadline(time.Now().Add(15 * time.Second))
|
|
|
+ r.conn.SetReadDeadline(time.Now().Add(40 * time.Second))
|
|
|
|
|
|
select {
|
|
|
case <-r.closeCh:
|
