| | |
|---|
| | | SharedMemory &shm = TestShm(); |
|---|
| | | MsgI::BindShm(shm); |
|---|
| | | |
|---|
| | | MQId id = boost::uuids::random_generator()(); |
|---|
| | | MQId id = ShmMsgQueue::NewId(); |
|---|
| | | const int timeout = 1000; |
|---|
| | | const uint32_t data_size = 4000; |
|---|
| | | const std::string proc_id = "demo_proc"; |
|---|
| | |
|---|
| | | req_body.set_topic("topic"); |
|---|
| | | req_body.set_data(msg_content); |
|---|
| | | auto req_head(InitMsgHead(GetType(req_body), client_proc_id)); |
|---|
| | | req_head.add_route()->set_mq_id(&cli.id(), cli.id().size()); |
|---|
| | | return cli.Send(&srv.id(), req_head, req_body); |
|---|
| | | req_head.add_route()->set_mq_id(cli.id()); |
|---|
| | | return cli.Send(srv.id(), req_head, req_body); |
|---|
| | | }; |
|---|
| | | |
|---|
| | | Req(); |
|---|
| | |
|---|
| | | DEFER1(req.Release()); |
|---|
| | | |
|---|
| | | if (req.ParseHead(req_head) && req_head.type() == kMsgTypeRequestTopic) { |
|---|
| | | auto &mqid = req_head.route()[0].mq_id(); |
|---|
| | | MQId src_id; |
|---|
| | | memcpy(&src_id, mqid.data(), sizeof(src_id)); |
|---|
| | | auto src_id = req_head.route()[0].mq_id(); |
|---|
| | | auto Reply = [&]() { |
|---|
| | | MsgRequestTopic reply_body; |
|---|
| | | reply_body.set_topic("topic"); |
|---|
| | | reply_body.set_data(msg_content); |
|---|
| | | auto reply_head(InitMsgHead(GetType(reply_body), server_proc_id, req_head.msg_id())); |
|---|
| | | return srv.Send(&src_id, reply_head, reply_body); |
|---|
| | | return srv.Send(src_id, reply_head, reply_body); |
|---|
| | | }; |
|---|
| | | Reply(); |
|---|
| | | } |
|---|
