本文整理了Java中org.apache.hadoop.ipc.Server.setupResponse()方法的一些代码示例，展示了Server.setupResponse()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Server.setupResponse()方法的具体详情如下：
包路径：org.apache.hadoop.ipc.Server
类名称：Server
方法名：setupResponse

Server.setupResponse介绍

[英]Setup response for the IPC Call.
[中]设置IPC呼叫的响应。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

RpcResponseHeaderProto header = headerBuilder.build();
try {
 setupResponse(call, header, rv);
} catch (Throwable t) {
 LOG.warn("Error serializing call response for call " + call, t);
 setupResponse(call, RpcStatusProto.ERROR,
   RpcErrorCodeProto.ERROR_SERIALIZING_RESPONSE,
   null, t.getClass().getName(),
headerBuilder.setErrorMsg(error);
headerBuilder.setErrorDetail(erCode);
setupResponse(call, headerBuilder.build(), null);

代码示例来源：origin: org.apache.hadoop/hadoop-common

private void wrapWithSasl(RpcCall call) throws IOException {
 if (call.connection.saslServer != null) {
  byte[] token = call.rpcResponse.array();
  // synchronization may be needed since there can be multiple Handler
  // threads using saslServer to wrap responses.
  synchronized (call.connection.saslServer) {
   token = call.connection.saslServer.wrap(token, 0, token.length);
  }
  if (LOG.isDebugEnabled())
   LOG.debug("Adding saslServer wrapped token of size " + token.length
     + " as call response.");
  // rebuild with sasl header and payload
  RpcResponseHeaderProto saslHeader = RpcResponseHeaderProto.newBuilder()
    .setCallId(AuthProtocol.SASL.callId)
    .setStatus(RpcStatusProto.SUCCESS)
    .build();
  RpcSaslProto saslMessage = RpcSaslProto.newBuilder()
    .setState(SaslState.WRAP)
    .setToken(ByteString.copyFrom(token))
    .build();
  setupResponse(call, saslHeader, RpcWritable.wrap(saslMessage));
 }
}

代码示例来源：origin: io.hops/hadoop-common

private void wrapWithSasl(RpcCall call) throws IOException {
 if (call.connection.saslServer != null) {
  byte[] token = call.rpcResponse.array();
  // synchronization may be needed since there can be multiple Handler
  // threads using saslServer to wrap responses.
  synchronized (call.connection.saslServer) {
   token = call.connection.saslServer.wrap(token, 0, token.length);
  }
  if (LOG.isDebugEnabled())
   LOG.debug("Adding saslServer wrapped token of size " + token.length
     + " as call response.");
  // rebuild with sasl header and payload
  RpcResponseHeaderProto saslHeader = RpcResponseHeaderProto.newBuilder()
    .setCallId(AuthProtocol.SASL.callId)
    .setStatus(RpcStatusProto.SUCCESS)
    .build();
  RpcSaslProto saslMessage = RpcSaslProto.newBuilder()
    .setState(SaslState.WRAP)
    .setToken(ByteString.copyFrom(token))
    .build();
  setupResponse(call, saslHeader, RpcWritable.wrap(saslMessage));
 }
}

代码示例来源：origin: io.hops/hadoop-common

RpcResponseHeaderProto header = headerBuilder.build();
try {
 setupResponse(call, header, rv);
} catch (Throwable t) {
 LOG.warn("Error serializing call response for call " + call, t);
 setupResponse(call, RpcStatusProto.ERROR,
   RpcErrorCodeProto.ERROR_SERIALIZING_RESPONSE,
   null, t.getClass().getName(),
headerBuilder.setErrorMsg(error);
headerBuilder.setErrorDetail(erCode);
setupResponse(call, headerBuilder.build(), null);

代码示例来源：origin: ch.cern.hadoop/hadoop-common

setupResponse(responseBuf, call, RpcStatusProto.ERROR,
  RpcErrorCodeProto.ERROR_SERIALIZING_RESPONSE,
  null, t.getClass().getName(),

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

setupResponse(responseBuf, call, RpcStatusProto.ERROR,
  RpcErrorCodeProto.ERROR_SERIALIZING_RESPONSE,
  null, t.getClass().getName(),

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

setupResponse(responseBuf, call, RpcStatusProto.ERROR,
  RpcErrorCodeProto.ERROR_SERIALIZING_RESPONSE,
  null, t.getClass().getName(),