()
| 192 | io.setExtOutputStream(out, dontclose); |
| 193 | } |
| 194 | public InputStream getInputStream() throws IOException { |
| 195 | int max_input_buffer_size = 32*1024; |
| 196 | try { |
| 197 | max_input_buffer_size = |
| 198 | Integer.parseInt(getSession().getConfig("max_input_buffer_size")); |
| 199 | } |
| 200 | catch(Exception e){} |
| 201 | PipedInputStream in = |
| 202 | new MyPipedInputStream( |
| 203 | 32*1024, // this value should be customizable. |
| 204 | max_input_buffer_size |
| 205 | ); |
| 206 | boolean resizable = 32*1024<max_input_buffer_size; |
| 207 | io.setOutputStream(new PassiveOutputStream(in, resizable), false); |
| 208 | return in; |
| 209 | } |
| 210 | public InputStream getExtInputStream() throws IOException { |
| 211 | int max_input_buffer_size = 32*1024; |
| 212 | try { |
nothing calls this directly
no test coverage detected