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

ByteString.size介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-ratis

private static UUID toUuid(ByteString bytes) {
 Objects.requireNonNull(bytes, "bytes == null");
 checkLength(bytes.size(), "bytes.size()");
 final ByteBuffer buf = bytes.asReadOnlyByteBuffer();
 return new UUID(buf.getLong(), buf.getLong());
}

代码示例来源：origin: apache/incubator-ratis

private RaftPeerId(ByteString id) {
 this.id = Objects.requireNonNull(id, "id == null");
 Preconditions.assertTrue(id.size() > 0, "id is empty.");
 this.idString = id.toString(StandardCharsets.UTF_8);
}

代码示例来源：origin: apache/incubator-ratis

public static String bytes2HexShortString(ByteString bytes) {
 final int size = bytes.size();
 if (size == 0) {
  return "<EMPTY>";
 } else if (size > 10) {
  // return only the first 10 bytes
  return bytes2HexString(bytes.substring(0, 10)) + "...(size=" + size + ")";
 } else {
  return bytes2HexString(bytes);
 }
}

代码示例来源：origin: apache/incubator-ratis

void verify(ByteString read, int offset, int length, ByteBuffer expected) {
 Assert.assertEquals(length, read.size());
 assertBuffers(offset, length, expected, read.asReadOnlyByteBuffer());
}

代码示例来源：origin: apache/incubator-ratis

CompletableFuture<Integer> write(
  long index, String relative, boolean close, long offset, ByteString data) {
 final int size = data != null? data.size(): 0;
 LOG.trace("write {}, offset={}, size={}, close? {} @{}:{}",
   relative, offset, size, close, getId(), index);
 final boolean createNew = offset == 0L;
 final UnderConstruction uc;
 if (createNew) {
  uc = new UnderConstruction(normalize(relative));
  files.putNew(uc);
 } else {
  try {
   uc = files.get(relative).asUnderConstruction();
  } catch (FileNotFoundException e) {
   return FileStoreCommon.completeExceptionally(
     index, "Failed to write to " + relative, e);
  }
 }
 return size == 0 && !close? CompletableFuture.completedFuture(0)
   : createNew? uc.submitCreate(this::resolve, data, close, writer, getId(), index)
   : uc.submitWrite(offset, data, close, writer, getId(), index);
}

代码示例来源：origin: apache/incubator-ratis

@Override
public CompletableFuture<Message> applyTransaction(TransactionContext trx) {
 final LogEntryProto entry = trx.getLogEntry();
 final long index = entry.getIndex();
 updateLastAppliedTermIndex(entry.getTerm(), index);
 final StateMachineLogEntryProto smLog = entry.getStateMachineLogEntry();
 final FileStoreRequestProto request;
 try {
  request = FileStoreRequestProto.parseFrom(smLog.getLogData());
 } catch (InvalidProtocolBufferException e) {
  return FileStoreCommon.completeExceptionally(index,
    "Failed to parse logData in" + smLog, e);
 }
 switch(request.getRequestCase()) {
  case DELETE:
   return delete(index, request.getDelete());
  case WRITEHEADER:
   return writeCommit(index, request.getWriteHeader(), smLog.getStateMachineEntry().getStateMachineData().size());
  case WRITE:
   // WRITE should not happen here since
   // startTransaction converts WRITE requests to WRITEHEADER requests.
  default:
   LOG.error(getId() + ": Unexpected request case " + request.getRequestCase());
   return FileStoreCommon.completeExceptionally(index,
     "Unexpected request case " + request.getRequestCase());
 }
}