()
| 1015 | } |
| 1016 | |
| 1017 | @Test |
| 1018 | public void handleMetaZnode() throws Exception { |
| 1019 | final ZKCallback cb = zk_client.new ZKCallback(); |
| 1020 | |
| 1021 | final ServerName server = ServerName.newBuilder() |
| 1022 | .setHostName("127.0.0.1").setPort(50511).build(); |
| 1023 | final MetaRegionServer meta_server = MetaRegionServer.newBuilder() |
| 1024 | .setServer(server).build(); |
| 1025 | final byte[] data = new byte[meta_server.getSerializedSize() + 10]; |
| 1026 | data[0] = ZKCallback.MAGIC; |
| 1027 | Bytes.setInt(data, 1, 1); |
| 1028 | Bytes.setInt(data, HBaseClient.PBUF_MAGIC, 6); |
| 1029 | System.arraycopy(meta_server.toByteArray(), 0, data, 10, |
| 1030 | meta_server.getSerializedSize()); |
| 1031 | |
| 1032 | final RegionClient rc = cb.handleMetaZnode(data); |
| 1033 | assertNotNull(rc); |
| 1034 | assertEquals("127.0.0.1:50511", rc.getRemoteAddress()); |
| 1035 | verifyPrivate(client).invoke("newClient", "127.0.0.1", 50511); |
| 1036 | assertFalse(client.has_root); |
| 1037 | } |
| 1038 | |
| 1039 | |
| 1040 | @Test |
nothing calls this directly
no test coverage detected