| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/yarn/proto/ |
| H A D | HSClientProtocol.java | 33 public static com.google.protobuf.BlockingService newReflectiveBlockingService( in newReflectiveBlockingService() method in HSClientProtocol.HSClientProtocolService
37 .newReflectiveBlockingService((MRClientProtocolService.BlockingInterface) impl); in newReflectiveBlockingService()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/server/ |
| H A D | HSAdminServer.java | 89 .newReflectiveBlockingService(refreshUserMappingXlator); in serviceInit()
94 .newReflectiveBlockingService(getUserMappingXlator); in serviceInit()
99 .newReflectiveBlockingService(refreshHSAdminProtocolXlator); in serviceInit()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/ |
| H A D | TestProtoBufRpc.java | 129 .newReflectiveBlockingService(serverImpl); in setUp()
139 .newReflectiveBlockingService(server2Impl); in setUp()
|
| H A D | TestMultipleProtocolServer.java | 191 .newReflectiveBlockingService(pbServerImpl); in setUp()
|
| H A D | RPCCallBenchmark.java | 237 .newReflectiveBlockingService(serverImpl); in startServer()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | NameNodeRpcServer.java | 236 newReflectiveBlockingService(clientProtocolServerTranslator); in NameNodeRpcServer()
241 .newReflectiveBlockingService(dnProtoPbTranslator); in NameNodeRpcServer()
246 .newReflectiveBlockingService(namenodeProtocolXlator); in NameNodeRpcServer()
251 .newReflectiveBlockingService(refreshAuthPolicyXlator); in NameNodeRpcServer()
256 .newReflectiveBlockingService(refreshUserMappingXlator); in NameNodeRpcServer()
261 .newReflectiveBlockingService(refreshCallQueueXlator); in NameNodeRpcServer()
266 .newReflectiveBlockingService(genericRefreshXlator); in NameNodeRpcServer()
271 .newReflectiveBlockingService(getUserMappingXlator); in NameNodeRpcServer()
276 .newReflectiveBlockingService(haServiceProtocolXlator); in NameNodeRpcServer()
281 .newReflectiveBlockingService(traceAdminXlator); in NameNodeRpcServer()
|
| H A D | BackupNode.java | 230 .newReflectiveBlockingService(journalProtocolTranslator); in BackupNodeRpcServer()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/ |
| H A D | ZKFCRpcServer.java | 57 .newReflectiveBlockingService(translator); in ZKFCRpcServer()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/ |
| H A D | AbstractTestIPC.java | 90 … .newReflectiveBlockingService(new TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface() {
330 .newReflectiveBlockingService(SERVICE1), null)), in TestRpcServer1()
|
| H A D | TestProtoBufRpc.java | 97 TestRpcServiceProtos.TestProtobufRpcProto.newReflectiveBlockingService(serverImpl); in setUp()
|
| H A D | TestRpcHandlerException.java | 75 .newReflectiveBlockingService(new TestRpcServiceProtos
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ha/ |
| H A D | DummyHAService.java | 109 .newReflectiveBlockingService(haServiceProtocolXlator); in startAndGetRPCServerAddress()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/ |
| H A D | JournalNodeRpcServer.java | 72 .newReflectiveBlockingService(translator); in JournalNodeRpcServer()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/protobuf/java/core/src/test/java/com/google/protobuf/ |
| H A D | ServiceTest.java | 201 BlockingService service = ServiceWithNoOuter.newReflectiveBlockingService(impl); in testNewReflectiveBlockingService()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/protobuf/java/compatibility_tests/v2.5.0/tests/src/main/java/com/google/protobuf/test/ |
| H A D | ServiceTest.java | 204 ServiceWithNoOuter.newReflectiveBlockingService(impl); in testNewReflectiveBlockingService()
|
| /dports/devel/protobuf25/protobuf-2.5.0/java/src/test/java/com/google/protobuf/ |
| H A D | ServiceTest.java | 203 ServiceWithNoOuter.newReflectiveBlockingService(impl); in testNewReflectiveBlockingService()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/security/ |
| H A D | TestSecureRPC.java | 79 TestRpcServiceProtos.TestProtobufRpcProto.newReflectiveBlockingService(
|
| /dports/databases/hbase/hbase-1.2.1/hbase-it/src/test/java/org/apache/hadoop/hbase/ipc/ |
| H A D | IntegrationTestRpcClient.java | 105 … .newReflectiveBlockingService(new TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface() {
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/security/token/block/ |
| H A D | TestBlockToken.java | 234 .newReflectiveBlockingService(mockDN); in createMockDatanode()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/security/token/ |
| H A D | TestTokenAuthentication.java | 139 AuthenticationProtos.AuthenticationService.newReflectiveBlockingService(this); in TokenServer()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ |
| H A D | RPC.java | 949 .newReflectiveBlockingService(xlator); in initProtocolMetaInfo()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ |
| H A D | AdminService.java | 192 .newReflectiveBlockingService(haServiceProtocolXlator); in startServer()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/protobuf/generated/ |
| H A D | TestRpcServiceProtos.java | 81 newReflectiveBlockingService(final BlockingInterface impl) { in newReflectiveBlockingService() method
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ |
| H A D | DataNode.java | 792 .newReflectiveBlockingService(clientDatanodeProtocolXlator); in initIpcServer()
806 .newReflectiveBlockingService(interDatanodeProtocolXlator); in initIpcServer()
813 .newReflectiveBlockingService(traceAdminXlator); in initIpcServer()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ |
| H A D | MasterRpcServices.java | 307 MasterService.newReflectiveBlockingService(this), in getServices()
310 RegionServerStatusService.newReflectiveBlockingService(this), in getServices()
|