Edit C:\galaxie\jobs\GALAXIE__JOBs\backup\GALAXIE__PCKG\src\main\java\routines\system\BufferedOutput.java
// ============================================================================ // // Copyright (C) 2006-2015 Talend Inc. - www.talend.com // // This source code is available under agreement available at // %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt // // You should have received a copy of the agreement // along with this program; if not, write to Talend SA // 9 rue Pages 92150 Suresnes, France // // ============================================================================ package routines.system; import java.io.IOException; import java.io.Writer; /** * @(#)BufferedWriter.java 1.26 03/12/19 * * @see java.io.BuffferedWriter * @author xzhang */ public class BufferedOutput extends java.io.Writer { private Writer out; private char cb[]; private int nChars, nextChar; private static int defaultCharBufferSize = 8192; /** * Line separator string. This is the value of the line.separator property at the moment that the stream was * created. */ private String lineSeparator; /** * Create a buffered character-output stream that uses a default-sized output buffer. * * @param out A Writer */ public BufferedOutput(Writer out) { this(out, defaultCharBufferSize); } /** * Create a new buffered character-output stream that uses an output buffer of the given size. * * @param out A Writer * @param sz Output-buffer size, a positive integer * * @exception IllegalArgumentException If sz is <= 0 */ public BufferedOutput(Writer out, int sz) { super(out); if (sz <= 0) throw new IllegalArgumentException("Buffer size <= 0"); //$NON-NLS-1$ this.out = out; cb = new char[sz]; nChars = sz; nextChar = 0; lineSeparator = (String) java.security.AccessController.doPrivileged(new sun.security.action.GetPropertyAction( "line.separator")); //$NON-NLS-1$ } /** Check to make sure that the stream has not been closed */ private void ensureOpen() throws IOException { if (out == null) throw new IOException("Stream closed"); //$NON-NLS-1$ } /** * Flush the output buffer to the underlying character stream, without flushing the stream itself. This method is * non-private only so that it may be invoked by PrintStream. */ void flushBuffer() throws IOException { synchronized (lock) { ensureOpen(); if (nextChar == 0) return; out.write(cb, 0, nextChar); // Flush the buffer of inside writer. out.flush(); nextChar = 0; } } /** * Write a single character. * * @exception IOException If an I/O error occurs */ public void write(int c) throws IOException { synchronized (lock) { ensureOpen(); if (nextChar >= nChars) flushBuffer(); cb[nextChar++] = (char) c; } } /** * Our own little min method, to avoid loading java.lang.Math if we've run out of file descriptors and we're trying * to print a stack trace. */ private int min(int a, int b) { if (a < b) return a; return b; } /** * Write a portion of an array of characters. * * <p> * Ordinarily this method stores characters from the given array into this stream's buffer, flushing the buffer to * the underlying stream as needed. If the requested length is at least as large as the buffer, however, then this * method will flush the buffer and write the characters directly to the underlying stream. Thus redundant * <code>BufferedWriter</code>s will not copy data unnecessarily. * * @param cbuf A character array * @param off Offset from which to start reading characters * @param len Number of characters to write * * @exception IOException If an I/O error occurs */ public void write(char cbuf[], int off, int len) throws IOException { synchronized (lock) { ensureOpen(); if ((off < 0) || (off > cbuf.length) || (len < 0) || ((off + len) > cbuf.length) || ((off + len) < 0)) { throw new IndexOutOfBoundsException(); } else if (len == 0) { return; } if (len >= nChars) { /* * If the request length exceeds the size of the output buffer, flush the buffer and then write the data * directly. In this way buffered streams will cascade harmlessly. */ flushBuffer(); out.write(cbuf, off, len); return; } int b = off, t = off + len; while (b < t) { int d = min(nChars - nextChar, t - b); System.arraycopy(cbuf, b, cb, nextChar, d); b += d; nextChar += d; if (nextChar >= nChars) flushBuffer(); } } } /** * Write a portion of a String. * * <p> * If the value of the <tt>len</tt> parameter is negative then no characters are written. This is contrary to the * specification of this method in the {@linkplain java.io.Writer#write(java.lang.String,int,int) superclass}, * which requires that an {@link IndexOutOfBoundsException} be thrown. * * @param s String to be written * @param off Offset from which to start reading characters * @param len Number of characters to be written * * @user xzhang * * @exception IOException If an I/O error occurs */ public void write(String s, int off, int len) throws IOException { synchronized (lock) { ensureOpen(); if (len >= nChars) { /* * If the request length exceeds the size of the output buffer, flush the buffer and then write the data * directly. In this way buffered streams will cascade harmlessly. */ flushBuffer(); char[] cbuf = new char[len]; s.getChars(off, (off + len), cbuf, 0); write(cbuf, 0, len); return; } if (len > 0) { /* * If it doesn't write all char of string to buffer, flush buffer chars then put the String to buffer. * Make sure String doesn't cut by ohter writer. */ if (nChars - nextChar < len) { flushBuffer(); } s.getChars(off, off + len, cb, nextChar); nextChar += len; if (nextChar >= nChars) flushBuffer(); } } } /** * Write a line separator. The line separator string is defined by the system property <tt>line.separator</tt>, * and is not necessarily a single newline ('\n') character. * * @exception IOException If an I/O error occurs */ public void newLine() throws IOException { write(lineSeparator); } /** * Flush the stream. * * @exception IOException If an I/O error occurs */ public void flush() throws IOException { synchronized (lock) { flushBuffer(); out.flush(); } } /** * Close the stream. * * @exception IOException If an I/O error occurs */ public void close() throws IOException { synchronized (lock) { if (out == null) return; flushBuffer(); out.close(); out = null; cb = null; } } }
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de