Method handleMetaZnodeResolve

test/TestZKClient.java:1063–1088

()

  }
  
  @Test
  public void handleMetaZnodeResolve() throws Exception {
    final InetAddress addr = mock(InetAddress.class);
    when(addr.getHostAddress()).thenReturn("192.168.1.1");
    mockStatic(InetAddress.class);
    PowerMockito.when(InetAddress.getByName("myzkhost")).thenReturn(addr);
    
    final ZKCallback cb = zk_client.new ZKCallback();

    final ServerName server = ServerName.newBuilder()
        .setHostName("myzkhost").setPort(50511).build();
    final MetaRegionServer meta_server = MetaRegionServer.newBuilder()
          .setServer(server).build();
    final byte[] data = new byte[meta_server.getSerializedSize() + 10];
    data[0] = ZKCallback.MAGIC;
    Bytes.setInt(data, 1, 1);
    Bytes.setInt(data, HBaseClient.PBUF_MAGIC, 6);
    System.arraycopy(meta_server.toByteArray(), 0, data, 10, 
        meta_server.getSerializedSize());
    
    final RegionClient rc = cb.handleMetaZnode(data);
    assertNotNull(rc);
    assertEquals("192.168.1.1:50511", rc.getRemoteAddress());
    verifyPrivate(client).invoke("newClient", "192.168.1.1", 50511);
    assertFalse(client.has_root);
  }
  
  @Test
  public void handleMetaZnodeIsRoot() throws Exception {