1f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin/* 2f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * Copyright (C) 2010 The Android Open Source Project 3f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * 4f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * Licensed under the Apache License, Version 2.0 (the "License"); 5f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * you may not use this file except in compliance with the License. 6f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * You may obtain a copy of the License at 7f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * 8f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * http://www.apache.org/licenses/LICENSE-2.0 9f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * 10f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * Unless required by applicable law or agreed to in writing, software 11f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * distributed under the License is distributed on an "AS IS" BASIS, 12f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * See the License for the specific language governing permissions and 14f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin * limitations under the License. 15f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin */ 16f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 17f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Linpackage com.android.gallery3d.util; 18f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 19f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Linimport com.android.gallery3d.common.Utils; 20f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 21f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Linimport java.io.IOException; 22f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Linimport java.io.InterruptedIOException; 23f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Linimport java.io.OutputStream; 24f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 25f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Linpublic class InterruptableOutputStream extends OutputStream { 26f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 27f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin private static final int MAX_WRITE_BYTES = 4096; 28f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 29f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin private OutputStream mOutputStream; 30f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin private volatile boolean mIsInterrupted = false; 31f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 32f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin public InterruptableOutputStream(OutputStream outputStream) { 33f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin mOutputStream = Utils.checkNotNull(outputStream); 34f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 35f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 36f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin @Override 37f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin public void write(int oneByte) throws IOException { 38f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin if (mIsInterrupted) throw new InterruptedIOException(); 39f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin mOutputStream.write(oneByte); 40f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 41f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 42f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin @Override 43f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin public void write(byte[] buffer, int offset, int count) throws IOException { 44f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin int end = offset + count; 45f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin while (offset < end) { 46f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin if (mIsInterrupted) throw new InterruptedIOException(); 47f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin int bytesCount = Math.min(MAX_WRITE_BYTES, end - offset); 48f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin mOutputStream.write(buffer, offset, bytesCount); 49f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin offset += bytesCount; 50f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 51f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 52f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 53f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin @Override 54f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin public void close() throws IOException { 55f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin mOutputStream.close(); 56f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 57f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 58f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin @Override 59f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin public void flush() throws IOException { 60f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin if (mIsInterrupted) throw new InterruptedIOException(); 61f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin mOutputStream.flush(); 62f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 63f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin 64f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin public void interrupt() { 65f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin mIsInterrupted = true; 66f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin } 67f9a0a4306d589b4a4e20554fed512a603426bfa1Owen Lin} 68