| 1539 | } |
| 1540 | |
| 1541 | void AgentClient::clear_tasker_sink() |
| 1542 | { |
| 1543 | LogTrace; |
| 1544 | |
| 1545 | if (reg_tasker_sink_id_ != MaaInvalidId) { |
| 1546 | if (reg_tasker_) { |
| 1547 | reg_tasker_->remove_sink(reg_tasker_sink_id_); |
| 1548 | } |
| 1549 | reg_tasker_sink_id_ = MaaInvalidId; |
| 1550 | } |
| 1551 | |
| 1552 | if (reg_tasker_ && reg_context_sink_id_ != MaaInvalidId) { |
| 1553 | if (reg_tasker_) { |
| 1554 | reg_tasker_->remove_context_sink(reg_context_sink_id_); |
| 1555 | } |
| 1556 | reg_context_sink_id_ = MaaInvalidId; |
| 1557 | } |
| 1558 | |
| 1559 | if (reg_tasker_) { |
| 1560 | reg_tasker_ = nullptr; |
| 1561 | } |
| 1562 | } |
| 1563 | |
| 1564 | bool AgentClient::handle_resource_status(const json::value& j) |
| 1565 | { |
nothing calls this directly
no test coverage detected