Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / ndp / fx / src / Net / System / Net / Mail / QuotedPrintableStream.cs / 1 / QuotedPrintableStream.cs
//------------------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//-----------------------------------------------------------------------------
namespace System.Net.Mime
{
using System;
using System.IO;
///
/// This stream performs in-place decoding of quoted-printable
/// encoded streams. Encoding requires copying into a separate
/// buffer as the data being encoded will most likely grow.
/// Encoding and decoding is done transparently to the caller.
///
internal class QuotedPrintableStream : DelegatedStream
{
bool encodeCRLF;
static int DefaultLineLength = 76;
static byte[] hexDecodeMap = new byte[] {// 0 1 2 3 4 5 6 7 8 9 A B C D E F
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 0
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 1
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 2
0, 1, 2, 3, 4, 5, 6, 7, 8, 9,255,255,255,255,255,255, // 3
255, 10, 11, 12, 13, 14, 15,255,255,255,255,255,255,255,255,255, // 4
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 5
255, 10, 11, 12, 13, 14, 15,255,255,255,255,255,255,255,255,255, // 6
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 7
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 8
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 9
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // A
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // B
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // C
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // D
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // E
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // F
};
static byte[] hexEncodeMap = new byte[] { 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 65, 66, 67, 68, 69, 70};
int lineLength;
ReadStateInfo readState;
WriteStateInfo writeState;
///
/// ctor.
///
/// Underlying stream
/// Preferred maximum line-length for writes
internal QuotedPrintableStream(Stream stream, int lineLength) : base(stream)
{
if (lineLength < 0)
throw new ArgumentOutOfRangeException("lineLength");
this.lineLength = lineLength;
}
/*
// Consider removing.
///
/// ctor.
///
/// Underlying stream
internal QuotedPrintableStream(Stream stream) : this(stream, DefaultLineLength)
{
}
*/
internal QuotedPrintableStream(Stream stream,bool encodeCRLF) : this(stream, DefaultLineLength)
{
this.encodeCRLF = encodeCRLF;
}
internal QuotedPrintableStream() {
this.lineLength = DefaultLineLength;
}
internal QuotedPrintableStream(int lineLength) {
this.lineLength = lineLength;
}
ReadStateInfo ReadState
{
get
{
if (this.readState == null)
this.readState = new ReadStateInfo();
return this.readState;
}
}
internal WriteStateInfo WriteState
{
get
{
if (this.writeState == null)
this.writeState = new WriteStateInfo(1024);
return this.writeState;
}
}
/*
public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, object state)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
ReadAsyncResult result = new ReadAsyncResult(this, buffer, offset, count, callback, state);
result.Read();
return result;
}
*/
public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, object state)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
WriteAsyncResult result = new WriteAsyncResult(this, buffer, offset, count, callback, state);
result.Write();
return result;
}
public override void Close()
{
FlushInternal();
base.Close();
}
internal int DecodeBytes(byte[] buffer, int offset, int count)
{
unsafe
{
fixed (byte* pBuffer = buffer)
{
byte* start = pBuffer + offset;
byte* source = start;
byte* dest = start;
byte* end = start + count;
// if the last read ended in a partially decoded
// sequence, pick up where we left off.
if (ReadState.IsEscaped)
{
// this will be -1 if the previous read ended
// with an escape character.
if (ReadState.Byte == -1)
{
// if we only read one byte from the underlying
// stream, we'll need to save the byte and
// ask for more.
if (count == 1)
{
ReadState.Byte = *source;
return 0;
}
// '=\r\n' means a soft (aka. invisible) CRLF sequence...
if (source[0] != '\r' || source[1] != '\n')
{
byte b1 = hexDecodeMap[source[0]];
byte b2 = hexDecodeMap[source[1]];
if (b1 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b1));
if (b2 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b2));
*dest++ = (byte)((b1 << 4) + b2);
}
source += 2;
}
else
{
// '=\r\n' means a soft (aka. invisible) CRLF sequence...
if (ReadState.Byte != '\r' || *source != '\n')
{
byte b1 = hexDecodeMap[ReadState.Byte];
byte b2 = hexDecodeMap[*source];
if (b1 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b1));
if (b2 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b2));
*dest++ = (byte)((b1 << 4) + b2);
}
source++;
}
// reset state for next read.
ReadState.IsEscaped = false;
ReadState.Byte = -1;
}
// Here's where most of the decoding takes place.
// We'll loop around until we've inspected all the
// bytes read.
while (source < end)
{
// if the source is not an escape character, then
// just copy as-is.
if (*source != '=')
{
*dest++ = *source++;
}
else
{
// determine where we are relative to the end
// of the data. If we don't have enough data to
// decode the escape sequence, save off what we
// have and continue the decoding in the next
// read. Otherwise, decode the data and copy
// into dest.
switch (end - source)
{
case 2:
ReadState.Byte = source[1];
goto case 1;
case 1:
ReadState.IsEscaped = true;
goto EndWhile;
default:
if (source[1] != '\r' || source[2] != '\n')
{
byte b1 = hexDecodeMap[source[1]];
byte b2 = hexDecodeMap[source[2]];
if (b1 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b1));
if (b2 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b2));
*dest++ = (byte)((b1 << 4) + b2);
}
source += 3;
break;
}
}
}
EndWhile:
count = (int)(dest - start);
}
}
return count;
}
internal int EncodeBytes(byte[] buffer, int offset, int count)
{
int cur = offset;
for (; cur < count + offset; cur++)
{
//only fold if we're before a whitespace
if (lineLength != -1 && WriteState.CurrentLineLength + 5 >= this.lineLength && (buffer[cur] == ' ' ||
buffer[cur] == '\t' || buffer[cur] == '\r' || buffer[cur] == '\n'))
{
if (WriteState.Buffer.Length - WriteState.Length < 3)
return cur - offset;
WriteState.CurrentLineLength = 0;
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = (byte)'\r';
WriteState.Buffer[WriteState.Length++] = (byte)'\n';
}
//need to dot stuff - rfc 2821 4.5.2 Transparency
if(WriteState.CurrentLineLength == 0 && buffer[cur] == '.'){
WriteState.Buffer[WriteState.Length++] = (byte)'.';
}
if (buffer[cur] == '\r' && cur + 1 < count + offset && buffer[cur+1] == '\n')
{
if (WriteState.Buffer.Length - WriteState.Length < (encodeCRLF ? 6 : 2))
return cur - offset;
cur++;
if(encodeCRLF){
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = (byte)'0';
WriteState.Buffer[WriteState.Length++] = (byte)'D';
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = (byte)'0';
WriteState.Buffer[WriteState.Length++] = (byte)'A';
WriteState.CurrentLineLength += 6;
}
else{
WriteState.Buffer[WriteState.Length++] = (byte)'\r';
WriteState.Buffer[WriteState.Length++] = (byte)'\n';
WriteState.CurrentLineLength = 0;
}
}
else if ((buffer[cur] < 32 && buffer[cur] != '\t') ||
buffer[cur] == '=' ||
buffer[cur] > 126)
{
if (WriteState.Buffer.Length - WriteState.Length < 3)
return cur - offset;
WriteState.CurrentLineLength += 3;
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = hexEncodeMap[buffer[cur] >> 4];
WriteState.Buffer[WriteState.Length++] = hexEncodeMap[buffer[cur] & 0xF];
}
else
{
if (WriteState.Buffer.Length - WriteState.Length < 1)
return cur - offset;
WriteState.CurrentLineLength++;
WriteState.Buffer[WriteState.Length++] = buffer[cur];
}
}
return cur - offset;
}
/*
public override int EndRead(IAsyncResult asyncResult)
{
int read = ReadAsyncResult.End(asyncResult);
return read;
}
*/
public override void EndWrite(IAsyncResult asyncResult)
{
WriteAsyncResult.End(asyncResult);
}
public override void Flush()
{
FlushInternal();
base.Flush();
}
void FlushInternal()
{
if (this.writeState != null && this.writeState.Length > 0)
{
base.Write(WriteState.Buffer, 0, WriteState.Length);
WriteState.Length = 0;
}
}
///
/// Reads data from the underlying stream into the supplied
/// buffer and does decoding in-place.
///
/// Buffer to read into
/// Offset within buffer to start writing
/// Maximum count of bytes to read
/// Number of decoded bytes read, 0 if EOS
/*
public override int Read(byte[] buffer, int offset, int count)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
for (;;)
{
// read data from the underlying stream
int read = base.Read(buffer, offset, count);
// if the underlying stream returns 0 then there
// is no more data - ust return 0.
if (read == 0)
{
return 0;
}
// while decoding, we may end up not having
// any bytes to return pending additional data
// from the underlying stream.
read = DecodeBytes(buffer, offset, read);
if (read > 0)
{
return read;
}
}
}
*/
public override void Write(byte[] buffer, int offset, int count)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
int written = 0;
for (;;)
{
written += EncodeBytes(buffer, offset + written, count - written);
if (written < count)
FlushInternal();
else
break;
}
}
/*
class ReadAsyncResult : LazyAsyncResult
{
QuotedPrintableStream parent;
byte[] buffer;
int offset;
int count;
int read;
static AsyncCallback onRead = new AsyncCallback(OnRead);
internal ReadAsyncResult(QuotedPrintableStream parent, byte[] buffer, int offset, int count, AsyncCallback callback, object state) : base(null, state, callback)
{
this.parent = parent;
this.buffer = buffer;
this.offset = offset;
this.count = count;
}
bool CompleteRead(IAsyncResult result)
{
this.read = this.parent.BaseStream.EndRead(result);
// if the underlying stream returns 0 then there
// is no more data - ust return 0.
if (read == 0)
{
InvokeCallback();
return true;
}
// while decoding, we may end up not having
// any bytes to return pending additional data
// from the underlying stream.
this.read = this.parent.DecodeBytes(this.buffer, this.offset, this.read);
if (this.read > 0)
{
InvokeCallback();
return true;
}
return false;
}
static void OnRead(IAsyncResult result)
{
if (!result.CompletedSynchronously)
{
ReadAsyncResult thisPtr = (ReadAsyncResult)result.AsyncState;
try
{
if (!thisPtr.CompleteRead(result))
thisPtr.Read();
}
catch (Exception e)
{
thisPtr.InvokeCallback(e);
}
catch {
thisPtr.InvokeCallback(new Exception(SR.GetString(SR.net_nonClsCompliantException)));
}
}
}
internal void Read()
{
for (;;)
{
IAsyncResult result = this.parent.BaseStream.BeginRead(this.buffer, this.offset, this.count, onRead, this);
if (!result.CompletedSynchronously || CompleteRead(result))
break;
}
}
internal static int End(IAsyncResult result)
{
ReadAsyncResult thisPtr = (ReadAsyncResult)result;
thisPtr.InternalWaitForCompletion();
return thisPtr.read;
}
}
*/
class ReadStateInfo
{
bool isEscaped = false;
short b1 = -1;
internal bool IsEscaped
{
get { return this.isEscaped; }
set { this.isEscaped = value; }
}
internal short Byte
{
get { return this.b1; }
set { this.b1 = value; }
}
}
internal class WriteStateInfo
{
int currentLineLength = 0;
byte[] buffer;
int length;
internal WriteStateInfo(int bufferSize)
{
this.buffer = new byte[bufferSize];
}
internal byte[] Buffer
{
get { return this.buffer; }
}
internal int CurrentLineLength
{
get { return this.currentLineLength; }
set { this.currentLineLength = value; }
}
internal int Length
{
get { return this.length; }
set { this.length = value; }
}
}
class WriteAsyncResult : LazyAsyncResult
{
QuotedPrintableStream parent;
byte[] buffer;
int offset;
int count;
static AsyncCallback onWrite = new AsyncCallback(OnWrite);
int written;
internal WriteAsyncResult(QuotedPrintableStream parent, byte[] buffer, int offset, int count, AsyncCallback callback, object state) : base(null, state, callback)
{
this.parent = parent;
this.buffer = buffer;
this.offset = offset;
this.count = count;
}
void CompleteWrite(IAsyncResult result)
{
this.parent.BaseStream.EndWrite(result);
this.parent.WriteState.Length = 0;
}
internal static void End(IAsyncResult result)
{
WriteAsyncResult thisPtr = (WriteAsyncResult)result;
thisPtr.InternalWaitForCompletion();
System.Diagnostics.Debug.Assert(thisPtr.written == thisPtr.count);
}
static void OnWrite(IAsyncResult result)
{
if (!result.CompletedSynchronously)
{
WriteAsyncResult thisPtr = (WriteAsyncResult)result.AsyncState;
try
{
thisPtr.CompleteWrite(result);
thisPtr.Write();
}
catch (Exception e)
{
thisPtr.InvokeCallback(e);
}
catch {
thisPtr.InvokeCallback(new Exception(SR.GetString(SR.net_nonClsCompliantException)));
}
}
}
internal void Write()
{
for (;;)
{
this.written += this.parent.EncodeBytes(this.buffer, this.offset + this.written, this.count - this.written);
if (this.written < this.count)
{
IAsyncResult result = this.parent.BaseStream.BeginWrite(this.parent.WriteState.Buffer, 0, this.parent.WriteState.Length, onWrite, this);
if (!result.CompletedSynchronously)
break;
CompleteWrite(result);
}
else
{
InvokeCallback();
break;
}
}
}
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
//------------------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//-----------------------------------------------------------------------------
namespace System.Net.Mime
{
using System;
using System.IO;
///
/// This stream performs in-place decoding of quoted-printable
/// encoded streams. Encoding requires copying into a separate
/// buffer as the data being encoded will most likely grow.
/// Encoding and decoding is done transparently to the caller.
///
internal class QuotedPrintableStream : DelegatedStream
{
bool encodeCRLF;
static int DefaultLineLength = 76;
static byte[] hexDecodeMap = new byte[] {// 0 1 2 3 4 5 6 7 8 9 A B C D E F
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 0
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 1
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 2
0, 1, 2, 3, 4, 5, 6, 7, 8, 9,255,255,255,255,255,255, // 3
255, 10, 11, 12, 13, 14, 15,255,255,255,255,255,255,255,255,255, // 4
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 5
255, 10, 11, 12, 13, 14, 15,255,255,255,255,255,255,255,255,255, // 6
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 7
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 8
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // 9
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // A
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // B
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // C
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // D
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // E
255,255,255,255,255,255,255,255,255,255,255,255,255,255,255,255, // F
};
static byte[] hexEncodeMap = new byte[] { 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 65, 66, 67, 68, 69, 70};
int lineLength;
ReadStateInfo readState;
WriteStateInfo writeState;
///
/// ctor.
///
/// Underlying stream
/// Preferred maximum line-length for writes
internal QuotedPrintableStream(Stream stream, int lineLength) : base(stream)
{
if (lineLength < 0)
throw new ArgumentOutOfRangeException("lineLength");
this.lineLength = lineLength;
}
/*
// Consider removing.
///
/// ctor.
///
/// Underlying stream
internal QuotedPrintableStream(Stream stream) : this(stream, DefaultLineLength)
{
}
*/
internal QuotedPrintableStream(Stream stream,bool encodeCRLF) : this(stream, DefaultLineLength)
{
this.encodeCRLF = encodeCRLF;
}
internal QuotedPrintableStream() {
this.lineLength = DefaultLineLength;
}
internal QuotedPrintableStream(int lineLength) {
this.lineLength = lineLength;
}
ReadStateInfo ReadState
{
get
{
if (this.readState == null)
this.readState = new ReadStateInfo();
return this.readState;
}
}
internal WriteStateInfo WriteState
{
get
{
if (this.writeState == null)
this.writeState = new WriteStateInfo(1024);
return this.writeState;
}
}
/*
public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, object state)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
ReadAsyncResult result = new ReadAsyncResult(this, buffer, offset, count, callback, state);
result.Read();
return result;
}
*/
public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, object state)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
WriteAsyncResult result = new WriteAsyncResult(this, buffer, offset, count, callback, state);
result.Write();
return result;
}
public override void Close()
{
FlushInternal();
base.Close();
}
internal int DecodeBytes(byte[] buffer, int offset, int count)
{
unsafe
{
fixed (byte* pBuffer = buffer)
{
byte* start = pBuffer + offset;
byte* source = start;
byte* dest = start;
byte* end = start + count;
// if the last read ended in a partially decoded
// sequence, pick up where we left off.
if (ReadState.IsEscaped)
{
// this will be -1 if the previous read ended
// with an escape character.
if (ReadState.Byte == -1)
{
// if we only read one byte from the underlying
// stream, we'll need to save the byte and
// ask for more.
if (count == 1)
{
ReadState.Byte = *source;
return 0;
}
// '=\r\n' means a soft (aka. invisible) CRLF sequence...
if (source[0] != '\r' || source[1] != '\n')
{
byte b1 = hexDecodeMap[source[0]];
byte b2 = hexDecodeMap[source[1]];
if (b1 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b1));
if (b2 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b2));
*dest++ = (byte)((b1 << 4) + b2);
}
source += 2;
}
else
{
// '=\r\n' means a soft (aka. invisible) CRLF sequence...
if (ReadState.Byte != '\r' || *source != '\n')
{
byte b1 = hexDecodeMap[ReadState.Byte];
byte b2 = hexDecodeMap[*source];
if (b1 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b1));
if (b2 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b2));
*dest++ = (byte)((b1 << 4) + b2);
}
source++;
}
// reset state for next read.
ReadState.IsEscaped = false;
ReadState.Byte = -1;
}
// Here's where most of the decoding takes place.
// We'll loop around until we've inspected all the
// bytes read.
while (source < end)
{
// if the source is not an escape character, then
// just copy as-is.
if (*source != '=')
{
*dest++ = *source++;
}
else
{
// determine where we are relative to the end
// of the data. If we don't have enough data to
// decode the escape sequence, save off what we
// have and continue the decoding in the next
// read. Otherwise, decode the data and copy
// into dest.
switch (end - source)
{
case 2:
ReadState.Byte = source[1];
goto case 1;
case 1:
ReadState.IsEscaped = true;
goto EndWhile;
default:
if (source[1] != '\r' || source[2] != '\n')
{
byte b1 = hexDecodeMap[source[1]];
byte b2 = hexDecodeMap[source[2]];
if (b1 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b1));
if (b2 == 255)
throw new FormatException(SR.GetString(SR.InvalidHexDigit, b2));
*dest++ = (byte)((b1 << 4) + b2);
}
source += 3;
break;
}
}
}
EndWhile:
count = (int)(dest - start);
}
}
return count;
}
internal int EncodeBytes(byte[] buffer, int offset, int count)
{
int cur = offset;
for (; cur < count + offset; cur++)
{
//only fold if we're before a whitespace
if (lineLength != -1 && WriteState.CurrentLineLength + 5 >= this.lineLength && (buffer[cur] == ' ' ||
buffer[cur] == '\t' || buffer[cur] == '\r' || buffer[cur] == '\n'))
{
if (WriteState.Buffer.Length - WriteState.Length < 3)
return cur - offset;
WriteState.CurrentLineLength = 0;
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = (byte)'\r';
WriteState.Buffer[WriteState.Length++] = (byte)'\n';
}
//need to dot stuff - rfc 2821 4.5.2 Transparency
if(WriteState.CurrentLineLength == 0 && buffer[cur] == '.'){
WriteState.Buffer[WriteState.Length++] = (byte)'.';
}
if (buffer[cur] == '\r' && cur + 1 < count + offset && buffer[cur+1] == '\n')
{
if (WriteState.Buffer.Length - WriteState.Length < (encodeCRLF ? 6 : 2))
return cur - offset;
cur++;
if(encodeCRLF){
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = (byte)'0';
WriteState.Buffer[WriteState.Length++] = (byte)'D';
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = (byte)'0';
WriteState.Buffer[WriteState.Length++] = (byte)'A';
WriteState.CurrentLineLength += 6;
}
else{
WriteState.Buffer[WriteState.Length++] = (byte)'\r';
WriteState.Buffer[WriteState.Length++] = (byte)'\n';
WriteState.CurrentLineLength = 0;
}
}
else if ((buffer[cur] < 32 && buffer[cur] != '\t') ||
buffer[cur] == '=' ||
buffer[cur] > 126)
{
if (WriteState.Buffer.Length - WriteState.Length < 3)
return cur - offset;
WriteState.CurrentLineLength += 3;
WriteState.Buffer[WriteState.Length++] = (byte)'=';
WriteState.Buffer[WriteState.Length++] = hexEncodeMap[buffer[cur] >> 4];
WriteState.Buffer[WriteState.Length++] = hexEncodeMap[buffer[cur] & 0xF];
}
else
{
if (WriteState.Buffer.Length - WriteState.Length < 1)
return cur - offset;
WriteState.CurrentLineLength++;
WriteState.Buffer[WriteState.Length++] = buffer[cur];
}
}
return cur - offset;
}
/*
public override int EndRead(IAsyncResult asyncResult)
{
int read = ReadAsyncResult.End(asyncResult);
return read;
}
*/
public override void EndWrite(IAsyncResult asyncResult)
{
WriteAsyncResult.End(asyncResult);
}
public override void Flush()
{
FlushInternal();
base.Flush();
}
void FlushInternal()
{
if (this.writeState != null && this.writeState.Length > 0)
{
base.Write(WriteState.Buffer, 0, WriteState.Length);
WriteState.Length = 0;
}
}
///
/// Reads data from the underlying stream into the supplied
/// buffer and does decoding in-place.
///
/// Buffer to read into
/// Offset within buffer to start writing
/// Maximum count of bytes to read
/// Number of decoded bytes read, 0 if EOS
/*
public override int Read(byte[] buffer, int offset, int count)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
for (;;)
{
// read data from the underlying stream
int read = base.Read(buffer, offset, count);
// if the underlying stream returns 0 then there
// is no more data - ust return 0.
if (read == 0)
{
return 0;
}
// while decoding, we may end up not having
// any bytes to return pending additional data
// from the underlying stream.
read = DecodeBytes(buffer, offset, read);
if (read > 0)
{
return read;
}
}
}
*/
public override void Write(byte[] buffer, int offset, int count)
{
if (buffer == null)
throw new ArgumentNullException("buffer");
if (offset < 0 || offset > buffer.Length)
throw new ArgumentOutOfRangeException("offset");
if (offset + count > buffer.Length)
throw new ArgumentOutOfRangeException("count");
int written = 0;
for (;;)
{
written += EncodeBytes(buffer, offset + written, count - written);
if (written < count)
FlushInternal();
else
break;
}
}
/*
class ReadAsyncResult : LazyAsyncResult
{
QuotedPrintableStream parent;
byte[] buffer;
int offset;
int count;
int read;
static AsyncCallback onRead = new AsyncCallback(OnRead);
internal ReadAsyncResult(QuotedPrintableStream parent, byte[] buffer, int offset, int count, AsyncCallback callback, object state) : base(null, state, callback)
{
this.parent = parent;
this.buffer = buffer;
this.offset = offset;
this.count = count;
}
bool CompleteRead(IAsyncResult result)
{
this.read = this.parent.BaseStream.EndRead(result);
// if the underlying stream returns 0 then there
// is no more data - ust return 0.
if (read == 0)
{
InvokeCallback();
return true;
}
// while decoding, we may end up not having
// any bytes to return pending additional data
// from the underlying stream.
this.read = this.parent.DecodeBytes(this.buffer, this.offset, this.read);
if (this.read > 0)
{
InvokeCallback();
return true;
}
return false;
}
static void OnRead(IAsyncResult result)
{
if (!result.CompletedSynchronously)
{
ReadAsyncResult thisPtr = (ReadAsyncResult)result.AsyncState;
try
{
if (!thisPtr.CompleteRead(result))
thisPtr.Read();
}
catch (Exception e)
{
thisPtr.InvokeCallback(e);
}
catch {
thisPtr.InvokeCallback(new Exception(SR.GetString(SR.net_nonClsCompliantException)));
}
}
}
internal void Read()
{
for (;;)
{
IAsyncResult result = this.parent.BaseStream.BeginRead(this.buffer, this.offset, this.count, onRead, this);
if (!result.CompletedSynchronously || CompleteRead(result))
break;
}
}
internal static int End(IAsyncResult result)
{
ReadAsyncResult thisPtr = (ReadAsyncResult)result;
thisPtr.InternalWaitForCompletion();
return thisPtr.read;
}
}
*/
class ReadStateInfo
{
bool isEscaped = false;
short b1 = -1;
internal bool IsEscaped
{
get { return this.isEscaped; }
set { this.isEscaped = value; }
}
internal short Byte
{
get { return this.b1; }
set { this.b1 = value; }
}
}
internal class WriteStateInfo
{
int currentLineLength = 0;
byte[] buffer;
int length;
internal WriteStateInfo(int bufferSize)
{
this.buffer = new byte[bufferSize];
}
internal byte[] Buffer
{
get { return this.buffer; }
}
internal int CurrentLineLength
{
get { return this.currentLineLength; }
set { this.currentLineLength = value; }
}
internal int Length
{
get { return this.length; }
set { this.length = value; }
}
}
class WriteAsyncResult : LazyAsyncResult
{
QuotedPrintableStream parent;
byte[] buffer;
int offset;
int count;
static AsyncCallback onWrite = new AsyncCallback(OnWrite);
int written;
internal WriteAsyncResult(QuotedPrintableStream parent, byte[] buffer, int offset, int count, AsyncCallback callback, object state) : base(null, state, callback)
{
this.parent = parent;
this.buffer = buffer;
this.offset = offset;
this.count = count;
}
void CompleteWrite(IAsyncResult result)
{
this.parent.BaseStream.EndWrite(result);
this.parent.WriteState.Length = 0;
}
internal static void End(IAsyncResult result)
{
WriteAsyncResult thisPtr = (WriteAsyncResult)result;
thisPtr.InternalWaitForCompletion();
System.Diagnostics.Debug.Assert(thisPtr.written == thisPtr.count);
}
static void OnWrite(IAsyncResult result)
{
if (!result.CompletedSynchronously)
{
WriteAsyncResult thisPtr = (WriteAsyncResult)result.AsyncState;
try
{
thisPtr.CompleteWrite(result);
thisPtr.Write();
}
catch (Exception e)
{
thisPtr.InvokeCallback(e);
}
catch {
thisPtr.InvokeCallback(new Exception(SR.GetString(SR.net_nonClsCompliantException)));
}
}
}
internal void Write()
{
for (;;)
{
this.written += this.parent.EncodeBytes(this.buffer, this.offset + this.written, this.count - this.written);
if (this.written < this.count)
{
IAsyncResult result = this.parent.BaseStream.BeginWrite(this.parent.WriteState.Buffer, 0, this.parent.WriteState.Length, onWrite, this);
if (!result.CompletedSynchronously)
break;
CompleteWrite(result);
}
else
{
InvokeCallback();
break;
}
}
}
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- BridgeDataRecord.cs
- BooleanToSelectiveScrollingOrientationConverter.cs
- DrawListViewSubItemEventArgs.cs
- WebPartCollection.cs
- PipeStream.cs
- CommandHelpers.cs
- SqlCaseSimplifier.cs
- AppLevelCompilationSectionCache.cs
- SettingsContext.cs
- HtmlLink.cs
- ValidationException.cs
- OdbcHandle.cs
- UnsafeNativeMethods.cs
- HttpWrapper.cs
- SystemColors.cs
- DataSourceView.cs
- NGCSerializerAsync.cs
- Model3DGroup.cs
- Literal.cs
- JulianCalendar.cs
- RectangleGeometry.cs
- DecimalKeyFrameCollection.cs
- IndependentAnimationStorage.cs
- PassportAuthentication.cs
- RemoteWebConfigurationHost.cs
- ContentTextAutomationPeer.cs
- CorrelationTokenInvalidatedHandler.cs
- ListViewItemSelectionChangedEvent.cs
- TransformGroup.cs
- ImportContext.cs
- ThreadExceptionDialog.cs
- AsyncWaitHandle.cs
- VirtualizingPanel.cs
- DateTimeUtil.cs
- ProbeMatchesMessage11.cs
- InnerItemCollectionView.cs
- OleDbSchemaGuid.cs
- ObjectHelper.cs
- Vector3DCollectionConverter.cs
- TableItemStyle.cs
- MetadataCache.cs
- NoClickablePointException.cs
- AppSettingsSection.cs
- PolicyImporterElement.cs
- FormViewModeEventArgs.cs
- TreeBuilderBamlTranslator.cs
- PageThemeBuildProvider.cs
- URLIdentityPermission.cs
- XPathScanner.cs
- BuildProvider.cs
- DataServiceHost.cs
- arabicshape.cs
- InvokeBase.cs
- WebPartConnectionsEventArgs.cs
- BitmapEffectInput.cs
- QilSortKey.cs
- HttpListenerContext.cs
- dataSvcMapFileLoader.cs
- BindingRestrictions.cs
- PropertyFilterAttribute.cs
- DtdParser.cs
- RadioButtonFlatAdapter.cs
- BooleanExpr.cs
- GeometryCollection.cs
- StylusSystemGestureEventArgs.cs
- ChtmlTextWriter.cs
- DependentList.cs
- NavigationCommands.cs
- RequestTimeoutManager.cs
- TableItemProviderWrapper.cs
- TransactionBridge.cs
- ComplexPropertyEntry.cs
- OutputCacheSettings.cs
- WebPartManager.cs
- HttpProfileGroupBase.cs
- WindowsStreamSecurityUpgradeProvider.cs
- ConfigUtil.cs
- ObjectDataSourceEventArgs.cs
- QuarticEase.cs
- GridViewHeaderRowPresenterAutomationPeer.cs
- AssociationEndMember.cs
- MobileErrorInfo.cs
- TextBreakpoint.cs
- PageStatePersister.cs
- path.cs
- RelationshipFixer.cs
- DataSourceCache.cs
- PermissionToken.cs
- ControlUtil.cs
- AbsoluteQuery.cs
- MatrixUtil.cs
- PermissionToken.cs
- RepeaterItem.cs
- ClientSection.cs
- PageClientProxyGenerator.cs
- CorrelationKey.cs
- VisualStyleInformation.cs
- DataReceivedEventArgs.cs
- MultiBinding.cs
- GenerateTemporaryTargetAssembly.cs