Updating existing JDK code to use InputStream.transferTo() (jdk) (original) (raw)

Fri May 8 23:00:15 UTC 2015

     private static String nativeDir(String filename) {
         if (System.getProperty("os.name").startsWith("Windows")) {
             if (filename.endsWith(".dll") || filename.endsWith(".diz")
       return copy(in, out);
       return in.transferTo(out);
   }
   int bytesRead = 0;
   long bytesWritten = 0;
    if( !isFileTypeSupported(type,in) ) {
        throw new IllegalArgumentException("Could not write MIDI file");
    }
   while( (bytesRead = fileStream.read( buffer )) >= 0 ) {
       out.write( buffer, 0, bytesRead );
       bytesWritten += bytesRead;
   }
   // Done....return bytesWritten
   return (int) bytesWritten;
   return (int) fileStream.transferTo(out);
   buf = new byte[16384];
   while(true) {
       count = in.read(buf);
       if (count < 0)
           break;
       this.write(buf, 0, count);
   }
   in.transferTo(this);
       try {
           while ((bread = bin.read(buffer)) >= 0) {
               bout.write(buffer, 0, bread);
           }
           bin.close();
       try (BufferedInputStream bin = new BufferedInputStream(instream);
            BufferedOutputStream bout = new BufferedOutputStream(output)) {
           bin.transferTo(bout);
           bout.flush();
           bout.close();
       } catch (IOException e) {
           notifyEvent(PrintJobEvent.JOB_FAILED);
           throw new PrintException (e);
               while ((cread = instream.read(buffer, 0, buffer.length)) >=0) {
                   fos.write(buffer, 0, cread);
               }
           try (FileOutputStream fos = new FileOutputStream(mDestination)) {
               instream.transferTo(fos);
               fos.flush();
               fos.close();
           } catch (FileNotFoundException fnfe) {
               notifyEvent(PrintJobEvent.JOB_FAILED);
               throw new PrintException(fnfe.toString());
   byte refBytes[] = null;
   FileInputStream fisRef = null;
   UnsyncByteArrayOutputStream baos = null;
   try {
       fisRef = new FileInputStream(fileName);
       baos = new UnsyncByteArrayOutputStream();
       byte buf[] = new byte[1024];
       int len;
       while ((len = fisRef.read(buf)) > 0) {
           baos.write(buf, 0, len);
       }
       refBytes = baos.toByteArray();
   } finally {
       if (baos != null) {
           baos.close();
       }
       if (fisRef != null) {
           fisRef.close();
       }
   try (FileInputStream fisRef = new FileInputStream(fileName);
        UnsyncByteArrayOutputStream baos = new UnsyncByteArrayOutputStream()) {
       fisRef.transferTo(baos);
       return baos.toByteArray();
   }
   return refBytes;
           fos = new FileOutputStream(f);
   if (filename != null && bytes != null) {
       File f = new File(filename);
       try (FileOutputStream fos = new FileOutputStream(f)) {
           fos.write(bytes);
           fos.close();
       } else {
       } catch (IOException ex) {
           if (log.isLoggable(java.util.logging.Level.FINE)) {
               log.log(java.util.logging.Level.FINE, "writeBytesToFilename got null byte[] pointed");
               log.log(java.util.logging.Level.FINE, ex.getMessage(), ex);
           }
       }
   } catch (IOException ex) {
       if (fos != null) {
           try {
               fos.close();
           } catch (IOException ioe) {
               if (log.isLoggable(java.util.logging.Level.FINE)) {
                   log.log(java.util.logging.Level.FINE, ioe.getMessage(), ioe);
               }
           }
       }
   } else if (log.isLoggable(java.util.logging.Level.FINE)) {
       log.log(java.util.logging.Level.FINE, "writeBytesToFilename got null byte[] pointed");
   }
     byte[] retBytes = null;
   try {
       baos = new UnsyncByteArrayOutputStream();
       byte buf[] = new byte[4 * 1024];
       int len;
       while ((len = inputStream.read(buf)) > 0) {
           baos.write(buf, 0, len);
       }
   try (UnsyncByteArrayOutputStream baos = new UnsyncByteArrayOutputStream()) {
       inputStream.transferTo(baos);
       retBytes = baos.toByteArray();
   } finally {
       baos.close();
   }
    return retBytes;
}
       while ((read = inputStream.read(buf)) >= 0) {
           baos.write(buf, 0, read);
           summarized += read;
       }
       long summarized = inputStream.transferTo(baos);

       if (log.isLoggable(java.util.logging.Level.FINE)) {
           log.log(java.util.logging.Level.FINE, "Fetched " + summarized + " bytes from URI " + uriNew.toString());
   byte[] buf = new byte[1024];
   while (true) {
       int read = is.read(buf);
       if (read == -1) { // EOF
           break;
       }
       baos.write(buf, 0, read);
       if (read < 1024) {
           break;
       }
   }
   is.transferTo(baos);
   return baos.toByteArray();
       InputStream is = zfs.newInputStream(getResolvedPath());
       try {
           OutputStream os = target.newOutputStream();
           try {
               byte[] buf = new byte[8192];
               int n = 0;
               while ((n = is.read(buf)) != -1) {
                   os.write(buf, 0, n);
               }
           } finally {
               os.close();
           }
       } finally {
           is.close();
       try (InputStream is = zfs.newInputStream(getResolvedPath());
            OutputStream os = target.newOutputStream()) {
           is.transferTo(os);
       }
   }
   if (copyAttrs) {

Updating existing JDK code to use InputStream.transferTo() (jdk) (original) (raw)

@@ -138,14 +133,8 @@ if (fileStream == null) { throw new IllegalArgumentException("Could not write MIDI file"); } - buffer = new byte[bufferSize];

@@ -94,30 +73,17 @@ * @param bytes */ public static void writeBytesToFilename(String filename, byte[] bytes) { - FileOutputStream fos = null; - try { - if (filename != null && bytes != null) { - File f = new File(filename);

@@ -132,22 +98,11 @@ * @throws IOException */ public static byte[] getBytesFromStream(InputStream inputStream) throws IOException { - UnsyncByteArrayOutputStream baos = null;