dial fix

panlei

2019-09-10 6be5f42ff0e8c9671dd0e99eb2988e8c7c305d91

 ruleserver/readyDataForRule.go

@@ -55,6 +55,10 @@
   if err != nil {
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
}

type BaseInfo struct {
@@ -175,12 +179,14 @@
      CompareThreshold:compareThreshold,
      Source:false,
   }
   serverIp, _ := GetLocalIP()
   bytes := Push("tcp://"+serverIp+":4010",comArg,sock)

   bytes := Push(comArg,sock)
   //bytes := []byte{}
   var scResult protomsg.SdkCompareResult
   err1 := proto.Unmarshal(bytes, &scResult)
   if err1 != nil {
      logger.Error("getBaseInfo解压错误", err1)
      return
   }
   //logger.Info("----------------------------------------map是", m)
   ids := []string{}
@@ -332,7 +338,7 @@
   }
}

func Push(url string,data *protomsg.CompareArgs,sock mangos.Socket) []byte{
func Push(data *protomsg.CompareArgs,sock mangos.Socket) []byte{
   //var sock mangos.Socket
   var err error
   var msg []byte
@@ -347,9 +353,7 @@
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
   if err = sock.Dial(url); err != nil {
      logger.Error("请求socket拨号失败: %s", err.Error())
   }

   logger.Info("序列化数据")
   bytes,err1 := proto.Marshal(data)
   logger.Info("数据长度为：",len(bytes))