Package java.util.zip

Examples of java.util.zip.Deflater.reset()

164
165
166
167
168
169
170
171
172
173
174
        int compressedDataLength = compresser.deflate(buffer);
        byte[] deflatedData = new byte[compressedDataLength];
        for (int i=0; i<compressedDataLength; i++) {
            deflatedData[i] = buffer[i];
        }
        compresser.reset();

        String base64EncodedText = classUnderTest.base64Encode(deflatedData);

        InputStream is2 = getClass().getClassLoader().getResourceAsStream("Base64DeflatedAndEncodedXml.text");
        String expectedText = IOUtils.toString(is2);
View Full Code Here
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
1419
    out.resetCRC32();
    otp.setOffset(out.length());
    out.writeHeader(otp, ldr.getSize());

    deflater.reset();
    DeflaterOutputStream dst = new DeflaterOutputStream(out, deflater);
    ldr.copyTo(dst);
    dst.finish();
  }
View Full Code Here
1436
1437
1438
1439
1440
1441
1442
1443
1444
1445
1446
    TemporaryBuffer.Heap delta = delta(otp);
    out.writeHeader(otp, delta.length());

    Deflater deflater = deflater();
    deflater.reset();
    DeflaterOutputStream dst = new DeflaterOutputStream(out, deflater);
    delta.writeTo(dst, null);
    dst.finish();
    typeStats.cntDeltas++;
    typeStats.deltaBytes += out.length() - otp.getOffset();
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
    private ServletRequest wrapDeflatedRequest(HttpServletRequest request) throws IOException {
        final Deflater deflater = buildDeflater();
        final DeflaterInputStream input = new DeflaterInputStream(request.getInputStream(), deflater, _bufferSize) {
            @Override
            public void close() throws IOException {
                deflater.reset();
                localDeflater.set(deflater);
                super.close();
            }
        };
        return new WrappedServletRequest(request, input);
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
    }

    public int compress(byte[] input, int inputOffset, int inputLength, ICompressor.WrappedArray output, int outputOffset)
    {
        Deflater def = deflater.get();
        def.reset();
        def.setInput(input, inputOffset, inputLength);
        def.finish();
        if (def.needsInput())
            return 0;
View Full Code Here
399
400
401
402
403
404
405
406
407
408
409
      if (i == 0) {
                curArray = byteArray;
            } else if (i == 1) {
                curArray = byteArray2;
            } else {
                defl.reset();
            }

      defl.setInput(curArray);
      defl.finish();
      while (!defl.finished()) {
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
    }

    public int compress(byte[] input, int inputOffset, int inputLength, ICompressor.WrappedArray output, int outputOffset) throws IOException
    {
        Deflater def = deflater.get();
        def.reset();
        def.setInput(input, inputOffset, inputLength);
        def.finish();
        if (def.needsInput())
            return 0;
View Full Code Here
1478
1479
1480
1481
1482
1483
1484
1485
1486
1487
1488
      finally
      {
        //Reset and put back
        if(compresser != null)
        {
          compresser.reset();
          TransientHolder<Deflater> th = TransientHolder.newTransientHolder(compresser);
          sessionMap.put("PAGE_STATE_DEFLATER", th);
        }
      }
    }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
    }

    public int compress(byte[] input, int inputOffset, int inputLength, ICompressor.WrappedArray output, int outputOffset) throws IOException
    {
        Deflater def = deflater.get();
        def.reset();
        def.setInput(input, inputOffset, inputLength);
        def.finish();
        if (def.needsInput())
            return 0;
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
                byte[] compressed_payload=new byte[length];
                int compressed_size;
                Deflater deflater=null;
                try {
                    deflater=deflater_pool.take();
                    deflater.reset();
                    deflater.setInput(payload, msg.getOffset(), length);
                    deflater.finish();
                    deflater.deflate(compressed_payload);
                    compressed_size=deflater.getTotalOut();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.