Searched refs:zkCrd (Results 1 – 5 of 5) sorted by relevance
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ |
| H A D | ZkCloseRegionCoordination.java | 57 ZkCloseRegionDetails zkCrd = (ZkCloseRegionDetails) crd; in checkClosingState() local
74 ZkCloseRegionDetails zkCrd = (ZkCloseRegionDetails) crd; in setClosedState() local
77 if (zkCrd.isPublishStatusInZk()) { in setClosedState()
78 if (setClosedState(region,sn, zkCrd)) { in setClosedState()
91 ZkCloseRegionCoordination.ZkCloseRegionDetails zkCrd = in parseFromProtoRequest() local
98 zkCrd.setExpectedVersion(versionOfClosingNode); in parseFromProtoRequest()
100 return zkCrd; in parseFromProtoRequest()
111 ZkCloseRegionCoordination.ZkCloseRegionDetails zkCrd = in getDetaultDetails() local
113 zkCrd.setPublishStatusInZk(false); in getDetaultDetails()
114 zkCrd.setExpectedVersion(FAILED_VERSION); in getDetaultDetails()
[all …]
|
| H A D | ZkOpenRegionCoordination.java | 258 ZkOpenRegionCoordination.ZkOpenRegionDetails zkCrd = in parseFromProtoRequest() local
265 zkCrd.setVersionOfOfflineNode(versionOfOfflineNode); in parseFromProtoRequest()
266 zkCrd.setServerName(coordination.getServer().getServerName()); in parseFromProtoRequest()
268 return zkCrd; in parseFromProtoRequest()
279 ZkOpenRegionCoordination.ZkOpenRegionDetails zkCrd = in getDetailsForNonCoordinatedOpening() local
281 zkCrd.setVersionOfOfflineNode(-1); in getDetailsForNonCoordinatedOpening()
282 zkCrd.setServerName(coordination.getServer().getServerName()); in getDetailsForNonCoordinatedOpening()
284 return zkCrd; in getDetailsForNonCoordinatedOpening()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/handler/ |
| H A D | TestOpenRegionHandler.java | 109 zkCrd.setServerName(server.getServerName()); in testYankingRegionFromUnderIt()
173 zkCrd.setServerName(server.getServerName()); in testRegionServerAbortionDueToFailureTransitioningToOpened()
194 -1, openRegionCoordination, zkCrd); in testRegionServerAbortionDueToFailureTransitioningToOpened()
230 zkCrd.setServerName(server.getServerName()); in testFailedOpenRegion()
235 csm.getOpenRegionCoordination(), zkCrd) { in testFailedOpenRegion()
267 zkCrd.setServerName(server.getServerName()); in testFailedUpdateMeta()
270 -1, csm.getOpenRegionCoordination(), zkCrd) { in testFailedUpdateMeta()
300 zkCrd.setServerName(server.getServerName()); in testTransitionToFailedOpenEvenIfCleanupFails()
303 -1, csm.getOpenRegionCoordination(), zkCrd) { in testTransitionToFailedOpenEvenIfCleanupFails()
338 zkCrd.setServerName(server.getServerName()); in testTransitionToFailedOpenFromOffline()
[all …]
|
| H A D | TestCloseRegionHandler.java | 122 ZkCloseRegionCoordination.ZkCloseRegionDetails zkCrd = in testFailedFlushAborts() local
124 zkCrd.setPublishStatusInZk(false); in testFailedFlushAborts()
125 zkCrd.setExpectedVersion(-1); in testFailedFlushAborts()
128 consensusProvider.getCloseRegionCoordination(), zkCrd); in testFailedFlushAborts()
175 ZkCloseRegionCoordination.ZkCloseRegionDetails zkCrd = in testZKClosingNodeVersionMismatch() local
177 zkCrd.setPublishStatusInZk(true); in testZKClosingNodeVersionMismatch()
178 zkCrd.setExpectedVersion(versionOfClosingNode+1); in testZKClosingNodeVersionMismatch()
181 coordinationProvider.getCloseRegionCoordination(), zkCrd); in testZKClosingNodeVersionMismatch()
221 ZkCloseRegionCoordination.ZkCloseRegionDetails zkCrd = in testCloseRegion() local
223 zkCrd.setPublishStatusInZk(true); in testCloseRegion()
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | TestRegionServerNoMaster.java | 379 ZkOpenRegionCoordination.ZkOpenRegionDetails zkCrd = in testCancelOpeningWithoutZK() local
381 zkCrd.setServerName(getRS().getServerName()); in testCancelOpeningWithoutZK()
382 zkCrd.setVersionOfOfflineNode(0); in testCancelOpeningWithoutZK()
385 -1, csm.getOpenRegionCoordination(), zkCrd)); in testCancelOpeningWithoutZK()
444 ZkOpenRegionCoordination.ZkOpenRegionDetails zkCrd = in testCancelOpeningWithZK() local
446 zkCrd.setServerName(getRS().getServerName()); in testCancelOpeningWithZK()
447 zkCrd.setVersionOfOfflineNode(0); in testCancelOpeningWithZK()
450 -1, csm.getOpenRegionCoordination(), zkCrd)); in testCancelOpeningWithZK()
|