Method handleResponse

src/SecureRpcHelper96.java:103–171

(final ChannelBuffer buf, 
      final Channel chan)

  }

  @Override
  public ChannelBuffer handleResponse(final ChannelBuffer buf, 
      final Channel chan) {
    if (sasl_client == null) {
      return buf;
    }

    if (!sasl_client.isComplete()) {
      final int state = buf.readInt();

      //0 is success, 1 is an exception
      //If unsuccessful let common exception handling do the work
      if (state != 0) {
        // We expect HBase to return a simple formated exception in the format:
        // int length | exception class | int length | exception message
        if (buf.readableBytes() < 8) {
          throw new SecurityException("Sasl initialization failed with a "
              + "status of [" + state + "] and an unknown exception. "
              + "Check HBase logs.: " + this);
        }
        int len = buf.readInt();
        byte[] temp = new byte[len];
        buf.readBytes(temp);
        final String exception = new String(temp);
        
        len = buf.readInt();
        temp = new byte[len];
        buf.readBytes(temp);
        final String msg = new String(temp);

        throw new SecurityException("Sasl initialization failed with a "
            + "status of [" + state + "] and exception [" + exception 
            + "] and message [" + msg + "]: " + this);
      } 

      final int len = buf.readInt();
      final byte[] b = new byte[len];
      buf.readBytes(b);
      //if (LOG.isDebugEnabled()) {
      //  LOG.debug("Got SASL challenge: "+Bytes.pretty(b));
      //}

      final byte[] challenge_bytes = processChallenge(b);

      if (challenge_bytes != null) {
        final byte[] out_bytes = new byte[4 + challenge_bytes.length];
        //if (LOG.isDebugEnabled()) {
        //  LOG.debug("Sending SASL response: "+Bytes.pretty(out_bytes));
        //}
        final ChannelBuffer out_buffer = ChannelBuffers.wrappedBuffer(out_bytes);
        out_buffer.clear();
        out_buffer.writeInt(challenge_bytes.length);
        out_buffer.writeBytes(challenge_bytes);
        Channels.write(chan, out_buffer);
      }

      if (sasl_client.isComplete()) {
        final String qop = (String)sasl_client.getNegotiatedProperty(Sasl.QOP);