ESocket.cs 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Runtime.InteropServices;
  4. using System.Threading.Tasks;
  5. namespace ENet
  6. {
  7. public sealed class ESocket: IDisposable
  8. {
  9. private IntPtr peerPtr = IntPtr.Zero;
  10. private readonly EService service;
  11. private readonly LinkedList<byte[]> recvBuffer = new LinkedList<byte[]>();
  12. public Action<EEvent> Connected { get; set; }
  13. public Action<EEvent> Received { get; set; }
  14. public Action<EEvent> Disconnect { get; set; }
  15. public Action<int> Error { get; set; }
  16. public ESocket(EService service)
  17. {
  18. this.service = service;
  19. }
  20. public void Dispose()
  21. {
  22. if (this.peerPtr == IntPtr.Zero)
  23. {
  24. return;
  25. }
  26. NativeMethods.EnetPeerReset(this.peerPtr);
  27. this.peerPtr = IntPtr.Zero;
  28. }
  29. public IntPtr PeerPtr
  30. {
  31. get
  32. {
  33. return this.peerPtr;
  34. }
  35. set
  36. {
  37. this.peerPtr = value;
  38. }
  39. }
  40. private ENetPeer Struct
  41. {
  42. get
  43. {
  44. if (this.peerPtr == IntPtr.Zero)
  45. {
  46. return new ENetPeer();
  47. }
  48. return (ENetPeer) Marshal.PtrToStructure(this.peerPtr, typeof (ENetPeer));
  49. }
  50. set
  51. {
  52. Marshal.StructureToPtr(value, this.peerPtr, false);
  53. }
  54. }
  55. public PeerState State
  56. {
  57. get
  58. {
  59. if (this.peerPtr == IntPtr.Zero)
  60. {
  61. return PeerState.Uninitialized;
  62. }
  63. return this.Struct.State;
  64. }
  65. }
  66. public void Ping()
  67. {
  68. NativeMethods.EnetPeerPing(this.peerPtr);
  69. }
  70. public void ConfigureThrottle(uint interval, uint acceleration, uint deceleration)
  71. {
  72. NativeMethods.EnetPeerThrottleConfigure(this.peerPtr, interval, acceleration, deceleration);
  73. }
  74. public Task<bool> ConnectAsync(
  75. string hostName, ushort port,
  76. uint channelLimit = NativeMethods.ENET_PROTOCOL_MAXIMUM_CHANNEL_COUNT,
  77. uint data = 0)
  78. {
  79. if (channelLimit > NativeMethods.ENET_PROTOCOL_MAXIMUM_CHANNEL_COUNT)
  80. {
  81. throw new ArgumentOutOfRangeException("channelLimit");
  82. }
  83. var tcs = new TaskCompletionSource<bool>();
  84. var address = new Address { HostName = hostName, Port = port };
  85. ENetAddress nativeAddress = address.Struct;
  86. this.peerPtr = NativeMethods.EnetHostConnect(
  87. this.service.HostPtr, ref nativeAddress, channelLimit, data);
  88. if (this.peerPtr == IntPtr.Zero)
  89. {
  90. throw new EException("host connect call failed.");
  91. }
  92. this.service.PeersManager.Add(this.peerPtr, this);
  93. this.Connected = eEvent =>
  94. {
  95. if (eEvent.EventState == EventState.DISCONNECTED)
  96. {
  97. tcs.TrySetException(new EException("socket disconnected in connect"));
  98. }
  99. tcs.TrySetResult(true);
  100. };
  101. return tcs.Task;
  102. }
  103. public Task<bool> AcceptAsync()
  104. {
  105. if (this.service.PeersManager.ContainsKey(IntPtr.Zero))
  106. {
  107. throw new EException("do not accept twice!");
  108. }
  109. var tcs = new TaskCompletionSource<bool>();
  110. // 如果有请求连接缓存的包,从缓存中取
  111. if (this.service.ConnEEvents.Count > 0)
  112. {
  113. EEvent eEvent = this.service.ConnEEvents.First.Value;
  114. this.service.ConnEEvents.RemoveFirst();
  115. this.PeerPtr = eEvent.PeerPtr;
  116. this.service.PeersManager.Add(this.PeerPtr, this);
  117. tcs.TrySetResult(true);
  118. }
  119. else
  120. {
  121. this.service.PeersManager.Add(this.PeerPtr, this);
  122. this.Connected = eEvent =>
  123. {
  124. if (eEvent.EventState == EventState.DISCONNECTED)
  125. {
  126. tcs.TrySetException(new EException("socket disconnected in accpet"));
  127. }
  128. this.service.PeersManager.Remove(IntPtr.Zero);
  129. this.PeerPtr = eEvent.PeerPtr;
  130. this.service.PeersManager.Add(this.PeerPtr, this);
  131. tcs.TrySetResult(true);
  132. };
  133. }
  134. return tcs.Task;
  135. }
  136. public void WriteAsync(byte[] data, byte channelID = 0, PacketFlags flags = PacketFlags.Reliable)
  137. {
  138. var packet = new EPacket(data, flags);
  139. NativeMethods.EnetPeerSend(this.peerPtr, channelID, packet.PacketPtr);
  140. // enet_peer_send函数会自动删除packet,设置为0,防止Dispose或者析构函数再次删除
  141. packet.PacketPtr = IntPtr.Zero;
  142. }
  143. public Task<byte[]> ReadAsync()
  144. {
  145. var tcs = new TaskCompletionSource<byte[]>();
  146. // 如果有缓存的包,从缓存中取
  147. if (this.recvBuffer.Count > 0)
  148. {
  149. var bytes = this.recvBuffer.First.Value;
  150. this.recvBuffer.RemoveFirst();
  151. tcs.TrySetResult(bytes);
  152. }
  153. // 没有缓存封包,设置回调等待
  154. else
  155. {
  156. this.Received = eEvent =>
  157. {
  158. if (eEvent.EventState == EventState.DISCONNECTED)
  159. {
  160. tcs.TrySetException(new EException("socket disconnected in receive"));
  161. }
  162. using (var packet = new EPacket(eEvent.PacketPtr))
  163. {
  164. var bytes = packet.Bytes;
  165. tcs.TrySetResult(bytes);
  166. }
  167. };
  168. }
  169. return tcs.Task;
  170. }
  171. public Task<bool> DisconnectAsync(uint data = 0)
  172. {
  173. NativeMethods.EnetPeerDisconnect(this.peerPtr, data);
  174. // EnetPeerDisconnect会reset Peer,这里设置为0,防止再次Dispose
  175. this.PeerPtr = IntPtr.Zero;
  176. var tcs = new TaskCompletionSource<bool>();
  177. this.Disconnect = eEvent => tcs.TrySetResult(true);
  178. return tcs.Task;
  179. }
  180. public Task<bool> DisconnectLaterAsync(uint data = 0)
  181. {
  182. NativeMethods.EnetPeerDisconnectLater(this.peerPtr, data);
  183. // EnetPeerDisconnect会reset Peer,这里设置为0,防止再次Dispose
  184. this.PeerPtr = IntPtr.Zero;
  185. var tcs = new TaskCompletionSource<bool>();
  186. this.Disconnect = eEvent => tcs.TrySetResult(true);
  187. return tcs.Task;
  188. }
  189. public void DisconnectNow(uint data)
  190. {
  191. NativeMethods.EnetPeerDisconnectNow(this.peerPtr, data);
  192. // EnetPeerDisconnect会reset Peer,这里设置为0,防止再次Dispose
  193. this.PeerPtr = IntPtr.Zero;
  194. }
  195. internal void OnConnected(EEvent eEvent)
  196. {
  197. if (this.Connected == null)
  198. {
  199. return;
  200. }
  201. Action<EEvent> localConnected = this.Connected;
  202. this.Connected = null;
  203. // 此调用将让await ConnectAsync返回,所以null必须在此之前设置
  204. localConnected(eEvent);
  205. }
  206. internal void OnReceived(EEvent eEvent)
  207. {
  208. // 如果应用层还未调用readasync则将包放到缓存队列
  209. if (this.Received == null)
  210. {
  211. using (var packet = new EPacket(eEvent.PacketPtr))
  212. {
  213. var bytes = packet.Bytes;
  214. this.recvBuffer.AddLast(bytes);
  215. }
  216. }
  217. else
  218. {
  219. Action<EEvent> localReceived = this.Received;
  220. this.Received = null;
  221. // 此调用将让await ReadAsync返回,所以null必须在此之前设置
  222. localReceived(eEvent);
  223. }
  224. }
  225. internal void OnDisconnect(EEvent eEvent)
  226. {
  227. if (this.Disconnect == null)
  228. {
  229. return;
  230. }
  231. this.Disconnect(eEvent);
  232. }
  233. internal void OnError(int errorCode)
  234. {
  235. if (this.Error == null)
  236. {
  237. return;
  238. }
  239. this.Error(errorCode);
  240. }
  241. }
  242. }