ENet.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086
  1. /*
  2. * Managed C# wrapper for an extended version of ENet
  3. * Copyright (c) 2013 James Bellinger
  4. * Copyright (c) 2016 Nate Shoffner
  5. * Copyright (c) 2018 Stanislav Denisov
  6. *
  7. * Permission is hereby granted, free of charge, to any person obtaining a copy
  8. * of this software and associated documentation files (the "Software"), to deal
  9. * in the Software without restriction, including without limitation the rights
  10. * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  11. * copies of the Software, and to permit persons to whom the Software is
  12. * furnished to do so, subject to the following conditions:
  13. *
  14. * The above copyright notice and this permission notice shall be included in all
  15. * copies or substantial portions of the Software.
  16. *
  17. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  18. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  19. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  20. * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  21. * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  22. * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  23. * SOFTWARE.
  24. */
  25. using System;
  26. using System.Runtime.InteropServices;
  27. using System.Security;
  28. using System.Text;
  29. namespace ENet {
  30. [Flags]
  31. public enum PacketFlags {
  32. None = 0,
  33. Reliable = 1 << 0,
  34. Unsequenced = 1 << 1,
  35. NoAllocate = 1 << 2,
  36. UnreliableFragmented = 1 << 3,
  37. Instant = 1 << 4
  38. }
  39. public enum EventType {
  40. None = 0,
  41. Connect = 1,
  42. Disconnect = 2,
  43. Receive = 3,
  44. Timeout = 4
  45. }
  46. public enum PeerState {
  47. Uninitialized = -1,
  48. Disconnected = 0,
  49. Connecting = 1,
  50. AcknowledgingConnect = 2,
  51. ConnectionPending = 3,
  52. ConnectionSucceeded = 4,
  53. Connected = 5,
  54. DisconnectLater = 6,
  55. Disconnecting = 7,
  56. AcknowledgingDisconnect = 8,
  57. Zombie = 9
  58. }
  59. [StructLayout(LayoutKind.Sequential)]
  60. internal struct ENetAddress {
  61. [MarshalAs(UnmanagedType.ByValArray, SizeConst = 16)]
  62. public byte[] ip;
  63. public ushort port;
  64. }
  65. [StructLayout(LayoutKind.Sequential)]
  66. internal struct ENetEvent {
  67. public EventType type;
  68. public IntPtr peer;
  69. public byte channelID;
  70. public uint data;
  71. public IntPtr packet;
  72. }
  73. [StructLayout(LayoutKind.Sequential)]
  74. internal struct ENetCallbacks {
  75. public AllocCallback malloc;
  76. public FreeCallback free;
  77. public NoMemoryCallback noMemory;
  78. }
  79. public delegate IntPtr AllocCallback(IntPtr size);
  80. public delegate void FreeCallback(IntPtr memory);
  81. public delegate void NoMemoryCallback();
  82. public delegate void PacketFreeCallback(Packet packet);
  83. internal static class ArrayPool {
  84. [ThreadStatic]
  85. private static byte[] byteBuffer;
  86. [ThreadStatic]
  87. private static IntPtr[] pointerBuffer;
  88. public static byte[] GetByteBuffer() {
  89. if (byteBuffer == null)
  90. byteBuffer = new byte[64];
  91. return byteBuffer;
  92. }
  93. public static IntPtr[] GetPointerBuffer() {
  94. if (pointerBuffer == null)
  95. pointerBuffer = new IntPtr[Library.maxPeers];
  96. return pointerBuffer;
  97. }
  98. }
  99. public struct Address {
  100. private ENetAddress nativeAddress;
  101. internal ENetAddress NativeData {
  102. get {
  103. return nativeAddress;
  104. }
  105. set {
  106. nativeAddress = value;
  107. }
  108. }
  109. internal Address(ENetAddress address) {
  110. nativeAddress = address;
  111. }
  112. public ushort Port {
  113. get {
  114. return nativeAddress.port;
  115. }
  116. set {
  117. nativeAddress.port = value;
  118. }
  119. }
  120. public string GetIP() {
  121. StringBuilder ip = new StringBuilder(1024);
  122. if (Native.enet_address_get_host_ip(nativeAddress, ip, (IntPtr)ip.Capacity) != 0)
  123. return String.Empty;
  124. return ip.ToString();
  125. }
  126. public bool SetIP(string ip) {
  127. if (ip == null)
  128. throw new ArgumentNullException("ip");
  129. return Native.enet_address_set_host_ip(ref nativeAddress, ip) == 0;
  130. }
  131. public string GetHost() {
  132. StringBuilder hostName = new StringBuilder(1024);
  133. if (Native.enet_address_get_host(nativeAddress, hostName, (IntPtr)hostName.Capacity) != 0)
  134. return String.Empty;
  135. return hostName.ToString();
  136. }
  137. public bool SetHost(string hostName) {
  138. if (hostName == null)
  139. throw new ArgumentNullException("hostName");
  140. return Native.enet_address_set_host(ref nativeAddress, hostName) == 0;
  141. }
  142. }
  143. public struct Event {
  144. private ENetEvent nativeEvent;
  145. internal ENetEvent NativeData {
  146. get {
  147. return nativeEvent;
  148. }
  149. set {
  150. nativeEvent = value;
  151. }
  152. }
  153. internal Event(ENetEvent @event) {
  154. nativeEvent = @event;
  155. }
  156. public EventType Type {
  157. get {
  158. return nativeEvent.type;
  159. }
  160. }
  161. public Peer Peer {
  162. get {
  163. return new Peer(nativeEvent.peer);
  164. }
  165. }
  166. public byte ChannelID {
  167. get {
  168. return nativeEvent.channelID;
  169. }
  170. }
  171. public uint Data {
  172. get {
  173. return nativeEvent.data;
  174. }
  175. }
  176. public Packet Packet {
  177. get {
  178. return new Packet(nativeEvent.packet);
  179. }
  180. }
  181. }
  182. public class Callbacks {
  183. private ENetCallbacks nativeCallbacks;
  184. internal ENetCallbacks NativeData {
  185. get {
  186. return nativeCallbacks;
  187. }
  188. set {
  189. nativeCallbacks = value;
  190. }
  191. }
  192. public Callbacks(AllocCallback allocCallback, FreeCallback freeCallback, NoMemoryCallback noMemoryCallback) {
  193. nativeCallbacks.malloc = allocCallback;
  194. nativeCallbacks.free = freeCallback;
  195. nativeCallbacks.noMemory = noMemoryCallback;
  196. }
  197. }
  198. public struct Packet : IDisposable {
  199. private IntPtr nativePacket;
  200. internal IntPtr NativeData {
  201. get {
  202. return nativePacket;
  203. }
  204. set {
  205. nativePacket = value;
  206. }
  207. }
  208. internal Packet(IntPtr packet) {
  209. nativePacket = packet;
  210. }
  211. public void Dispose() {
  212. if (nativePacket != IntPtr.Zero) {
  213. Native.enet_packet_dispose(nativePacket);
  214. nativePacket = IntPtr.Zero;
  215. }
  216. }
  217. public bool IsSet {
  218. get {
  219. return nativePacket != IntPtr.Zero;
  220. }
  221. }
  222. public IntPtr Data {
  223. get {
  224. CheckCreated();
  225. return Native.enet_packet_get_data(nativePacket);
  226. }
  227. }
  228. public int Length {
  229. get {
  230. CheckCreated();
  231. return Native.enet_packet_get_length(nativePacket);
  232. }
  233. }
  234. public bool HasReferences {
  235. get {
  236. CheckCreated();
  237. return Native.enet_packet_check_references(nativePacket) != 0;
  238. }
  239. }
  240. internal void CheckCreated() {
  241. if (nativePacket == IntPtr.Zero)
  242. throw new InvalidOperationException("Packet not created");
  243. }
  244. public void SetFreeCallback(IntPtr callback) {
  245. CheckCreated();
  246. Native.enet_packet_set_free_callback(nativePacket, callback);
  247. }
  248. public void SetFreeCallback(PacketFreeCallback callback) {
  249. CheckCreated();
  250. Native.enet_packet_set_free_callback(nativePacket, Marshal.GetFunctionPointerForDelegate(callback));
  251. }
  252. public void Create(byte[] data) {
  253. if (data == null)
  254. throw new ArgumentNullException("data");
  255. Create(data, data.Length);
  256. }
  257. public void Create(byte[] data, int length) {
  258. Create(data, length, PacketFlags.None);
  259. }
  260. public void Create(byte[] data, PacketFlags flags) {
  261. Create(data, data.Length, flags);
  262. }
  263. public void Create(byte[] data, int length, PacketFlags flags) {
  264. if (data == null)
  265. throw new ArgumentNullException("data");
  266. if (length < 0 || length > data.Length)
  267. throw new ArgumentOutOfRangeException();
  268. nativePacket = Native.enet_packet_create(data, (IntPtr)length, flags);
  269. }
  270. public void Create(IntPtr data, int length, PacketFlags flags) {
  271. if (data == IntPtr.Zero)
  272. throw new ArgumentNullException("data");
  273. if (length < 0)
  274. throw new ArgumentOutOfRangeException();
  275. nativePacket = Native.enet_packet_create(data, (IntPtr)length, flags);
  276. }
  277. public void Create(byte[] data, int offset, int length, PacketFlags flags) {
  278. if (data == null)
  279. throw new ArgumentNullException("data");
  280. if (offset < 0 || length < 0 || length > data.Length)
  281. throw new ArgumentOutOfRangeException();
  282. nativePacket = Native.enet_packet_create_offset(data, (IntPtr)length, (IntPtr)offset, flags);
  283. }
  284. public void Create(IntPtr data, int offset, int length, PacketFlags flags) {
  285. if (data == IntPtr.Zero)
  286. throw new ArgumentNullException("data");
  287. if (offset < 0 || length < 0)
  288. throw new ArgumentOutOfRangeException();
  289. nativePacket = Native.enet_packet_create_offset(data, (IntPtr)length, (IntPtr)offset, flags);
  290. }
  291. public void CopyTo(byte[] destination) {
  292. if (destination == null)
  293. throw new ArgumentNullException("destination");
  294. Marshal.Copy(Data, destination, 0, Length);
  295. }
  296. }
  297. public class Host : IDisposable {
  298. private IntPtr nativeHost;
  299. internal IntPtr NativeData {
  300. get {
  301. return nativeHost;
  302. }
  303. set {
  304. nativeHost = value;
  305. }
  306. }
  307. public void Dispose() {
  308. Dispose(true);
  309. GC.SuppressFinalize(this);
  310. }
  311. protected virtual void Dispose(bool disposing) {
  312. if (nativeHost != IntPtr.Zero) {
  313. Native.enet_host_destroy(nativeHost);
  314. nativeHost = IntPtr.Zero;
  315. }
  316. }
  317. ~Host() {
  318. Dispose(false);
  319. }
  320. public bool IsSet {
  321. get {
  322. return nativeHost != IntPtr.Zero;
  323. }
  324. }
  325. public uint PeersCount {
  326. get {
  327. CheckCreated();
  328. return Native.enet_host_get_peers_count(nativeHost);
  329. }
  330. }
  331. public uint PacketsSent {
  332. get {
  333. CheckCreated();
  334. return Native.enet_host_get_packets_sent(nativeHost);
  335. }
  336. }
  337. public uint PacketsReceived {
  338. get {
  339. CheckCreated();
  340. return Native.enet_host_get_packets_received(nativeHost);
  341. }
  342. }
  343. public uint BytesSent {
  344. get {
  345. CheckCreated();
  346. return Native.enet_host_get_bytes_sent(nativeHost);
  347. }
  348. }
  349. public uint BytesReceived {
  350. get {
  351. CheckCreated();
  352. return Native.enet_host_get_bytes_received(nativeHost);
  353. }
  354. }
  355. internal void CheckCreated() {
  356. if (nativeHost == IntPtr.Zero)
  357. throw new InvalidOperationException("Host not created");
  358. }
  359. private void CheckChannelLimit(int channelLimit) {
  360. if (channelLimit < 0 || channelLimit > Library.maxChannelCount)
  361. throw new ArgumentOutOfRangeException("channelLimit");
  362. }
  363. public void Create() {
  364. Create(null, 1, 0);
  365. }
  366. public void Create(int bufferSize) {
  367. Create(null, 1, 0, 0, 0, bufferSize);
  368. }
  369. public void Create(Address? address, int peerLimit) {
  370. Create(address, peerLimit, 0);
  371. }
  372. public void Create(Address? address, int peerLimit, int channelLimit) {
  373. Create(address, peerLimit, channelLimit, 0, 0, 0);
  374. }
  375. public void Create(int peerLimit, int channelLimit) {
  376. Create(null, peerLimit, channelLimit, 0, 0, 0);
  377. }
  378. public void Create(int peerLimit, int channelLimit, uint incomingBandwidth, uint outgoingBandwidth) {
  379. Create(null, peerLimit, channelLimit, incomingBandwidth, outgoingBandwidth, 0);
  380. }
  381. public void Create(Address? address, int peerLimit, int channelLimit, uint incomingBandwidth, uint outgoingBandwidth) {
  382. Create(address, peerLimit, channelLimit, incomingBandwidth, outgoingBandwidth, 0);
  383. }
  384. public void Create(Address? address, int peerLimit, int channelLimit, uint incomingBandwidth, uint outgoingBandwidth, int bufferSize) {
  385. if (nativeHost != IntPtr.Zero)
  386. throw new InvalidOperationException("Host already created");
  387. if (peerLimit < 0 || peerLimit > Library.maxPeers)
  388. throw new ArgumentOutOfRangeException("peerLimit");
  389. CheckChannelLimit(channelLimit);
  390. if (address != null) {
  391. var nativeAddress = address.Value.NativeData;
  392. nativeHost = Native.enet_host_create(ref nativeAddress, (IntPtr)peerLimit, (IntPtr)channelLimit, incomingBandwidth, outgoingBandwidth, bufferSize);
  393. } else {
  394. nativeHost = Native.enet_host_create(IntPtr.Zero, (IntPtr)peerLimit, (IntPtr)channelLimit, incomingBandwidth, outgoingBandwidth, bufferSize);
  395. }
  396. if (nativeHost == IntPtr.Zero)
  397. throw new InvalidOperationException("Host creation call failed");
  398. }
  399. public void EnableCompression() {
  400. CheckCreated();
  401. Native.enet_host_enable_compression(nativeHost);
  402. }
  403. public void PreventConnections(bool state) {
  404. CheckCreated();
  405. Native.enet_host_prevent_connections(nativeHost, (byte)(state ? 1 : 0));
  406. }
  407. public void Broadcast(byte channelID, ref Packet packet) {
  408. CheckCreated();
  409. packet.CheckCreated();
  410. Native.enet_host_broadcast(nativeHost, channelID, packet.NativeData);
  411. packet.NativeData = IntPtr.Zero;
  412. }
  413. public void Broadcast(byte channelID, ref Packet packet, Peer excludedPeer) {
  414. CheckCreated();
  415. packet.CheckCreated();
  416. Native.enet_host_broadcast_exclude(nativeHost, channelID, packet.NativeData, excludedPeer.NativeData);
  417. packet.NativeData = IntPtr.Zero;
  418. }
  419. public void Broadcast(byte channelID, ref Packet packet, Peer[] peers) {
  420. CheckCreated();
  421. packet.CheckCreated();
  422. if (peers.Length > 0) {
  423. IntPtr[] nativePeers = ArrayPool.GetPointerBuffer();
  424. int nativeCount = 0;
  425. for (int i = 0; i < peers.Length; i++) {
  426. if (peers[i].NativeData != IntPtr.Zero) {
  427. nativePeers[nativeCount] = peers[i].NativeData;
  428. nativeCount++;
  429. }
  430. }
  431. Native.enet_host_broadcast_selective(nativeHost, channelID, packet.NativeData, nativePeers, (IntPtr)nativeCount);
  432. }
  433. packet.NativeData = IntPtr.Zero;
  434. }
  435. public int CheckEvents(out Event @event) {
  436. CheckCreated();
  437. ENetEvent nativeEvent;
  438. var result = Native.enet_host_check_events(nativeHost, out nativeEvent);
  439. if (result <= 0) {
  440. @event = default(Event);
  441. return result;
  442. }
  443. @event = new Event(nativeEvent);
  444. return result;
  445. }
  446. public Peer Connect(Address address) {
  447. return Connect(address, 0, 0);
  448. }
  449. public Peer Connect(Address address, int channelLimit) {
  450. return Connect(address, channelLimit, 0);
  451. }
  452. public Peer Connect(Address address, int channelLimit, uint data) {
  453. CheckCreated();
  454. CheckChannelLimit(channelLimit);
  455. var nativeAddress = address.NativeData;
  456. var peer = new Peer(Native.enet_host_connect(nativeHost, ref nativeAddress, (IntPtr)channelLimit, data));
  457. if (peer.NativeData == IntPtr.Zero)
  458. throw new InvalidOperationException("Host connect call failed");
  459. return peer;
  460. }
  461. public int Service(int timeout, out Event @event) {
  462. if (timeout < 0)
  463. throw new ArgumentOutOfRangeException("timeout");
  464. CheckCreated();
  465. ENetEvent nativeEvent;
  466. var result = Native.enet_host_service(nativeHost, out nativeEvent, (uint)timeout);
  467. if (result <= 0) {
  468. @event = default(Event);
  469. return result;
  470. }
  471. @event = new Event(nativeEvent);
  472. return result;
  473. }
  474. public void SetBandwidthLimit(uint incomingBandwidth, uint outgoingBandwidth) {
  475. CheckCreated();
  476. Native.enet_host_bandwidth_limit(nativeHost, incomingBandwidth, outgoingBandwidth);
  477. }
  478. public void SetChannelLimit(int channelLimit) {
  479. CheckCreated();
  480. CheckChannelLimit(channelLimit);
  481. Native.enet_host_channel_limit(nativeHost, (IntPtr)channelLimit);
  482. }
  483. public void Flush() {
  484. CheckCreated();
  485. Native.enet_host_flush(nativeHost);
  486. }
  487. }
  488. public struct Peer {
  489. private IntPtr nativePeer;
  490. private uint nativeID;
  491. internal IntPtr NativeData {
  492. get {
  493. return nativePeer;
  494. }
  495. set {
  496. nativePeer = value;
  497. }
  498. }
  499. internal Peer(IntPtr peer) {
  500. nativePeer = peer;
  501. nativeID = nativePeer != IntPtr.Zero ? Native.enet_peer_get_id(nativePeer) : 0;
  502. }
  503. public bool IsSet {
  504. get {
  505. return nativePeer != IntPtr.Zero;
  506. }
  507. }
  508. public uint ID {
  509. get {
  510. return nativeID;
  511. }
  512. }
  513. public string IP {
  514. get {
  515. CheckCreated();
  516. byte[] ip = ArrayPool.GetByteBuffer();
  517. if (Native.enet_peer_get_ip(nativePeer, ip, (IntPtr)ip.Length) == 0)
  518. return Encoding.ASCII.GetString(ip, 0, ip.StringLength());
  519. else
  520. return String.Empty;
  521. }
  522. }
  523. public ushort Port {
  524. get {
  525. CheckCreated();
  526. return Native.enet_peer_get_port(nativePeer);
  527. }
  528. }
  529. public uint MTU {
  530. get {
  531. CheckCreated();
  532. return Native.enet_peer_get_mtu(nativePeer);
  533. }
  534. }
  535. public PeerState State {
  536. get {
  537. return nativePeer == IntPtr.Zero ? PeerState.Uninitialized : Native.enet_peer_get_state(nativePeer);
  538. }
  539. }
  540. public uint RoundTripTime {
  541. get {
  542. CheckCreated();
  543. return Native.enet_peer_get_rtt(nativePeer);
  544. }
  545. }
  546. public uint LastSendTime {
  547. get {
  548. CheckCreated();
  549. return Native.enet_peer_get_lastsendtime(nativePeer);
  550. }
  551. }
  552. public uint LastReceiveTime {
  553. get {
  554. CheckCreated();
  555. return Native.enet_peer_get_lastreceivetime(nativePeer);
  556. }
  557. }
  558. public ulong PacketsSent {
  559. get {
  560. CheckCreated();
  561. return Native.enet_peer_get_packets_sent(nativePeer);
  562. }
  563. }
  564. public ulong PacketsLost {
  565. get {
  566. CheckCreated();
  567. return Native.enet_peer_get_packets_lost(nativePeer);
  568. }
  569. }
  570. public ulong BytesSent {
  571. get {
  572. CheckCreated();
  573. return Native.enet_peer_get_bytes_sent(nativePeer);
  574. }
  575. }
  576. public ulong BytesReceived {
  577. get {
  578. CheckCreated();
  579. return Native.enet_peer_get_bytes_received(nativePeer);
  580. }
  581. }
  582. public IntPtr Data {
  583. get {
  584. CheckCreated();
  585. return Native.enet_peer_get_data(nativePeer);
  586. }
  587. set {
  588. CheckCreated();
  589. Native.enet_peer_set_data(nativePeer, value);
  590. }
  591. }
  592. internal void CheckCreated() {
  593. if (nativePeer == IntPtr.Zero)
  594. throw new InvalidOperationException("Peer not created");
  595. }
  596. public void ConfigureThrottle(uint interval, uint acceleration, uint deceleration, uint threshold) {
  597. CheckCreated();
  598. Native.enet_peer_throttle_configure(nativePeer, interval, acceleration, deceleration, threshold);
  599. }
  600. public bool Send(byte channelID, ref Packet packet) {
  601. CheckCreated();
  602. packet.CheckCreated();
  603. return Native.enet_peer_send(nativePeer, channelID, packet.NativeData) == 0;
  604. }
  605. public bool Receive(out byte channelID, out Packet packet) {
  606. CheckCreated();
  607. IntPtr nativePacket = Native.enet_peer_receive(nativePeer, out channelID);
  608. if (nativePacket != IntPtr.Zero) {
  609. packet = new Packet(nativePacket);
  610. return true;
  611. }
  612. packet = default(Packet);
  613. return false;
  614. }
  615. public void Ping() {
  616. CheckCreated();
  617. Native.enet_peer_ping(nativePeer);
  618. }
  619. public void PingInterval(uint interval) {
  620. CheckCreated();
  621. Native.enet_peer_ping_interval(nativePeer, interval);
  622. }
  623. public void Timeout(uint timeoutLimit, uint timeoutMinimum, uint timeoutMaximum) {
  624. CheckCreated();
  625. Native.enet_peer_timeout(nativePeer, timeoutLimit, timeoutMinimum, timeoutMaximum);
  626. }
  627. public void Disconnect(uint data) {
  628. CheckCreated();
  629. Native.enet_peer_disconnect(nativePeer, data);
  630. }
  631. public void DisconnectNow(uint data) {
  632. CheckCreated();
  633. Native.enet_peer_disconnect_now(nativePeer, data);
  634. }
  635. public void DisconnectLater(uint data) {
  636. CheckCreated();
  637. Native.enet_peer_disconnect_later(nativePeer, data);
  638. }
  639. public void Reset() {
  640. CheckCreated();
  641. Native.enet_peer_reset(nativePeer);
  642. }
  643. }
  644. public static class Extensions {
  645. public static int StringLength(this byte[] data) {
  646. if (data == null)
  647. throw new ArgumentNullException("data");
  648. int i;
  649. for (i = 0; i < data.Length && data[i] != 0; i++);
  650. return i;
  651. }
  652. }
  653. public static class Library {
  654. public const uint maxChannelCount = 0xFF;
  655. public const uint maxPeers = 0xFFF;
  656. public const uint maxPacketSize = 32 * 1024 * 1024;
  657. public const uint throttleScale = 32;
  658. public const uint throttleAcceleration = 2;
  659. public const uint throttleDeceleration = 2;
  660. public const uint throttleInterval = 5000;
  661. public const uint timeoutLimit = 32;
  662. public const uint timeoutMinimum = 5000;
  663. public const uint timeoutMaximum = 30000;
  664. public const uint version = (2 << 16) | (3 << 8) | (0);
  665. public static bool Initialize() {
  666. return Native.enet_initialize() == 0;
  667. }
  668. public static bool Initialize(Callbacks inits) {
  669. return Native.enet_initialize_with_callbacks(version, inits.NativeData) == 0;
  670. }
  671. public static void Deinitialize() {
  672. Native.enet_deinitialize();
  673. }
  674. public static uint Time {
  675. get {
  676. return Native.enet_time_get();
  677. }
  678. }
  679. }
  680. [SuppressUnmanagedCodeSecurity]
  681. internal static class Native {
  682. #if __IOS__ || UNITY_IOS && !UNITY_EDITOR
  683. private const string nativeLibrary = "__Internal";
  684. #else
  685. private const string nativeLibrary = "enet";
  686. #endif
  687. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  688. internal static extern int enet_initialize();
  689. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  690. internal static extern int enet_initialize_with_callbacks(uint version, ENetCallbacks inits);
  691. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  692. internal static extern void enet_deinitialize();
  693. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  694. internal static extern uint enet_time_get();
  695. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  696. internal static extern int enet_address_set_host_ip(ref ENetAddress address, string ip);
  697. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  698. internal static extern int enet_address_set_host(ref ENetAddress address, string hostName);
  699. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  700. internal static extern int enet_address_get_host_ip(ENetAddress address, StringBuilder ip, IntPtr ipLength);
  701. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  702. internal static extern int enet_address_get_host(ENetAddress address, StringBuilder hostName, IntPtr nameLength);
  703. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  704. internal static extern IntPtr enet_packet_create(byte[] data, IntPtr dataLength, PacketFlags flags);
  705. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  706. internal static extern IntPtr enet_packet_create(IntPtr data, IntPtr dataLength, PacketFlags flags);
  707. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  708. internal static extern IntPtr enet_packet_create_offset(byte[] data, IntPtr dataLength, IntPtr dataOffset, PacketFlags flags);
  709. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  710. internal static extern IntPtr enet_packet_create_offset(IntPtr data, IntPtr dataLength, IntPtr dataOffset, PacketFlags flags);
  711. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  712. internal static extern int enet_packet_check_references(IntPtr packet);
  713. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  714. internal static extern IntPtr enet_packet_get_data(IntPtr packet);
  715. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  716. internal static extern int enet_packet_get_length(IntPtr packet);
  717. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  718. internal static extern void enet_packet_set_free_callback(IntPtr packet, IntPtr callback);
  719. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  720. internal static extern void enet_packet_dispose(IntPtr packet);
  721. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  722. internal static extern IntPtr enet_host_create(ref ENetAddress address, IntPtr peerLimit, IntPtr channelLimit, uint incomingBandwidth, uint outgoingBandwidth, int bufferSize);
  723. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  724. internal static extern IntPtr enet_host_create(IntPtr address, IntPtr peerLimit, IntPtr channelLimit, uint incomingBandwidth, uint outgoingBandwidth, int bufferSize);
  725. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  726. internal static extern IntPtr enet_host_connect(IntPtr host, ref ENetAddress address, IntPtr channelCount, uint data);
  727. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  728. internal static extern void enet_host_broadcast(IntPtr host, byte channelID, IntPtr packet);
  729. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  730. internal static extern void enet_host_broadcast_exclude(IntPtr host, byte channelID, IntPtr packet, IntPtr excludedPeer);
  731. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  732. internal static extern void enet_host_broadcast_selective(IntPtr host, byte channelID, IntPtr packet, IntPtr[] peers, IntPtr peersLength);
  733. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  734. internal static extern int enet_host_service(IntPtr host, out ENetEvent @event, uint timeout);
  735. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  736. internal static extern int enet_host_check_events(IntPtr host, out ENetEvent @event);
  737. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  738. internal static extern void enet_host_channel_limit(IntPtr host, IntPtr channelLimit);
  739. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  740. internal static extern void enet_host_bandwidth_limit(IntPtr host, uint incomingBandwidth, uint outgoingBandwidth);
  741. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  742. internal static extern uint enet_host_get_peers_count(IntPtr host);
  743. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  744. internal static extern uint enet_host_get_packets_sent(IntPtr host);
  745. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  746. internal static extern uint enet_host_get_packets_received(IntPtr host);
  747. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  748. internal static extern uint enet_host_get_bytes_sent(IntPtr host);
  749. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  750. internal static extern uint enet_host_get_bytes_received(IntPtr host);
  751. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  752. internal static extern void enet_host_flush(IntPtr host);
  753. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  754. internal static extern void enet_host_destroy(IntPtr host);
  755. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  756. internal static extern void enet_host_enable_compression(IntPtr host);
  757. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  758. internal static extern void enet_host_prevent_connections(IntPtr host, byte state);
  759. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  760. internal static extern void enet_peer_throttle_configure(IntPtr peer, uint interval, uint acceleration, uint deceleration, uint threshold);
  761. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  762. internal static extern uint enet_peer_get_id(IntPtr peer);
  763. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  764. internal static extern int enet_peer_get_ip(IntPtr peer, byte[] ip, IntPtr ipLength);
  765. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  766. internal static extern ushort enet_peer_get_port(IntPtr peer);
  767. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  768. internal static extern uint enet_peer_get_mtu(IntPtr peer);
  769. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  770. internal static extern PeerState enet_peer_get_state(IntPtr peer);
  771. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  772. internal static extern uint enet_peer_get_rtt(IntPtr peer);
  773. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  774. internal static extern uint enet_peer_get_lastsendtime(IntPtr peer);
  775. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  776. internal static extern uint enet_peer_get_lastreceivetime(IntPtr peer);
  777. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  778. internal static extern ulong enet_peer_get_packets_sent(IntPtr peer);
  779. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  780. internal static extern ulong enet_peer_get_packets_lost(IntPtr peer);
  781. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  782. internal static extern ulong enet_peer_get_bytes_sent(IntPtr peer);
  783. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  784. internal static extern ulong enet_peer_get_bytes_received(IntPtr peer);
  785. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  786. internal static extern IntPtr enet_peer_get_data(IntPtr peer);
  787. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  788. internal static extern void enet_peer_set_data(IntPtr peer, IntPtr data);
  789. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  790. internal static extern int enet_peer_send(IntPtr peer, byte channelID, IntPtr packet);
  791. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  792. internal static extern IntPtr enet_peer_receive(IntPtr peer, out byte channelID);
  793. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  794. internal static extern void enet_peer_ping(IntPtr peer);
  795. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  796. internal static extern void enet_peer_ping_interval(IntPtr peer, uint pingInterval);
  797. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  798. internal static extern void enet_peer_timeout(IntPtr peer, uint timeoutLimit, uint timeoutMinimum, uint timeoutMaximum);
  799. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  800. internal static extern void enet_peer_disconnect(IntPtr peer, uint data);
  801. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  802. internal static extern void enet_peer_disconnect_now(IntPtr peer, uint data);
  803. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  804. internal static extern void enet_peer_disconnect_later(IntPtr peer, uint data);
  805. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  806. internal static extern void enet_peer_reset(IntPtr peer);
  807. }
  808. }