Java 类org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmRequestProto 实例源码

项目:hadoop    文件:Sender.java   
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto.Builder builder =
      ShortCircuitShmRequestProto.newBuilder().
      setClientName(clientName);
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ShortCircuitShmRequestProto proto = builder.build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
项目:hadoop    文件:Receiver.java   
/** Receive {@link Op#REQUEST_SHORT_CIRCUIT_SHM} */
private void opRequestShortCircuitShm(DataInputStream in) throws IOException {
  final ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    requestShortCircuitShm(proto.getClientName());
  } finally {
    if (traceScope != null) traceScope.close();
  }
}
项目:aliyun-oss-hadoop-fs    文件:Sender.java   
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto.Builder builder =
      ShortCircuitShmRequestProto.newBuilder().
          setClientName(clientName);
  SpanId spanId = Tracer.getCurrentSpanId();
  if (spanId.isValid()) {
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder().
        setTraceId(spanId.getHigh()).
        setParentId(spanId.getLow()));
  }
  ShortCircuitShmRequestProto proto = builder.build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
项目:aliyun-oss-hadoop-fs    文件:Receiver.java   
/** Receive {@link Op#REQUEST_SHORT_CIRCUIT_SHM} */
private void opRequestShortCircuitShm(DataInputStream in) throws IOException {
  final ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    requestShortCircuitShm(proto.getClientName());
  } finally {
    if (traceScope != null) traceScope.close();
  }
}
项目:big-c    文件:Sender.java   
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto.Builder builder =
      ShortCircuitShmRequestProto.newBuilder().
      setClientName(clientName);
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ShortCircuitShmRequestProto proto = builder.build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
项目:big-c    文件:Receiver.java   
/** Receive {@link Op#REQUEST_SHORT_CIRCUIT_SHM} */
private void opRequestShortCircuitShm(DataInputStream in) throws IOException {
  final ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    requestShortCircuitShm(proto.getClientName());
  } finally {
    if (traceScope != null) traceScope.close();
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:Sender.java   
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto.Builder builder =
      ShortCircuitShmRequestProto.newBuilder().
      setClientName(clientName);
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ShortCircuitShmRequestProto proto = builder.build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:Receiver.java   
/** Receive {@link Op#REQUEST_SHORT_CIRCUIT_SHM} */
private void opRequestShortCircuitShm(DataInputStream in) throws IOException {
  final ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    requestShortCircuitShm(proto.getClientName());
  } finally {
    if (traceScope != null) traceScope.close();
  }
}
项目:FlexMap    文件:Sender.java   
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto.Builder builder =
      ShortCircuitShmRequestProto.newBuilder().
      setClientName(clientName);
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ShortCircuitShmRequestProto proto = builder.build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
项目:FlexMap    文件:Receiver.java   
/** Receive {@link Op#REQUEST_SHORT_CIRCUIT_SHM} */
private void opRequestShortCircuitShm(DataInputStream in) throws IOException {
  final ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    requestShortCircuitShm(proto.getClientName());
  } finally {
    if (traceScope != null) traceScope.close();
  }
}
项目:hadoop-on-lustre2    文件:Sender.java   
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.newBuilder().
      setClientName(clientName).
      build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
项目:hadoop-on-lustre2    文件:Receiver.java   
/** Receive {@link Op#REQUEST_SHORT_CIRCUIT_SHM} */
private void opRequestShortCircuitShm(DataInputStream in) throws IOException {
  final ShortCircuitShmRequestProto proto =
      ShortCircuitShmRequestProto.parseFrom(vintPrefixed(in));
  requestShortCircuitShm(proto.getClientName());
}