bug fixed memvirt leak

zhangmeng

2019-10-30 467d125ef6ac819cc1e8bd1a8b5dcd00d491f624

 sdk/sdk.go

@@ -1,9 +1,10 @@
package sdk

import (
   "github.com/gogo/protobuf/proto"
   "taskpubsub/tasktag"
   "taskpubsub/util"

   "github.com/gogo/protobuf/proto"

   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/deliver.git"
@@ -30,13 +31,13 @@
}

func initInnerTopic() {
   for _, sendTopic := range innerSendTopic {
      createSdkSendServerAndListen(sendTopic)
   }
   // for _, sendTopic := range innerSendTopic {
   //    createSdkSendServerAndListen(sendTopic)
   // }

   for _, recvTopic := range innerRecvTopic {
      createSdkRecvServerAndListen(recvTopic)
   }
   // for _, recvTopic := range innerRecvTopic {
   //    createSdkRecvServerAndListen(recvTopic)
   // }
}

func Init(useShm bool) {
@@ -221,6 +222,7 @@
         if msg, err := socket.Sock.Recv(); err != nil {
            if socket.UseSHM {
               if tryCount > util.SHMMaxTryCount {
                  socket.Sock.Close()
                  socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM)
                  logger.Info("SDK RECV SHM TRY :", tryCount, " RESTART IT")

@@ -273,6 +275,7 @@

               if socket.UseSHM {
                  if tryCount > util.SHMMaxTryCount {
                     socket.Sock.Close()
                     socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM)
                     logger.Info("SDK SEND SHM TRY :", util.SHMMaxTryCount, " RESTART IT")