pb.go MsgQueryProcReply add subLocalTopics and subNetTopics

liuxiaolong

2022-01-05 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6

 api/bhsgo/bhome_node.go

@@ -4,7 +4,7 @@
#include "../../src/bh_api.h"

*/
// #cgo LDFLAGS: -L/usr/local/lib -lbhome_shmq -lstdc++ -lpthread -lrt
// #cgo LDFLAGS: -L/usr/local/lib -lshm_queue -lstdc++ -lpthread -lrt
import "C"

import (
@@ -149,8 +149,11 @@
   r := C.BHReadSub(&cpid, &cpid_len, &creply, &creply_len, C.int(timeout_ms)) > 0
   defer C.BHFree(cpid, cpid_len)
   defer C.BHFree(creply, creply_len)
   *proc_id = string(C.GoBytes(cpid, cpid_len))
   pub.Unmarshal(C.GoBytes(creply, creply_len))
   if r {
      *proc_id = string(C.GoBytes(cpid, cpid_len))
      pub.Unmarshal(C.GoBytes(creply, creply_len))
   }

   return r
}

@@ -197,7 +200,7 @@
   r := C.BHReadRequest(&cpid, &cpid_len, &creply, &creply_len, psrc, C.int(timeout_ms)) > 0
   defer C.BHFree(cpid, cpid_len)
   defer C.BHFree(creply, creply_len)
   if r {
   if r {	
      *proc_id = string(C.GoBytes(cpid, cpid_len))
      req.Unmarshal(C.GoBytes(creply, creply_len))
   }
@@ -206,6 +209,7 @@

func SendReply(src unsafe.Pointer, rep *bh.MsgRequestTopicReply) bool {
   data, _ := rep.Marshal()
   defer C.BHFree(src, 0)
   return C.BHSendReply(src, getPtr(&data), C.int(len(data))) > 0
}