multipartstream.html

ava 项目中

<a name="660" href="#660">660</a> <em>     * @param b     The second array to compare.</em>
<a name="661" href="#661">661</a> <em>     * @param count How many bytes should be compared.</em>
<a name="662" href="#662">662</a> <em>     *</em>
<a name="663" href="#663">663</a> <em>     * @return &lt;code>true&lt;/code> if &lt;code>count&lt;/code> first bytes in arrays</em>
<a name="664" href="#664">664</a> <em>     *         &lt;code>a&lt;/code> and &lt;code>b&lt;/code> are equal.</em>
<a name="665" href="#665">665</a> <em>     */</em>
<a name="666" href="#666">666</a>     <strong>public</strong> <strong>static</strong> <strong>boolean</strong> arrayequals(byte[] a,
<a name="667" href="#667">667</a>             byte[] b,
<a name="668" href="#668">668</a>             <strong>int</strong> count) {
<a name="669" href="#669">669</a>         <strong>for</strong> (<strong>int</strong> i = 0; i &lt; count; i++) {
<a name="670" href="#670">670</a>             <strong>if</strong> (a[i] != b[i]) {
<a name="671" href="#671">671</a>                 <strong>return</strong> false;
<a name="672" href="#672">672</a>             }
<a name="673" href="#673">673</a>         }
<a name="674" href="#674">674</a>         <strong>return</strong> <strong>true</strong>;
<a name="675" href="#675">675</a>     }
<a name="676" href="#676">676</a> 
<a name="677" href="#677">677</a> 
<a name="678" href="#678">678</a>     <em>/**</em>
<a name="679" href="#679">679</a> <em>     * Searches for a byte of specified value in the &lt;code>buffer&lt;/code>,</em>
<a name="680" href="#680">680</a> <em>     * starting at the specified &lt;code>position&lt;/code>.</em>
<a name="681" href="#681">681</a> <em>     *</em>
<a name="682" href="#682">682</a> <em>     * @param value The value to find.</em>
<a name="683" href="#683">683</a> <em>     * @param pos   The starting position for searching.</em>
<a name="684" href="#684">684</a> <em>     *</em>
<a name="685" href="#685">685</a> <em>     * @return The position of byte found, counting from beginning of the</em>
<a name="686" href="#686">686</a> <em>     *         &lt;code>buffer&lt;/code>, or &lt;code>-1&lt;/code> if not found.</em>
<a name="687" href="#687">687</a> <em>     */</em>
<a name="688" href="#688">688</a>     <strong>protected</strong> <strong>int</strong> findByte(byte value,
<a name="689" href="#689">689</a>             <strong>int</strong> pos) {
<a name="690" href="#690">690</a>         <strong>for</strong> (<strong>int</strong> i = pos; i &lt; tail; i++) {
<a name="691" href="#691">691</a>             <strong>if</strong> (buffer[i] == value) {
<a name="692" href="#692">692</a>                 <strong>return</strong> i;
<a name="693" href="#693">693</a>             }
<a name="694" href="#694">694</a>         }
<a name="695" href="#695">695</a> 
<a name="696" href="#696">696</a>         <strong>return</strong> -1;
<a name="697" href="#697">697</a>     }
<a name="698" href="#698">698</a> 
<a name="699" href="#699">699</a> 
<a name="700" href="#700">700</a>     <em>/**</em>
<a name="701" href="#701">701</a> <em>     * Searches for the &lt;code>boundary&lt;/code> in the &lt;code>buffer&lt;/code></em>
<a name="702" href="#702">702</a> <em>     * region delimited by &lt;code>head&lt;/code> and &lt;code>tail&lt;/code>.</em>
<a name="703" href="#703">703</a> <em>     *</em>
<a name="704" href="#704">704</a> <em>     * @return The position of the boundary found, counting from the</em>
<a name="705" href="#705">705</a> <em>     *         beginning of the &lt;code>buffer&lt;/code>, or &lt;code>-1&lt;/code> if</em>
<a name="706" href="#706">706</a> <em>     *         not found.</em>
<a name="707" href="#707">707</a> <em>     */</em>
<a name="708" href="#708">708</a>     <strong>protected</strong> <strong>int</strong> findSeparator() {
<a name="709" href="#709">709</a>         <strong>int</strong> first;
<a name="710" href="#710">710</a>         <strong>int</strong> match = 0;
<a name="711" href="#711">711</a>         <strong>int</strong> maxpos = tail - boundaryLength;
<a name="712" href="#712">712</a>         <strong>for</strong> (first = head;
<a name="713" href="#713">713</a>         (first &lt;= maxpos) &amp;&amp; (match != boundaryLength);
<a name="714" href="#714">714</a>         first++) {
<a name="715" href="#715">715</a>             first = findByte(boundary[0], first);
<a name="716" href="#716">716</a>             <strong>if</strong> (first == -1 || (first > maxpos)) {
<a name="717" href="#717">717</a>                 <strong>return</strong> -1;
<a name="718" href="#718">718</a>             }
<a name="719" href="#719">719</a>             <strong>for</strong> (match = 1; match &lt; boundaryLength; match++) {
<a name="720" href="#720">720</a>                 <strong>if</strong> (buffer[first + match] != boundary[match]) {
<a name="721" href="#721">721</a>                     <strong>break</strong>;
<a name="722" href="#722">722</a>                 }
<a name="723" href="#723">723</a>             }
<a name="724" href="#724">724</a>         }
<a name="725" href="#725">725</a>         <strong>if</strong> (match == boundaryLength) {
<a name="726" href="#726">726</a>             <strong>return</strong> first - 1;
<a name="727" href="#727">727</a>         }
<a name="728" href="#728">728</a>         <strong>return</strong> -1;
<a name="729" href="#729">729</a>     }
<a name="730" href="#730">730</a> 
<a name="731" href="#731">731</a>     <em>/**</em>
<a name="732" href="#732">732</a> <em>     * Thrown to indicate that the input stream fails to follow the</em>
<a name="733" href="#733">733</a> <em>     * required syntax.</em>
<a name="734" href="#734">734</a> <em>     */</em>
<a name="735" href="#735">735</a>     <strong>public</strong> <strong>static</strong> <strong>class</strong> MalformedStreamException
<a name="736" href="#736">736</a>     <strong>extends</strong> IOException {
<a name="737" href="#737">737</a>         <em>/**</em>
<a name="738" href="#738">738</a> <em>         * Constructs a &lt;code>MalformedStreamException&lt;/code> with no</em>
<a name="739" href="#739">739</a> <em>         * detail message.</em>
<a name="740" href="#740">740</a> <em>         */</em>
<a name="741" href="#741">741</a>         <strong>public</strong> MalformedStreamException() {
<a name="742" href="#742">742</a>             <strong>super</strong>();
<a name="743" href="#743">743</a>         }
<a name="744" href="#744">744</a> 
<a name="745" href="#745">745</a>         <em>/**</em>
<a name="746" href="#746">746</a> <em>         * Constructs an &lt;code>MalformedStreamException&lt;/code> with</em>
<a name="747" href="#747">747</a> <em>         * the specified detail message.</em>
<a name="748" href="#748">748</a> <em>         *</em>
<a name="749" href="#749">749</a> <em>         * @param message The detail message.</em>
<a name="750" href="#750">750</a> <em>         */</em>
<a name="751" href="#751">751</a>         <strong>public</strong> MalformedStreamException(String message) {
<a name="752" href="#752">752</a>             <strong>super</strong>(message);
<a name="753" href="#753">753</a>         }
<a name="754" href="#754">754</a>     }
<a name="755" href="#755">755</a> 
<a name="756" href="#756">756</a> 
<a name="757" href="#757">757</a>     <em>/**</em>
<a name="758" href="#758">758</a> <em>     * Thrown upon attempt of setting an invalid boundary token.</em>
<a name="759" href="#759">759</a> <em>     */</em>
<a name="760" href="#760">760</a>     <strong>public</strong> <strong>static</strong> <strong>class</strong> IllegalBoundaryException
<a name="761" href="#761">761</a>             <strong>extends</strong> IOException {
<a name="762" href="#762">762</a>         <em>/**</em>
<a name="763" href="#763">763</a> <em>         * Constructs an &lt;code>IllegalBoundaryException&lt;/code> with no</em>
<a name="764" href="#764">764</a> <em>         * detail message.</em>
<a name="765" href="#765">765</a> <em>         */</em>
<a name="766" href="#766">766</a>         <strong>public</strong> IllegalBoundaryException() {
<a name="767" href="#767">767</a>             <strong>super</strong>();
<a name="768" href="#768">768</a>         }
<a name="769" href="#769">769</a> 
<a name="770" href="#770">770</a>         <em>/**</em>
<a name="771" href="#771">771</a> <em>         * Constructs an &lt;code>IllegalBoundaryException&lt;/code> with</em>
<a name="772" href="#772">772</a> <em>         * the specified detail message.</em>
<a name="773" href="#773">773</a> <em>         *</em>
<a name="774" href="#774">774</a> <em>         * @param message The detail message.</em>
<a name="775" href="#775">775</a> <em>         */</em>
<a name="776" href="#776">776</a>         <strong>public</strong> IllegalBoundaryException(String message) {
<a name="777" href="#777">777</a>             <strong>super</strong>(message);
<a name="778" href="#778">778</a>         }
<a name="779" href="#779">779</a>     }
<a name="780" href="#780">780</a> 
<a name="781" href="#781">781</a>     <em>/**</em>
<a name="782" href="#782">782</a> <em>     * An {@link InputStream} for reading an items contents.</em>
<a name="783" href="#783">783</a> <em>     */</em>
<a name="784" href="#784">784</a>     <strong>public</strong> <strong>class</strong> ItemInputStream <strong>extends</strong> InputStream implements <a href="../../../../org/apache/commons/fileupload/util/Closeable.html">Closeable</a> {
<a name="785" href="#785">785</a>         <em>/**</em><em> The number of bytes, which have been read so far.</em>
<a name="786" href="#786">786</a> <em>         */</em>
<a name="787" href="#787">787</a>         <strong>private</strong> <strong>long</strong> total;
<a name="788" href="#788">788</a>         <em>/**</em><em> The number of bytes, which must be hold, because</em>
<a name="789" href="#789">789</a> <em>         * they might be a part of the boundary.</em>
<a name="790" href="#790">790</a> <em>         */</em>
<a name="791" href="#791">791</a>         <strong>private</strong> <strong>int</strong> pad;
<a name="792" href="#792">792</a>         <em>/**</em><em> The current offset in the buffer.</em>
<a name="793" href="#793">793</a> <em>         */</em>
<a name="794" href="#794">794</a>         <strong>private</strong> <strong>int</strong> pos;
<a name="795" href="#795">795</a>         <em>/**</em><em> Whether the stream is already closed.</em>
<a name="796" href="#796">796</a> <em>         */</em>
<a name="797" href="#797">797</a>         <strong>private</strong> <strong>boolean</strong> closed;
<a name="798" href="#798">798</a> 
<a name="799" href="#799">799</a>         <em>/**</em>
<a name="800" href="#800">800</a> <em>         * Creates a new instance.</em>
<a name="801" href="#801">801</a> <em>         */</em>
<a name="802" href="#802">802</a>         ItemInputStream() {
<a name="803" href="#803">803</a>             findSeparator();
<a name="804" href="#804">804</a>         }
<a name="805" href="#805">805</a> 
<a name="806" href="#806">806</a>         <em>/**</em>
<a name="807" href="#807">807</a> <em>         * Called for finding the separator.</em>
<a name="808" href="#808">808</a> <em>         */</em>
<a name="809" href="#809">809</a>         <strong>private</strong> <strong>void</strong> findSeparator() {
<a name="810" href="#810">810</a>             pos = MultipartStream.<strong>this</strong>.findSeparator();
<a name="811" href="#811">811</a>             <strong>if</strong> (pos == -1) {
<a name="812" href="#812">812</a>                 <strong>if</strong> (tail - head > keepRegion) {
<a name="813" href="#813">813</a>                     pad = keepRegion;
<a name="814" href="#814">814</a>                 } <strong>else</strong> {
<a name="815" href="#815">815</a>                     pad = tail - head;
<a name="816" href="#816">816</a>                 }
<a name="817" href="#817">817</a>             }
<a name="818" href="#818">818</a>         }
<a name="819" href="#819">819</a> 
<a name="820" href="#820">820</a>         <em>/**</em>
<a name="821" href="#821">821</a> <em>         * Returns the number of bytes, which have been read</em>
<a name="822" href="#822">822</a> <em>         * by the stream.</em>
<a name="823" href="#823">823</a> <em>         * @return Number of bytes, which have been read so far.</em>
<a name="824" href="#824">824</a> <em>         */</em>
<a name="825" href="#825">825</a>