Package java.util.zip

Examples of java.util.zip.CheckedOutputStream

221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
     */
    public synchronized void serialize(DataTree dt, Map<Long, Integer> sessions, File snapShot)
            throws IOException {
        if (!close) {
            OutputStream sessOS = new BufferedOutputStream(new FileOutputStream(snapShot));
            CheckedOutputStream crcOut = new CheckedOutputStream(sessOS, new Adler32());
            //CheckedOutputStream cout = new CheckedOutputStream()
            OutputArchive oa = BinaryOutputArchive.getArchive(crcOut);
            FileHeader header = new FileHeader(SNAP_MAGIC, VERSION, dbId);
            serialize(dt,sessions,oa, header);
            long val = crcOut.getChecksum().getValue();
            oa.writeLong(val, "val");
            oa.writeString("/", "path");
            sessOS.flush();
            crcOut.close();
            sessOS.close();
        }
    }
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
     * @param snapShot the file to store snapshot into
     */
    public void serialize(DataTree dt, Map<Long, Integer> sessions, File snapShot)
            throws IOException {
        OutputStream sessOS = new BufferedOutputStream(new FileOutputStream(snapShot));
        CheckedOutputStream crcOut = new CheckedOutputStream(sessOS, new Adler32());
        //CheckedOutputStream cout = new CheckedOutputStream()
        OutputArchive oa = BinaryOutputArchive.getArchive(crcOut);
        FileHeader header = new FileHeader(SNAP_MAGIC, VERSION, dbId);
        serialize(dt,sessions,oa, header);
        long val = crcOut.getChecksum().getValue();
        oa.writeLong(val, "val");
        oa.writeString("/", "path");
        sessOS.flush();
        crcOut.close();
        sessOS.close();
    }
View Full Code Here
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
    @Override
    public synchronized void serialize(DataTree dt, Map<Long, Long> sessions, File snapShot)
            throws IOException {
        if (!close) {
            OutputStream sessOS = new BufferedOutputStream(new FileOutputStream(snapShot));
            CheckedOutputStream crcOut = new CheckedOutputStream(sessOS, new Adler32());
            //CheckedOutputStream cout = new CheckedOutputStream()
            OutputArchive oa = BinaryOutputArchive.getArchive(crcOut);
            FileHeader header = new FileHeader(SNAP_MAGIC, VERSION, dbId);
            serialize(dt,sessions,oa, header);
            long val = crcOut.getChecksum().getValue();
            oa.writeLong(val, "val");
            oa.writeString("/", "path");
            sessOS.flush();
            crcOut.close();
            sessOS.close();
        }
    }
View Full Code Here
83
84
85
86
87
88
89
    public ForkServer(InputStream input, OutputStream output)
            throws IOException {
        this.input =
            new DataInputStream(new CheckedInputStream(input, this));
        this.output =
            new DataOutputStream(new CheckedOutputStream(output, this));
    }
View Full Code Here
88
89
90
91
92
93
94
    public ForkServer(InputStream input, OutputStream output)
            throws IOException {
        this.input =
            new DataInputStream(new CheckedInputStream(input, this));
        this.output =
            new DataOutputStream(new CheckedOutputStream(output, this));
    }
View Full Code Here
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
    crc32 = new CRC32();
    final PackOutputStream out = new PackOutputStream(
      writeMonitor,
      isIndexDisabled()
        ? packStream
        : new CheckedOutputStream(packStream, crc32),
      this);

    long objCnt = getObjectCount();
    stats.totalObjects = objCnt;
    beginPhase(PackingPhase.WRITING, writeMonitor, objCnt);
View Full Code Here
635
636
637
638
639
640
641
642
643
644
645
646
647
    indexFile.createNewFile();
    FSDataOutputStream output = FileSystem.getLocal(conf).getRaw().append(
        new Path(indexFile.getAbsolutePath()));
    Checksum crc = new PureJavaCrc32();
    crc.reset();
    CheckedOutputStream chk = new CheckedOutputStream(output, crc);
    String msg = "Writing new index file. This file will be used only " +
        "for the testing.";
    chk.write(Arrays.copyOf(msg.getBytes(),
        MapTask.MAP_OUTPUT_INDEX_RECORD_LENGTH));
    output.writeLong(chk.getChecksum().getValue());
    output.close();
  }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
  }

  public void writeToFile(Path loc, JobConf job, Checksum crc)
      throws IOException {
    final FileSystem rfs = FileSystem.getLocal(job).getRaw();
    CheckedOutputStream chk = null;
    final FSDataOutputStream out = rfs.create(loc);
    try {
      if (crc != null) {
        crc.reset();
        chk = new CheckedOutputStream(out, crc);
        chk.write(buf.array());
        out.writeLong(chk.getChecksum().getValue());
      } else {
        out.write(buf.array());
      }
    } finally {
      if (chk != null) {
        chk.close();
      } else {
        out.close();
      }
    }
  }
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
  public void write(HttpServletResponse response)
    throws IOException {
    response.setHeader("Content-disposition", "attachment; filename=" + filename);
    response.setHeader("Content-type", "application/zip");

    CheckedOutputStream stream = new CheckedOutputStream(response.getOutputStream(), new CRC32());
    try (ZipOutputStream zip = new ZipOutputStream(stream)) {
      for (Path file : files) {
        zip.putNextEntry(new ZipEntry(file.getFileName().toString()));
        copy(file, zip);
        zip.closeEntry();
View Full Code Here
86
87
88
89
90
91
92
    public ForkServer(InputStream input, OutputStream output)
            throws IOException {
        this.input =
            new DataInputStream(new CheckedInputStream(input, this));
        this.output =
            new DataOutputStream(new CheckedOutputStream(output, this));
    }
View Full Code Here
TOP

Related Classes of java.util.zip.CheckedOutputStream

  • br.com.caelum.vraptor.observer.download.ZipDownload
  • com.sun.enterprise.ee.synchronization.processor.ByteProcessor
  • com.sun.enterprise.ee.synchronization.processor.ZipProcessor
  • com.sun.star.tool.starjar.StarJar
  • cu.ftpd.commands.transfer.CommandSTOR
  • de.fu_berlin.inf.dpp.util.FileZipper
  • net.sourceforge.processdash.tool.bridge.report.ListingHashcodeCalculator
  • net.sourceforge.processdash.util.RobustFileOutputStream
  • nextapp.echo2.webcontainer.image.PngEncoder
  • org.apache.commons.compress.archivers.zip.ExplodeSupportTest
    • Copyright © 2018 www.massapicom. 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.