ENet.cs 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923
  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. UnreliableFragment = 1 << 3
  37. }
  38. public enum EventType {
  39. None = 0,
  40. Connect = 1,
  41. Disconnect = 2,
  42. Receive = 3,
  43. Timeout = 4
  44. }
  45. public enum PeerState {
  46. Uninitialized = -1,
  47. Disconnected = 0,
  48. Connecting = 1,
  49. AcknowledgingConnect = 2,
  50. ConnectionPending = 3,
  51. ConnectionSucceeded = 4,
  52. Connected = 5,
  53. DisconnectLater = 6,
  54. Disconnecting = 7,
  55. AcknowledgingDisconnect = 8,
  56. Zombie = 9
  57. }
  58. [StructLayout(LayoutKind.Sequential)]
  59. public struct ENetAddress {
  60. [MarshalAs(UnmanagedType.ByValArray, SizeConst = 16)]
  61. public byte[] host;
  62. public ushort port;
  63. public ushort sin6_scope_id;
  64. }
  65. [StructLayout(LayoutKind.Sequential)]
  66. public 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. public struct ENetCallbacks {
  75. public IntPtr malloc;
  76. public IntPtr free;
  77. public IntPtr no_memory;
  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[] buffer;
  86. public static byte[] GetBuffer() {
  87. if (buffer == null)
  88. buffer = new byte[64];
  89. return buffer;
  90. }
  91. }
  92. public struct Address {
  93. private ENetAddress nativeAddress;
  94. internal ENetAddress NativeData {
  95. get {
  96. return nativeAddress;
  97. }
  98. set {
  99. nativeAddress = value;
  100. }
  101. }
  102. public Address(ENetAddress address) {
  103. nativeAddress = address;
  104. }
  105. public ushort Port {
  106. get {
  107. return nativeAddress.port;
  108. }
  109. set {
  110. nativeAddress.port = value;
  111. }
  112. }
  113. public bool SetHost(string hostName) {
  114. if (hostName == null)
  115. throw new ArgumentNullException("hostName");
  116. return Native.enet_address_set_host(ref nativeAddress, Encoding.ASCII.GetBytes(hostName)) == 0;
  117. }
  118. }
  119. public struct Event {
  120. private ENetEvent nativeEvent;
  121. internal ENetEvent NativeData {
  122. get {
  123. return nativeEvent;
  124. }
  125. set {
  126. nativeEvent = value;
  127. }
  128. }
  129. public Event(ENetEvent @event) {
  130. nativeEvent = @event;
  131. }
  132. public EventType Type {
  133. get {
  134. return nativeEvent.type;
  135. }
  136. }
  137. public Peer Peer {
  138. get {
  139. return new Peer(nativeEvent.peer);
  140. }
  141. }
  142. public byte ChannelID {
  143. get {
  144. return nativeEvent.channelID;
  145. }
  146. }
  147. public uint Data {
  148. get {
  149. return nativeEvent.data;
  150. }
  151. }
  152. public Packet Packet {
  153. get {
  154. return new Packet(nativeEvent.packet);
  155. }
  156. }
  157. }
  158. public class Callbacks {
  159. private ENetCallbacks nativeCallbacks;
  160. internal ENetCallbacks NativeData {
  161. get {
  162. return nativeCallbacks;
  163. }
  164. set {
  165. nativeCallbacks = value;
  166. }
  167. }
  168. public Callbacks(AllocCallback allocCallback, FreeCallback freeCallback, NoMemoryCallback noMemoryCallback) {
  169. nativeCallbacks.malloc = Marshal.GetFunctionPointerForDelegate(allocCallback);
  170. nativeCallbacks.free = Marshal.GetFunctionPointerForDelegate(freeCallback);
  171. nativeCallbacks.no_memory = Marshal.GetFunctionPointerForDelegate(noMemoryCallback);
  172. }
  173. }
  174. public struct Packet : IDisposable {
  175. private IntPtr nativePacket;
  176. internal IntPtr NativeData {
  177. get {
  178. return nativePacket;
  179. }
  180. set {
  181. nativePacket = value;
  182. }
  183. }
  184. public Packet(IntPtr packet) {
  185. nativePacket = packet;
  186. }
  187. public void Dispose() {
  188. if (nativePacket != IntPtr.Zero) {
  189. Native.enet_packet_dispose(nativePacket);
  190. nativePacket = IntPtr.Zero;
  191. }
  192. }
  193. public bool IsSet {
  194. get {
  195. return nativePacket != IntPtr.Zero;
  196. }
  197. }
  198. public IntPtr Data {
  199. get {
  200. CheckCreated();
  201. return Native.enet_packet_get_data(nativePacket);
  202. }
  203. }
  204. public int Length {
  205. get {
  206. CheckCreated();
  207. return Native.enet_packet_get_length(nativePacket);
  208. }
  209. }
  210. internal void CheckCreated() {
  211. if (nativePacket == IntPtr.Zero)
  212. throw new InvalidOperationException("Packet not created");
  213. }
  214. public void SetFreeCallback(PacketFreeCallback callback) {
  215. CheckCreated();
  216. Native.enet_packet_set_free_callback(nativePacket, Marshal.GetFunctionPointerForDelegate(callback));
  217. }
  218. public void Create(byte[] data) {
  219. if (data == null)
  220. throw new ArgumentNullException("data");
  221. Create(data, data.Length);
  222. }
  223. public void Create(byte[] data, int length) {
  224. Create(data, length, PacketFlags.None);
  225. }
  226. public void Create(byte[] data, PacketFlags flags) {
  227. Create(data, data.Length, flags);
  228. }
  229. public void Create(byte[] data, int length, PacketFlags flags) {
  230. if (data == null)
  231. throw new ArgumentNullException("data");
  232. if (length < 0 || length > data.Length)
  233. throw new ArgumentOutOfRangeException();
  234. nativePacket = Native.enet_packet_create(data, (IntPtr)length, flags);
  235. }
  236. public void Create(IntPtr data, int length, PacketFlags flags) {
  237. if (data == IntPtr.Zero)
  238. throw new ArgumentNullException("data");
  239. if (length < 0)
  240. throw new ArgumentOutOfRangeException();
  241. nativePacket = Native.enet_packet_create(data, (IntPtr)length, flags);
  242. }
  243. public void CopyTo(byte[] destination) {
  244. if (destination == null)
  245. throw new ArgumentNullException("destination");
  246. Marshal.Copy(Data, destination, 0, Length);
  247. }
  248. }
  249. public class Host : IDisposable {
  250. private IntPtr nativeHost;
  251. internal IntPtr NativeData {
  252. get {
  253. return nativeHost;
  254. }
  255. set {
  256. nativeHost = value;
  257. }
  258. }
  259. public void Dispose() {
  260. Dispose(true);
  261. GC.SuppressFinalize(this);
  262. }
  263. protected virtual void Dispose(bool disposing) {
  264. if (nativeHost != IntPtr.Zero) {
  265. Native.enet_host_destroy(nativeHost);
  266. nativeHost = IntPtr.Zero;
  267. }
  268. }
  269. ~Host() {
  270. Dispose(false);
  271. }
  272. public bool IsSet {
  273. get {
  274. return nativeHost != IntPtr.Zero;
  275. }
  276. }
  277. public uint PeersCount {
  278. get {
  279. CheckCreated();
  280. return Native.enet_host_get_peers_count(nativeHost);
  281. }
  282. }
  283. public uint PacketsSent {
  284. get {
  285. CheckCreated();
  286. return Native.enet_host_get_packets_sent(nativeHost);
  287. }
  288. }
  289. public uint PacketsReceived {
  290. get {
  291. CheckCreated();
  292. return Native.enet_host_get_packets_received(nativeHost);
  293. }
  294. }
  295. public uint BytesSent {
  296. get {
  297. CheckCreated();
  298. return Native.enet_host_get_bytes_sent(nativeHost);
  299. }
  300. }
  301. public uint BytesReceived {
  302. get {
  303. CheckCreated();
  304. return Native.enet_host_get_bytes_received(nativeHost);
  305. }
  306. }
  307. internal void CheckCreated() {
  308. if (nativeHost == IntPtr.Zero)
  309. throw new InvalidOperationException("Host not created");
  310. }
  311. private void CheckChannelLimit(int channelLimit) {
  312. if (channelLimit < 0 || channelLimit > Library.maxChannelCount)
  313. throw new ArgumentOutOfRangeException("channelLimit");
  314. }
  315. public void Create() {
  316. Create(null, 1, 0);
  317. }
  318. public void Create(Address? address, int peerLimit) {
  319. Create(address, peerLimit, 0);
  320. }
  321. public void Create(Address? address, int peerLimit, int channelLimit) {
  322. Create(address, peerLimit, channelLimit, 0, 0);
  323. }
  324. public void Create(int peerLimit, int channelLimit, uint incomingBandwidth, uint outgoingBandwidth) {
  325. Create(null, peerLimit, channelLimit, incomingBandwidth, outgoingBandwidth);
  326. }
  327. public void Create(Address? address, int peerLimit, int channelLimit, uint incomingBandwidth, uint outgoingBandwidth) {
  328. if (nativeHost != IntPtr.Zero)
  329. throw new InvalidOperationException("Host already created");
  330. if (peerLimit < 0 || peerLimit > Library.maxPeers)
  331. throw new ArgumentOutOfRangeException("peerLimit");
  332. CheckChannelLimit(channelLimit);
  333. if (address != null) {
  334. var nativeAddress = address.Value.NativeData;
  335. nativeHost = Native.enet_host_create(ref nativeAddress, (IntPtr)peerLimit, (IntPtr)channelLimit, incomingBandwidth, outgoingBandwidth);
  336. } else {
  337. nativeHost = Native.enet_host_create(IntPtr.Zero, (IntPtr)peerLimit, (IntPtr)channelLimit, incomingBandwidth, outgoingBandwidth);
  338. }
  339. if (nativeHost == IntPtr.Zero)
  340. throw new InvalidOperationException("Host creation call failed");
  341. }
  342. public void EnableCompression() {
  343. CheckCreated();
  344. Native.enet_host_enable_compression(nativeHost);
  345. }
  346. public void PreventConnections(bool state) {
  347. CheckCreated();
  348. Native.enet_host_prevent_connections(nativeHost, (byte)(state ? 1 : 0));
  349. }
  350. public void Broadcast(byte channelID, ref Packet packet) {
  351. CheckCreated();
  352. packet.CheckCreated();
  353. Native.enet_host_broadcast(nativeHost, channelID, packet.NativeData);
  354. packet.NativeData = IntPtr.Zero;
  355. }
  356. public int CheckEvents(out Event @event) {
  357. CheckCreated();
  358. ENetEvent nativeEvent;
  359. var result = Native.enet_host_check_events(nativeHost, out nativeEvent);
  360. if (result <= 0) {
  361. @event = new Event();
  362. return result;
  363. }
  364. @event = new Event(nativeEvent);
  365. return result;
  366. }
  367. public Peer Connect(Address address) {
  368. return Connect(address, 0, 0);
  369. }
  370. public Peer Connect(Address address, int channelLimit) {
  371. return Connect(address, channelLimit, 0);
  372. }
  373. public Peer Connect(Address address, int channelLimit, uint data) {
  374. CheckCreated();
  375. CheckChannelLimit(channelLimit);
  376. var nativeAddress = address.NativeData;
  377. var peer = new Peer(Native.enet_host_connect(nativeHost, ref nativeAddress, (IntPtr)channelLimit, data));
  378. if (peer.NativeData == IntPtr.Zero)
  379. throw new InvalidOperationException("Host connect call failed");
  380. return peer;
  381. }
  382. public int Service(int timeout, out Event @event) {
  383. if (timeout < 0)
  384. throw new ArgumentOutOfRangeException("timeout");
  385. CheckCreated();
  386. ENetEvent nativeEvent;
  387. var result = Native.enet_host_service(nativeHost, out nativeEvent, (uint)timeout);
  388. if (result <= 0) {
  389. @event = new Event();
  390. return result;
  391. }
  392. @event = new Event(nativeEvent);
  393. return result;
  394. }
  395. public void SetBandwidthLimit(uint incomingBandwidth, uint outgoingBandwidth) {
  396. CheckCreated();
  397. Native.enet_host_bandwidth_limit(nativeHost, incomingBandwidth, outgoingBandwidth);
  398. }
  399. public void SetChannelLimit(int channelLimit) {
  400. CheckCreated();
  401. CheckChannelLimit(channelLimit);
  402. Native.enet_host_channel_limit(nativeHost, (IntPtr)channelLimit);
  403. }
  404. public void Flush() {
  405. CheckCreated();
  406. Native.enet_host_flush(nativeHost);
  407. }
  408. }
  409. public struct Peer {
  410. private IntPtr nativePeer;
  411. internal IntPtr NativeData {
  412. get {
  413. return nativePeer;
  414. }
  415. set {
  416. nativePeer = value;
  417. }
  418. }
  419. public Peer(IntPtr peer) {
  420. nativePeer = peer;
  421. }
  422. public bool IsSet {
  423. get {
  424. return nativePeer != IntPtr.Zero;
  425. }
  426. }
  427. public uint ID {
  428. get {
  429. CheckCreated();
  430. return Native.enet_peer_get_id(nativePeer);
  431. }
  432. }
  433. public string IP {
  434. get {
  435. CheckCreated();
  436. byte[] ip = ArrayPool.GetBuffer();
  437. if (Native.enet_peer_get_ip(nativePeer, ip, (IntPtr)ip.Length) == 0) {
  438. if (Encoding.ASCII.GetString(ip).Remove(7) == "::ffff:")
  439. return Encoding.ASCII.GetString(ip).Substring(7);
  440. return Encoding.ASCII.GetString(ip);
  441. } else {
  442. return String.Empty;
  443. }
  444. }
  445. }
  446. public ushort Port {
  447. get {
  448. CheckCreated();
  449. return Native.enet_peer_get_port(nativePeer);
  450. }
  451. }
  452. public uint MTU {
  453. get {
  454. CheckCreated();
  455. return Native.enet_peer_get_mtu(nativePeer);
  456. }
  457. }
  458. public PeerState State {
  459. get {
  460. return nativePeer == IntPtr.Zero ? PeerState.Uninitialized : Native.enet_peer_get_state(nativePeer);
  461. }
  462. }
  463. public uint RoundTripTime {
  464. get {
  465. CheckCreated();
  466. return Native.enet_peer_get_rtt(nativePeer);
  467. }
  468. }
  469. public uint LastSendTime {
  470. get {
  471. CheckCreated();
  472. return Native.enet_peer_get_lastsendtime(nativePeer);
  473. }
  474. }
  475. public uint LastReceiveTime {
  476. get {
  477. CheckCreated();
  478. return Native.enet_peer_get_lastreceivetime(nativePeer);
  479. }
  480. }
  481. public ulong PacketsSent {
  482. get {
  483. CheckCreated();
  484. return Native.enet_peer_get_packets_sent(nativePeer);
  485. }
  486. }
  487. public uint PacketsLost {
  488. get {
  489. CheckCreated();
  490. return Native.enet_peer_get_packets_lost(nativePeer);
  491. }
  492. }
  493. public ulong BytesSent {
  494. get {
  495. CheckCreated();
  496. return Native.enet_peer_get_bytes_sent(nativePeer);
  497. }
  498. }
  499. public ulong BytesReceived {
  500. get {
  501. CheckCreated();
  502. return Native.enet_peer_get_bytes_received(nativePeer);
  503. }
  504. }
  505. public IntPtr Data {
  506. get {
  507. CheckCreated();
  508. return Native.enet_peer_get_data(nativePeer);
  509. }
  510. set {
  511. CheckCreated();
  512. Native.enet_peer_set_data(nativePeer, value);
  513. }
  514. }
  515. internal void CheckCreated() {
  516. if (nativePeer == IntPtr.Zero)
  517. throw new InvalidOperationException("Peer not created");
  518. }
  519. public void ConfigureThrottle(uint interval, uint acceleration, uint deceleration) {
  520. CheckCreated();
  521. Native.enet_peer_throttle_configure(nativePeer, interval, acceleration, deceleration);
  522. }
  523. public bool Send(byte channelID, ref Packet packet) {
  524. CheckCreated();
  525. return Native.enet_peer_send(nativePeer, channelID, packet.NativeData) == 0;
  526. }
  527. public void Ping() {
  528. CheckCreated();
  529. Native.enet_peer_ping(nativePeer);
  530. }
  531. public void PingInterval(uint interval) {
  532. CheckCreated();
  533. Native.enet_peer_ping_interval(nativePeer, interval);
  534. }
  535. public void Timeout(uint timeoutLimit, uint timeoutMinimum, uint timeoutMaximum) {
  536. CheckCreated();
  537. Native.enet_peer_timeout(nativePeer, timeoutLimit, timeoutMinimum, timeoutMaximum);
  538. }
  539. public void Disconnect(uint data) {
  540. CheckCreated();
  541. Native.enet_peer_disconnect(nativePeer, data);
  542. }
  543. public void DisconnectNow(uint data) {
  544. CheckCreated();
  545. Native.enet_peer_disconnect_now(nativePeer, data);
  546. }
  547. public void DisconnectLater(uint data) {
  548. CheckCreated();
  549. Native.enet_peer_disconnect_later(nativePeer, data);
  550. }
  551. public void Reset() {
  552. CheckCreated();
  553. Native.enet_peer_reset(nativePeer);
  554. }
  555. }
  556. public static class Library {
  557. public const uint maxChannelCount = 0xFF;
  558. public const uint maxPeers = 0xFFF;
  559. public const uint throttleScale = 32;
  560. public const uint throttleAcceleration = 2;
  561. public const uint throttleDeceleration = 2;
  562. public const uint throttleInterval = 5000;
  563. public const uint timeoutLimit = 32;
  564. public const uint timeoutMinimum = 5000;
  565. public const uint timeoutMaximum = 30000;
  566. public const uint version = (2 << 16) | (1 << 8) | (2);
  567. public static bool Initialize() {
  568. return Native.enet_initialize() == 0;
  569. }
  570. public static bool Initialize(Callbacks inits) {
  571. var nativeCallbacks = inits.NativeData;
  572. return Native.enet_initialize_with_callbacks(version, ref nativeCallbacks) == 0;
  573. }
  574. public static void Deinitialize() {
  575. Native.enet_deinitialize();
  576. }
  577. public static uint Time {
  578. get {
  579. return Native.enet_time_get();
  580. }
  581. }
  582. }
  583. [SuppressUnmanagedCodeSecurity]
  584. internal static class Native {
  585. #if __IOS__ || UNITY_IOS && !UNITY_EDITOR
  586. private const string nativeLibrary = "__Internal";
  587. #else
  588. private const string nativeLibrary = "enet";
  589. #endif
  590. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  591. internal static extern int enet_initialize();
  592. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  593. internal static extern int enet_initialize_with_callbacks(uint version, ref ENetCallbacks inits);
  594. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  595. internal static extern void enet_deinitialize();
  596. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  597. internal static extern uint enet_time_get();
  598. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  599. internal static extern int enet_address_set_host(ref ENetAddress address, byte[] hostName);
  600. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  601. internal static extern IntPtr enet_packet_create(byte[] data, IntPtr dataLength, PacketFlags flags);
  602. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  603. internal static extern IntPtr enet_packet_create(IntPtr data, IntPtr dataLength, PacketFlags flags);
  604. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  605. internal static extern IntPtr enet_packet_get_data(IntPtr packet);
  606. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  607. internal static extern int enet_packet_get_length(IntPtr packet);
  608. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  609. internal static extern void enet_packet_set_free_callback(IntPtr packet, IntPtr callback);
  610. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  611. internal static extern void enet_packet_dispose(IntPtr packet);
  612. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  613. internal static extern IntPtr enet_host_create(ref ENetAddress address, IntPtr peerLimit, IntPtr channelLimit, uint incomingBandwidth, uint outgoingBandwidth);
  614. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  615. internal static extern IntPtr enet_host_create(IntPtr address, IntPtr peerLimit, IntPtr channelLimit, uint incomingBandwidth, uint outgoingBandwidth);
  616. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  617. internal static extern IntPtr enet_host_connect(IntPtr host, ref ENetAddress address, IntPtr channelCount, uint data);
  618. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  619. internal static extern void enet_host_broadcast(IntPtr host, byte channelID, IntPtr packet);
  620. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  621. internal static extern int enet_host_service(IntPtr host, out ENetEvent @event, uint timeout);
  622. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  623. internal static extern int enet_host_check_events(IntPtr host, out ENetEvent @event);
  624. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  625. internal static extern void enet_host_channel_limit(IntPtr host, IntPtr channelLimit);
  626. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  627. internal static extern void enet_host_bandwidth_limit(IntPtr host, uint incomingBandwidth, uint outgoingBandwidth);
  628. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  629. internal static extern uint enet_host_get_peers_count(IntPtr host);
  630. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  631. internal static extern uint enet_host_get_packets_sent(IntPtr host);
  632. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  633. internal static extern uint enet_host_get_packets_received(IntPtr host);
  634. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  635. internal static extern uint enet_host_get_bytes_sent(IntPtr host);
  636. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  637. internal static extern uint enet_host_get_bytes_received(IntPtr host);
  638. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  639. internal static extern void enet_host_flush(IntPtr host);
  640. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  641. internal static extern void enet_host_destroy(IntPtr host);
  642. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  643. internal static extern void enet_host_enable_compression(IntPtr host);
  644. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  645. internal static extern void enet_host_prevent_connections(IntPtr host, byte state);
  646. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  647. internal static extern void enet_peer_throttle_configure(IntPtr peer, uint interval, uint acceleration, uint deceleration);
  648. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  649. internal static extern uint enet_peer_get_id(IntPtr peer);
  650. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  651. internal static extern int enet_peer_get_ip(IntPtr peer, byte[] ip, IntPtr ipLength);
  652. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  653. internal static extern ushort enet_peer_get_port(IntPtr peer);
  654. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  655. internal static extern uint enet_peer_get_mtu(IntPtr peer);
  656. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  657. internal static extern PeerState enet_peer_get_state(IntPtr peer);
  658. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  659. internal static extern uint enet_peer_get_rtt(IntPtr peer);
  660. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  661. internal static extern uint enet_peer_get_lastsendtime(IntPtr peer);
  662. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  663. internal static extern uint enet_peer_get_lastreceivetime(IntPtr peer);
  664. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  665. internal static extern ulong enet_peer_get_packets_sent(IntPtr peer);
  666. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  667. internal static extern uint enet_peer_get_packets_lost(IntPtr peer);
  668. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  669. internal static extern ulong enet_peer_get_bytes_sent(IntPtr peer);
  670. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  671. internal static extern ulong enet_peer_get_bytes_received(IntPtr peer);
  672. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  673. internal static extern IntPtr enet_peer_get_data(IntPtr peer);
  674. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  675. internal static extern void enet_peer_set_data(IntPtr peer, IntPtr data);
  676. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  677. internal static extern int enet_peer_send(IntPtr peer, byte channelID, IntPtr packet);
  678. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  679. internal static extern void enet_peer_ping(IntPtr peer);
  680. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  681. internal static extern void enet_peer_ping_interval(IntPtr peer, uint pingInterval);
  682. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  683. internal static extern void enet_peer_timeout(IntPtr peer, uint timeoutLimit, uint timeoutMinimum, uint timeoutMaximum);
  684. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  685. internal static extern void enet_peer_disconnect(IntPtr peer, uint data);
  686. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  687. internal static extern void enet_peer_disconnect_now(IntPtr peer, uint data);
  688. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  689. internal static extern void enet_peer_disconnect_later(IntPtr peer, uint data);
  690. [DllImport(nativeLibrary, CallingConvention = CallingConvention.Cdecl)]
  691. internal static extern void enet_peer_reset(IntPtr peer);
  692. }
  693. }