Method channelConnected

src/RegionClient.java:1097–1131

(final ChannelHandlerContext ctx,
                               final ChannelStateEvent e)

  // -------------------------------------- //

  @Override
  public void channelConnected(final ChannelHandlerContext ctx,
                               final ChannelStateEvent e) {
    final Channel chan = e.getChannel();
    final ChannelBuffer header;
    
    if (hbase_client.getConfig().getBoolean("hbase.security.auth.enable") && 
        hbase_client.getConfig().hasProperty("hbase.security.auth.94")) {
      secure_rpc_helper = new SecureRpcHelper94(hbase_client, this, 
          chan.getRemoteAddress());
      secure_rpc_helper.sendHello(chan);
      LOG.info("Initialized security helper: " + secure_rpc_helper + 
          " for region client: " + this);
    } else {
      if (!hbase_client.has_root || hbase_client.split_meta) {
        if (hbase_client.getConfig().getBoolean("hbase.security.auth.enable")) {
          secure_rpc_helper = new SecureRpcHelper96(hbase_client, this, 
              chan.getRemoteAddress());
          secure_rpc_helper.sendHello(chan);
          LOG.info("Initialized security helper: " + secure_rpc_helper + 
              " for region client: " + this);
          return;
        }
        header = header095();
        Channels.write(chan, header);
        becomeReady(chan, SERVER_VERSION_095_OR_ABOVE);
        return;
      } else if (System.getProperty("org.hbase.async.cdh3b3") != null) {
        header = headerCDH3b3();
      } else {
        header = header090();
      }
      helloRpc(chan, header);
    }
  }

  /**
   * Sends the queued RPCs to the server, once we're connected to it.