1211

pending completion

Build # 1211

Build Type

Pull #184

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/apache/commons-io/commit/<a class=hub.com/apache/commons-io/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/commons-io/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/commons-io/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/commons-io/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed18606935b69">16dfcbe33">&lt;a href=&quot;https://github.com/apache/commons-io/commit/</a><a class="double-link" href="https://github.com/apache/commons-io/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/commons-io/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/commons-io/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed18606935b69">16dfcbe33</a><a href="https://github.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed18606935b69">&lt;a href=&quot;https://github.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed18606935b69&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/apache/commons-io/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/apache/commons-io/commit/&amp;amp;lt;a class=&amp;amp;quot;double-link&amp;amp;quot; href=&amp;amp;quot;https://git&amp;quot;&amp;gt;&amp;amp;lt;a class=&amp;lt;/a&amp;gt;hub.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed18606935b69&amp;quot;&amp;gt;16dfcbe33&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed18606935b69&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/apache/commons-io/commit/16dfcbe33078acbfc642face064ed186&amp;lt;/a&amp;gt;06935</a>b69&quot;&gt;&amp;quot;&amp;gt;Merge &amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/apache/commons-io/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/apache/commons-io/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/commons-io/commit/bd9fd8af0&quot;&gt;bd9fd8a... (continued)

Pull Request Pull Request #184: [IO-698] add Unsynchronized version of UnsynchronizedBufferedInputStream and UnsynchronizedBufferedInputStream, and performance tests.

Run Details

110 of 110 new or added lines in 2 files covered. (100.0%)

6054 of 6827 relevant lines covered (88.68%)

44814.36 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

85.45

/src/main/java/org/apache/commons/io/input/buffer/UnsynchronizedBufferedReader.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.commons.io.input.buffer;

import java.io.IOException;
import java.io.Reader;
import org.apache.commons.io.IOUtils;
import static org.apache.commons.io.IOUtils.EOF;

/**
 * A BufferedReader class who does not care about thread safety, but very much faster.
 *
 * Should be able to replace java.io.BufferedReader in nearly every use-cases when you
 * need the Reader be buffered, but do not need it have thread safety.
 */
public class UnsynchronizedBufferedReader extends Reader {
    private final Reader reader;
    private final char[] charBuffer;

    private int nowIndex = 0;
    private int nowLimit = 0;

    /**
     * Creates a new instance, which filters the given reader, and
     * uses the given buffer size.
     *
     * @param reader The original reader, which is being buffered.
     * @param charBufferSize size of the buffer.
     */
    public UnsynchronizedBufferedReader(Reader reader, int charBufferSize) {
        this(reader, new char[charBufferSize]);
    }

    /**
     * Creates a new instance, which filters the given reader, and
     * uses IOUtils.DEFAULT_BUFFER_SIZE.
     *
     * @param reader The original reader, which is being buffered.
     * @see IOUtils#DEFAULT_BUFFER_SIZE
     */
    public UnsynchronizedBufferedReader(Reader reader) {
        this(reader, IOUtils.DEFAULT_BUFFER_SIZE);
    }

    /**
     * Creates a new instance, which filters the given reader, and
     * uses the given buffer.
     *
     * @param reader The original reader, which is being buffered.
     * @param charBuffer buffer used.
     */
    public UnsynchronizedBufferedReader(Reader reader, char[] charBuffer) {
        this.reader = reader;
        this.charBuffer = charBuffer;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public int read(char[] cbuf, int off, int len) throws IOException {
        if (len <= 0) {
            return 0;
        }
        int currentBufferSize = this.nowLimit - this.nowIndex;
        if (currentBufferSize == 0) {
            int readLength;
            do {
                readLength = this.reader.read(this.charBuffer, 0, this.charBuffer.length);
            } while (readLength == 0);
            if (readLength == EOF) {
                return EOF;
            }
            this.nowLimit = readLength;
            this.nowIndex = 0;
            currentBufferSize = this.nowLimit - this.nowIndex;
        }
        if (currentBufferSize <= len) {
            System.arraycopy(this.charBuffer, this.nowIndex, cbuf, off, currentBufferSize);
            this.nowLimit = this.nowIndex = 0;
            return currentBufferSize;
        } else {
            System.arraycopy(this.charBuffer, this.nowIndex, cbuf, off, len);
            this.nowIndex += len;
            return len;
        }
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public int read() throws IOException {
        int res = this.peek();
        if (res != EOF) {
            eat();
        }
        return res;
    }

    /**
     * see the next char, but not mark it as read.
     *
     * @return the next char
     * @throws IOException by reader.read()
     * @see #read()
     */
    public int peek() throws IOException {
        int currentBufferSize = this.nowLimit - this.nowIndex;
        if (currentBufferSize == 0) {
            int readLength;
            do {
                readLength = this.reader.read(this.charBuffer, 0, this.charBuffer.length);
            } while (readLength == 0);
            if (readLength == EOF) {
                return EOF;
            }
            this.nowLimit = readLength;
            this.nowIndex = 0;
            return this.charBuffer[0];
        }
        return this.charBuffer[this.nowIndex];
    }

    /**
     * mark the current char as read.
     * must be used after invoke peek.
     *
     * @see #read()
     * @see #peek()
     */
    public void eat() {
        this.nowIndex++;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public void close() throws IOException {
        if (this.reader != null) {
            this.reader.close();
        }
    }

    /**
     * getter for this.reader
     * @return this.reader
     */
    public Reader getReader() {
        return this.reader;
    }

    /**
     * getter for this.charBuffer
     * @return this.charBuffer
     */
    public char[] getCharBuffer() {
        return this.charBuffer;
    }

    /**
     * getter for this.nowIndex
     * @return this.nowIndex
     */
    public int getNowIndex() {
        return this.nowIndex;
    }

    /**
     * setter for this.nowIndex
     * @param nowIndex this.nowIndex
     */
    public void setNowIndex(int nowIndex) {
        this.nowIndex = nowIndex;
    }

    /**
     * getter for this.nowLimit
     * @return this.nowLimit
     */
    public int getNowLimit() {
        return this.nowLimit;
    }

    /**
     * setter for this.nowLimit
     * @param nowLimit this.nowLimit
     */
    public void setNowLimit(int nowLimit) {
        this.nowLimit = nowLimit;
    }
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17	package org.apache.commons.io.input.buffer;
18
19	import java.io.IOException;
20	import java.io.Reader;
21	import org.apache.commons.io.IOUtils;
22	import static org.apache.commons.io.IOUtils.EOF;
23
24	/**
25	* A BufferedReader class who does not care about thread safety, but very much faster.
26	*
27	* Should be able to replace java.io.BufferedReader in nearly every use-cases when you
28	* need the Reader be buffered, but do not need it have thread safety.
29	*/
30	public class UnsynchronizedBufferedReader extends Reader {
31	private final Reader reader;
32	private final char[] charBuffer;
33
34	private int nowIndex = 0;	6✔
35	private int nowLimit = 0;	6✔
36
37	/**
38	* Creates a new instance, which filters the given reader, and
39	* uses the given buffer size.
40	*
41	* @param reader The original reader, which is being buffered.
42	* @param charBufferSize size of the buffer.
43	*/
44	public UnsynchronizedBufferedReader(Reader reader, int charBufferSize) {
45	this(reader, new char[charBufferSize]);	6✔
46	}	6✔
47
48	/**
49	* Creates a new instance, which filters the given reader, and
50	* uses IOUtils.DEFAULT_BUFFER_SIZE.
51	*
52	* @param reader The original reader, which is being buffered.
53	* @see IOUtils#DEFAULT_BUFFER_SIZE
54	*/
55	public UnsynchronizedBufferedReader(Reader reader) {
56	this(reader, IOUtils.DEFAULT_BUFFER_SIZE);	5✔
57	}	5✔
58
59	/**
60	* Creates a new instance, which filters the given reader, and
61	* uses the given buffer.
62	*
63	* @param reader The original reader, which is being buffered.
64	* @param charBuffer buffer used.
65	*/
66	public UnsynchronizedBufferedReader(Reader reader, char[] charBuffer) {	6✔
67	this.reader = reader;	6✔
68	this.charBuffer = charBuffer;	6✔
69	}	6✔
70
71	/**
72	* {@inheritDoc}
73	*/
74	@Override
75	public int read(char[] cbuf, int off, int len) throws IOException {
76	if (len <= 0) {	90✔
77	return 0;	2✔
78	}
79	int currentBufferSize = this.nowLimit - this.nowIndex;	88✔
80	if (currentBufferSize == 0) {	88✔
81	int readLength;
82	do {
83	readLength = this.reader.read(this.charBuffer, 0, this.charBuffer.length);	19✔
84	} while (readLength == 0);	19✔
85	if (readLength == EOF) {	19✔
86	return EOF;	1✔
87	}
88	this.nowLimit = readLength;	18✔
89	this.nowIndex = 0;	18✔
90	currentBufferSize = this.nowLimit - this.nowIndex;	18✔
91	}
92	if (currentBufferSize <= len) {	87✔
93	System.arraycopy(this.charBuffer, this.nowIndex, cbuf, off, currentBufferSize);	34✔
94	this.nowLimit = this.nowIndex = 0;	34✔
95	return currentBufferSize;	34✔
96	} else {
97	System.arraycopy(this.charBuffer, this.nowIndex, cbuf, off, len);	53✔
98	this.nowIndex += len;	53✔
99	return len;	53✔
100	}
101	}
102
103	/**
104	* {@inheritDoc}
105	*/
106	@Override
107	public int read() throws IOException {
108	int res = this.peek();	99✔
109	if (res != EOF) {	99✔
110	eat();	98✔
111	}
112	return res;	99✔
113	}
114
115	/**
116	* see the next char, but not mark it as read.
117	*
118	* @return the next char
119	* @throws IOException by reader.read()
120	* @see #read()
121	*/
122	public int peek() throws IOException {
123	int currentBufferSize = this.nowLimit - this.nowIndex;	99✔
124	if (currentBufferSize == 0) {	99✔
125	int readLength;
126	do {
127	readLength = this.reader.read(this.charBuffer, 0, this.charBuffer.length);	18✔
128	} while (readLength == 0);	18✔
129	if (readLength == EOF) {	18✔
130	return EOF;	1✔
131	}
132	this.nowLimit = readLength;	17✔
133	this.nowIndex = 0;	17✔
134	return this.charBuffer[0];	17✔
135	}
136	return this.charBuffer[this.nowIndex];	81✔
137	}
138
139	/**
140	* mark the current char as read.
141	* must be used after invoke peek.
142	*
143	* @see #read()
144	* @see #peek()
145	*/
146	public void eat() {
147	this.nowIndex++;	98✔
148	}	98✔
149
150	/**
151	* {@inheritDoc}
152	*/
153	@Override
154	public void close() throws IOException {
155	if (this.reader != null) {	11✔
156	this.reader.close();	6✔
157	}
158	}	11✔
159
160	/**
161	* getter for this.reader
162	* @return this.reader
163	*/
164	public Reader getReader() {
165	return this.reader;	×
166	}
167
168	/**
169	* getter for this.charBuffer
170	* @return this.charBuffer
171	*/
172	public char[] getCharBuffer() {
173	return this.charBuffer;	×
174	}
175
176	/**
177	* getter for this.nowIndex
178	* @return this.nowIndex
179	*/
180	public int getNowIndex() {
181	return this.nowIndex;	×
182	}
183
184	/**
185	* setter for this.nowIndex
186	* @param nowIndex this.nowIndex
187	*/
188	public void setNowIndex(int nowIndex) {
189	this.nowIndex = nowIndex;	×
190	}	×
191
192	/**
193	* getter for this.nowLimit
194	* @return this.nowLimit
195	*/
196	public int getNowLimit() {
197	return this.nowLimit;	×
198	}
199
200	/**
201	* setter for this.nowLimit
202	* @param nowLimit this.nowLimit
203	*/
204	public void setNowLimit(int nowLimit) {
205	this.nowLimit = nowLimit;	×
206	}	×
207	}

apache / commons-io / 1211

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous