bug fixed memvirt leak

zhangmeng

2019-10-30 467d125ef6ac819cc1e8bd1a8b5dcd00d491f624

 camera/camera.go

@@ -1,12 +1,13 @@
package camera

import (
   "basic.com/valib/deliver.git"
   "basic.com/valib/logger.git"
   "basic.com/pubsub/protomsg.git"
   "github.com/gogo/protobuf/proto"
   "taskpubsub/sdk"
   "taskpubsub/util"

   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/deliver.git"
   "basic.com/valib/logger.git"
   "github.com/gogo/protobuf/proto"
)

const (
@@ -23,9 +24,9 @@
}

func initInnerTopic() {
   for _, recvTopic := range innerRecvTopic {
      createCameraRecvServerAndListen(recvTopic)
   }
   // for _, recvTopic := range innerRecvTopic {
   //    createCameraRecvServerAndListen(recvTopic)
   // }
}

func Init(useShm bool) {
@@ -132,6 +133,7 @@

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