LÖVE

Code: Select all

function udpClient:_receive()
	local data, ip, port = self.socket:receivefrom()

Code: Select all

function client:receive()
	-- Check if we're connected and pass it on.
	print("client receive")
	if not self.connected then
		return false, "Not connected"
	end
	
	return self:_receive()
end
function client:update(dt)
	if not self.connected then return end
	assert(dt, "Update needs a dt!")
	-- First, let's handle ping messages.
	if self.ping then
		self.ping.timer = self.ping.timer + dt
		if self.ping.timer > self.ping.time then
			self:_send(self.ping.msg)
			self.ping.timer = 0
		end
	end
	-- If a recv callback is set, let's grab
	-- all incoming messages. If not, leave
	-- them in the queue.
        
	if self.callbacks.recv then          
		local data, err = self:_receive()
		while data do
			self.callbacks.recv(data)
			data, err = self:_receive()
		end
	end
end

Code: Select all

function onConnect(id)
    server:send("hi", id) -- never gets through
    print(id) -- always prints id
end
function onReceive(data, id)
    print(data .. "sent from "..id) -- always see this
end

function StartServer()
    server = lube.udpServer()
    server:listen("7000")
    server.callbacks.connect = onConnect
    server.callbacks.recv = onReceive
    server.handshake = "Hi!"
    print("started server")
end

Code: Select all

_ip = "127.0.0.1"
_port = "7000"

function StartClient()
    client = lube.udpClient()
    client.handshake = "Hi!"
    client.callbacks.recv = Receive
    success, er = client:connect(_ip, _port)
    
    print("success : " .. tostring(success)) -- always true, even if the server hasnt been started
    client:send("hello") -- server always receives and prints this (see above)
    return success
end

Code: Select all

function client:update(dt)
	if not self.connected then return end
	assert(dt, "Update needs a dt!")
	-- First, let's handle ping messages.
	if self.ping then
		self.ping.timer = self.ping.timer + dt
		if self.ping.timer > self.ping.time then
			self:_send(self.ping.msg)
			self.ping.timer = 0
		end
	end
	-- If a recv callback is set, let's grab
	-- all incoming messages. If not, leave
	-- them in the queue.
        
	if self.callbacks.recv then
                
		local data, err = self:_receive()
                print(data) -- always nil/false
               print(err) -- "Unknown remote sent data." (from the function udpClient:_receive()
		while data do
			self.callbacks.recv(data)
			data, err = self:_receive()
		end
	end
end