更长的尝试连接ws时间,调整wsconn系列函数对外超时逻辑
This commit is contained in:
@@ -110,27 +110,30 @@ function NET.wsconn_app()
|
|||||||
WS.connect('app','/app')
|
WS.connect('app','/app')
|
||||||
end
|
end
|
||||||
function NET.wsconn_user_pswd(email,password)
|
function NET.wsconn_user_pswd(email,password)
|
||||||
|
if WS.status('wsc_user')=='dead'then NET.unlock('wsc_user')end
|
||||||
if NET.lock('wsc_user',5)then
|
if NET.lock('wsc_user',5)then
|
||||||
WS.connect('user','/user',JSON.encode{
|
WS.connect('user','/user',JSON.encode{
|
||||||
email=email,
|
email=email,
|
||||||
password=password,
|
password=password,
|
||||||
})
|
},6)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
function NET.wsconn_user_token(uid,authToken)
|
function NET.wsconn_user_token(uid,authToken)
|
||||||
|
if WS.status('wsc_user')=='dead'then NET.unlock('wsc_user')end
|
||||||
if NET.lock('wsc_user',5)then
|
if NET.lock('wsc_user',5)then
|
||||||
WS.connect('user','/user',JSON.encode{
|
WS.connect('user','/user',JSON.encode{
|
||||||
uid=uid,
|
uid=uid,
|
||||||
authToken=authToken,
|
authToken=authToken,
|
||||||
})
|
},6)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
function NET.wsconn_play()
|
function NET.wsconn_play()
|
||||||
|
if WS.status('wsc_play')=='dead'then NET.unlock('wsc_play')end
|
||||||
if NET.lock('wsc_play',5)then
|
if NET.lock('wsc_play',5)then
|
||||||
WS.connect('play','/play',JSON.encode{
|
WS.connect('play','/play',JSON.encode{
|
||||||
uid=USER.uid,
|
uid=USER.uid,
|
||||||
accessToken=NET.accessToken,
|
accessToken=NET.accessToken,
|
||||||
})
|
},6)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
function NET.wsconn_stream(srid)
|
function NET.wsconn_stream(srid)
|
||||||
@@ -140,7 +143,7 @@ function NET.wsconn_stream(srid)
|
|||||||
uid=USER.uid,
|
uid=USER.uid,
|
||||||
accessToken=NET.accessToken,
|
accessToken=NET.accessToken,
|
||||||
srid=srid,
|
srid=srid,
|
||||||
})
|
},10)
|
||||||
TASK.new(NET.updateWS_stream)
|
TASK.new(NET.updateWS_stream)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user