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

项目：hadoop 文件：Sender.java

@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto.Builder builder =
      ReleaseShortCircuitAccessRequestProto.newBuilder().
      setSlotId(PBHelper.convert(slotId));
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ReleaseShortCircuitAccessRequestProto proto = builder.build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}

项目：hadoop 文件：Receiver.java

/** Receive {@link Op#RELEASE_SHORT_CIRCUIT_FDS} */
private void opReleaseShortCircuitFds(DataInputStream in)
    throws IOException {
  final ReleaseShortCircuitAccessRequestProto proto =
    ReleaseShortCircuitAccessRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    releaseShortCircuitFds(PBHelper.convert(proto.getSlotId()));
  } finally {
    if (traceScope != null) traceScope.close();
  }
}

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

@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto.Builder builder =
      ReleaseShortCircuitAccessRequestProto.newBuilder().
          setSlotId(PBHelperClient.convert(slotId));
  SpanId spanId = Tracer.getCurrentSpanId();
  if (spanId.isValid()) {
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder().
        setTraceId(spanId.getHigh()).
        setParentId(spanId.getLow()));
  }
  ReleaseShortCircuitAccessRequestProto proto = builder.build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}

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

/** Receive {@link Op#RELEASE_SHORT_CIRCUIT_FDS} */
private void opReleaseShortCircuitFds(DataInputStream in)
    throws IOException {
  final ReleaseShortCircuitAccessRequestProto proto =
    ReleaseShortCircuitAccessRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    releaseShortCircuitFds(PBHelperClient.convert(proto.getSlotId()));
  } finally {
    if (traceScope != null) traceScope.close();
  }
}

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

@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto.Builder builder =
      ReleaseShortCircuitAccessRequestProto.newBuilder().
      setSlotId(PBHelper.convert(slotId));
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ReleaseShortCircuitAccessRequestProto proto = builder.build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}

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

/** Receive {@link Op#RELEASE_SHORT_CIRCUIT_FDS} */
private void opReleaseShortCircuitFds(DataInputStream in)
    throws IOException {
  final ReleaseShortCircuitAccessRequestProto proto =
    ReleaseShortCircuitAccessRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    releaseShortCircuitFds(PBHelper.convert(proto.getSlotId()));
  } finally {
    if (traceScope != null) traceScope.close();
  }
}

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

@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto.Builder builder =
      ReleaseShortCircuitAccessRequestProto.newBuilder().
      setSlotId(PBHelper.convert(slotId));
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ReleaseShortCircuitAccessRequestProto proto = builder.build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}

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

/** Receive {@link Op#RELEASE_SHORT_CIRCUIT_FDS} */
private void opReleaseShortCircuitFds(DataInputStream in)
    throws IOException {
  final ReleaseShortCircuitAccessRequestProto proto =
    ReleaseShortCircuitAccessRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    releaseShortCircuitFds(PBHelper.convert(proto.getSlotId()));
  } finally {
    if (traceScope != null) traceScope.close();
  }
}

项目：FlexMap 文件：Sender.java

@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto.Builder builder =
      ReleaseShortCircuitAccessRequestProto.newBuilder().
      setSlotId(PBHelper.convert(slotId));
  if (Trace.isTracing()) {
    Span s = Trace.currentSpan();
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(s.getTraceId()).setParentId(s.getSpanId()));
  }
  ReleaseShortCircuitAccessRequestProto proto = builder.build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}

项目：FlexMap 文件：Receiver.java

/** Receive {@link Op#RELEASE_SHORT_CIRCUIT_FDS} */
private void opReleaseShortCircuitFds(DataInputStream in)
    throws IOException {
  final ReleaseShortCircuitAccessRequestProto proto =
    ReleaseShortCircuitAccessRequestProto.parseFrom(vintPrefixed(in));
  TraceScope traceScope = continueTraceSpan(proto.getTraceInfo(),
      proto.getClass().getSimpleName());
  try {
    releaseShortCircuitFds(PBHelper.convert(proto.getSlotId()));
  } finally {
    if (traceScope != null) traceScope.close();
  }
}

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

@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto proto = 
      ReleaseShortCircuitAccessRequestProto.newBuilder().
      setSlotId(PBHelper.convert(slotId)).
      build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}

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

/** Receive {@link Op#RELEASE_SHORT_CIRCUIT_FDS} */
private void opReleaseShortCircuitFds(DataInputStream in)
    throws IOException {
  final ReleaseShortCircuitAccessRequestProto proto =
    ReleaseShortCircuitAccessRequestProto.parseFrom(vintPrefixed(in));
  releaseShortCircuitFds(PBHelper.convert(proto.getSlotId()));
}