src/java/nginx/unit/OutputStream.java


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

package nginx.unit;

import java.io.IOException;

import javax.servlet.ServletOutputStream;
import javax.servlet.WriteListener;

public class OutputStream extends ServletOutputStream {

    private long req_info_ptr;

    public OutputStream(long ptr) {
        req_info_ptr = ptr;
    }

    @Override
    public void write(int b) throws IOException
    {
        write(req_info_ptr, b);
    }

    private static native void write(long req_info_ptr, int b);


    @Override
    public void write(byte b[], int off, int len) throws IOException
    {
        if (b == null) {
            throw new NullPointerException();
        } else if ((off < 0) || (off > b.length) || (len < 0) ||
                   ((off + len) > b.length) || ((off + len) < 0)) {
            throw new IndexOutOfBoundsException();
        } else if (len == 0) {
            return;
        }

        write(req_info_ptr, b, off, len);
    }

    private static native void write(long req_info_ptr, byte b[], int off, int len);

    @Override
    public void flush()
    {
        flush(req_info_ptr);
    }

    private static native void flush(long req_info_ptr);

    @Override
    public void close()
    {
        close(req_info_ptr);
    }

    private static native void close(long req_info_ptr);

    @Override
    public boolean isReady()
    {
        return true;
    }

    @Override
    public void setWriteListener(WriteListener listener)
    {
    }
}