| | |
|---|
| | | const int proc_id_len, |
|---|
| | | const void *data, |
|---|
| | | const int data_len, |
|---|
| | | const void *tag) |
|---|
| | | void *src) |
|---|
| | | { |
|---|
| | | // printf("ServerProc: "); |
|---|
| | | // DEFER1(printf("\n");); |
|---|
| | |
|---|
| | | reply.set_data(" reply: " + request.data()); |
|---|
| | | std::string s(reply.SerializeAsString()); |
|---|
| | | // printf("%s", reply.data().c_str()); |
|---|
| | | BHServerCallbackReply(tag, s.data(), s.size()); |
|---|
| | | BHSendReply(src, s.data(), s.size()); |
|---|
| | | ++Status().nserved_; |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | printf("maxsec: %ld\n", CountSeconds(max_time)); |
|---|
| | | |
|---|
| | | bool reg = false; |
|---|
| | | for (int i = 0; i < 10 && !reg; ++i) { |
|---|
| | | for (int i = 0; i < 3 && !reg; ++i) { |
|---|
| | | ProcInfo proc; |
|---|
| | | proc.set_proc_id("demo_client"); |
|---|
| | | proc.set_public_info("public info of demo_client. etc..."); |
|---|
| | |
|---|
| | | |
|---|
| | | BHFree(reply, reply_len); |
|---|
| | | Sleep(1s); |
|---|
| | | } |
|---|
| | | if (!reg) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | const std::string topic_ = "topic_"; |
|---|
| | |
|---|
| | | for (int i = 0; i < 1; ++i) { |
|---|
| | | MsgPublish pub; |
|---|
| | | pub.set_topic(topic_ + std::to_string(i)); |
|---|
| | | pub.set_data("pub_data_" + std::string(1024 * 1024, 'a')); |
|---|
| | | pub.set_data("pub_data_" + std::string(1024 * 1, 'a')); |
|---|
| | | std::string s(pub.SerializeAsString()); |
|---|
| | | BHPublish(s.data(), s.size(), 0); |
|---|
| | | // Sleep(1s); |
|---|
