RanchiMall/SuperNodeStorage
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug fix: backup rotation exceptions

Browse Source 
Limiting the rotation while connecting to backup nodes. i.e, not enough supernodes available.
Handling the above exception in backup_node_offline event
This commit is contained in:
sairajzero 2019-11-23 21:11:53 +05:30
parent db3c86e8c7
commit 3f7a8c1479
1 changed files with 33 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
index.html
View File

@ -5412,7 +5412,7 @@
upperKey: request.upperVectorClock, upperKey: request.upperVectorClock,
lastOnly: request.mostRecent, lastOnly: request.mostRecent,
atKey: request.atVectorClock, atKey: request.atVectorClock,
patternEval: (k, v) => { return (v.application == request.application && (!request.receiverID || v.receiverID == request.receiverID) && (!request.comment || v.comment == request.comment) && (!request.type || v.type == request.type) && (!request.senderIDs || request.senderIDs.includes(v.senderID))) } patternEval: (k, v) => { return (v.application == request.application && v.receiverID == request.receiverID && (!request.comment || v.comment == request.comment) && (!request.type || v.type == request.type) && (!request.senderIDs || request.senderIDs.includes(v.senderID))) }
} }
compactIDB.searchData( floGlobals.storageList.includes(request.application) ? request.application : floGlobals.defaultStorage, filterOptions, `SN_${result[0].floID}`) compactIDB.searchData( floGlobals.storageList.includes(request.application) ? request.application : floGlobals.defaultStorage, filterOptions, `SN_${result[0].floID}`)
.then(result => floSupernode.supernodeClientWS.send(`${requestor} ${JSON.stringify(result)}`)) .then(result => floSupernode.supernodeClientWS.send(`${requestor} ${JSON.stringify(result)}`))
@ -6139,12 +6139,16 @@
resolve("Connected to all backup nodes") resolve("Connected to all backup nodes")
else{ else{
floSupernode.kBucket.getNextSupernode(curNode).then(nextBackupNode => { floSupernode.kBucket.getNextSupernode(curNode).then(nextBackupNode => {
connectToBackupSupernode(nextBackupNode[0].floID).then(backupConn => { if(myFloID === nextBackupNode[0].floID)
floGlobals.backupNodes[i] = backupConn reject("Not enough supernodes available")
connectToAllBackupSupernode(backupConn.floID, i+1) else{
.then(result => resolve(result)) connectToBackupSupernode(nextBackupNode[0].floID).then(backupConn => {
.catch(error => reject(error)) floGlobals.backupNodes[i] = backupConn
}) connectToAllBackupSupernode(backupConn.floID, i+1)
.then(result => resolve(result))
.catch(error => reject(error))
})
}
}).catch(error => reject(error)) }).catch(error => reject(error))
} }
@ -6225,8 +6229,9 @@
//remove offline node and add the immediate next available node //remove offline node and add the immediate next available node
var index = floGlobals.backupNodes.indexOf(offlineNodeID); var index = floGlobals.backupNodes.indexOf(offlineNodeID);
if (index !== -1) floGlobals.backupNodes.splice(index, 1); if (index !== -1) floGlobals.backupNodes.splice(index, 1);
//connect to next node available
var len = floGlobals.backupNodes.length var len = floGlobals.backupNodes.length
connectToAllBackupSupernode(floGlobals.backupNodes[len-1], len).then(result => { connectToAllBackupSupernode(len == 0? offlineNodeID : floGlobals.backupNodes[len-1], len).then(result => {
console.log(result) console.log(result)
//inform the newly connected node to store backups of self //inform the newly connected node to store backups of self
var sendData1 = { var sendData1 = {
@ -6252,6 +6257,26 @@
sendData2.sign = floCrypto.signData(JSON.stringify(sendData2.backupMsg), myPrivKey) sendData2.sign = floCrypto.signData(JSON.stringify(sendData2.backupMsg), myPrivKey)
floGlobals.backupNodes[0].wsConn.send(JSON.stringify(sendData2)) floGlobals.backupNodes[0].wsConn.send(JSON.stringify(sendData2))
} }
}).catch(error => {
console.log(error)
if(index == 0){
//start serving the dead node
if(floGlobals.backupNodes.length === 0)
reactor.dispatchEvent("start_backup_serve", offlineNodeID)
//inform the immediate next node of the dead to start serving it
else{
var sendData = {
from: myFloID,
backupMsg: {
type: "startBackupServe",
snfloID: offlineNodeID,
time: Date.now()
}
}
sendData.sign = floCrypto.signData(JSON.stringify(sendData.backupMsg), myPrivKey)
floGlobals.backupNodes[0].wsConn.send(JSON.stringify(sendData))
}
}
}) })
}) })