001: //httpChunkedOutputStream.java
002: //-------------------------------------
003: //part of YACY
004: //(C) by Michael Peter Christen; mc@anomic.de
005: //first published on http://www.anomic.de
006: //Frankfurt, Germany, 2004
007: //
008: //This file ist contributed by Martin Thelian
009: //last major change: 05.09.2005
010: //
011: //This program is free software; you can redistribute it and/or modify
012: //it under the terms of the GNU General Public License as published by
013: //the Free Software Foundation; either version 2 of the License, or
014: //(at your option) any later version.
015: //
016: //This program is distributed in the hope that it will be useful,
017: //but WITHOUT ANY WARRANTY; without even the implied warranty of
018: //MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
019: //GNU General Public License for more details.
020: //
021: //You should have received a copy of the GNU General Public License
022: //along with this program; if not, write to the Free Software
023: //Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
024: //
025: //Using this software in any meaning (reading, learning, copying, compiling,
026: //running) means that you agree that the Author(s) is (are) not responsible
027: //for cost, loss of data or any harm that may be caused directly or indirectly
028: //by usage of this softare or this documentation. The usage of this software
029: //is on your own risk. The installation and usage (starting/running) of this
030: //software may allow other people or application to access your computer and
031: //any attached devices and is highly dependent on the configuration of the
032: //software which must be done by the user of the software; the author(s) is
033: //(are) also not responsible for proper configuration and usage of the
034: //software, even if provoked by documentation provided together with
035: //the software.
036: //
037: //Any changes to this file according to the GPL as documented in the file
038: //gpl.txt aside this file in the shipment you received can be done to the
039: //lines that follows this copyright notice here, but changes must not be
040: //done inside the copyright notive above. A re-distribution must contain
041: //the intact and unchanged copyright notice.
042: //Contributions and changes to the program code must be marked as such.
043:
044: package de.anomic.http;
045:
046: import java.io.FilterOutputStream;
047: import java.io.IOException;
048: import java.io.InputStream;
049: import java.io.OutputStream;
050:
051: import de.anomic.server.serverByteBuffer;
052: import de.anomic.server.serverCore;
053: import de.anomic.server.serverFileUtils;
054:
055: public final class httpChunkedOutputStream extends FilterOutputStream {
056: private boolean finished = false;
057:
058: public httpChunkedOutputStream(OutputStream out) {
059: super (out);
060: }
061:
062: public void close() throws IOException {
063: if (!this .finished)
064: this .finish();
065: this .out.close();
066: }
067:
068: public void finish() throws IOException {
069: if (!this .finished) {
070: this .out.write((byte) 48);
071: this .out.write(serverCore.CRLF);
072: this .out.write(serverCore.CRLF);
073: this .out.flush();
074: this .finished = true;
075: }
076: }
077:
078: public void write(byte[] b) throws IOException {
079: if (this .finished)
080: throw new IOException(
081: "ChunkedOutputStream already finalized.");
082: if (b.length == 0)
083: return;
084:
085: this .out.write(Integer.toHexString(b.length).getBytes());
086: this .out.write(serverCore.CRLF);
087: this .out.write(b);
088: this .out.write(serverCore.CRLF);
089: this .out.flush();
090: }
091:
092: public void write(byte[] b, int off, int len) throws IOException {
093: if (this .finished)
094: throw new IOException(
095: "ChunkedOutputStream already finalized.");
096: if (len == 0)
097: return;
098:
099: this .out.write(Integer.toHexString(len).getBytes());
100: this .out.write(serverCore.CRLF);
101: this .out.write(b, off, len);
102: this .out.write(serverCore.CRLF);
103: this .out.flush();
104: }
105:
106: public void write(serverByteBuffer b, int off, int len)
107: throws IOException {
108: if (this .finished)
109: throw new IOException(
110: "ChunkedOutputStream already finalized.");
111: if (len == 0)
112: return;
113:
114: this .out.write(Integer.toHexString(len).getBytes());
115: this .out.write(serverCore.CRLF);
116: this .out.write(b.getBytes(off, len));
117: this .out.write(serverCore.CRLF);
118: this .out.flush();
119: }
120:
121: public void write(InputStream b) throws IOException {
122: if (this .finished)
123: throw new IOException(
124: "ChunkedOutputStream already finalized.");
125: int len = b.available();
126: if (len == 0)
127: return;
128:
129: this .out.write(Integer.toHexString(len).getBytes());
130: this .out.write(serverCore.CRLF);
131: serverFileUtils.copy(b, out, len);
132: this .out.write(serverCore.CRLF);
133: this .out.flush();
134: }
135:
136: public void write(int b) throws IOException {
137: if (this .finished)
138: throw new IOException(
139: "ChunkedOutputStream already finalized.");
140:
141: this .out.write("1".getBytes());
142: this.out.write(serverCore.CRLF);
143: this.out.write(b);
144: this.out.write(serverCore.CRLF);
145: this.out.flush();
146: }
147: }
|