Java 类org.apache.hadoop.security.SaslInputStream 实例源码

项目：hadoop 文件：SaslParticipant.java

/**
 * Return some input/output streams that may henceforth have their
 * communication encrypted, depending on the negotiated quality of protection.
 *
 * @param out output stream to wrap
 * @param in input stream to wrap
 * @return IOStreamPair wrapping the streams
 */
public IOStreamPair createStreamPair(DataOutputStream out,
    DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：aliyun-oss-hadoop-fs 文件：SaslParticipant.java

/**
 * Return some input/output streams that may henceforth have their
 * communication encrypted, depending on the negotiated quality of protection.
 *
 * @param out output stream to wrap
 * @param in input stream to wrap
 * @return IOStreamPair wrapping the streams
 */
public IOStreamPair createStreamPair(DataOutputStream out,
    DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：big-c 文件：SaslParticipant.java

/**
 * Return some input/output streams that may henceforth have their
 * communication encrypted, depending on the negotiated quality of protection.
 *
 * @param out output stream to wrap
 * @param in input stream to wrap
 * @return IOStreamPair wrapping the streams
 */
public IOStreamPair createStreamPair(DataOutputStream out,
    DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：SaslParticipant.java

/**
 * Return some input/output streams that may henceforth have their
 * communication encrypted, depending on the negotiated quality of protection.
 *
 * @param out output stream to wrap
 * @param in input stream to wrap
 * @return IOStreamPair wrapping the streams
 */
public IOStreamPair createStreamPair(DataOutputStream out,
    DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：hadoop-plus 文件：DataTransferEncryptor.java

private IOStreamPair createEncryptedStreamPair(
    DataOutputStream out, DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：FlexMap 文件：SaslParticipant.java

/**
 * Return some input/output streams that may henceforth have their
 * communication encrypted, depending on the negotiated quality of protection.
 *
 * @param out output stream to wrap
 * @param in input stream to wrap
 * @return IOStreamPair wrapping the streams
 */
public IOStreamPair createStreamPair(DataOutputStream out,
    DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：hops 文件：DataTransferEncryptor.java

private IOStreamPair createEncryptedStreamPair(DataOutputStream out,
    DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：hadoop-TCP 文件：DataTransferEncryptor.java

private IOStreamPair createEncryptedStreamPair(
    DataOutputStream out, DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：hardfs 文件：DataTransferEncryptor.java

private IOStreamPair createEncryptedStreamPair(
    DataOutputStream out, DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：hadoop-on-lustre2 文件：DataTransferEncryptor.java

private IOStreamPair createEncryptedStreamPair(
    DataOutputStream out, DataInputStream in) {
  if (saslClient != null) {
    return new IOStreamPair(
        new SaslInputStream(in, saslClient),
        new SaslOutputStream(out, saslClient));
  } else {
    return new IOStreamPair(
        new SaslInputStream(in, saslServer),
        new SaslOutputStream(out, saslServer));
  }
}

项目：ditb 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 *
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：pbase 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 *
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：HIndex 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：IRIndex 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：PyroDB 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：c5 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：HBase-Research 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：hbase-0.94.8-qod 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：hbase-0.94.8-qod 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：DominoHBase 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}

项目：hindex 文件：HBaseSaslRpcClient.java

/**
 * Get a SASL wrapped InputStream. Can be called only after saslConnect() has
 * been called.
 * 
 * @param in
 *          the InputStream to wrap
 * @return a SASL wrapped InputStream
 * @throws IOException
 */
public InputStream getInputStream(InputStream in) throws IOException {
  if (!saslClient.isComplete()) {
    throw new IOException("Sasl authentication exchange hasn't completed yet");
  }
  return new SaslInputStream(in, saslClient);
}