mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-25 12:43:09 +00:00
fix invalid fd after reconnected, used in unpack_f
This commit is contained in:
@@ -131,7 +131,7 @@ local text = "echo"
|
|||||||
local index = 1
|
local index = 1
|
||||||
|
|
||||||
print("connect")
|
print("connect")
|
||||||
local fd = assert(socket.connect("127.0.0.1", 8888))
|
fd = assert(socket.connect("127.0.0.1", 8888))
|
||||||
last = ""
|
last = ""
|
||||||
|
|
||||||
local handshake = string.format("%s@%s#%s:%d", crypt.base64encode(token.user), crypt.base64encode(token.server),crypt.base64encode(subid) , index)
|
local handshake = string.format("%s@%s#%s:%d", crypt.base64encode(token.user), crypt.base64encode(token.server),crypt.base64encode(subid) , index)
|
||||||
@@ -151,7 +151,7 @@ socket.close(fd)
|
|||||||
index = index + 1
|
index = index + 1
|
||||||
|
|
||||||
print("connect again")
|
print("connect again")
|
||||||
local fd = assert(socket.connect("127.0.0.1", 8888))
|
fd = assert(socket.connect("127.0.0.1", 8888))
|
||||||
last = ""
|
last = ""
|
||||||
|
|
||||||
local handshake = string.format("%s@%s#%s:%d", crypt.base64encode(token.user), crypt.base64encode(token.server),crypt.base64encode(subid) , index)
|
local handshake = string.format("%s@%s#%s:%d", crypt.base64encode(token.user), crypt.base64encode(token.server),crypt.base64encode(subid) , index)
|
||||||
|
|||||||
Reference in New Issue
Block a user