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

bug fix : start serve and store backup process only when its not

Browse Source
This commit is contained in:
sairajzero 2019-11-15 17:56:04 +05:30
parent f123cf611d
commit 466d0d621b
1 changed files with 28 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
index.html
View File

@ -6414,13 +6414,19 @@
reactor.addEventListener("indicate_supernode_up", function (snfloID) { reactor.addEventListener("indicate_supernode_up", function (snfloID) {
console.log("indicate_supernode_up"); console.log("indicate_supernode_up");
//send message to backup's backup to server for backup node //send message to backup's backup to server for backup node
var backupMsg = { var backupMsg1 = {
type: "supernodeUp", type: "supernodeUp",
snfloID: snfloID, snfloID: snfloID,
time: Date.now() time: Date.now()
} }
reactor.dispatchEvent("send_message_to_backup_nodes", backupMsg) reactor.dispatchEvent("send_message_to_backup_nodes", backupMsg1)
reactor.dispatchEvent("request_data", {holder:floGlobals.backupNodes[0].floID, snfloID:myFloID}) var backupMsg2 = {
type: "startBackupStore",
snfloID: snfloID,
time: Date.now()
}
reactor.dispatchEvent("send_message_to_backup_nodes", backupMsg2)
reactor.dispatchEvent("request_data", {holder:floGlobals.backupNodes[0].floID, snfloID:snfloID})
}) })
reactor.registerEvent("supernode_back_online"); reactor.registerEvent("supernode_back_online");
@ -6471,7 +6477,7 @@
} }
if(index){ if(index){
initateBackupWebsocket(snfloID).then(result => { initateBackupWebsocket(snfloID).then(result => {
floGlobals.backupNodes.splice(index,0,result) // add revived node as backup node floGlobals.backupNodes.splice(index, 0, result) // add revived node as backup node
floGlobals.backupNodes.pop() // remove the last extra backup node floGlobals.backupNodes.pop() // remove the last extra backup node
}).catch(error => console.log(error)) }).catch(error => console.log(error))
} }
@ -6482,20 +6488,21 @@
reactor.addEventListener("start_backup_serve", function (snfloID) { reactor.addEventListener("start_backup_serve", function (snfloID) {
console.log("start_backup_serve :"+snfloID); console.log("start_backup_serve :"+snfloID);
//start serving the dead node //start serving the dead node
if(!floGlobals.serveList.includes(snfloID)) if(!floGlobals.serveList.includes(snfloID)){
floGlobals.serveList.push(snfloID) floGlobals.serveList.push(snfloID)
//indicate the last backup node to store the dead's backup too //indicate the last backup node to store the dead's backup too
var sendData = { var sendData = {
from: myFloID, from: myFloID,
backupMsg: { backupMsg: {
type: "startBackupStore", type: "startBackupStore",
snfloID: snfloID, snfloID: snfloID,
time: Date.now() time: Date.now()
}, },
sign: floCrypto.signData(JSON.stringify(this.backupMsg), myPrivKey) sign: floCrypto.signData(JSON.stringify(this.backupMsg), myPrivKey)
}
var lastIndex = floGlobals.backupNodes.length - 1
floGlobals.backupNodes[lastIndex].wsConn.send(JSON.stringify(sendData))
} }
var lastIndex = floGlobals.backupNodes.length - 1
floGlobals.backupNodes[lastIndex].wsConn.send(JSON.stringify(sendData))
}) })
reactor.registerEvent("stop_backup_serve"); reactor.registerEvent("stop_backup_serve");
@ -6521,11 +6528,12 @@
reactor.registerEvent("start_backup_store"); reactor.registerEvent("start_backup_store");
reactor.addEventListener("start_backup_store", function (event) { reactor.addEventListener("start_backup_store", function (event) {
console.log("start_backup_store :"+event.snfloID); console.log("start_backup_store :"+event.snfloID);
if(!floGlobals.backupStoredList.includes(event.snfloID)) if(!floGlobals.backupStoredList.includes(event.snfloID)){
floGlobals.backupStoredList.push(event.snfloID) floGlobals.backupStoredList.push(event.snfloID)
initIndexedDBforSupernodeDataStorage(event.snfloID).then(result => { initIndexedDBforSupernodeDataStorage(event.snfloID).then(result => {
reactor.dispatchEvent("request_data",{holder:event.from, snfloID:event.snfloID}) reactor.dispatchEvent("request_data",{holder:event.from, snfloID:event.snfloID})
}).catch(error => console.log(error)) }).catch(error => console.log(error))
}
}) })
reactor.registerEvent("stop_backup_store"); reactor.registerEvent("stop_backup_store");