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());
}