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
|
package nginx.unit;
import java.io.IOException;
import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
public class InputStream extends ServletInputStream {
private long req_info_ptr;
public InputStream(long ptr)
{
req_info_ptr = ptr;
}
@Override
public int readLine(byte[] b, int off, int len) throws IOException {
if (len <= 0) {
return 0;
}
return readLine(req_info_ptr, b, off, len);
}
private static native int readLine(long req_info_ptr, byte[] b, int off, int len);
@Override
public boolean isFinished()
{
return isFinished(req_info_ptr);
}
private static native boolean isFinished(long req_info_ptr);
@Override
public boolean isReady()
{
return true;
}
@Override
public void setReadListener(ReadListener listener)
{
}
@Override
public int read() throws IOException
{
return read(req_info_ptr);
}
private static native int read(long req_info_ptr);
@Override
public int read(byte b[], int off, int len) throws IOException {
if (b == null) {
throw new NullPointerException();
} else if (off < 0 || len < 0 || len > b.length - off) {
throw new IndexOutOfBoundsException();
} else if (len == 0) {
return 0;
}
return read(req_info_ptr, b, off, len);
}
private static native int read(long req_info_ptr, byte b[], int off, int len);
@Override
public long skip(long n) throws IOException {
return skip(req_info_ptr, n);
}
private static native long skip(long req_info_ptr, long n);
@Override
public int available() throws IOException {
return available(req_info_ptr);
}
private static native int available(long req_info_ptr);
}
|
