diff options
Diffstat (limited to 'Tools/Hazel-Networking/Hazel/MessageWriter.cs')
| -rw-r--r-- | Tools/Hazel-Networking/Hazel/MessageWriter.cs | 24 |
1 files changed, 15 insertions, 9 deletions
diff --git a/Tools/Hazel-Networking/Hazel/MessageWriter.cs b/Tools/Hazel-Networking/Hazel/MessageWriter.cs index 68280cd..a156c77 100644 --- a/Tools/Hazel-Networking/Hazel/MessageWriter.cs +++ b/Tools/Hazel-Networking/Hazel/MessageWriter.cs @@ -24,18 +24,19 @@ namespace Hazel public static readonly ObjectPool<MessageWriter> WriterPool = new ObjectPool<MessageWriter>(() => new MessageWriter(BufferSize)); public byte[] Buffer; // 缓冲区，保存了整个包体，包括头部和内容 - public int Length; // 有效数据在buffer中的长度，可能包含多个嵌套子协议。Length>=Position + public int Length; // 有效数据在buffer中的长度，包含header，可能包含多个嵌套子协议。Length>=Position public int Position; // 写入游标 public SendOption SendOption { get; private set; } private Stack<int> messageStarts = new Stack<int>(); - public MessageWriter(byte[] buffer) - { - this.Buffer = buffer; - this.Length = this.Buffer.Length; - } + // 没用，注释掉了 + //public MessageWriter(byte[] buffer) + //{ + // this.Buffer = buffer; + // this.Length = this.Buffer.Length; + //} /// public MessageWriter(int bufferSize) @@ -98,10 +99,10 @@ namespace Hazel { if (this.SendOption == SendOption.None) { - return this.Length > 1 + expected; + return this.Length > 1 + expected; // header=1 byte } - return this.Length > 3 + expected; + return this.Length > 3 + expected; // header=3 bytes } /// @@ -109,9 +110,10 @@ namespace Hazel { var messageStart = this.Position; messageStarts.Push(messageStart); - this.Buffer[messageStart] = 0; // + this.Buffer[messageStart] = 0; // length this.Buffer[messageStart + 1] = 0; this.Position += 2; + //this.Length = this.Position; this.Write(typeFlag); } @@ -131,6 +133,10 @@ namespace Hazel this.Length = this.Position; } + /// <summary> + /// 重置为sendOption类型的空包 + /// </summary> + /// <param name="sendOption"></param> public void Clear(SendOption sendOption) { Array.Clear(this.Buffer, 0, this.Buffer.Length);//完全清空整个缓冲区 |