KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > maverick > http > ChunkedContentSource


1 /*
2  * SSL-Explorer
3  *
4  * Copyright (C) 2003-2006 3SP LTD. All Rights Reserved
5  *
6  * This program is free software; you can redistribute it and/or
7  * modify it under the terms of the GNU General Public License
8  * as published by the Free Software Foundation; either version 2 of
9  * the License, or (at your option) any later version.
10  * This program is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13  * GNU General Public License for more details.
14  *
15  * You should have received a copy of the GNU General Public
16  * License along with this program; if not, write to the Free Software
17  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
18  */
19             
20 package com.maverick.http;
21
22 import java.io.IOException JavaDoc;
23 import java.io.OutputStream JavaDoc;
24
25 /**
26  *
27  * @author Lee David Painter <a HREF="mailto:lee@3sp.com">&lt;lee@3sp.com&gt;</a>
28  */
29 public class ChunkedContentSource implements ContentSource {
30
31     ChunkedOutputStream actualOut = new ChunkedOutputStream();
32     HttpConnection con;
33
34     long bytesTransfered = 0;
35
36     public ChunkedContentSource() throws IOException JavaDoc {
37
38     }
39
40     public long getBytesTransferred() {
41         return bytesTransfered;
42     }
43
44     public void setHeaders(HttpRequest request, HttpConnection con) {
45         this.con = con;
46         request.setHeaderField("transfer-encoding", "chunked"); //$NON-NLS-1$ //$NON-NLS-2$
47 }
48
49     public OutputStream JavaDoc getOutputStream() {
50         return actualOut;
51     }
52
53     class ChunkedOutputStream extends OutputStream JavaDoc {
54
55         public void write(byte[] buf, int off, int len) throws IOException JavaDoc {
56             bytesTransfered += len;
57             con.getOutputStream().write((Integer.toHexString(len) + "\r\n").getBytes("UTF8")); //$NON-NLS-1$ //$NON-NLS-2$
58 con.getOutputStream().write(buf, off, len);
59             con.getOutputStream().write("\r\n".getBytes("UTF8")); //$NON-NLS-1$ //$NON-NLS-2$
60 }
61
62         public void write(int b) throws IOException JavaDoc {
63             write(new byte[] { (byte) b }, 0, 1);
64         }
65
66         public void close() throws IOException JavaDoc {
67             con.getOutputStream().write("0\r\n\r\n".getBytes("UTF8")); //$NON-NLS-1$ //$NON-NLS-2$
68 }
69     }
70 }
71
Popular Tags