Net error

[Astralcircle]

This may be a duplicate of #2282

[wire-master] Trying to send an overflowed net message!
1. FlushQueue - addons/wire-master/lua/wire/wireshared.lua:609
 2. func - addons/wire-master/lua/wire/wireshared.lua:626
  3. internal_call - lua/includes/modules/hook.lua:409
   4. unknown - lua/includes/modules/hook.lua:428

[Denneisk]

The queue seriously doesn't have any protection against overflow.

https://github.com/wiremod/wire/tree/master/lua/wire/wireshared.lua#L604

[thegrb93]

do
local function PlyQueue()
    return {
        __flushing = false,
        add = function(self, item) self[#self+1]=item end
    }
end

local net_Send = SERVER and net.Send or net.SendToServer
WireLib.NetQueue = {
    __index = {
        add = SERVER and function(self, item, ply)
            if ply==nil then
                for _, ply in players.iterator() do self.plyqueues[ply]:add(item) end
            else
                self.plyqueues[ply]:add(item)
            end
            self:notifyFlush()
        end or function(self, item)
            self.plyqueues[NULL]:add(item)
            self:notifyFlush()
        end,
        cleanup = function(self, ply)
            self.plyqueues[ply] = nil
        end,
        notifyFlush = function(self)
            if self.flushing then return end
            self.flushing = true
            timer.Simple(0, function() self:flush() end)
        end,
        flush = function(self)
            if self.flushcb == nil then error("Flush callback isn't set!") end
            for ply, queue in pairs(self.plyqueues) do self:flushQueue(ply, queue) end
            self.flushing = false
        end,
        flushQueue = function(self, ply, queue)
            if queue[1]==nil or queue.__flushing then return end
            queue.__flushing = true
            net.Start(self.name)
                local written = 0
                while net.BytesWritten() < 32768 do
                    net.WriteUInt(1, 8)
                    written = written + 1
                    self.flushcb(queue[written])
                end
                net.WriteUInt(0, 8)
            net_Send(ply)
            for i=1,#queue do queue[i]=queue[i+written] end
        end,
        receive = function(self, ply)
            if net.ReadUInt(8)==0 then -- An empty message indicates a receive Ack
                local plyqueue = self.plyqueues[ply]
                plyqueue.__flushing = false
                self:flushQueue(ply, plyqueue)
            else
                while net.BytesRead() < 32768 do
                    if self.receivecb then self.receivecb() end
                    if net.ReadUInt(8)==0 then break end
                end
                net.Start(self.name) net.WriteUInt(0, 8) net_Send(ply) -- Send an empty message to Ack
            end
        end,
    },
    __call = function(t, name, flushcb, receivecb)
        if SERVER then util.AddNetworkString(name) end

        local queue = setmetatable({
            name = name,
            flushcb = flushcb,
            receivecb = receivecb,
            flushing = false,
            plyqueues = setmetatable({},{__index = function(t,k) local v=PlyQueue() t[k]=v return v end})
        }, t)

        net.Receive(name, function(len, ply) queue:receive(ply or NULL) end)

        return queue
    end
}
setmetatable(WireLib.NetQueue, WireLib.NetQueue)
end


local WirePortQueue = WireLib.NetQueue("wire_ports")
if SERVER then
    function WirePortQueue.flushcb(msg)
        -- writemsg code here
    end

    hook.Add("EntityRemoved", "wire_ports", function(ent)
		if not ent:IsPlayer() then
			WireLib._RemoveWire(ent:EntIndex())
		else
			WirePortQueue:cleanup(ent)
		end
	end)

    hook.Add("PlayerInitialSpawn", "wire_ports", function(ply)
        local queue = WirePortQueue.plyqueues[ply]
		for eid, _ in pairs(ents_with_inputs) do
			WireLib._SetInputs(Entity(eid), queue)
		end
		for eid, _ in pairs(ents_with_outputs) do
			WireLib._SetOutputs(Entity(eid), queue)
		end
		WirePortQueue:flushQueue(ply, queue)
	end)
else
    function WirePortQueue.receivecb()
        -- net.Receive("wire_ports" code here
    end
end

Can integrate this later