| 679 | } |
| 680 | |
| 681 | void Master::MakeCallable(const MakeCallableRequest* req, |
| 682 | MakeCallableResponse* resp, MyClosure done) { |
| 683 | Status s = recent_request_ids_.TrackUnique(req->request_id(), |
| 684 | "MakeCallable (Master)", *req); |
| 685 | if (!s.ok()) { |
| 686 | done(s); |
| 687 | return; |
| 688 | } |
| 689 | auto session = FindMasterSession(req->session_handle()); |
| 690 | if (session == nullptr) { |
| 691 | done(errors::Aborted("Session ", req->session_handle(), " is not found.")); |
| 692 | return; |
| 693 | } |
| 694 | |
| 695 | SchedClosure(std::bind( |
| 696 | [session, req, resp](MyClosure done) { |
| 697 | Status s = session->MakeCallable(*req, resp); |
| 698 | session->Unref(); |
| 699 | done(s); |
| 700 | }, |
| 701 | std::move(done))); |
| 702 | } |
| 703 | |
| 704 | void Master::RunCallable(CallOptions* opts, const RunCallableRequest* req, |
| 705 | RunCallableResponse* resp, MyClosure done) { |
nothing calls this directly
no test coverage detected