OutboundRpcMessage.java 文件源码

OutboundRpcMessage(RpcMode mode, int rpcTypeNumber, int coordinationId, MessageLite pBody, ByteBuf... dBodies) {
  super(mode, rpcTypeNumber, coordinationId);
  this.pBody = pBody;

  // Netty doesn't traditionally release the reference on an unreadable buffer.  However, we need to so that if we send a empty or unwritable buffer, we still release.  otherwise we get weird memory leaks when sending empty vectors.
  List<ByteBuf> bufs = Lists.newArrayList();
  for (ByteBuf d : dBodies) {
    if (d.readableBytes() == 0) {
      d.release();
    } else {
      bufs.add(d);
    }
  }
  this.dBodies = bufs.toArray(new ByteBuf[bufs.size()]);
}