add api Cleanup.

lichao

2021-04-27 5b800932ae33e571edfdc21304c2185e17f69a38

add api Cleanup.

 api/bhsgo/bhome_node.go

@@ -153,6 +153,10 @@

}

func Cleanup() {
    C.BHCleanup()
}

type ServerCB func(src unsafe.Pointer, proc_id *string, req *bh.MsgRequestTopic)
type ClientCB func(proc_id *string, msg_id *[]byte, reply *bh.MsgRequestTopicReply)
type SubDataCB func(proc_id *string, pub *bh.MsgPublish)

 api/bhsgo/bhome_node_test.go

@@ -27,6 +27,7 @@
    proc := bh.ProcInfo{}
    proc.ProcId = []byte(proc_id)
    reply := bh.MsgCommonReply{}
    defer Cleanup()

    StartWorker(ClientCallback, ServerCallback, SubDataCallback)

@@ -35,7 +36,6 @@
        fmt.Println("register ok")
    } else {
        fmt.Println("register failed")
        t.Log("register error")
        return
    }
    r = Unregister(&proc, &reply, 1000)

 src/bh_api.cpp

@@ -320,6 +320,11 @@
    free(data);
}

int BHCleanup()
{
    ProcNode().Stop();
}

int BHGetLastError(void **msg, int *msg_len)
{
    int ec = 0;

 src/bh_api.h

@@ -115,7 +115,7 @@
                const void *reply,
                const int reply_len);

// int BHCleanUp();
int BHCleanup();

void BHFree(void *buf, int size);