softether-vpn/src/BuildUtil/CoreUtil/Buf.cs

704 lines
16 KiB
C#

// CoreUtil
//
// Copyright (C) 2012-2014 Daiyuu Nobori. All Rights Reserved.
// Copyright (C) 2012-2014 SoftEther VPN Project at University of Tsukuba. All Rights Reserved.
// Comments: Tetsuo Sugiyama, Ph.D.
//
// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public License
// version 2 as published by the Free Software Foundation.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License version 2
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//
// THE LICENSE AGREEMENT IS ATTACHED ON THE SOURCE-CODE PACKAGE
// AS "LICENSE.TXT" FILE. READ THE TEXT FILE IN ADVANCE TO USE THE SOFTWARE.
//
//
// THIS SOFTWARE IS DEVELOPED IN JAPAN, AND DISTRIBUTED FROM JAPAN,
// UNDER JAPANESE LAWS. YOU MUST AGREE IN ADVANCE TO USE, COPY, MODIFY,
// MERGE, PUBLISH, DISTRIBUTE, SUBLICENSE, AND/OR SELL COPIES OF THIS
// SOFTWARE, THAT ANY JURIDICAL DISPUTES WHICH ARE CONCERNED TO THIS
// SOFTWARE OR ITS CONTENTS, AGAINST US (SOFTETHER PROJECT, SOFTETHER
// CORPORATION, DAIYUU NOBORI OR OTHER SUPPLIERS), OR ANY JURIDICAL
// DISPUTES AGAINST US WHICH ARE CAUSED BY ANY KIND OF USING, COPYING,
// MODIFYING, MERGING, PUBLISHING, DISTRIBUTING, SUBLICENSING, AND/OR
// SELLING COPIES OF THIS SOFTWARE SHALL BE REGARDED AS BE CONSTRUED AND
// CONTROLLED BY JAPANESE LAWS, AND YOU MUST FURTHER CONSENT TO
// EXCLUSIVE JURISDICTION AND VENUE IN THE COURTS SITTING IN TOKYO,
// JAPAN. YOU MUST WAIVE ALL DEFENSES OF LACK OF PERSONAL JURISDICTION
// AND FORUM NON CONVENIENS. PROCESS MAY BE SERVED ON EITHER PARTY IN
// THE MANNER AUTHORIZED BY APPLICABLE LAW OR COURT RULE.
//
// USE ONLY IN JAPAN. DO NOT USE THIS SOFTWARE IN ANOTHER COUNTRY UNLESS
// YOU HAVE A CONFIRMATION THAT THIS SOFTWARE DOES NOT VIOLATE ANY
// CRIMINAL LAWS OR CIVIL RIGHTS IN THAT PARTICULAR COUNTRY. USING THIS
// SOFTWARE IN OTHER COUNTRIES IS COMPLETELY AT YOUR OWN RISK. THE
// SOFTETHER VPN PROJECT HAS DEVELOPED AND DISTRIBUTED THIS SOFTWARE TO
// COMPLY ONLY WITH THE JAPANESE LAWS AND EXISTING CIVIL RIGHTS INCLUDING
// PATENTS WHICH ARE SUBJECTS APPLY IN JAPAN. OTHER COUNTRIES' LAWS OR
// CIVIL RIGHTS ARE NONE OF OUR CONCERNS NOR RESPONSIBILITIES. WE HAVE
// NEVER INVESTIGATED ANY CRIMINAL REGULATIONS, CIVIL LAWS OR
// INTELLECTUAL PROPERTY RIGHTS INCLUDING PATENTS IN ANY OF OTHER 200+
// COUNTRIES AND TERRITORIES. BY NATURE, THERE ARE 200+ REGIONS IN THE
// WORLD, WITH DIFFERENT LAWS. IT IS IMPOSSIBLE TO VERIFY EVERY
// COUNTRIES' LAWS, REGULATIONS AND CIVIL RIGHTS TO MAKE THE SOFTWARE
// COMPLY WITH ALL COUNTRIES' LAWS BY THE PROJECT. EVEN IF YOU WILL BE
// SUED BY A PRIVATE ENTITY OR BE DAMAGED BY A PUBLIC SERVANT IN YOUR
// COUNTRY, THE DEVELOPERS OF THIS SOFTWARE WILL NEVER BE LIABLE TO
// RECOVER OR COMPENSATE SUCH DAMAGES, CRIMINAL OR CIVIL
// RESPONSIBILITIES. NOTE THAT THIS LINE IS NOT LICENSE RESTRICTION BUT
// JUST A STATEMENT FOR WARNING AND DISCLAIMER.
//
//
// SOURCE CODE CONTRIBUTION
// ------------------------
//
// Your contribution to SoftEther VPN Project is much appreciated.
// Please send patches to us through GitHub.
// Read the SoftEther VPN Patch Acceptance Policy in advance:
// http://www.softether.org/5-download/src/9.patch
//
//
// DEAR SECURITY EXPERTS
// ---------------------
//
// If you find a bug or a security vulnerability please kindly inform us
// about the problem immediately so that we can fix the security problem
// to protect a lot of users around the world as soon as possible.
//
// Our e-mail address for security reports is:
// softether-vpn-security [at] softether.org
//
// Please note that the above e-mail address is not a technical support
// inquiry address. If you need technical assistance, please visit
// http://www.softether.org/ and ask your question on the users forum.
//
// Thank you for your cooperation.
//
//
// NO MEMORY OR RESOURCE LEAKS
// ---------------------------
//
// The memory-leaks and resource-leaks verification under the stress
// test has been passed before release this source code.
using System;
using System.Threading;
using System.Data;
using System.Data.Sql;
using System.Data.SqlClient;
using System.Data.SqlTypes;
using System.Text;
using System.Configuration;
using System.Collections;
using System.Collections.Generic;
using System.Security.Cryptography;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.IO;
using System.Drawing;
using System.Drawing.Imaging;
using System.Drawing.Drawing2D;
using System.Web.Mail;
namespace CoreUtil
{
// FIFO
public class Fifo
{
byte[] p;
int pos, size;
public int Size
{
get { return size; }
}
public byte[] Data
{
get
{
return this.p;
}
}
public int DataOffset
{
get
{
return this.pos;
}
}
public int PhysicalSize
{
get
{
return p.Length;
}
}
int reallocMemSize;
public const int FifoInitMemSize = 4096;
public const int FifoReallocMemSize = 65536;
public const int FifoReallocMemSizeSmall = 65536;
long totalWriteSize = 0, totalReadSize = 0;
public long TotalReadSize
{
get { return totalReadSize; }
}
public long TotalWriteSize
{
get { return totalWriteSize; }
}
public Fifo()
{
init(0);
}
public Fifo(int reallocMemSize)
{
init(reallocMemSize);
}
void init(int reallocMemSize)
{
if (reallocMemSize == 0)
{
reallocMemSize = FifoReallocMemSize;
}
this.size = this.pos = 0;
this.reallocMemSize = reallocMemSize;
this.p = new byte[FifoInitMemSize];
}
public void Write(Buf buf)
{
Write(buf.ByteData);
}
public void Write(byte[] src)
{
Write(src, src.Length);
}
public void SkipWrite(int size)
{
Write(null, size);
}
public void Write(byte[] src, int size)
{
Write(src, 0, size);
}
public void Write(byte[] src, int offset, int size)
{
int i, need_size;
bool realloc_flag;
i = this.size;
this.size += size;
need_size = this.pos + this.size;
realloc_flag = false;
int memsize = p.Length;
while (need_size > memsize)
{
memsize = Math.Max(memsize, FifoInitMemSize) * 3;
realloc_flag = true;
}
if (realloc_flag)
{
byte[] new_p = new byte[memsize];
Util.CopyByte(new_p, 0, this.p, 0, this.p.Length);
this.p = new_p;
}
if (src != null)
{
Util.CopyByte(this.p, this.pos + i, src, offset, size);
}
totalWriteSize += size;
}
public byte[] Read()
{
return Read(this.Size);
}
public void ReadToBuf(Buf buf, int size)
{
byte[] data = Read(size);
buf.Write(data);
}
public Buf ReadToBuf(int size)
{
byte[] data = Read(size);
return new Buf(data);
}
public byte[] Read(int size)
{
byte[] ret = new byte[size];
int read_size = Read(ret);
Array.Resize<byte>(ref ret, read_size);
return ret;
}
public int Read(byte[] dst)
{
return Read(dst, dst.Length);
}
public int SkipRead(int size)
{
return Read(null, size);
}
public int Read(byte[] dst, int size)
{
return Read(dst, 0, size);
}
public int Read(byte[] dst, int offset, int size)
{
int read_size;
read_size = Math.Min(size, this.size);
if (read_size == 0)
{
return 0;
}
if (dst != null)
{
Util.CopyByte(dst, offset, this.p, this.pos, size);
}
this.pos += read_size;
this.size -= read_size;
if (this.size == 0)
{
this.pos = 0;
}
if (this.pos >= FifoInitMemSize &&
this.p.Length >= this.reallocMemSize &&
(this.p.Length / 2) > this.size)
{
byte[] new_p;
int new_size;
new_size = Math.Max(this.p.Length / 2, FifoInitMemSize);
new_p = new byte[new_size];
Util.CopyByte(new_p, 0, this.p, this.pos, this.size);
this.p = new_p;
this.pos = 0;
}
totalReadSize += read_size;
return read_size;
}
}
public class Buf
{
MemoryStream buf;
public Buf()
{
init(new byte[0]);
}
public Buf(byte[] data)
{
init(data);
}
void init(byte[] data)
{
buf = new MemoryStream();
Write(data);
SeekToBegin();
}
public void Clear()
{
buf.SetLength(0);
}
public void WriteByte(byte data)
{
byte[] a = new byte[1] { data };
Write(a);
}
public void Write(byte[] data)
{
buf.Write(data, 0, data.Length);
}
public void Write(byte[] data, int pos, int len)
{
buf.Write(data, pos, len);
}
public uint Size
{
get
{
return (uint)buf.Length;
}
}
public uint Pos
{
get
{
return (uint)buf.Position;
}
}
public byte[] ByteData
{
get
{
return buf.ToArray();
}
}
public byte this[uint i]
{
get
{
return buf.GetBuffer()[i];
}
set
{
buf.GetBuffer()[i] = value;
}
}
public byte[] Read()
{
return Read(this.Size);
}
public byte[] Read(uint size)
{
byte[] tmp = new byte[size];
int i = buf.Read(tmp, 0, (int)size);
byte[] ret = new byte[i];
Array.Copy(tmp, 0, ret, 0, i);
return ret;
}
public byte ReadByte()
{
byte[] a = Read(1);
return a[0];
}
public void SeekToBegin()
{
Seek(0);
}
public void SeekToEnd()
{
Seek(0, SeekOrigin.End);
}
public void Seek(uint offset)
{
Seek(offset, SeekOrigin.Begin);
}
public void Seek(uint offset, SeekOrigin mode)
{
buf.Seek(offset, mode);
}
public ushort ReadShort()
{
byte[] data = Read(2);
if (data.Length != 2)
{
return 0;
}
if (Env.IsLittleEndian)
{
Array.Reverse(data);
}
return BitConverter.ToUInt16(data, 0);
}
public ushort RawReadShort()
{
byte[] data = Read(2);
if (data.Length != 2)
{
return 0;
}
return BitConverter.ToUInt16(data, 0);
}
public uint ReadInt()
{
byte[] data = Read(4);
if (data.Length != 4)
{
return 0;
}
if (Env.IsLittleEndian)
{
Array.Reverse(data);
}
return BitConverter.ToUInt32(data, 0);
}
public uint RawReadInt()
{
byte[] data = Read(4);
if (data.Length != 4)
{
return 0;
}
return BitConverter.ToUInt32(data, 0);
}
public ulong ReadInt64()
{
byte[] data = Read(8);
if (data.Length != 8)
{
return 0;
}
if (Env.IsLittleEndian)
{
Array.Reverse(data);
}
return BitConverter.ToUInt64(data, 0);
}
public ulong RawReadInt64()
{
byte[] data = Read(8);
if (data.Length != 8)
{
return 0;
}
return BitConverter.ToUInt64(data, 0);
}
public string ReadStr()
{
return ReadStr(false);
}
public string ReadStr(bool include_null)
{
uint len = ReadInt();
byte[] data = Read(len - (uint)(include_null ? 1 : 0));
return Str.ShiftJisEncoding.GetString(data);
}
public string ReadUniStr()
{
return ReadUniStr(false);
}
public string ReadUniStr(bool include_null)
{
uint len = ReadInt();
if (len == 0)
{
return null;
}
byte[] data = Read(len - (uint)(include_null ? 2 : 0));
return Str.Utf8Encoding.GetString(data);
}
public void WriteShort(ushort shortValue)
{
byte[] data = BitConverter.GetBytes(shortValue);
if (Env.IsLittleEndian)
{
Array.Reverse(data);
}
Write(data);
}
public void RawWriteShort(ushort shortValue)
{
byte[] data = BitConverter.GetBytes(shortValue);
Write(data);
}
public void WriteInt(uint intValue)
{
byte[] data = BitConverter.GetBytes(intValue);
if (Env.IsLittleEndian)
{
Array.Reverse(data);
}
Write(data);
}
public void RawWriteInt(uint intValue)
{
byte[] data = BitConverter.GetBytes(intValue);
Write(data);
}
public void WriteInt64(ulong int64Value)
{
byte[] data = BitConverter.GetBytes(int64Value);
if (Env.IsLittleEndian)
{
Array.Reverse(data);
}
Write(data);
}
public void RawWriteInt64(ulong int64Value)
{
byte[] data = BitConverter.GetBytes(int64Value);
Write(data);
}
public string ReadNextLineAsString()
{
return ReadNextLineAsString(Str.Utf8Encoding);
}
public string ReadNextLineAsString(Encoding encoding)
{
byte[] ret = ReadNextLineAsData();
if (ret == null)
{
return null;
}
return encoding.GetString(ret);
}
public byte[] ReadNextLineAsData()
{
if (this.Size <= this.Pos)
{
return null;
}
long pos = buf.Position;
long i;
byte[] tmp = new byte[1];
for (i = pos; i < buf.Length; i++)
{
buf.Read(tmp, 0, 1);
if (tmp[0] == 13 || tmp[0] == 10)
{
if (tmp[0] == 13)
{
if ((i + 2) < buf.Length)
{
i++;
}
}
break;
}
}
long len = i - pos;
buf.Position = pos;
byte[] ret = Read((uint)((int)len));
try
{
Seek(1, SeekOrigin.Current);
}
catch
{
}
if (ret.Length >= 1 && ret[ret.Length - 1] == 13)
{
Array.Resize<byte>(ref ret, ret.Length - 1);
}
return ret;
}
public void WriteStr(string strValue)
{
WriteStr(strValue, false);
}
public void WriteStr(string strValue, bool include_null)
{
byte[] data = Str.ShiftJisEncoding.GetBytes(strValue);
WriteInt((uint)data.Length + (uint)(include_null ? 1 : 0));
Write(data);
}
public void WriteUniStr(string strValue)
{
WriteUniStr(strValue, false);
}
public void WriteUniStr(string strValue, bool include_null)
{
byte[] data = Str.Utf8Encoding.GetBytes(strValue);
WriteInt((uint)data.Length + (uint)(include_null ? 2 : 0));
Write(data);
}
public static Buf ReadFromFile(string filename)
{
return new Buf(IO.ReadFile(filename));
}
public void WriteToFile(string filename)
{
IO.SaveFile(filename, this.ByteData);
}
public static Buf ReadFromStream(Stream st)
{
Buf ret = new Buf();
int size = 32767;
while (true)
{
byte[] tmp = new byte[size];
int i = st.Read(tmp, 0, tmp.Length);
if (i <= 0)
{
break;
}
Array.Resize<byte>(ref tmp, i);
ret.Write(tmp);
}
ret.SeekToBegin();
return ret;
}
}
}
// Developed by SoftEther VPN Project at University of Tsukuba in Japan.
// Department of Computer Science has dozens of overly-enthusiastic geeks.
// Join us: http://www.tsukuba.ac.jp/english/admission/