001package net.minecraft.network.packet;
002
003import cpw.mods.fml.relauncher.Side;
004import cpw.mods.fml.relauncher.SideOnly;
005import java.io.DataInputStream;
006import java.io.DataOutputStream;
007import java.io.IOException;
008import java.util.List;
009import java.util.concurrent.Semaphore;
010import java.util.zip.DataFormatException;
011import java.util.zip.Deflater;
012import java.util.zip.Inflater;
013import net.minecraft.world.chunk.Chunk;
014
015public class Packet56MapChunks extends Packet
016{
017    private int[] chunkPostX;
018    private int[] chunkPosZ;
019    public int[] field_73590_a;
020    public int[] field_73588_b;
021
022    /** The compressed chunk data buffer */
023    private byte[] chunkDataBuffer;
024    private byte[][] field_73584_f;
025
026    /** total size of the compressed data */
027    private int dataLength;
028
029    /**
030     * Whether or not the chunk data contains a light nibble array. This is true in the main world, false in the end +
031     * nether.
032     */
033    private boolean skyLightSent;
034    private static byte[] chunkDataNotCompressed = new byte[0];
035    private int maxLen = 0;
036
037    private Semaphore deflateGate;
038
039    public Packet56MapChunks() {}
040
041    public Packet56MapChunks(List par1List)
042    {
043        int i = par1List.size();
044        this.chunkPostX = new int[i];
045        this.chunkPosZ = new int[i];
046        this.field_73590_a = new int[i];
047        this.field_73588_b = new int[i];
048        this.field_73584_f = new byte[i][];
049        this.skyLightSent = !par1List.isEmpty() && !((Chunk)par1List.get(0)).worldObj.provider.hasNoSky;
050        int j = 0;
051
052        for (int k = 0; k < i; ++k)
053        {
054            Chunk chunk = (Chunk)par1List.get(k);
055            Packet51MapChunkData packet51mapchunkdata = Packet51MapChunk.getMapChunkData(chunk, true, 65535);
056            j += packet51mapchunkdata.compressedData.length;
057            this.chunkPostX[k] = chunk.xPosition;
058            this.chunkPosZ[k] = chunk.zPosition;
059            this.field_73590_a[k] = packet51mapchunkdata.chunkExistFlag;
060            this.field_73588_b[k] = packet51mapchunkdata.chunkHasAddSectionFlag;
061            this.field_73584_f[k] = packet51mapchunkdata.compressedData;
062        }
063        deflateGate = new Semaphore(1);
064        maxLen = j;
065    }
066
067    private void deflate()
068    {
069        byte[] data = new byte[maxLen];
070        int offset = 0;
071        for (int x = 0; x < field_73584_f.length; x++)
072        {
073            System.arraycopy(field_73584_f[x], 0, data, offset, field_73584_f[x].length);
074            offset += field_73584_f[x].length;
075        }
076
077        Deflater deflater = new Deflater(-1);
078
079        try
080        {
081            deflater.setInput(data, 0, maxLen);
082            deflater.finish();
083            byte[] deflated = new byte[maxLen];
084            this.dataLength = deflater.deflate(deflated);
085            this.chunkDataBuffer = deflated;
086        }
087        finally
088        {
089            deflater.end();
090        }
091    }
092
093    /**
094     * Abstract. Reads the raw packet data from the data stream.
095     */
096    public void readPacketData(DataInputStream par1DataInputStream) throws IOException
097    {
098        short short1 = par1DataInputStream.readShort();
099        this.dataLength = par1DataInputStream.readInt();
100        this.skyLightSent = par1DataInputStream.readBoolean();
101        this.chunkPostX = new int[short1];
102        this.chunkPosZ = new int[short1];
103        this.field_73590_a = new int[short1];
104        this.field_73588_b = new int[short1];
105        this.field_73584_f = new byte[short1][];
106
107        if (chunkDataNotCompressed.length < this.dataLength)
108        {
109            chunkDataNotCompressed = new byte[this.dataLength];
110        }
111
112        par1DataInputStream.readFully(chunkDataNotCompressed, 0, this.dataLength);
113        byte[] abyte = new byte[196864 * short1];
114        Inflater inflater = new Inflater();
115        inflater.setInput(chunkDataNotCompressed, 0, this.dataLength);
116
117        try
118        {
119            inflater.inflate(abyte);
120        }
121        catch (DataFormatException dataformatexception)
122        {
123            throw new IOException("Bad compressed data format");
124        }
125        finally
126        {
127            inflater.end();
128        }
129
130        int i = 0;
131
132        for (int j = 0; j < short1; ++j)
133        {
134            this.chunkPostX[j] = par1DataInputStream.readInt();
135            this.chunkPosZ[j] = par1DataInputStream.readInt();
136            this.field_73590_a[j] = par1DataInputStream.readShort();
137            this.field_73588_b[j] = par1DataInputStream.readShort();
138            int k = 0;
139            int l = 0;
140            int i1;
141
142            for (i1 = 0; i1 < 16; ++i1)
143            {
144                k += this.field_73590_a[j] >> i1 & 1;
145                l += this.field_73588_b[j] >> i1 & 1;
146            }
147
148            i1 = 2048 * 4 * k + 256;
149            i1 += 2048 * l;
150
151            if (this.skyLightSent)
152            {
153                i1 += 2048 * k;
154            }
155
156            this.field_73584_f[j] = new byte[i1];
157            System.arraycopy(abyte, i, this.field_73584_f[j], 0, i1);
158            i += i1;
159        }
160    }
161
162    /**
163     * Abstract. Writes the raw packet data to the data stream.
164     */
165    public void writePacketData(DataOutputStream par1DataOutputStream) throws IOException
166    {
167        if (this.chunkDataBuffer == null)
168        {
169            deflateGate.acquireUninterruptibly();
170            if (this.chunkDataBuffer == null)
171            {
172                deflate();
173            }
174            deflateGate.release();
175        }
176
177        par1DataOutputStream.writeShort(this.chunkPostX.length);
178        par1DataOutputStream.writeInt(this.dataLength);
179        par1DataOutputStream.writeBoolean(this.skyLightSent);
180        par1DataOutputStream.write(this.chunkDataBuffer, 0, this.dataLength);
181
182        for (int i = 0; i < this.chunkPostX.length; ++i)
183        {
184            par1DataOutputStream.writeInt(this.chunkPostX[i]);
185            par1DataOutputStream.writeInt(this.chunkPosZ[i]);
186            par1DataOutputStream.writeShort((short)(this.field_73590_a[i] & 65535));
187            par1DataOutputStream.writeShort((short)(this.field_73588_b[i] & 65535));
188        }
189    }
190
191    /**
192     * Passes this Packet on to the NetHandler for processing.
193     */
194    public void processPacket(NetHandler par1NetHandler)
195    {
196        par1NetHandler.handleMapChunks(this);
197    }
198
199    /**
200     * Abstract. Return the size of the packet (not counting the header).
201     */
202    public int getPacketSize()
203    {
204        return 6 + this.dataLength + 12 * this.getNumberOfChunkInPacket();
205    }
206
207    @SideOnly(Side.CLIENT)
208    public int getChunkPosX(int par1)
209    {
210        return this.chunkPostX[par1];
211    }
212
213    @SideOnly(Side.CLIENT)
214    public int getChunkPosZ(int par1)
215    {
216        return this.chunkPosZ[par1];
217    }
218
219    public int getNumberOfChunkInPacket()
220    {
221        return this.chunkPostX.length;
222    }
223
224    @SideOnly(Side.CLIENT)
225    public byte[] getChunkCompressedData(int par1)
226    {
227        return this.field_73584_f[par1];
228    }
229}