| 74 | } |
| 75 | |
| 76 | phxqueue::comm::RetCode |
| 77 | Consumer::GetAddrScale(const phxqueue::comm::proto::GetAddrScaleRequest &req, |
| 78 | phxqueue::comm::proto::GetAddrScaleResponse &resp) { |
| 79 | static __thread SchedulerClient scheduler_client; |
| 80 | auto ret = scheduler_client.ProtoGetAddrScale(req, resp); |
| 81 | if (phxqueue::comm::RetCode::RET_OK != ret) { |
| 82 | QLErr("ProtoGetAddrScale ret %d", phxqueue::comm::as_integer(ret)); |
| 83 | } |
| 84 | return ret; |
| 85 | } |
| 86 | |
| 87 | phxqueue::comm::RetCode |
| 88 | Consumer::GetLockInfo(const phxqueue::comm::proto::GetLockInfoRequest &req, |
nothing calls this directly
no test coverage detected