mirror of
https://github.com/imezx/Warp.git
synced 2025-04-24 15:10:03 +00:00
Fix: server invoke
This commit is contained in:
parent
5b2e36b7bb
commit
10de54608a
2 changed files with 6 additions and 2 deletions
|
@ -204,6 +204,7 @@ function ClientProcess.start()
|
||||||
queueOutRequest[1][Identifier] = {}
|
queueOutRequest[1][Identifier] = {}
|
||||||
end
|
end
|
||||||
table.insert(queueOutRequest[1][Identifier], { requestData[1], requestData[3] })
|
table.insert(queueOutRequest[1][Identifier], { requestData[1], requestData[3] })
|
||||||
|
requestData[3] = nil
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -267,6 +267,7 @@ function ServerProcess.start()
|
||||||
for _, Identifier: string in registeredIdentifier do
|
for _, Identifier: string in registeredIdentifier do
|
||||||
if serverRequestQueue[Identifier] then
|
if serverRequestQueue[Identifier] then
|
||||||
for player, content in serverRequestQueue[Identifier] do
|
for player, content in serverRequestQueue[Identifier] do
|
||||||
|
if #content == 0 then serverRequestQueue[Identifier][player] = nil continue end
|
||||||
for _, requestData in content do
|
for _, requestData in content do
|
||||||
if not requestData[3] then continue end
|
if not requestData[3] then continue end
|
||||||
if not queueOutRequest[1][Identifier] then
|
if not queueOutRequest[1][Identifier] then
|
||||||
|
@ -276,6 +277,7 @@ function ServerProcess.start()
|
||||||
queueOutRequest[1][Identifier][player] = {}
|
queueOutRequest[1][Identifier][player] = {}
|
||||||
end
|
end
|
||||||
table.insert(queueOutRequest[1][Identifier][player], { requestData[1], requestData[3] })
|
table.insert(queueOutRequest[1][Identifier][player], { requestData[1], requestData[3] })
|
||||||
|
requestData[3] = nil
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
@ -347,7 +349,6 @@ function ServerProcess.start()
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
queueInRequest[2][Identifier][player] = nil
|
queueInRequest[2][Identifier][player] = nil
|
||||||
serverRequestQueue[Identifier] = nil
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end)
|
end)
|
||||||
|
@ -375,6 +376,8 @@ function ServerProcess.start()
|
||||||
Identifier = Buffer.convert(Identifier)
|
Identifier = Buffer.convert(Identifier)
|
||||||
if not queueInRequest[1][Identifier][player] then
|
if not queueInRequest[1][Identifier][player] then
|
||||||
queueInRequest[1][Identifier][player] = {}
|
queueInRequest[1][Identifier][player] = {}
|
||||||
|
end
|
||||||
|
if not queueInRequest[2][Identifier][player] then
|
||||||
queueInRequest[2][Identifier][player] = {}
|
queueInRequest[2][Identifier][player] = {}
|
||||||
end
|
end
|
||||||
if not serverQueue[Identifier] then
|
if not serverQueue[Identifier] then
|
||||||
|
|
Loading…
Reference in a new issue