| 557 | } |
| 558 | |
| 559 | bool MgrClient::handle_command_reply( |
| 560 | uint64_t tid, |
| 561 | bufferlist& data, |
| 562 | const std::string& rs, |
| 563 | int r) |
| 564 | { |
| 565 | ceph_assert(ceph_mutex_is_locked_by_me(lock)); |
| 566 | |
| 567 | ldout(cct, 20) << "tid " << tid << " r " << r << dendl; |
| 568 | |
| 569 | if (!command_table.exists(tid)) { |
| 570 | ldout(cct, 4) << "handle_command_reply tid " << tid |
| 571 | << " not found" << dendl; |
| 572 | return true; |
| 573 | } |
| 574 | |
| 575 | auto &op = command_table.get_command(tid); |
| 576 | if (op.outbl) { |
| 577 | *op.outbl = std::move(data); |
| 578 | } |
| 579 | |
| 580 | if (op.outs) { |
| 581 | *(op.outs) = rs; |
| 582 | } |
| 583 | |
| 584 | if (op.on_finish) { |
| 585 | op.on_finish->complete(r); |
| 586 | } |
| 587 | |
| 588 | command_table.erase(tid); |
| 589 | return true; |
| 590 | } |
| 591 | |
| 592 | int MgrClient::update_daemon_metadata( |
| 593 | const std::string& service, |
nothing calls this directly
no test coverage detected