![]() |
Quadcap Embeddable Server |
00001 package com.quadcap.io; 00002 00003 /* Copyright 1997 - 2003 Quadcap Software. All rights reserved. 00004 * 00005 * This software is distributed under the Quadcap Free Software License. 00006 * This software may be used or modified for any purpose, personal or 00007 * commercial. Open Source redistributions are permitted. Commercial 00008 * redistribution of larger works derived from, or works which bundle 00009 * this software requires a "Commercial Redistribution License"; see 00010 * http://www.quadcap.com/purchase. 00011 * 00012 * Redistributions qualify as "Open Source" under one of the following terms: 00013 * 00014 * Redistributions are made at no charge beyond the reasonable cost of 00015 * materials and delivery. 00016 * 00017 * Redistributions are accompanied by a copy of the Source Code or by an 00018 * irrevocable offer to provide a copy of the Source Code for up to three 00019 * years at the cost of materials and delivery. Such redistributions 00020 * must allow further use, modification, and redistribution of the Source 00021 * Code under substantially the same terms as this license. 00022 * 00023 * Redistributions of source code must retain the copyright notices as they 00024 * appear in each source code file, these license terms, and the 00025 * disclaimer/limitation of liability set forth as paragraph 6 below. 00026 * 00027 * Redistributions in binary form must reproduce this Copyright Notice, 00028 * these license terms, and the disclaimer/limitation of liability set 00029 * forth as paragraph 6 below, in the documentation and/or other materials 00030 * provided with the distribution. 00031 * 00032 * The Software is provided on an "AS IS" basis. No warranty is 00033 * provided that the Software is free of defects, or fit for a 00034 * particular purpose. 00035 * 00036 * Limitation of Liability. Quadcap Software shall not be liable 00037 * for any damages suffered by the Licensee or any third party resulting 00038 * from use of the Software. 00039 */ 00040 00041 import java.io.*; 00042 00043 import com.quadcap.util.Debug; 00044 import com.quadcap.util.Util; 00045 00046 /** 00047 * A filter output stream that tees off its output to a log file 00048 * 00049 * @author Stan Bailes 00050 */ 00051 00052 public class LogOutputStream extends OutputStream { 00053 OutputStream out; 00054 OutputStream log; 00055 byte[] prefix; 00056 boolean bol = true; 00057 00058 /** 00059 * Construct a new log output stream 00060 * 00061 * @param os the underlying output stream 00062 * @param log the log stream 00063 * @param prefix a string identifying this log stream to be prefixed 00064 * to every line output by this filter. 00065 */ 00066 public LogOutputStream(OutputStream os, OutputStream log, String prefix) { 00067 this.out = os; 00068 this.log = log; 00069 this.prefix = prefix.getBytes(); 00070 } 00071 00072 /** 00073 * Write a byte. 00074 * 00075 * @param b the byte. 00076 * @exception IOException may be thrown. 00077 */ 00078 synchronized public void write(int b) throws IOException { 00079 out.write(b); 00080 if (bol) log.write(prefix); 00081 log.write(b); 00082 bol = (b == '\n'); 00083 } 00084 00085 /** 00086 * Write a buffer 00087 * 00088 * @param b the buffer 00089 * @param off the index of the first byte in the buffer to write. 00090 * @param len the number of bytes to write. 00091 * 00092 * @exception IOException may be thrown. 00093 */ 00094 synchronized public void write(byte[] b, int off, int len) 00095 throws IOException 00096 { 00097 for (int i = 0; i < len; i++) write(b[off+i]); 00098 } 00099 00100 /** 00101 * Write a buffer 00102 * 00103 * @param b the buffer 00104 * 00105 * @exception IOException may be thrown. 00106 */ 00107 synchronized public void write(byte[] b) throws IOException { 00108 write(b, 0, b.length); 00109 } 00110 00111 /** 00112 * Close the underlying stream and the log output stream 00113 * 00114 * @exception IOException may be thrown 00115 */ 00116 public void close() throws IOException { 00117 out.close(); 00118 log.close(); 00119 } 00120 00121 /** 00122 * Flush the underlying stream. 00123 * 00124 * @exception IOException may be thrown 00125 */ 00126 public void flush() throws IOException { 00127 out.flush(); 00128 } 00129 }