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