|
276 | 276 | import java.util.Map;
|
277 | 277 | import java.util.stream.Collectors;
|
278 | 278 |
|
279 |
| -import static org.apache.hadoop.hdfs.protocolPB.AsyncRpcProtocolPBUtil.LOG; |
280 | 279 | import static org.apache.hadoop.hdfs.protocolPB.AsyncRpcProtocolPBUtil.asyncRouterServer;
|
281 | 280 |
|
282 | 281 | public class RouterClientNamenodeProtocolServerSideTranslatorPB
|
@@ -831,7 +830,6 @@ public MetaSaveResponseProto metaSave(
|
831 | 830 | public GetFileInfoResponseProto getFileInfo(
|
832 | 831 | RpcController controller,
|
833 | 832 | GetFileInfoRequestProto req) {
|
834 |
| - LOG.info("[ZHB]RouterClientNamenodeProtocolServerSideTranslatorPB#getFileInfo"); |
835 | 833 | asyncRouterServer(() -> server.getFileInfo(req.getSrc()),
|
836 | 834 | result -> {
|
837 | 835 | if (result != null) {
|
@@ -1705,14 +1703,12 @@ public MsyncResponseProto msync(RpcController controller, MsyncRequestProto req)
|
1705 | 1703 |
|
1706 | 1704 | @Override
|
1707 | 1705 | public SatisfyStoragePolicyResponseProto satisfyStoragePolicy(
|
1708 |
| - RpcController controller, SatisfyStoragePolicyRequestProto request) |
1709 |
| - throws ServiceException { |
1710 |
| - try { |
| 1706 | + RpcController controller, SatisfyStoragePolicyRequestProto request) { |
| 1707 | + asyncRouterServer(() -> { |
1711 | 1708 | server.satisfyStoragePolicy(request.getSrc());
|
1712 |
| - } catch (IOException e) { |
1713 |
| - throw new ServiceException(e); |
1714 |
| - } |
1715 |
| - return VOID_SATISFYSTORAGEPOLICY_RESPONSE; |
| 1709 | + return null; |
| 1710 | + }, vo -> VOID_SATISFYSTORAGEPOLICY_RESPONSE); |
| 1711 | + return null; |
1716 | 1712 | }
|
1717 | 1713 |
|
1718 | 1714 | @Override
|
|
0 commit comments