| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- using System;
- using System.IO;
- using System.Net;
- namespace ET
- {
- public enum ChannelType
- {
- Connect,
- Accept,
- }
- public struct Packet
- {
- public const int MinPacketSize = 2;
- public const int OpcodeIndex = 8;
- public const int KcpOpcodeIndex = 0;
- public const int OpcodeLength = 2;
- public const int ActorIdIndex = 0;
- public const int ActorIdLength = 8;
- public const int MessageIndex = 10;
- public ushort Opcode;
- public long ActorId;
- public MemoryStream MemoryStream;
- }
-
- public enum ServiceType
- {
- Outer,
- Inner,
- }
- public abstract class AChannel: IDisposable
- {
- public long Id;
-
- public ChannelType ChannelType { get; protected set; }
- public int Error { get; set; }
-
- private IPEndPoint remoteAddress;
- public IPEndPoint RemoteAddress
- {
- get
- {
- return this.remoteAddress;
- }
- set
- {
- this.remoteAddress = value;
- }
- }
- public bool IsDisposed
- {
- get
- {
- return this.Id == 0;
- }
- }
- public abstract void Dispose();
- }
- }
|