14fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy/**************************************************************** 24fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * Licensed to the Apache Software Foundation (ASF) under one * 34fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * or more contributor license agreements. See the NOTICE file * 44fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * distributed with this work for additional information * 54fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * regarding copyright ownership. The ASF licenses this file * 64fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * to you under the Apache License, Version 2.0 (the * 74fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * "License"); you may not use this file except in compliance * 84fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * with the License. You may obtain a copy of the License at * 94fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * * 104fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * http://www.apache.org/licenses/LICENSE-2.0 * 114fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * * 124fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * Unless required by applicable law or agreed to in writing, * 134fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * software distributed under the License is distributed on an * 144fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * 154fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * KIND, either express or implied. See the License for the * 164fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * specific language governing permissions and limitations * 174fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy * under the License. * 184fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy ****************************************************************/ 194fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 204fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 214fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedypackage org.apache.james.mime4j.util; 224fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 234fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedyimport java.io.InputStream; 244fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedyimport java.io.IOException; 254fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 264fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedypublic class PositionInputStream extends InputStream { 274fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 284fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy private final InputStream inputStream; 294fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy protected long position = 0; 304fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy private long markedPosition = 0; 314fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 324fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public PositionInputStream(InputStream inputStream) { 334fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy this.inputStream = inputStream; 344fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 354fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 364fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public long getPosition() { 374fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return position; 384fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 394fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 404fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public int available() throws IOException { 414fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return inputStream.available(); 424fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 434fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 444fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public int read() throws IOException { 454fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy int b = inputStream.read(); 464fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy if (b != -1) 474fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy position++; 484fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return b; 494fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 504fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 514fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public void close() throws IOException { 524fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy inputStream.close(); 534fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 544fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 554fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public void reset() throws IOException { 564fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy inputStream.reset(); 574fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy position = markedPosition; 584fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 594fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 604fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public boolean markSupported() { 614fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return inputStream.markSupported(); 624fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 634fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 644fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public void mark(int readlimit) { 654fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy inputStream.mark(readlimit); 664fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy markedPosition = position; 674fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 684fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 694fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public long skip(long n) throws IOException { 704fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy final long c = inputStream.skip(n); 714fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy position += c; 724fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return c; 734fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 744fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 754fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public int read(byte b[]) throws IOException { 764fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy final int c = inputStream.read(b); 774fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy position += c; 784fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return c; 794fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 804fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 814fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy public int read(byte b[], int off, int len) throws IOException { 824fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy final int c = inputStream.read(b, off, len); 834fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy position += c; 844fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy return c; 854fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy } 864fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy 874fa0a3295bcacbdcd6a9e7709cf17aa5adb90356Scott Kennedy} 88