An ENet wrapper for Godot.
GDNet for Godot 3. If you need to use GDNet for Godot 2.1+, you can find it here.
ENet is a library that provides a number of features on top of UDP such as, connection handling, sequencing, reliability, channels, bandwidth throttling, packet fragmentation and reassembly. GDNet provides a (mostly) thin wrapper around ENet.
Simply drop the code into a gdnet3 directory in your godot/modules directory and build for the platfom of your choice. GDNet has been verified to build on Linux (64 bit), MacOS X (32/64 bit), and Windows (32/64 bit cross-compiled using MinGW).
extends Node
var client1 = null
var client2 = null
var peer1 = null
var peer2 = null
var server = null
func _init():
var address = GDNetAddress.new()
address.set_host("localhost")
address.set_port(3000)
server = GDNetHost.new()
server.bind(address)
client1 = GDNetHost.new()
client1.bind()
peer1 = client1.host_connect(address)
client2 = GDNetHost.new()
client2.bind()
peer2 = client2.host_connect(address)
func _process(delta):
if (client1.is_event_available()):
var event = client1.get_event()
if (event.get_event_type() == GDNetEvent.CONNECT):
print("Client1 connected")
peer1.send_var("Hello from client 1", 0)
if (event.get_event_type() == GDNetEvent.RECEIVE):
print(event.get_var())
if (client2.is_event_available()):
var event = client2.get_event()
if (event.get_event_type() == GDNetEvent.CONNECT):
print("Client2 connected")
peer2.send_var("Hello from client 2", 0)
if (event.get_event_type() == GDNetEvent.RECEIVE):
print(event.get_var())
if (server.is_event_available()):
var event = server.get_event()
if (event.get_event_type() == GDNetEvent.CONNECT):
var peer = server.get_peer(event.get_peer_id())
var address = peer.get_address();
print("Peer connected from ", address.get_host(), ":", address.get_port())
peer.send_var(str("Hello from server to peer ", event.get_peer_id()), 0)
elif (event.get_event_type() == GDNetEvent.RECEIVE):
print(event.get_var())
server.broadcast_var("Server broadcast", 0)Sample Output:
Client1 connected
Client2 connected
Peer connected from 127.0.0.1:56075
Peer connected from 127.0.0.1:42174
Hello from server to peer 0
Hello from client 2
Hello from server to peer 1
Server broadcast
Hello from client 1
Server broadcast
Server broadcast
Server broadcast
- set_port(port:Integer)
- get_port():Integer
- set_host(host:String)
- get_host():String
- get_event_type():Integer - returns one of
GDNetEvent.CONNECT,GDNetEvent.DISCONNECT, orGDNetEvent.RECEIVE - get_peer_id():Integer - the peer associated with the event
- get_channel_id():Integer - only valid for
GDNetEvent.RECEIVEevents - get_packet():PoolByteArray - only valid for
GDNetEvent.RECEIVEevents - get_var():Variant - only valid for
GDNetEvent.RECEIVEevents - get_data():Integer - only valid for
GDNetEvent.CONNECTandGDNetEvent.DISCONNECTevents
- get_peer(id:Integer):GDNetPeer
- set_event_wait(id:Integer) - sets the duration of time the host thread will wait (block) for events (default: 1 ms)
- set_max_peers(max:Integer) - must be called before
bind(default: 32) - set_max_channels(max:Integer) - must be called before
bind(default: 1) - set_max_bandwidth_in(max:Integer) - measured in bytes/sec, must be called before
bind(default: unlimited) - set_max_bandwidth_out(max:Integer) - measured in bytes/sec, must be called before
bind(default: unlimited) - bind(addr:GDNetAddress) - starts the host (the system determines the interface/port to bind if
addris empty) - unbind() - stops the host
- host_connect(addr:GDNetAddress, data:Integer):GDNetPeer - attempt to connect to a remote host (data default: 0)
- broadcast_packet(packet:PoolByteArray, channel_id:Integer, type:Integer) - type must be one of
GDNetMessage.UNSEQUENCED,GDNetMessage.SEQUENCED, orGDNetMessage.RELIABLE - broadcast_var(var:Variant, channel_id:Integer, type:Integer) - type must be one of
GDNetMessage.UNSEQUENCED,GDNetMessage.SEQUENCED, orGDNetMessage.RELIABLE - is_event_available():Boolean - returns
trueif there is an event in the queue - get_event_count():Integer - returns the number of events in the queue
- get_event():GDNetEvent - return the next event in the queue
These methods should be called after a successful connection is established, that is, only after a GDNetEvent.CONNECT event is consumed.
- get_peer_id():Integer
- get_address():GDNetAddress
- ping() - sends a ping to the remote peer
- set_ping_interval(pingInterval:Integer) - Sets the interval at which pings will be sent to a peer
- get_avg_rtt():Integer - Average Round Trip Time (RTT). Note, this value is initially 500 ms and will be adjusted by traffic or pings.
- reset() - forcefully disconnect a peer (foreign host is not notified)
- peer_disconnect(data:Integer) - request a disconnection from a peer (data default: 0)
- disconnect_later(data:Integer) - request disconnection after all queued packets have been sent (data default: 0)
- disconnect_now(data:Integer) - forcefully disconnect peer (notification is sent, but not guaranteed to arrive) (data default: 0)
- send_packet(packet:PoolByteArray, channel_id:int, type:int) - type must be one of
GDNetMessage.UNSEQUENCED,GDNetMessage.SEQUENCED, orGDNetMessage.RELIABLE - send_var(var:Variant, channel_id:Integer, type:Integer) - type must be one of
GDNetMessage.UNSEQUENCED,GDNetMessage.SEQUENCED, orGDNetMessage.RELIABLE - set_timeout(limit:int, min_timeout:Integer, max_timeout:Integer)
- limit - A factor that is multiplied with a value that based on the average round trip time to compute the timeout limit.
- min_timeout - Timeout value, in milliseconds, that a reliable packet has to be acknowledged if the variable timeout limit was exceeded before dropping the peer.
- max_timeout - Fixed timeout in milliseconds for which any packet has to be acknowledged before dropping the peer.
Copyright (c) 2015 James McLean
Licensed under the MIT license.