Mercurial Hosting > luan
comparison src/org/eclipse/jetty/http/HttpParser.java @ 1051:1ab2dd0a7db5
remove JBuffer.get(int)
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 08 Nov 2016 00:18:45 -0700 |
parents | 5ef954fad97b |
children | 4a2489f1d5fe |
comparison
equal
deleted
inserted
replaced
1050:5ef954fad97b | 1051:1ab2dd0a7db5 |
---|---|
112 _buffer.setGetIndex( old - _mark ); | 112 _buffer.setGetIndex( old - _mark ); |
113 _mark = 0; | 113 _mark = 0; |
114 } | 114 } |
115 } | 115 } |
116 | 116 |
117 public JBuffer getBuffer(int length) { | |
118 JBuffer dup = _buffer.duplicate(); | |
119 int end = _buffer.position() + length; | |
120 dup.limit(end); | |
121 _buffer.position(end); | |
122 return dup; | |
123 } | |
124 | |
125 | |
117 public long getContentLength() | 126 public long getContentLength() |
118 { | 127 { |
119 return _contentLength; | 128 return _contentLength; |
120 } | 129 } |
121 | 130 |
234 // do we have content to deliver? | 243 // do we have content to deliver? |
235 if (_state>STATE_END) | 244 if (_state>STATE_END) |
236 { | 245 { |
237 if (_buffer.remaining()>0 && !_headResponse) | 246 if (_buffer.remaining()>0 && !_headResponse) |
238 { | 247 { |
239 JBuffer chunk = _buffer.get(_buffer.remaining()); | 248 JBuffer chunk = getBuffer(_buffer.remaining()); |
240 _contentPosition += chunk.remaining(); | 249 _contentPosition += chunk.remaining(); |
241 _contentView = chunk; | 250 _contentView = chunk; |
242 _handler.content(); // May recurse here | 251 _handler.content(); // May recurse here |
243 } | 252 } |
244 } | 253 } |
781 _eol=0; | 790 _eol=0; |
782 switch (_state) | 791 switch (_state) |
783 { | 792 { |
784 case STATE_EOF_CONTENT: | 793 case STATE_EOF_CONTENT: |
785 { | 794 { |
786 JBuffer chunk = _buffer.get(_buffer.remaining()); | 795 JBuffer chunk = getBuffer(_buffer.remaining()); |
787 _contentPosition += chunk.remaining(); | 796 _contentPosition += chunk.remaining(); |
788 _contentView = chunk; | 797 _contentView = chunk; |
789 _handler.content(); // May recurse here | 798 _handler.content(); // May recurse here |
790 // TODO adjust the _buffer to keep unconsumed content | 799 // TODO adjust the _buffer to keep unconsumed content |
791 return 1; | 800 return 1; |
806 // We can cast reamining to an int as we know that it is smaller than | 815 // We can cast reamining to an int as we know that it is smaller than |
807 // or equal to length which is already an int. | 816 // or equal to length which is already an int. |
808 length=(int)remaining; | 817 length=(int)remaining; |
809 } | 818 } |
810 | 819 |
811 JBuffer chunk = _buffer.get(length); | 820 JBuffer chunk = getBuffer(length); |
812 _contentPosition += chunk.remaining(); | 821 _contentPosition += chunk.remaining(); |
813 _contentView = chunk; | 822 _contentView = chunk; |
814 _handler.content(); // May recurse here | 823 _handler.content(); // May recurse here |
815 | 824 |
816 if(_contentPosition == _contentLength) | 825 if(_contentPosition == _contentLength) |
897 _state=STATE_CHUNKED_CONTENT; | 906 _state=STATE_CHUNKED_CONTENT; |
898 break; | 907 break; |
899 } | 908 } |
900 else if (length > remaining) | 909 else if (length > remaining) |
901 length=remaining; | 910 length=remaining; |
902 JBuffer chunk = _buffer.get(length); | 911 JBuffer chunk = getBuffer(length); |
903 _contentPosition += chunk.remaining(); | 912 _contentPosition += chunk.remaining(); |
904 _chunkPosition += chunk.remaining(); | 913 _chunkPosition += chunk.remaining(); |
905 _contentView = chunk; | 914 _contentView = chunk; |
906 _handler.content(); // May recurse here | 915 _handler.content(); // May recurse here |
907 // TODO adjust the _buffer to keep unconsumed content | 916 // TODO adjust the _buffer to keep unconsumed content |