import io.protostuff.LowCopyProtostuffOutput; //导入依赖的package包/类
@Override
public void serialize(RepositoryData repository, Buffer buffer) {
	changeClassLoaderIfRequired();

       ZeroCopyLinkBuffer zeroCopyLinkBuffer = linkedBuff.get();
       LowCopyProtostuffOutput lowCopyProtostuffOutput = output.get();

       zeroCopyLinkBuffer.withBuffer(buffer);
       lowCopyProtostuffOutput.buffer = zeroCopyLinkBuffer;

       try {
           repoSchema.writeTo(lowCopyProtostuffOutput, repository);
       } catch (IOException e) {
           throw new RuntimeException(e);
       }
}
 

import io.protostuff.LowCopyProtostuffOutput; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void serializeObject(Buffer buffer, Object tc) {
       ZeroCopyLinkBuffer zeroCopyLinkBuffer = linkedBuff.get();
       LowCopyProtostuffOutput lowCopyProtostuffOutput = output.get();
	zeroCopyLinkBuffer.withBuffer(buffer);
	lowCopyProtostuffOutput.buffer = zeroCopyLinkBuffer;

	long crc = crcNames.get(tc.getClass());
       ProtoTransactionTypeHolder ptth = registeredCrc.get(crc);
	if (ptth.crcCollision) {
		byte[] key = sha1Names.get(tc.getClass());
		ptth = registeredSha1.get(key);
		buffer.writeByte(SHA1_TYPE);
		buffer.writeBytes(key, 0, SHA1_DIGEST_SIZE);
	} else {
		buffer.writeByte(CRC32_TYPE);
		buffer.writeLong(crc);
	}

       buffer.markSize();
	Schema<Object> schema = (Schema<Object>) ptth.schema;
       try {
           schema.writeTo(lowCopyProtostuffOutput, tc);
       } catch (IOException e) {
           throw new RuntimeException(e);
       }
	buffer.writeSize();
   }
 

import io.protostuff.LowCopyProtostuffOutput; //导入依赖的package包/类
private static void addLengthPrependedEntryBuffersToList(RegionWalEntry entry, List<ByteBuffer> buffers)
    throws IOException {
  LinkBuffer entryBuffer = new LinkBuffer();
  LowCopyProtostuffOutput lcpo = new LowCopyProtostuffOutput(entryBuffer);
  RegionWalEntry.getSchema().writeTo(lcpo, entry);

  final int length = Ints.checkedCast(lcpo.buffer.size());
  final LinkBuffer lengthBuf = new LinkBuffer().writeVarInt32(length);

  buffers.addAll(lengthBuf.finish());
  buffers.addAll(entryBuffer.finish());
}
 

import io.protostuff.LowCopyProtostuffOutput; //导入依赖的package包/类
protected LowCopyProtostuffOutput initialValue() {
    return new LowCopyProtostuffOutput();
}