()
| 1038 | |
| 1039 | |
| 1040 | @Test |
| 1041 | public void handleMetaZnodeSplitMeta() throws Exception { |
| 1042 | client.split_meta = true; |
| 1043 | final ZKCallback cb = zk_client.new ZKCallback(); |
| 1044 | |
| 1045 | final ServerName server = ServerName.newBuilder() |
| 1046 | .setHostName("127.0.0.1").setPort(50511).build(); |
| 1047 | final MetaRegionServer meta_server = MetaRegionServer.newBuilder() |
| 1048 | .setServer(server).build(); |
| 1049 | final byte[] data = new byte[meta_server.getSerializedSize() + 10]; |
| 1050 | data[0] = ZKCallback.MAGIC; |
| 1051 | Bytes.setInt(data, 1, 1); |
| 1052 | Bytes.setInt(data, HBaseClient.PBUF_MAGIC, 6); |
| 1053 | System.arraycopy(meta_server.toByteArray(), 0, data, 10, |
| 1054 | meta_server.getSerializedSize()); |
| 1055 | |
| 1056 | final RegionClient rc = cb.handleMetaZnode(data); |
| 1057 | assertNotNull(rc); |
| 1058 | assertEquals("127.0.0.1:50511", rc.getRemoteAddress()); |
| 1059 | verifyPrivate(client).invoke("newClient", "127.0.0.1", 50511); |
| 1060 | assertTrue(client.has_root); |
| 1061 | } |
| 1062 | |
| 1063 | @Test |
| 1064 | public void handleMetaZnodeResolve() throws Exception { |
nothing calls this directly
no test coverage detected