| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.hadoop.yarn.server.resourcemanager.api.impl.pb.service; |
| |
| import org.apache.hadoop.yarn.exceptions.YarnRemoteException; |
| import org.apache.hadoop.yarn.proto.RMAdminProtocol.RMAdminProtocolService.BlockingInterface; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.*; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.RMAdminProtocol; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.RefreshAdminAclsResponse; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.RefreshNodesResponse; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.RefreshQueuesResponse; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.RefreshUserToGroupsMappingsResponse; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshAdminAclsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshAdminAclsResponsePBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshNodesRequestPBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshNodesResponsePBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshQueuesRequestPBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshQueuesResponsePBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshSuperUserGroupsConfigurationRequestPBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshSuperUserGroupsConfigurationResponsePBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshUserToGroupsMappingsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.resourcemanager.api.protocolrecords.impl.pb.RefreshUserToGroupsMappingsResponsePBImpl; |
| |
| import com.google.protobuf.RpcController; |
| import com.google.protobuf.ServiceException; |
| |
| public class RMAdminProtocolPBServiceImpl implements BlockingInterface { |
| |
| private RMAdminProtocol real; |
| |
| public RMAdminProtocolPBServiceImpl(RMAdminProtocol impl) { |
| this.real = impl; |
| } |
| |
| @Override |
| public RefreshQueuesResponseProto refreshQueues(RpcController controller, |
| RefreshQueuesRequestProto proto) throws ServiceException { |
| RefreshQueuesRequestPBImpl request = new RefreshQueuesRequestPBImpl(proto); |
| try { |
| RefreshQueuesResponse response = real.refreshQueues(request); |
| return ((RefreshQueuesResponsePBImpl)response).getProto(); |
| } catch (YarnRemoteException e) { |
| throw new ServiceException(e); |
| } |
| } |
| |
| @Override |
| public RefreshAdminAclsResponseProto refreshAdminAcls( |
| RpcController controller, RefreshAdminAclsRequestProto proto) |
| throws ServiceException { |
| RefreshAdminAclsRequestPBImpl request = |
| new RefreshAdminAclsRequestPBImpl(proto); |
| try { |
| RefreshAdminAclsResponse response = real.refreshAdminAcls(request); |
| return ((RefreshAdminAclsResponsePBImpl)response).getProto(); |
| } catch (YarnRemoteException e) { |
| throw new ServiceException(e); |
| } |
| } |
| |
| @Override |
| public RefreshNodesResponseProto refreshNodes(RpcController controller, |
| RefreshNodesRequestProto proto) throws ServiceException { |
| RefreshNodesRequestPBImpl request = new RefreshNodesRequestPBImpl(proto); |
| try { |
| RefreshNodesResponse response = real.refreshNodes(request); |
| return ((RefreshNodesResponsePBImpl)response).getProto(); |
| } catch (YarnRemoteException e) { |
| throw new ServiceException(e); |
| } |
| } |
| |
| @Override |
| public RefreshSuperUserGroupsConfigurationResponseProto |
| refreshSuperUserGroupsConfiguration( |
| RpcController controller, |
| RefreshSuperUserGroupsConfigurationRequestProto proto) |
| throws ServiceException { |
| RefreshSuperUserGroupsConfigurationRequestPBImpl request = |
| new RefreshSuperUserGroupsConfigurationRequestPBImpl(proto); |
| try { |
| RefreshSuperUserGroupsConfigurationResponse response = |
| real.refreshSuperUserGroupsConfiguration(request); |
| return ((RefreshSuperUserGroupsConfigurationResponsePBImpl)response).getProto(); |
| } catch (YarnRemoteException e) { |
| throw new ServiceException(e); |
| } |
| } |
| |
| @Override |
| public RefreshUserToGroupsMappingsResponseProto refreshUserToGroupsMappings( |
| RpcController controller, RefreshUserToGroupsMappingsRequestProto proto) |
| throws ServiceException { |
| RefreshUserToGroupsMappingsRequestPBImpl request = |
| new RefreshUserToGroupsMappingsRequestPBImpl(proto); |
| try { |
| RefreshUserToGroupsMappingsResponse response = |
| real.refreshUserToGroupsMappings(request); |
| return ((RefreshUserToGroupsMappingsResponsePBImpl)response).getProto(); |
| } catch (YarnRemoteException e) { |
| throw new ServiceException(e); |
| } |
| } |
| |
| } |