1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000 1.2 +++ b/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/LoggingSessionOutputBuffer.java Wed Dec 31 06:09:35 2014 +0100 1.3 @@ -0,0 +1,119 @@ 1.4 +/* 1.5 + * ==================================================================== 1.6 + * 1.7 + * Licensed to the Apache Software Foundation (ASF) under one or more 1.8 + * contributor license agreements. See the NOTICE file distributed with 1.9 + * this work for additional information regarding copyright ownership. 1.10 + * The ASF licenses this file to You under the Apache License, Version 2.0 1.11 + * (the "License"); you may not use this file except in compliance with 1.12 + * the License. You may obtain a copy of the License at 1.13 + * 1.14 + * http://www.apache.org/licenses/LICENSE-2.0 1.15 + * 1.16 + * Unless required by applicable law or agreed to in writing, software 1.17 + * distributed under the License is distributed on an "AS IS" BASIS, 1.18 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1.19 + * See the License for the specific language governing permissions and 1.20 + * limitations under the License. 1.21 + * ==================================================================== 1.22 + * 1.23 + * This software consists of voluntary contributions made by many 1.24 + * individuals on behalf of the Apache Software Foundation. For more 1.25 + * information on the Apache Software Foundation, please see 1.26 + * <http://www.apache.org/>. 1.27 + * 1.28 + */ 1.29 + 1.30 +package ch.boye.httpclientandroidlib.impl.conn; 1.31 + 1.32 +import java.io.IOException; 1.33 + 1.34 +import ch.boye.httpclientandroidlib.annotation.Immutable; 1.35 + 1.36 +import ch.boye.httpclientandroidlib.io.HttpTransportMetrics; 1.37 +import ch.boye.httpclientandroidlib.io.SessionOutputBuffer; 1.38 +import ch.boye.httpclientandroidlib.protocol.HTTP; 1.39 +import ch.boye.httpclientandroidlib.util.CharArrayBuffer; 1.40 + 1.41 +/** 1.42 + * Logs all data written to the wire LOG. 1.43 + * 1.44 + * 1.45 + * @since 4.0 1.46 + */ 1.47 +@Immutable 1.48 +public class LoggingSessionOutputBuffer implements SessionOutputBuffer { 1.49 + 1.50 + /** Original data transmitter. */ 1.51 + private final SessionOutputBuffer out; 1.52 + 1.53 + /** The wire log to use. */ 1.54 + private final Wire wire; 1.55 + 1.56 + private final String charset; 1.57 + 1.58 + /** 1.59 + * Create an instance that wraps the specified session output buffer. 1.60 + * @param out The session output buffer. 1.61 + * @param wire The Wire log to use. 1.62 + * @param charset protocol charset, <code>ASCII</code> if <code>null</code> 1.63 + */ 1.64 + public LoggingSessionOutputBuffer( 1.65 + final SessionOutputBuffer out, final Wire wire, final String charset) { 1.66 + super(); 1.67 + this.out = out; 1.68 + this.wire = wire; 1.69 + this.charset = charset != null ? charset : HTTP.ASCII; 1.70 + } 1.71 + 1.72 + public LoggingSessionOutputBuffer(final SessionOutputBuffer out, final Wire wire) { 1.73 + this(out, wire, null); 1.74 + } 1.75 + 1.76 + public void write(byte[] b, int off, int len) throws IOException { 1.77 + this.out.write(b, off, len); 1.78 + if (this.wire.enabled()) { 1.79 + this.wire.output(b, off, len); 1.80 + } 1.81 + } 1.82 + 1.83 + public void write(int b) throws IOException { 1.84 + this.out.write(b); 1.85 + if (this.wire.enabled()) { 1.86 + this.wire.output(b); 1.87 + } 1.88 + } 1.89 + 1.90 + public void write(byte[] b) throws IOException { 1.91 + this.out.write(b); 1.92 + if (this.wire.enabled()) { 1.93 + this.wire.output(b); 1.94 + } 1.95 + } 1.96 + 1.97 + public void flush() throws IOException { 1.98 + this.out.flush(); 1.99 + } 1.100 + 1.101 + public void writeLine(final CharArrayBuffer buffer) throws IOException { 1.102 + this.out.writeLine(buffer); 1.103 + if (this.wire.enabled()) { 1.104 + String s = new String(buffer.buffer(), 0, buffer.length()); 1.105 + String tmp = s + "\r\n"; 1.106 + this.wire.output(tmp.getBytes(this.charset)); 1.107 + } 1.108 + } 1.109 + 1.110 + public void writeLine(final String s) throws IOException { 1.111 + this.out.writeLine(s); 1.112 + if (this.wire.enabled()) { 1.113 + String tmp = s + "\r\n"; 1.114 + this.wire.output(tmp.getBytes(this.charset)); 1.115 + } 1.116 + } 1.117 + 1.118 + public HttpTransportMetrics getMetrics() { 1.119 + return this.out.getMetrics(); 1.120 + } 1.121 + 1.122 +}