blob: 9b284cbd88925d26a9075834230a8a09189a0ffb (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
/*******************************************************************************
* Copyright (c) 2001, 2006 IBM Corporation and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* IBM Corporation - initial API and implementation
* Jens Lukowski/Innoopract - initial renaming/restructuring
* Angelo Zerr <angelo.zerr@gmail.com> - copied from org.eclipse.wst.css.core.internal.contenttype.ByteReader
* modified in order to process JSON Objects.
*******************************************************************************/
package org.eclipse.wst.json.core.internal.contenttype;
import java.io.IOException;
import java.io.InputStream;
import java.io.Reader;
import org.eclipse.wst.sse.core.internal.encoding.CodedIO;
/**
* This is an "adapter" class, simply to get in input stream to act like a
* reader. We could not use InputStreamReader directly because its internal
* buffers are not controllable, and it sometimes pulls too much out of input
* stream (even when it wasn't needed for our purposes).
*
* The use of this class is highly specialized and by no means meant to be
* general purpose. Its use is restricted to those cases where the input
* stream can be regarded as ascii just long enough to determine what the real
* encoding should be.
*/
public class ByteReader extends Reader {
public static final int DEFAULT_BUFFER_SIZE = CodedIO.MAX_BUF_SIZE;
protected byte[] fBuffer;
protected InputStream fInputStream;
protected ByteReader() {
super();
}
public ByteReader(InputStream inputStream) {
this(inputStream, DEFAULT_BUFFER_SIZE);
if (!inputStream.markSupported()) {
throw new IllegalArgumentException("ByteReader is required to have a resettable stream"); //$NON-NLS-1$
}
}
public ByteReader(InputStream inputStream, int size) {
this.fInputStream = inputStream;
if (!inputStream.markSupported()) {
throw new IllegalArgumentException("ByteReader is required to have a resettable stream"); //$NON-NLS-1$
}
this.fBuffer = new byte[size];
}
public void close() throws IOException {
this.fInputStream.close();
}
public void mark(int readAheadLimit) {
this.fInputStream.mark(readAheadLimit);
}
public boolean markSupported() {
return true;
}
public int read() throws IOException {
int b0 = this.fInputStream.read();
return (b0 & 0x00FF);
}
public int read(char ch[], int offset, int length) throws IOException {
if (length > this.fBuffer.length) {
length = this.fBuffer.length;
}
int count = this.fInputStream.read(this.fBuffer, 0, length);
for (int i = 0; i < count; i++) {
int b0 = this.fBuffer[i];
// the 0x00FF is to "lose" the negative bits filled in the byte to
// int conversion
// (and which would be there if cast directly from byte to char).
char c0 = (char) (b0 & 0x00FF);
ch[offset + i] = c0;
}
return count;
}
public boolean ready() throws IOException {
return this.fInputStream.available() > 0;
}
public void reset() throws IOException {
this.fInputStream.reset();
}
public long skip(long n) throws IOException {
return this.fInputStream.skip(n);
}
}
|
