()
| 1153 | |
| 1154 | // TODO - shouldn't allow this! |
| 1155 | @Test |
| 1156 | public void handleMetaZnodeNoPort() throws Exception { |
| 1157 | final ZKCallback cb = zk_client.new ZKCallback(); |
| 1158 | |
| 1159 | final ServerName server = ServerName.newBuilder() |
| 1160 | .setHostName("127.0.0.1").build(); |
| 1161 | final MetaRegionServer meta_server = MetaRegionServer.newBuilder() |
| 1162 | .setServer(server).build(); |
| 1163 | final byte[] data = new byte[meta_server.getSerializedSize() + 10]; |
| 1164 | data[0] = ZKCallback.MAGIC; |
| 1165 | Bytes.setInt(data, 1, 1); |
| 1166 | Bytes.setInt(data, HBaseClient.PBUF_MAGIC, 6); |
| 1167 | System.arraycopy(meta_server.toByteArray(), 0, data, 10, |
| 1168 | meta_server.getSerializedSize()); |
| 1169 | |
| 1170 | final RegionClient rc = cb.handleMetaZnode(data); |
| 1171 | assertNotNull(rc); |
| 1172 | assertEquals("127.0.0.1:0", rc.getRemoteAddress()); |
| 1173 | verifyPrivate(client).invoke("newClient", "127.0.0.1", 0); |
| 1174 | } |
| 1175 | |
| 1176 | // Defaults to localhost apparently |
| 1177 | @Test |
nothing calls this directly
no test coverage detected