Mercurial Hosting > luan

annotate src/org/eclipse/jetty/http/HttpGenerator.java @ 1066:bbbda7c6e8ec

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix use of HttpGenerator._header
author Franklin Schmidt <fschmidt@gmail.com>
date Wed, 09 Nov 2016 05:48:10 -0700
parents 158d1e6ac17f
children 56b515be91e1
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
1 //
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
2 // ========================================================================
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
3 // Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd.
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
4 // ------------------------------------------------------------------------
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
5 // All rights reserved. This program and the accompanying materials
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
6 // are made available under the terms of the Eclipse Public License v1.0
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
7 // and Apache License v2.0 which accompanies this distribution.
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
8 //
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
9 // The Eclipse Public License is available at
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
10 // http://www.eclipse.org/legal/epl-v10.html
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
11 //
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
12 // The Apache License v2.0 is available at
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
13 // http://www.opensource.org/licenses/apache2.0.php
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
14 //
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
15 // You may elect to redistribute this code under either of these licenses.
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
16 // ========================================================================
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
17 //
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
18
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
19 package org.eclipse.jetty.http;
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
20
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
21 import java.io.IOException;
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
22 import java.io.InterruptedIOException;
1039
a7319f14ba1e remove Buffer.isImmutable()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1038
diff changeset
23 import java.util.Arrays;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
24
1048
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
25 import org.eclipse.jetty.io.JBuffer;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
26 import org.eclipse.jetty.io.BufferUtil;
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
27 import org.eclipse.jetty.io.Buffers;
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
28 import org.eclipse.jetty.io.EndPoint;
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
29 import org.eclipse.jetty.io.EofException;
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
30 import org.eclipse.jetty.util.StringUtil;
884
cb78ee27b0e0 remove Server.getVersion()
Franklin Schmidt <fschmidt@gmail.com>
parents: 877
diff changeset
31 import org.eclipse.jetty.server.Server;
820
8e9db0bbf4f9 remove org.eclipse.jetty.util.log and upgrade slf4j
Franklin Schmidt <fschmidt@gmail.com>
parents: 802
diff changeset
32 import org.slf4j.Logger;
8e9db0bbf4f9 remove org.eclipse.jetty.util.log and upgrade slf4j
Franklin Schmidt <fschmidt@gmail.com>
parents: 802
diff changeset
33 import org.slf4j.LoggerFactory;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
34
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
35 /* ------------------------------------------------------------ */
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
36 /**
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
37 * HttpGenerator. Builds HTTP Messages.
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
38 *
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
39 *
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
40 *
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
41 */
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
42 public final class HttpGenerator
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
43 {
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
44 private static final Logger LOG = LoggerFactory.getLogger(HttpGenerator.class);
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
45
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
46 // Build cache of response lines for status
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
47 private static class Status
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
48 {
1039
a7319f14ba1e remove Buffer.isImmutable()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1038
diff changeset
49 byte[] _schemeCode;
a7319f14ba1e remove Buffer.isImmutable()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1038
diff changeset
50 byte[] _responseLine;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
51 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
52 private static final Status[] __status = new Status[HttpStatus.MAX_CODE+1];
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
53 static
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
54 {
1019
f126d30e04a4 start replacing BufferCache with StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 990
diff changeset
55 final int versionLength=HttpVersions.HTTP_1_1_BYTES.length;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
56
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
57 for (int i=0;i<__status.length;i++)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
58 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
59 HttpStatus.Code code = HttpStatus.getCode(i);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
60 if (code==null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
61 continue;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
62 String reason=code.getMessage();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
63 byte[] bytes=new byte[versionLength+5+reason.length()+2];
1019
f126d30e04a4 start replacing BufferCache with StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 990
diff changeset
64 // HttpVersions.HTTP_1_1_BUFFER.peek(0,bytes, 0, versionLength);
f126d30e04a4 start replacing BufferCache with StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 990
diff changeset
65 System.arraycopy(HttpVersions.HTTP_1_1_BYTES,0,bytes,0,versionLength);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
66 bytes[versionLength+0]=' ';
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
67 bytes[versionLength+1]=(byte)('0'+i/100);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
68 bytes[versionLength+2]=(byte)('0'+(i%100)/10);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
69 bytes[versionLength+3]=(byte)('0'+(i%10));
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
70 bytes[versionLength+4]=' ';
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
71 for (int j=0;j<reason.length();j++)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
72 bytes[versionLength+5+j]=(byte)reason.charAt(j);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
73 bytes[versionLength+5+reason.length()]=HttpTokens.CARRIAGE_RETURN;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
74 bytes[versionLength+6+reason.length()]=HttpTokens.LINE_FEED;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
75
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
76 __status[i] = new Status();
1039
a7319f14ba1e remove Buffer.isImmutable()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1038
diff changeset
77 __status[i]._schemeCode = Arrays.copyOf(bytes,versionLength+5);
a7319f14ba1e remove Buffer.isImmutable()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1038
diff changeset
78 __status[i]._responseLine = bytes;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
79 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
80 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
81
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
82
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
83 // common _content
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
84 private static final byte[] LAST_CHUNK =
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
85 { (byte) '0', (byte) '\015', (byte) '\012', (byte) '\015', (byte) '\012'};
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
86 private static final byte[] CONTENT_LENGTH_0 = StringUtil.getBytes("Content-Length: 0\015\012");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
87 private static final byte[] CONNECTION_KEEP_ALIVE = StringUtil.getBytes("Connection: keep-alive\015\012");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
88 private static final byte[] CONNECTION_CLOSE = StringUtil.getBytes("Connection: close\015\012");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
89 private static final byte[] CONNECTION_ = StringUtil.getBytes("Connection: ");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
90 private static final byte[] CRLF = StringUtil.getBytes("\015\012");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
91 private static final byte[] TRANSFER_ENCODING_CHUNKED = StringUtil.getBytes("Transfer-Encoding: chunked\015\012");
884
cb78ee27b0e0 remove Server.getVersion()
Franklin Schmidt <fschmidt@gmail.com>
parents: 877
diff changeset
92 private static byte[] SERVER = StringUtil.getBytes("Server: Jetty("+Server.version+")\015\012");
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
93
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
94 // other statics
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
95 private static final int CHUNK_SPACE = 12;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
96
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
97 // data
983
23ec25435b8c simplify AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 982
diff changeset
98 private boolean _bypass = false; // True if _content buffer can be written directly to endp and bypass the content buffer
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
99 private boolean _needCRLF = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
100 private boolean _needEOC = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
101 private boolean _bufferChunked = false;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
102
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
103
1034
563458c4dc93 remove HttpGenerator.reset()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1022
diff changeset
104 public void shutdown() {
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
105 if (_persistent!=null && !_persistent && !_endp.isOutputShutdown())
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
106 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
107 try
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
108 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
109 _endp.shutdownOutput();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
110 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
111 catch(IOException e)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
112 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
113 LOG.trace("",e);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
114 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
115 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
116 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
117
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
118 /* ------------------------------------------------------------ */
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
119 /**
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
120 * Add content.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
121 *
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
122 * @param content
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
123 * @param last
1048
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
124 * @throws IllegalArgumentException if <code>content</code> is {@link JBuffer#isImmutable immutable}.
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
125 * @throws IllegalStateException If the request is not expecting any more content,
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
126 * or if the buffers are full and cannot be flushed.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
127 * @throws IOException if there is a problem flushing the buffers.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
128 */
1048
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
129 public void addContent(JBuffer content, boolean last) throws IOException
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
130 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
131 if (_noContent)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
132 throw new IllegalStateException("NO CONTENT");
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
133
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
134 if (_last || _state==STATE_END)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
135 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
136 LOG.warn("Ignoring extra content {}",content);
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
137 // content.clear();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
138 return;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
139 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
140 _last = last;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
141
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
142 // Handle any unfinished business?
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
143 if (_content!=null && _content.remaining()>0 || _bufferChunked)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
144 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
145 if (_endp.isOutputShutdown())
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
146 throw new EofException();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
147 flushBuffer();
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
148 if (_content != null && _content.remaining()>0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
149 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
150 if (_bufferChunked)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
151 {
1048
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
152 JBuffer nc = _buffers.getBuffer(_content.remaining()+CHUNK_SPACE+content.remaining());
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
153 nc.clear();
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
154 nc.putQ(_content);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
155 nc.putQ(HttpTokens.CRLF);
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
156 BufferUtil.putHexInt(nc, content.remaining());
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
157 nc.putQ(HttpTokens.CRLF);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
158 nc.putQ(content);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
159 nc.flip();
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
160 content = nc;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
161 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
162 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
163 {
1048
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
164 JBuffer nc = _buffers.getBuffer(_content.remaining()+content.remaining());
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
165 nc.clear();
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
166 nc.putQ(_content);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
167 nc.putQ(content);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
168 nc.flip();
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
169 content = nc;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
170 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
171 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
172 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
173
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
174 _content = content;
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
175 _contentWritten += content.remaining();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
176
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
177 // Handle the _content
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
178 if (_head)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
179 {
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
180 // content.clear();
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
181 _content = null;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
182 }
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
183 else if ((_buffer==null || _buffer.remaining()==0) && _content.remaining() > 0 && (_last || isCommitted() && _content.remaining()>1024))
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
184 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
185 _bypass = true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
186 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
187 else if (!_bufferChunked)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
188 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
189 // Yes - so we better check we have a buffer
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
190 if (_buffer == null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
191 _buffer = _buffers.getBuffer();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
192
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
193 // Copy _content to buffer;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
194 int len=_buffer.put(_content);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
195 _content.skip(len);
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
196 if (_content.remaining() == 0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
197 _content = null;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
198 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
199 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
200
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
201 /* ------------------------------------------------------------ */
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
202 /** Prepare buffer for unchecked writes.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
203 * Prepare the generator buffer to receive unchecked writes
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
204 * @return the available space in the buffer.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
205 * @throws IOException
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
206 */
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
207 public void prepareUncheckedAddContent() throws IOException
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
208 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
209 if (_noContent)
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
210 // return -1;
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
211 throw new RuntimeException("_noContent");
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
212
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
213 if (_last || _state==STATE_END)
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
214 // return -1;
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
215 throw new RuntimeException("_last");
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
216
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
217 // Handle any unfinished business?
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
218 if (_content != null && _content.remaining()>0 || _bufferChunked)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
219 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
220 flushBuffer();
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
221 if (_content != null && _content.remaining()>0 || _bufferChunked)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
222 throw new IllegalStateException("FULL");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
223 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
224
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
225 _contentWritten -= _buffer.remaining();
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
226 /*
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
227 // Handle the _content
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
228 if (_head)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
229 return Integer.MAX_VALUE;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
230
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
231 return _buffer.space();
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
232 */
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
233 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
234
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
235 public boolean isBufferFull()
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
236 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
237 // Should we flush the buffers?
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
238 return isBufferFull2() || _bufferChunked || _bypass /* || (_contentLength == HttpTokens.CHUNKED_CONTENT && _buffer != null && _buffer.space() < CHUNK_SPACE)*/;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
239 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
240
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
241 public void send1xx(int code) throws IOException
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
242 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
243 if (_state != STATE_HEADER)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
244 return;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
245
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
246 if (code<100||code>199)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
247 throw new IllegalArgumentException("!1xx");
983
23ec25435b8c simplify AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 982
diff changeset
248 Status status = __status[code];
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
249 if (status==null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
250 throw new IllegalArgumentException(code+"?");
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
251
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
252 _header.putQ(status._responseLine);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
253 _header.putQ(HttpTokens.CRLF);
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
254
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
255 try
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
256 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
257 // nasty semi busy flush!
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
258 _header.flip();
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
259 while(_header.remaining()>0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
260 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
261 int len = _endp.flush(_header);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
262 if (len<0)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
263 throw new EofException();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
264 if (len==0)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
265 Thread.sleep(100);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
266 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
267 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
268 catch(InterruptedException e)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
269 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
270 LOG.debug("",e);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
271 throw new InterruptedIOException(e.toString());
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
272 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
273 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
274
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
275 public void completeHeader(HttpFields fields, boolean allContentAdded) throws IOException
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
276 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
277 if (_state != STATE_HEADER)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
278 return;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
279
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
280 // handle a reset
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
281 if (_status==0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
282 throw new EofException();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
283
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
284 if (_last && !allContentAdded)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
285 throw new IllegalStateException("last?");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
286 _last = _last | allContentAdded;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
287
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
288 boolean has_server = false;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
289
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
290 try
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
291 {
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
292 // Responses
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
293 if (_version == HttpVersions.HTTP_0_9_ORDINAL)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
294 {
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
295 _persistent = false;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
296 _contentLength = HttpTokens.EOF_CONTENT;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
297 _state = STATE_CONTENT;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
298 return;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
299 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
300 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
301 {
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
302 if (_persistent==null)
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
303 _persistent = (_version > HttpVersions.HTTP_1_0_ORDINAL);
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
304
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
305 // add response line
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
306 Status status = _status<__status.length?__status[_status]:null;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
307
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
308 if (status==null)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
309 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
310 _header.putQ(HttpVersions.HTTP_1_1_BYTES);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
311 _header.putQ((byte) ' ');
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
312 _header.putQ((byte) ('0' + _status / 100));
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
313 _header.putQ((byte) ('0' + (_status % 100) / 10));
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
314 _header.putQ((byte) ('0' + (_status % 10)));
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
315 _header.putQ((byte) ' ');
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
316 if (_reason==null)
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
317 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
318 _header.putQ((byte) ('0' + _status / 100));
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
319 _header.putQ((byte) ('0' + (_status % 100) / 10));
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
320 _header.putQ((byte) ('0' + (_status % 10)));
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
321 }
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
322 else
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
323 _header.putQ(_reason);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
324 _header.putQ(HttpTokens.CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
325 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
326 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
327 {
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
328 if (_reason==null)
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
329 _header.putQ(status._responseLine);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
330 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
331 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
332 _header.putQ(status._schemeCode);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
333 _header.putQ(_reason);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
334 _header.putQ(HttpTokens.CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
335 }
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
336 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
337
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
338 if (_status<200 && _status>=100 )
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
339 {
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
340 _noContent = true;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
341 _content=null;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
342 if (_buffer!=null)
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
343 _buffer.clearJ();
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
344 // end the header.
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
345
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
346 if (_status!=101 )
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
347 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
348 _header.putQ(HttpTokens.CRLF);
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
349 _state = STATE_CONTENT;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
350 return;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
351 }
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
352 }
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
353 else if (_status==204 || _status==304)
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
354 {
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
355 _noContent = true;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
356 _content=null;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
357 if (_buffer!=null)
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
358 _buffer.clearJ();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
359 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
360 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
361
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
362 // key field values
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
363 HttpFields.Field content_length = null;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
364 HttpFields.Field transfer_encoding = null;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
365 boolean keep_alive = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
366 boolean close=false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
367 boolean content_type=false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
368 StringBuilder connection = null;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
369
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
370 if (fields != null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
371 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
372 int s=fields.size();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
373 for (int f=0;f<s;f++)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
374 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
375 HttpFields.Field field = fields.getField(f);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
376 if (field==null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
377 continue;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
378
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
379 switch (field.getNameOrdinal())
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
380 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
381 case HttpHeaders.CONTENT_LENGTH_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
382 content_length = field;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
383 _contentLength = field.getLongValue();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
384
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
385 if (_contentLength < _contentWritten || _last && _contentLength != _contentWritten)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
386 content_length = null;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
387
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
388 // write the field to the header buffer
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
389 field.putTo(_header);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
390 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
391
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
392 case HttpHeaders.CONTENT_TYPE_ORDINAL:
1020
6be43ef1eb96 HttpHeaderValues uses StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 1019
diff changeset
393 // if (BufferUtil.isPrefix(MimeTypes.MULTIPART_BYTERANGES_BUFFER, field.getValueBuffer()))
6be43ef1eb96 HttpHeaderValues uses StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 1019
diff changeset
394 if (field.getValue().startsWith(MimeTypes.MULTIPART_BYTERANGES))
6be43ef1eb96 HttpHeaderValues uses StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 1019
diff changeset
395 _contentLength = HttpTokens.SELF_DEFINING_CONTENT;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
396
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
397 // write the field to the header buffer
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
398 content_type=true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
399 field.putTo(_header);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
400 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
401
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
402 case HttpHeaders.TRANSFER_ENCODING_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
403 if (_version == HttpVersions.HTTP_1_1_ORDINAL)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
404 transfer_encoding = field;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
405 // Do NOT add yet!
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
406 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
407
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
408 case HttpHeaders.CONNECTION_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
409 int connection_value = field.getValueOrdinal();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
410 switch (connection_value)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
411 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
412 case -1:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
413 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
414 String[] values = field.getValue().split(",");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
415 for (int i=0;values!=null && i<values.length;i++)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
416 {
1020
6be43ef1eb96 HttpHeaderValues uses StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 1019
diff changeset
417 int ord = HttpHeaderValues.CACHE.getOrdinal(values[i].trim());
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
418
1020
6be43ef1eb96 HttpHeaderValues uses StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 1019
diff changeset
419 if (ord != -1)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
420 {
1020
6be43ef1eb96 HttpHeaderValues uses StringCache
Franklin Schmidt <fschmidt@gmail.com>
parents: 1019
diff changeset
421 switch(ord)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
422 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
423 case HttpHeaderValues.CLOSE_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
424 close=true;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
425 _persistent = false;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
426 keep_alive=false;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
427 if (!_persistent && _contentLength == HttpTokens.UNKNOWN_CONTENT)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
428 _contentLength = HttpTokens.EOF_CONTENT;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
429 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
430
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
431 case HttpHeaderValues.KEEP_ALIVE_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
432 if (_version == HttpVersions.HTTP_1_0_ORDINAL)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
433 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
434 keep_alive = true;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
435 _persistent = true;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
436 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
437 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
438
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
439 default:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
440 if (connection==null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
441 connection=new StringBuilder();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
442 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
443 connection.append(',');
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
444 connection.append(values[i]);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
445 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
446 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
447 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
448 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
449 if (connection==null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
450 connection=new StringBuilder();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
451 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
452 connection.append(',');
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
453 connection.append(values[i]);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
454 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
455 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
456
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
457 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
458 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
459 case HttpHeaderValues.UPGRADE_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
460 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
461 // special case for websocket connection ordering
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
462 field.putTo(_header);
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
463 continue;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
464 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
465 case HttpHeaderValues.CLOSE_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
466 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
467 close=true;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
468 _persistent=false;
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
469 if (!_persistent && _contentLength == HttpTokens.UNKNOWN_CONTENT)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
470 _contentLength = HttpTokens.EOF_CONTENT;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
471 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
472 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
473 case HttpHeaderValues.KEEP_ALIVE_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
474 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
475 if (_version == HttpVersions.HTTP_1_0_ORDINAL)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
476 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
477 keep_alive = true;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
478 _persistent=true;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
479 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
480 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
481 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
482 default:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
483 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
484 if (connection==null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
485 connection=new StringBuilder();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
486 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
487 connection.append(',');
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
488 connection.append(field.getValue());
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
489 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
490 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
491
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
492 // Do NOT add yet!
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
493 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
494
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
495 case HttpHeaders.SERVER_ORDINAL:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
496 has_server=true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
497 field.putTo(_header);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
498 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
499
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
500 default:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
501 // write the field to the header buffer
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
502 field.putTo(_header);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
503 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
504 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
505 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
506
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
507 // Calculate how to end _content and connection, _content length and transfer encoding
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
508 // settings.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
509 // From RFC 2616 4.4:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
510 // 1. No body for 1xx, 204, 304 & HEAD response
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
511 // 2. Force _content-length?
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
512 // 3. If Transfer-Encoding!=identity && HTTP/1.1 && !HttpConnection==close then chunk
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
513 // 4. Content-Length
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
514 // 5. multipart/byteranges
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
515 // 6. close
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
516 switch ((int) _contentLength)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
517 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
518 case HttpTokens.UNKNOWN_CONTENT:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
519 // It may be that we have no _content, or perhaps _content just has not been
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
520 // written yet?
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
521
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
522 // Response known not to have a body
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
523 if (_contentWritten == 0 && (_status < 200 || _status == 204 || _status == 304))
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
524 _contentLength = HttpTokens.NO_CONTENT;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
525 else if (_last)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
526 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
527 // we have seen all the _content there is
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
528 _contentLength = _contentWritten;
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
529 if (content_length == null && !_noContent)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
530 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
531 // known length but not actually set.
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
532 _header.putQ(HttpHeaders.CONTENT_LENGTH_BYTES);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
533 _header.putQ(HttpTokens.COLON);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
534 _header.putQ((byte) ' ');
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
535 BufferUtil.putDecLong(_header, _contentLength);
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
536 _header.putQ(HttpTokens.CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
537 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
538 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
539 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
540 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
541 // No idea, so we must assume that a body is coming
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
542 _contentLength = (!_persistent || _version < HttpVersions.HTTP_1_1_ORDINAL ) ? HttpTokens.EOF_CONTENT : HttpTokens.CHUNKED_CONTENT;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
543 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
544 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
545
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
546 case HttpTokens.NO_CONTENT:
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
547 if (content_length == null && _status >= 200 && _status != 204 && _status != 304)
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
548 _header.putQ(CONTENT_LENGTH_0);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
549 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
550
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
551 case HttpTokens.EOF_CONTENT:
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
552 _persistent = false;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
553 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
554
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
555 case HttpTokens.CHUNKED_CONTENT:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
556 break;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
557
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
558 default:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
559 // TODO - maybe allow forced chunking by setting te ???
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
560 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
561 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
562
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
563 // Add transfer_encoding if needed
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
564 if (_contentLength == HttpTokens.CHUNKED_CONTENT)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
565 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
566 // try to use user supplied encoding as it may have other values.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
567 if (transfer_encoding != null && HttpHeaderValues.CHUNKED_ORDINAL != transfer_encoding.getValueOrdinal())
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
568 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
569 String c = transfer_encoding.getValue();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
570 if (c.endsWith(HttpHeaderValues.CHUNKED))
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
571 transfer_encoding.putTo(_header);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
572 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
573 throw new IllegalArgumentException("BAD TE");
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
574 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
575 else
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
576 _header.putQ(TRANSFER_ENCODING_CHUNKED);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
577 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
578
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
579 // Handle connection if need be
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
580 if (_contentLength==HttpTokens.EOF_CONTENT)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
581 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
582 keep_alive=false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
583 _persistent=false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
584 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
585
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
586 if (!_persistent && (close || _version > HttpVersions.HTTP_1_0_ORDINAL))
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
587 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
588 _header.putQ(CONNECTION_CLOSE);
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
589 if (connection!=null)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
590 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
591 _header.position(_header.position()-2);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
592 _header.putQ((byte)',');
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
593 _header.putQ(connection.toString().getBytes());
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
594 _header.putQ(CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
595 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
596 }
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
597 else if (keep_alive)
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
598 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
599 _header.putQ(CONNECTION_KEEP_ALIVE);
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
600 if (connection!=null)
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
601 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
602 _header.position(_header.position()-2);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
603 _header.putQ((byte)',');
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
604 _header.putQ(connection.toString().getBytes());
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
605 _header.putQ(CRLF);
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
606 }
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
607 }
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
608 else if (connection!=null)
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
609 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
610 _header.putQ(CONNECTION_);
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
611 _header.putQ(connection.toString().getBytes());
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
612 _header.putQ(CRLF);
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
613 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
614
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
615 if (!has_server && _status>199)
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
616 _header.putQ(SERVER);
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
617
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
618 // end the header.
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
619 _header.putQ(HttpTokens.CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
620 _state = STATE_CONTENT;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
621
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
622 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
623 catch(ArrayIndexOutOfBoundsException e)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
624 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
625 throw new RuntimeException("Header>"+_header.remaining(),e);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
626 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
627 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
628
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
629 /* ------------------------------------------------------------ */
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
630 /**
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
631 * Complete the message.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
632 *
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
633 * @throws IOException
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
634 */
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
635 public void complete() throws IOException
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
636 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
637 if (_state == STATE_END)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
638 return;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
639
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
640 complete2();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
641
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
642 if (_state < STATE_FLUSHING)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
643 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
644 _state = STATE_FLUSHING;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
645 if (_contentLength == HttpTokens.CHUNKED_CONTENT)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
646 _needEOC = true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
647 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
648
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
649 flushBuffer();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
650 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
651
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
652 public int flushBuffer() throws IOException
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
653 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
654 try
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
655 {
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
656
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
657 if (_state == STATE_HEADER)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
658 throw new IllegalStateException("State==HEADER");
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
659
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
660 prepareBuffers();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
661
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
662 int total= 0;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
663
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
664 int len = -1;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
665 int to_flush = flushMask();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
666 int last_flush;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
667
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
668 do
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
669 {
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
670 last_flush = to_flush;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
671 switch (to_flush)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
672 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
673 //qqq
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
674 case 7:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
675 throw new IllegalStateException(); // should never happen!
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
676 case 6:
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
677 _header.flip();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
678 len = _endp.flush(_header, _buffer, null);
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
679 _header.compact();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
680 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
681 case 5:
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
682 _header.flip();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
683 len = _endp.flush(_header, _content, null);
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
684 _header.compact();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
685 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
686 case 4:
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
687 _header.flip();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
688 len = _endp.flush(_header);
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
689 _header.compact();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
690 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
691 case 3:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
692 len = _endp.flush(_buffer, _content, null);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
693 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
694 case 2:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
695 len = _endp.flush(_buffer);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
696 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
697 case 1:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
698 len = _endp.flush(_content);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
699 break;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
700 case 0:
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
701 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
702 len=0;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
703 // Nothing more we can write now.
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
704 _header.clear();
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
705
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
706 _bypass = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
707 _bufferChunked = false;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
708
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
709 if (_buffer != null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
710 {
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
711 _buffer.clearJ();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
712 if (_contentLength == HttpTokens.CHUNKED_CONTENT)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
713 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
714 // Special case handling for small left over buffer from
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
715 // an addContent that caused a buffer flush.
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
716 if (_content != null && _content.remaining() < _buffer.space() && _state != STATE_FLUSHING)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
717 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
718 _buffer.put(_content);
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
719 _content.clearJ();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
720 _content=null;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
721 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
722 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
723 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
724
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
725 // Are we completely finished for now?
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
726 if (!_needCRLF && !_needEOC && (_content==null || _content.remaining()==0))
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
727 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
728 if (_state == STATE_FLUSHING)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
729 _state = STATE_END;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
730
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
731 if (_state==STATE_END && _persistent != null && !_persistent && _status!=100)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
732 _endp.shutdownOutput();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
733 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
734 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
735 // Try to prepare more to write.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
736 prepareBuffers();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
737 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
738
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
739 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
740
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
741 if (len > 0)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
742 total+=len;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
743
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
744 to_flush = flushMask();
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
745 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
746 // loop while progress is being made (OR we have prepared some buffers that might make progress)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
747 while (len>0 || (to_flush!=0 && last_flush==0));
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
748
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
749 return total;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
750 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
751 catch (IOException e)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
752 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
753 LOG.trace("",e);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
754 throw (e instanceof EofException) ? e:new EofException(e);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
755 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
756 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
757
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
758 private int flushMask()
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
759 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
760 return ((_header.position() > 0)?4:0)
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
761 | ((_buffer != null && _buffer.remaining() > 0)?2:0)
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
762 | ((_bypass && _content != null && _content.remaining() > 0)?1:0);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
763 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
764
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
765 private void prepareBuffers()
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
766 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
767 // if we are not flushing an existing chunk
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
768 if (!_bufferChunked)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
769 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
770 // Refill buffer if possible
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
771 if (!_bypass && _content != null && _content.remaining() > 0 && _buffer != null && _buffer.space() > 0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
772 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
773 int len = _buffer.put(_content);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
774 _content.skip(len);
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
775 if (_content.remaining() == 0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
776 _content = null;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
777 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
778
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
779 // Chunk buffer if need be
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
780 if (_contentLength == HttpTokens.CHUNKED_CONTENT)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
781 {
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
782 if (_bypass && (_buffer==null||_buffer.remaining()==0) && _content!=null)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
783 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
784 // this is a bypass write
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
785 int size = _content.remaining();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
786 _bufferChunked = true;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
787
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
788 // if we need CRLF add this to header
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
789 if (_needCRLF)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
790 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
791 if (_header.position() > 0) throw new IllegalStateException("EOC");
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
792 _header.putQ(HttpTokens.CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
793 _needCRLF = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
794 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
795 // Add the chunk size to the header
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
796 BufferUtil.putHexInt(_header, size);
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
797 _header.putQ(HttpTokens.CRLF);
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
798
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
799 // Need a CRLF after the content
983
23ec25435b8c simplify AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 982
diff changeset
800 _needCRLF = true;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
801 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
802 else if (_buffer!=null)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
803 {
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
804 int size = _buffer.remaining();
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
805 if (size > 0)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
806 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
807 // Prepare a chunk!
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
808 _bufferChunked = true;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
809
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
810 if (_needCRLF)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
811 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
812 if (_header.position() > 0) throw new IllegalStateException("EOC");
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
813 _header.putQ(HttpTokens.CRLF);
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
814 _needCRLF = false;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
815 }
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
816 BufferUtil.putHexInt(_header, size);
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
817 _header.putQ(HttpTokens.CRLF);
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
818
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
819 // Add end chunk trailer.
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
820 if (_buffer.space() >= 2)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
821 _buffer.put(HttpTokens.CRLF);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
822 else
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
823 _needCRLF = true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
824 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
825 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
826
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
827 // If we need EOC and everything written
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
828 if (_needEOC && (_content == null || _content.remaining() == 0))
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
829 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
830 if (_needCRLF)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
831 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
832 if (_buffer == null && _header.remaining() >= HttpTokens.CRLF.length)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
833 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
834 _header.putQ(HttpTokens.CRLF);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
835 _needCRLF = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
836 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
837 else if (_buffer!=null && _buffer.space() >= HttpTokens.CRLF.length)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
838 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
839 _buffer.put(HttpTokens.CRLF);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
840 _needCRLF = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
841 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
842 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
843
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
844 if (!_needCRLF && _needEOC)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
845 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
846 if (_buffer == null && _header.remaining() >= LAST_CHUNK.length)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
847 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
848 if (!_head)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
849 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
850 _header.putQ(LAST_CHUNK);
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
851 _bufferChunked=true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
852 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
853 _needEOC = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
854 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
855 else if (_buffer!=null && _buffer.space() >= LAST_CHUNK.length)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
856 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
857 if (!_head)
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
858 {
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
859 _buffer.put(LAST_CHUNK);
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
860 _bufferChunked=true;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
861 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
862 _needEOC = false;
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
863 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
864 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
865 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
866 }
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
867 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
868
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
869 if (_content != null && _content.remaining() == 0)
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
870 _content = null;
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
871
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
872 }
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
873
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
874 @Override
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
875 public String toString()
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
876 {
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
877 JBuffer header = _header;
1048
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
878 JBuffer buffer=_buffer;
2b769da7f67d remove Buffer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1039
diff changeset
879 JBuffer content=_content;
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
880 return String.format("%s{s=%d,h=%d,b=%d,c=%d}",
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
881 getClass().getSimpleName(),
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
882 _state,
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
883 header == null ? -1 : header.position(),
1038
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
884 buffer == null ? -1 : buffer.remaining(),
b71ad168fe34 rename Buffer.length() to remaining()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1036
diff changeset
885 content == null ? -1 : content.remaining());
877
fef4392f4905 remove sendServerVersion
Franklin Schmidt <fschmidt@gmail.com>
parents: 820
diff changeset
886 }
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
887
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
888
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
889
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
890
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
891
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
892
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
893
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
894
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
895
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
896
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
897
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
898
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
899 // AbstractGenerator
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
900
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
901 public static final boolean LAST=true;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
902 public static final boolean MORE=false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
903
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
904 // states
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
905 private final static int STATE_HEADER = 0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
906 private final static int STATE_CONTENT = 2;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
907 private final static int STATE_FLUSHING = 3;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
908 private final static int STATE_END = 4;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
909
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
910 // data
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
911
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
912 private final Buffers _buffers; // source of buffers
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
913 private final EndPoint _endp;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
914
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
915 private int _state = STATE_HEADER;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
916
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
917 private int _status = 0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
918 private int _version = HttpVersions.HTTP_1_1_ORDINAL;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
919 private JBuffer _reason;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
920
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
921 private long _contentWritten = 0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
922 private long _contentLength = HttpTokens.UNKNOWN_CONTENT;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
923 private boolean _last = false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
924 private boolean _head = false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
925 private boolean _noContent = false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
926 private Boolean _persistent = null;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
927
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
928 private final JBuffer _header; // JBuffer for HTTP header (and maybe small _content)
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
929 private JBuffer _buffer; // JBuffer for copy of passed _content
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
930 private JBuffer _content; // JBuffer passed to addContent
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
931
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
932
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
933 public HttpGenerator(Buffers buffers, EndPoint io)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
934 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
935 this._buffers = buffers;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
936 this._endp = io;
1066
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
937 _header = _buffers.getHeader();
bbbda7c6e8ec fix use of HttpGenerator._header
Franklin Schmidt <fschmidt@gmail.com>
parents: 1065
diff changeset
938 _header.clear();
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
939 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
940
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
941 public final boolean isOpen()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
942 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
943 return _endp.isOpen();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
944 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
945
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
946 public final void resetBuffer()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
947 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
948 if(_state>=STATE_FLUSHING)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
949 throw new IllegalStateException("Flushed");
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
950
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
951 _last = false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
952 _persistent = null;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
953 _contentWritten = 0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
954 _contentLength = HttpTokens.UNKNOWN_CONTENT;
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
955 _content = null;
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
956 if (_buffer!=null)
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
957 _buffer.clearJ();
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
958 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
959
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
960 /* ------------------------------------------------------------ */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
961 /**
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
962 * @return Returns the contentBufferSize.
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
963 */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
964 public final int getContentBufferSize()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
965 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
966 if (_buffer==null)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
967 _buffer = _buffers.getBuffer();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
968 return _buffer.capacity();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
969 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
970
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
971 public final JBuffer getUncheckedBuffer()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
972 {
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
973 if (_buffer == null)
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
974 _buffer = _buffers.getBuffer();
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
975 return _buffer;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
976 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
977
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
978 public final boolean isComplete()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
979 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
980 return _state == STATE_END;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
981 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
982
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
983 public final boolean isIdle()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
984 {
1058
419bf9c03d84 remove HttpGenerator._method
Franklin Schmidt <fschmidt@gmail.com>
parents: 1057
diff changeset
985 return _state == STATE_HEADER && _status==0;
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
986 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
987
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
988 public final boolean isCommitted()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
989 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
990 return _state != STATE_HEADER;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
991 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
992
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
993 public final void setContentLength(long value)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
994 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
995 if (value<0)
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
996 _contentLength = HttpTokens.UNKNOWN_CONTENT;
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
997 else
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
998 _contentLength = value;
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
999 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1000
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1001 public final void setHead(boolean head)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1002 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1003 _head = head;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1004 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1005
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1006 /* ------------------------------------------------------------ */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1007 /**
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1008 * @return <code>false</code> if the connection should be closed after a request has been read,
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1009 * <code>true</code> if it should be used for additional requests.
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1010 */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1011 public final boolean isPersistent()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1012 {
1059
013939bfc9e8 remove JBuffer.poke()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1058
diff changeset
1013 return _persistent!=null ? _persistent.booleanValue() : _version>HttpVersions.HTTP_1_0_ORDINAL;
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1014 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1015
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1016 public final void setPersistent(boolean persistent)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1017 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1018 _persistent = persistent;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1019 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1020
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1021 /* ------------------------------------------------------------ */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1022 /**
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1023 * @param version The version of the client the response is being sent to (NB. Not the version
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1024 * in the response, which is the version of the server).
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1025 */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1026 public final void setVersion(int version)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1027 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1028 if (_state != STATE_HEADER)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1029 throw new IllegalStateException("STATE!=START "+_state);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1030 _version = version;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1031 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1032
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1033 /* ------------------------------------------------------------ */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1034 /**
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1035 * @param status The status code to send.
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1036 * @param reason the status message to send.
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1037 */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1038 public final void setResponse(int status, String reason)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1039 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1040 if (_state != STATE_HEADER) throw new IllegalStateException("STATE!=START");
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1041 _status = status;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1042 if (reason!=null)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1043 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1044 int len=reason.length();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1045
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1046 // TODO don't hard code
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1047 if (len>1024)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1048 len=1024;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1049 _reason = BufferUtil.newBuffer(len);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1050 for (int i=0;i<len;i++)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1051 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1052 char ch = reason.charAt(i);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1053 if (ch!='\r'&&ch!='\n')
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1054 _reason.put((byte)ch);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1055 else
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1056 _reason.put((byte)' ');
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1057 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1058 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1059 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1060
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1061 public final void completeUncheckedAddContent()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1062 {
1064
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
1063 _contentWritten += _buffer.remaining();
a0abb16cf6e7 remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1059
diff changeset
1064 if (_head)
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
1065 _buffer.clearJ();
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1066 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1067
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1068 private boolean isBufferFull2()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1069 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1070 if (_buffer != null && _buffer.space()==0)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1071 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1072 if (_buffer.remaining()==0)
1065
158d1e6ac17f fix JBuffer.compact()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1064
diff changeset
1073 _buffer.limit(0);
1057
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1074 return _buffer.space()==0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1075 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1076
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1077 return _content!=null && _content.remaining()>0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1078 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1079
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1080 public final boolean isWritten()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1081 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1082 return _contentWritten>0;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1083 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1084
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1085 public final boolean isAllContentWritten()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1086 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1087 return _contentLength>=0 && _contentWritten>=_contentLength;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1088 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1089
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1090
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1091 private void complete2() throws IOException
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1092 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1093 if (_state == STATE_HEADER)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1094 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1095 throw new IllegalStateException("State==HEADER");
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1096 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1097
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1098 if (_contentLength >= 0 && _contentLength != _contentWritten && !_head)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1099 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1100 if (LOG.isDebugEnabled())
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1101 LOG.debug("ContentLength written=="+_contentWritten+" != contentLength=="+_contentLength);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1102 _persistent = false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1103 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1104 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1105
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1106
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1107 public final void flush(long maxIdleTime) throws IOException
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1108 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1109 // block until everything is flushed
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1110 long now=System.currentTimeMillis();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1111 long end=now+maxIdleTime;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1112 JBuffer content = _content;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1113 JBuffer buffer = _buffer;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1114 if (content!=null && content.remaining()>0 || buffer!=null && buffer.remaining()>0 || isBufferFull())
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1115 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1116 flushBuffer();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1117
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1118 while (now<end && (content!=null && content.remaining()>0 ||buffer!=null && buffer.remaining()>0) && _endp.isOpen()&& !_endp.isOutputShutdown())
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1119 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1120 blockForOutput(end-now);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1121 now=System.currentTimeMillis();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1122 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1123 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1124 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1125
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1126 /* ------------------------------------------------------------ */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1127 /**
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1128 * Utility method to send an error response. If the builder is not committed, this call is
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1129 * equivalent to a setResponse, addContent and complete call.
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1130 *
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1131 * @param code The error code
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1132 * @param reason The error reason
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1133 * @param content Contents of the error page
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1134 * @param close True if the connection should be closed
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1135 * @throws IOException if there is a problem flushing the response
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1136 */
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1137 public final void sendError(int code, String reason, String content, boolean close) throws IOException
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1138 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1139 if (close)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1140 _persistent=false;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1141 if (isCommitted())
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1142 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1143 LOG.debug("sendError on committed: {} {}",code,reason);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1144 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1145 else
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1146 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1147 LOG.debug("sendError: {} {}",code,reason);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1148 setResponse(code, reason);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1149 if (content != null)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1150 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1151 completeHeader(null, false);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1152 addContent(BufferUtil.wrap(content), LAST);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1153 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1154 else if (code>=400)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1155 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1156 completeHeader(null, false);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1157 addContent(BufferUtil.wrap("Error: "+(reason==null?(""+code):reason)), LAST);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1158 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1159 else
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1160 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1161 completeHeader(null, true);
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1162 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1163 complete();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1164 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1165 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1166
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1167 public final long getContentWritten()
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1168 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1169 return _contentWritten;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1170 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1171
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1172
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1173 public final void blockForOutput(long maxIdleTime) throws IOException
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1174 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1175 if (_endp.isBlocking())
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1176 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1177 try
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1178 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1179 flushBuffer();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1180 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1181 catch(IOException e)
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1182 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1183 _endp.close();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1184 throw e;
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1185 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1186 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1187 else
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1188 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1189 if (!_endp.blockWritable(maxIdleTime))
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1190 {
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1191 _endp.close();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1192 throw new EofException("timeout");
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1193 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1194
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1195 flushBuffer();
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1196 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1197 }
afc9610dc12e remove AbstractGenerator
Franklin Schmidt <fschmidt@gmail.com>
parents: 1048
diff changeset
1198
802
3428c60d7cfc replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
1199 }