From 04fd16bc831ce3a247d92ad3529d20abd5ac4f46 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 01 十一月 2019 16:37:50 +0800 Subject: [PATCH] --- --- labelFilter/req.go | 24 ++++++++++++------------ 1 files changed, 12 insertions(+), 12 deletions(-) diff --git a/labelFilter/req.go b/labelFilter/req.go index 250876b..dab3aaf 100644 --- a/labelFilter/req.go +++ b/labelFilter/req.go @@ -79,7 +79,7 @@ func GoPush(url string) { var err error - var msg []byte + //var msg []byte var sock mangos.Socket if sock, err = req.NewSocket(); err != nil { Die("鍒涘缓璇锋眰socket澶辫触: %s", err.Error()) @@ -121,17 +121,17 @@ if err1 != nil { logger.Info("搴忓垪鍖栧け璐ワ細",err1) } - logger.Debug("groutine"+url+"鎺ㄩ�佹暟鎹�") - //bytes := []byte("ndfasojdfaidsos") - if err = sock.Send(bytes); err != nil { - Die("groutine"+url+"鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: ", err.Error()) - } - msg, err = sock.Recv(); - if err != nil { - Die("groutine"+url+"鎺ユ敹鍝嶅簲澶辫触: ", err.Error()) - } else { - logger.Debug("浜嬩欢鎺ㄩ�佹垚鍔燂紒groutine"+url+"鏀跺埌鍝嶅簲",string(msg)) - } + //logger.Debug("groutine"+url+"鎺ㄩ�佹暟鎹�") + ////bytes := []byte("ndfasojdfaidsos") + //if err = sock.Send(bytes); err != nil { + // Die("groutine"+url+"鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: ", err.Error()) + //} + //msg, err = sock.Recv(); + //if err != nil { + // Die("groutine"+url+"鎺ユ敹鍝嶅簲澶辫触: ", err.Error()) + //} else { + // logger.Debug("浜嬩欢鎺ㄩ�佹垚鍔燂紒groutine"+url+"鏀跺埌鍝嶅簲",string(msg)) + //} default: -- Gitblit v1.8.0