| 539 | } |
| 540 | |
| 541 | void *zmq::msg_t::command_body () |
| 542 | { |
| 543 | unsigned char *data = NULL; |
| 544 | |
| 545 | if (this->is_ping () || this->is_pong ()) |
| 546 | data = |
| 547 | static_cast<unsigned char *> (this->data ()) + ping_cmd_name_size; |
| 548 | // With inproc, command flag is not set for sub/cancel |
| 549 | else if (!(this->flags () & msg_t::command) |
| 550 | && (this->is_subscribe () || this->is_cancel ())) |
| 551 | data = static_cast<unsigned char *> (this->data ()); |
| 552 | else if (this->is_subscribe ()) |
| 553 | data = static_cast<unsigned char *> (this->data ()) + sub_cmd_name_size; |
| 554 | else if (this->is_cancel ()) |
| 555 | data = |
| 556 | static_cast<unsigned char *> (this->data ()) + cancel_cmd_name_size; |
| 557 | |
| 558 | return data; |
| 559 | } |
| 560 | |
| 561 | void zmq::msg_t::add_refs (int refs_) |
| 562 | { |
no test coverage detected