Merge pull request #341 from azul/race_condition
make PadMessageHandler more robust against timing issuespull/342/merge
commit
165f26947d
|
@ -516,7 +516,12 @@ exports.updatePadClients = function(pad, callback)
|
||||||
], function(err)
|
], function(err)
|
||||||
{
|
{
|
||||||
if(ERR(err, callback)) return;
|
if(ERR(err, callback)) return;
|
||||||
|
// next if session has not been deleted
|
||||||
|
if(sessioninfos[session] == null)
|
||||||
|
{
|
||||||
|
callback(null);
|
||||||
|
return;
|
||||||
|
}
|
||||||
if(author == sessioninfos[session].author)
|
if(author == sessioninfos[session].author)
|
||||||
{
|
{
|
||||||
socketio.sockets.sockets[session].json.send({"type":"COLLABROOM","data":{type:"ACCEPT_COMMIT", newRev:r}});
|
socketio.sockets.sockets[session].json.send({"type":"COLLABROOM","data":{type:"ACCEPT_COMMIT", newRev:r}});
|
||||||
|
@ -538,7 +543,10 @@ exports.updatePadClients = function(pad, callback)
|
||||||
callback
|
callback
|
||||||
);
|
);
|
||||||
|
|
||||||
|
if(sessioninfos[session] != null)
|
||||||
|
{
|
||||||
sessioninfos[session].rev = pad.getHeadRevisionNumber();
|
sessioninfos[session].rev = pad.getHeadRevisionNumber();
|
||||||
|
}
|
||||||
},callback);
|
},callback);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue