Method processResultMeta

test/TestZKClient.java:369–388

()

  }
  
  @Test
  public void processResultMeta() throws Exception {
    final ZKCallback cb = zk_client.new ZKCallback();
    final byte[] string = "127.0.0.1,50511,1388534400000".getBytes(CHARSET);
    final byte[] data = new byte[string.length + 6];
    data[0] = ZKCallback.MAGIC;
    Bytes.setInt(data, 1, 1);
    System.arraycopy(string, 0, data, 6, string.length);
    
    cb.processResult(Code.OK.intValue(), "/hbase/root-region-server", null, 
        data, stat);
    verifyPrivate(client).invoke("newClient", "127.0.0.1", 50511);
    verifyPrivate(zk_client, never()).invoke("connectZK");
    verifyPrivate(zk_client).invoke("disconnectZK");
    verifyPrivate(zk_client, never()).invoke("retryGetRootRegionLater");
    assertEquals(Byte.valueOf("1"), 
        (Byte)Whitebox.getInternalState(cb, "found_root"));
    assertEquals(Byte.valueOf("0"), 
        (Byte)Whitebox.getInternalState(cb, "found_meta"));
  }
  
  @Test
  public void processResultMetaBadMeta() throws Exception {