java类net.minecraftforge.fml.common.network.ByteBufUtils的实例源码

@Override
public void toBytes(ByteBuf buf) {
    buf.writeInt(this.entityId);
    buf.writeInt(cart.size());
    for (int i = 0; i < cart.size(); i++) {
        ByteBufUtils.writeItemStack(buf, cart.get(i));
    }
}

@Override
public void fromBytes(ByteBuf buf) {
    try {
        this.cooldown = buf.readInt();
        this.maxCooldown = buf.readInt();
        this.className = ByteBufUtils.readUTF8String(buf);
        this.cooldownFieldName = ByteBufUtils.readUTF8String(buf);
        this.maxCooldownFieldName = ByteBufUtils.readUTF8String(buf);
    } catch (IndexOutOfBoundsException ioe) {
        Utils.getLogger(Refs.NAME).catching(ioe);
        return;
    }
    this.messageValid = true;
}

@Override
public void writeTo(ByteBuf buf)
{
    ByteBufUtils.writeUTF8String(buf, abc_md5);
    ByteBufUtils.writeUTF8String(buf, bandName);
    buf.writeBoolean(syncPlay);
    buf.writeBoolean(syncTrack);
}

@Override
public void writeTo(ByteBuf buf)
{
    PacketBuffer buff = new PacketBuffer(buf);
    buf.writeInt(tracks.length);
    for(Track track : tracks)
    {
        ByteBufUtils.writeUTF8String(buf, track.getId());
        ByteBufUtils.writeUTF8String(buf, track.getBandName());
        ByteBufUtils.writeUTF8String(buf, track.getMd5());
        buf.writeBoolean(track.playing);
        buf.writeInt(track.playProg);
        buf.writeInt(track.players.size());
        for(EntityPlayer player : track.players.keySet())
        {
            ByteBufUtils.writeUTF8String(buf, player.getName());
        }
        buf.writeInt(track.instrumentPlayers.size());
        for(Map.Entry<Integer, HashSet<BlockPos>> e : track.instrumentPlayers.entrySet())
        {
            buf.writeInt(e.getKey());
            buf.writeInt(e.getValue().size());
            for(BlockPos pos : e.getValue())
            {
                buff.writeBlockPos(pos);
            }
        }
        buf.writeInt(track.zombies.size());
        for(Integer i : track.zombies)
        {
            buf.writeInt(i);
        }
    }
}

@Override
public void toBytes(ByteBuf buffer) {
    ByteBufUtils.writeUTF8String(buffer, message);
    if (replacements != null) {
        buffer.writeInt(replacements.length);
        for (String replacement : replacements) {
            ByteBufUtils.writeUTF8String(buffer, replacement);
        }
    } else {
        buffer.writeInt(0);
    }
}

@Override
public void onMessage(MalmoMessageType messageType, Map<String, String> data) 
{
    String bufstring = data.get("message");
    ByteBuf buf = Unpooled.copiedBuffer(DatatypeConverter.parseBase64Binary(bufstring));
    ItemStack itemStack = ByteBufUtils.readItemStack(buf);
    if (itemStack != null && itemStack.getItem() != null)
    {
        accumulateReward(this.params.getDimension(), itemStack);
    }
    else
    {
        System.out.println("Error - couldn't understand the itemstack we received.");
    }
}

@Override
public void fromBytes(ByteBuf buf)
{
    chatLines = new ITextComponent[buf.readInt()];
    for (int i = 0; i < chatLines.length; i++)
    {
        chatLines[i] = ITextComponent.Serializer.jsonToComponent(ByteBufUtils.readUTF8String(buf));
    }
}

@Override
void fromBytes(ByteBuf dat)
{
    super.fromBytes(dat);
    modId = ByteBufUtils.readUTF8String(dat);
    modEntityTypeId = dat.readInt();
    entityUUID = new UUID(dat.readLong(), dat.readLong());
    rawX = dat.readDouble();
    rawY = dat.readDouble();
    rawZ = dat.readDouble();
    scaledYaw = dat.readByte() * 360F / 256F;
    scaledPitch = dat.readByte() * 360F / 256F;
    scaledHeadYaw = dat.readByte() * 360F / 256F;
    try
    {
        dataWatcherList = EntityDataManager.readEntries(new PacketBuffer(dat));
    } catch (IOException e)
    {
        FMLLog.log(Level.FATAL, e, "There was a critical error decoding the datawatcher stream for a mod entity.");
        throw Throwables.propagate(e);
    }

    throwerId = dat.readInt();
    if (throwerId != 0)
    {
        speedScaledX = dat.readInt() / 8000D;
        speedScaledY = dat.readInt() / 8000D;
        speedScaledZ = dat.readInt() / 8000D;
    }
    this.dataStream = dat;
}

@Override
public void toBytes(ByteBuf buffer)
{
    super.toBytes(buffer);
    ByteBufUtils.writeVarInt(buffer, modTags.size(), 2);
    for (Map.Entry<String,String> modTag: modTags.entrySet())
    {
        ByteBufUtils.writeUTF8String(buffer, modTag.getKey());
        ByteBufUtils.writeUTF8String(buffer, modTag.getValue());
    }
}

@Override
public void toBytes(ByteBuf buf) {
    NBTTagCompound compound = new NBTTagCompound();
    compound.setInteger("size", objects.length);
    for(int i = 0; i < objects.length; i++) compound.setByteArray("byte" + i, HarshenUtils.serialize(objects[i]));
    ByteBufUtils.writeTag(buf, compound);

}