| | |
|---|
| | | reply := bh.MsgCommonReply{} |
|---|
| | | defer Cleanup() |
|---|
| | | |
|---|
| | | StartWorker(ClientCallback, ServerCallback, SubDataCallback) |
|---|
| | | |
|---|
| | | r := Register(&proc, &reply, 1000) |
|---|
| | | if r { |
|---|
| | | fmt.Println("register ok") |
|---|
| | |
|---|
| | | t.Log("register error") |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | StartWorker(ClientCallback, ServerCallback, SubDataCallback) |
|---|
| | | |
|---|
| | | r = HeartbeatEasy(1000) |
|---|
| | | if r { |
|---|
| | |
|---|
| | | pid := "" |
|---|
| | | rr := bh.MsgRequestTopicReply{} |
|---|
| | | dest := bh.BHAddress{} |
|---|
| | | for i := 0; i < 10000; i++ { |
|---|
| | | for i := 0; i < 100; i++ { |
|---|
| | | if Request(&dest, &req, &pid, &rr, 3000) { |
|---|
| | | fmt.Println("server:" + pid + ", reply:" + string(rr.Data)) |
|---|
| | | } else { |
|---|
