tera/Source/core/block-exchange.js

1579 lines
54 KiB
JavaScript
Raw Normal View History

2019-02-10 19:53:54 +00:00
/*
* @project: TERA
* @version: Development (beta)
* @license: MIT (not for evil)
2019-03-16 16:08:05 +00:00
* @copyright: Yuriy Ivanov (Vtools) 2017-2019 [progr76@gmail.com]
2019-02-10 19:53:54 +00:00
* Web: https://terafoundation.org
* Twitter: https://twitter.com/terafoundation
* Telegram: https://web.telegram.org/#/im?p=@terafoundation
*/
"use strict";
require('./library');
require('./crypto-library');
const TX_PROCESS_TIME = 100;
const TX_DELTA_PROCESS_TIME = 300;
global.CAN_START = false;
global.StrWarn = "";
global.SUM_LIST_LENGTH = 2 * BLOCK_PROCESSING_LENGTH;
global.CONSENSUS_TIK_TIME = CONSENSUS_PERIOD_TIME / 10;
global.CONSENSUS_CHECK_TIME = CONSENSUS_PERIOD_TIME / 20;
const PERIOD_FOR_NEXT_SEND = CONSENSUS_TIK_TIME * 3;
global.BLOCK_DELTA_ACTIVATE = 0;
global.TIME_END_EXCHANGE = - 3;
global.TIME_START_POW = - 4;
global.TIME_START_SAVE = - 4;
global.TIME_START_LOAD = global.TIME_START_SAVE - 4;
var FORMAT_DATA_TRANSFER = "{\
Version:uint16,\
BlockNum:uint,\
Reserv1:uint32,\
MaxPOW:[{BlockNum:uint,AddrHash:hash,SeqHash:hash}],\
Reserv2:uint32,\
BaseBlockNum:uint,\
MaxSumID:[{BlockNum:uint,SumHash:hash,SumListID:[uint16]}],\
BlockList:[{ID:uint16, AddrHash:hash,SeqHash:hash}],\
TicketArray:[{HashTicket:arr10}],\
TxArray:[{body:tr}],\
NoSendTx:uint,\
}";
const WorkStructSend = {};
module.exports = class CConsensus extends require("./block-loader")
{
constructor(SetKeyPair, RunIP, RunPort, UseRNDHeader, bVirtual)
{
super(SetKeyPair, RunIP, RunPort, UseRNDHeader, bVirtual)
this.CurrentBlockNum = 0
this.SendBlockID = 0
this.RelayMode = false
this.TreeSendPacket = new RBTree(CompareItemHash)
if(!global.ADDRLIST_MODE && !this.VirtualMode)
{
this.idBlockChainTimer = setInterval(this.StartBlockChain.bind(this), CONSENSUS_PERIOD_TIME - 5)
setInterval(this.DoTransfer.bind(this), CONSENSUS_CHECK_TIME)
}
}
StartBlockChain()
{
this.OnStartSecond()
var CurTimeNum = GetCurrentTime() - CONSENSUS_PERIOD_TIME / 2;
var StartTimeNum = Math.floor((CurTimeNum + CONSENSUS_PERIOD_TIME) / CONSENSUS_PERIOD_TIME) * CONSENSUS_PERIOD_TIME;
var DeltaForStart = StartTimeNum - CurTimeNum;
if(DeltaForStart < (CONSENSUS_PERIOD_TIME - 5))
{
var self = this;
if(self.idBlockChainTimer)
clearInterval(self.idBlockChainTimer)
self.idBlockChainTimer = 0
setTimeout(function ()
{
self.idBlockChainTimer = setInterval(self.StartBlockChain.bind(self), CONSENSUS_PERIOD_TIME)
self.OnStartSecond()
}, DeltaForStart)
}
}
OnStartSecond()
{
PrepareStatEverySecond()
this.AddStatOnTimer()
this.DoBlockChain()
}
CreateBlockContext()
{
var Context = {};
Context.AddInfo = AddInfoBlock.bind(Context)
Context.Active = false
Context.TransferFromAddr = {}
Context.LevelsTransfer = []
Context.ErrRun = ""
Context.PowTxTree = new RBTree(CompareItemTimePow)
Context.PowTicketTree = new RBTree(CompareItemTimePow)
Context.bSave = false
Context.PrevHash = undefined
Context.TreeHash = undefined
Context.MaxPOW = {}
Context.MaxSum = {}
Context.SumPow = 0
Context.Power = 0
Context.TrCount = 0
Context.TrDataPos = 0
Context.TrDataLen = 0
Context.Info = "Create at:" + GetStrOnlyTimeUTC()
var Transfer;
var TransferM2;
var LocalLevel = 0;
var Levels = this.LevelNodes;
for(let L = 0; L < Levels.length; L++)
{
var arr = Levels[L];
if(arr && arr.length > 0)
{
Transfer = {LocalLevel:LocalLevel, TreeLevel:L, SendCount:0, GetCount:0, TransferNodes:{}, WasGet:false, WasSend:false, MustDeltaTime:CONSENSUS_TIK_TIME * (2 + MAX_LEVEL_SPECIALIZATION - L),
}
LocalLevel++
Context.LevelsTransfer.push(Transfer)
Context.StartLevel = Context.LevelsTransfer.length - 1
for(let j = 0; j < arr.length; j++)
{
var Node = arr[j];
var Addr = Node.addrStr;
if(!Transfer.TransferNodes[Addr])
{
let Item = {Node:Node, SendCount:0, GetCount:0, addrStr:Addr, TreeLevel:L, GetTiming:3 * CONSENSUS_PERIOD_TIME, };
Transfer.TransferNodes[Addr] = Item
}
Context.TransferFromAddr[Addr] = Transfer
}
}
}
Context.MLevelSend = Context.StartLevel
return Context;
}
StartConsensus()
{
if(!CAN_START)
return ;
var StartBlockNum = GetCurrentBlockNumByTime();
if(StartBlockNum < BLOCK_PROCESSING_LENGTH2)
return ;
this.CurrentBlockNum = StartBlockNum
var Block0 = this.GetBlockContext(StartBlockNum - BLOCK_DELTA_ACTIVATE);
if(!Block0.Active)
{
AddInfoBlock(Block0, "Activate")
this.StartBlock(Block0)
}
else
{
AddInfoBlock(Block0, "Was Active")
}
}
TrToInfo(Block, Array, StrInfo)
{
var Str = "";
for(var i = 0; i < Array.length; i++)
{
var Item = Array[i];
this.CheckCreateTransactionObject(Item)
Str += this.GetStrFromHashShort(shaarr(Item.body)) + "(" + Item.body.length + "),"
}
AddInfoBlock(Block, "" + StrInfo + ": Arr=[" + Str + "]")
}
TRANSFER(Info, CurTime)
{
var startTime = process.hrtime();
var Data = this.DataFromF(Info);
var Node = Info.Node;
Node.TransferBlockNum = Data.BlockNum
Node.CurBlockNum = Data.BaseBlockNum + Data.BlockNum
if(Data.Version !== 5)
return ;
var Block = this.GetBlockContext(Data.BlockNum);
if(!Block || Block.StartLevel === undefined)
{
ADD_TO_STAT("TRANSFER_ERR_STARTLEVEL")
this.AddCheckErrCount(Node, 1, "Err GetBlockContext")
return ;
}
if(!Block.Active)
this.StartBlock(Block)
var Key = Node.addrStr;
var Transfer = Block.TransferFromAddr[Key];
if(!Transfer)
{
ADD_TO_STAT("NO_TRANSFER")
this.AddCheckErrCount(Node, 1, "Err Transfer")
return ;
}
Transfer.WasGet = true
if(global.DoTxLog && Data.TicketArray.length)
ToLog("TRANSFER BlockNum:" + Block.BlockNum + " TicketArray=" + Data.TicketArray.length + " from " + NodeName(Node))
if(global.DoTxLog && Data.TxArray.length)
ToLog("TRANSFER BlockNum:" + Block.BlockNum + " TxArray=" + Data.TxArray.length + " from " + NodeName(Node))
this.ToMaxPOWList(Data.MaxPOW)
this.ToMaxSumList(this.GetMaxSumListFromID(Node, Data.MaxSumID, Data.BlockList))
var WasNewAdd = 0;
if(Data.TxArray.length)
{
for(var i = 0; i < Data.TxArray.length; i++)
{
var Tr = Data.TxArray[i];
var Res = this.AddTrToBlockQuote(Block, Tr);
if(Res === 1)
WasNewAdd = 1
if(global.USE_CHECK_SENDING && Res > 0)
{
var Tt = Block.PowTxTree.find(Tr);
if(Tt)
{
if(!Tt.NodesList)
Tt.NodesList = []
Tt.NodesList.push(Node)
Tt.TreeLevel = Transfer.TreeLevel
}
}
}
}
else
{
for(var i = 0; i < Data.TicketArray.length; i++)
{
var Tr = this.AddTicketToBlockQuote(Block, Data.TicketArray[i]);
if(Tr)
{
if(!Tr.NodesList)
Tr.NodesList = []
Tr.NodesList.push(Node)
}
}
}
ADD_TO_STAT_TIME("TRANSFER_MS", startTime)
var Delta = Date.now() - this.StartLoadBlockTime;
if(Delta > 10 * 1000 && Node.TransferCount > 10)
{
Node.BlockProcessCount++
Node.NextHotDelta = 10 * 1000
}
Node.TransferCount++
Node.LastTimeTransfer = GetCurrentTime() - 0
var Item = Transfer.TransferNodes[Key];
Item.GetTiming = GetCurrentTime(Block.DELTA_CURRENT_TIME) - Block.StartTimeNum
if(!Block.TransferNodesCount)
Block.TransferNodesCount = 0
Block.TransferNodesCount++
}
DoTransfer()
{
if(glStopNode)
return ;
if(!CAN_START)
return ;
var MaxPOWList;
var MaxSumList;
var start = this.CurrentBlockNum - BLOCK_PROCESSING_LENGTH;
var finish = this.GetLastCorrectBlockNum();
for(var b = start; b <= finish; b++)
{
var Block = this.GetBlock(b);
if(!Block)
continue;
if(Block.StartLevel === undefined || Block.MLevelSend === undefined)
continue;
if(!Block.Active)
continue;
if(global.USE_TICKET)
this.DoJobListTX(Block)
if(Block.MLevelSend < 0)
{
this.CheckEndExchange(Block)
continue;
}
if(Block.EndExchange)
continue;
var Transfer = Block.LevelsTransfer[Block.MLevelSend];
if(!Transfer.WasSend)
{
if(!MaxPOWList)
{
MaxPOWList = this.GetMaxPOWList()
MaxSumList = this.GetMaxSumList()
}
var ArrT;
if(global.USE_TICKET)
ArrT = this.GetArrayFromTicketTree(Block)
else
ArrT = this.GetArrayFromTxTree(Block)
this.SendDataTransfer(Transfer, ArrT, MaxPOWList, MaxSumList, Block)
}
Transfer.WasSend = true
var bNext = Transfer.WasGet;
if(!bNext)
{
var CurTimeNum = GetCurrentTime(Block.DELTA_CURRENT_TIME) - 0;
var DeltaTime = CurTimeNum - Block.StartTimeNum;
if(DeltaTime > Transfer.MustDeltaTime)
{
bNext = true
Block.ErrRun = "" + Transfer.LocalLevel + " " + Block.ErrRun
for(var Addr in Transfer.TransferNodes)
{
var Item = Transfer.TransferNodes[Addr];
ADD_TO_STAT("TRANSFER_TIME_OUT")
this.AddCheckErrCount(Item.Node, 1, "TRANSFER_TIME_OUT")
}
ADD_TO_STAT("TimeOutLevel")
}
}
if(bNext)
{
if(Block.MLevelSend === 0)
{
Block.EndExchangeTime = Date.now()
if(!global.USE_TICKET)
this.CheckEndExchange(Block)
}
Block.MLevelSend--
}
}
}
CheckEndExchange(Block)
{
if(Block.EndExchange)
return ;
if(!global.USE_TICKET)
{
this.CreateTreeHash(Block)
return ;
}
if(!Block.JobListTX || !Block.EndExchangeTime)
return ;
var CurTime = Date.now();
var Delta = CurTime - Block.EndExchangeTime;
if(Delta >= TX_DELTA_PROCESS_TIME * 2)
{
if(global.DoTxLog)
ToLog("END:" + Block.BlockNum + " -> CreateTreeHash")
this.CreateTreeHash(Block)
}
}
SendDataTransfer(Transfer, ArrT, MaxPOWList, MaxSumList, Block)
{
for(var Addr in Transfer.TransferNodes)
{
var Item = Transfer.TransferNodes[Addr];
Transfer.SendCount++
var arrPow = [];
for(var i = 0; i < MaxPOWList.length; i++)
{
var elem = MaxPOWList[i];
var Str = "POW:" + Item.Node.id + elem.BlockNum + "-" + GetHexFromArr(elem.AddrHash);
var bWasSend = global.TreeBlockBuf.LoadValue(Str, 1);
if(!bWasSend)
{
global.TreeBlockBuf.SaveValue(Str, true)
arrPow.push(elem)
}
}
var arrSum = [];
for(var i = 0; i < MaxSumList.length; i++)
{
var elem = MaxSumList[i];
var Str = "MAX:" + Item.Node.id + elem.BlockNum + "-" + GetHexFromArr(elem.SumHash);
var bWasSend = global.TreeBlockBuf.LoadValue(Str, 1);
if(!bWasSend)
{
global.TreeBlockBuf.SaveValue(Str, true)
arrSum.push(elem)
}
}
var Arr;
if(global.USE_CHECK_SENDING)
Arr = this.FilterArrForSendNode(Block, Item.Node, ArrT, global.USE_TICKET)
else
Arr = ArrT
if(global.USE_LEVEL_WAY)
{
var Arr2 = [];
for(var t = 0; t < Arr.length; t++)
{
var Tr = Arr[t];
if(Tr.TreeLevel !== Transfer.TreeLevel)
Arr2.push(Tr)
}
Arr = Arr2
}
if(global.DoTxLog)
ToLog("SEND TRANSFER BlockNum:" + Block.BlockNum + " Arr=" + Arr.length + " to " + NodeName(Item.Node))
var BufData = this.CreateTransferBuffer(Arr, arrPow, arrSum, Block, Item.Node);
this.Send(Item.Node, {"Method":"TRANSFER", "Context":{}, "Data":BufData}, 1)
if(!Block.JobListTX)
Block.JobListTX = []
Block.JobListTX.push({Node:Item.Node, TreeLevel:Item.TreeLevel, Time:Date.now()})
}
}
TRANSFERTX(Info, CurTime)
{
var Data = this.DataFromF(Info);
var Node = Info.Node;
var Block = this.GetBlockContext(Data.BlockNum);
if(!Block)
{
return ;
}
if(global.DoTxLog)
ToLog("TRANSFERTX BlockNum:" + Block.BlockNum + " Array=" + Data.Array.length + " from " + NodeName(Node))
for(var i = 0; i < Data.Array.length; i++)
{
this.AddTrToBlockQuote(Block, Data.Array[i], 1)
}
}
static
TRANSFERTX_F()
{
return "{BlockNum:uint, Array:[{body:tr}]}";
}
static
GETTRANSFERTX_F()
{
return "{BlockNum:uint, TicketArray:[{HashTicket:arr10}]}";
}
GETTRANSFERTX(Info, CurTime)
{
return ;
var Data = this.DataFromF(Info);
var Node = Info.Node;
var Block = this.GetBlockContext(Data.BlockNum);
if(!Block)
{
return ;
}
this.SendTrByTickets(Info, Node, Block, Data.TicketArray, 10)
}
CanSendTest()
{
return 1;
}
SendTrByTickets(Info, Node, Block, ArrTT, CountTrySend)
{
if(!Block.PowTxTree)
return ;
var Arr = [];
var bFindTT = 0;
var BufLength = 0;
for(var i = 0; i < ArrTT.length; i++)
{
var Tr = ArrTT[i];
this.CheckCreateTicketObject(Tr, Block.BlockNum)
var Tr0 = Block.PowTxTree.find(Tr);
if(Tr0)
{
if(Tr0.IsTx)
{
if(this.CanSendTest())
Arr.push(Tr0)
BufLength += Tr0.body.length
if(BufLength > MAX_BLOCK_SIZE)
break;
}
else
{
bFindTT = 1
}
}
}
if(bFindTT && CountTrySend)
{
let SELF = this;
setTimeout(function ()
{
SELF.SendTrByTickets(Info, Node, Block, ArrTT, CountTrySend - 1)
}, 100)
return ;
}
if(!Arr.length)
return ;
var SendData = {"Method":"RETTRANSFERTX", "Context":Info.Context, "Data":{BlockNum:Block.BlockNum, Array:Arr, }};
this.SendF(Node, SendData, global.MAX_BLOCK_SIZE + 1000)
}
static
RETTRANSFERTX_F()
{
return "{BlockNum:uint,Array:[{body:tr}]}";
}
RETTRANSFERTX(Info, CurTime)
{
return ;
var Data = this.DataFromF(Info);
var Node = Info.Node;
Node.TransferBlockNum = Data.BlockNum
var Block = this.GetBlockContext(Data.BlockNum);
if(!Block || !Block.PowTxTree)
{
return ;
}
if(global.DoTxLog)
ToLog("RETTRANSFERTX BlockNum:" + Block.BlockNum + " Array=" + Data.Array.length + " from " + NodeName(Node))
for(var i = 0; i < Data.Array.length; i++)
{
var Tr = Data.Array[i];
this.CheckCreateTransactionObject(Tr)
var Tr0 = Block.PowTxTree.find(Tr);
if(Tr0)
{
if(!Tr0.IsTx)
{
Tr0.IsTx = 1
Tr0.body = Tr.body
Tr0.HASH = Tr.HASH
}
}
}
}
DoJobListTX(Block)
{
if(Block.EndExchange || !Block.JobListTX || !Block.PowTicketTree)
return ;
var ArrTx;
var CurTime = Date.now();
for(var i = 0; i < Block.JobListTX.length; i++)
{
var JobItem = Block.JobListTX[i];
var Delta = CurTime - JobItem.Time;
if(!JobItem.WasSend && Delta >= TX_DELTA_PROCESS_TIME)
{
JobItem.WasSend = 1
if(!ArrTx)
ArrTx = this.GetArrayFromTxTree(Block)
var Arr = this.FilterArrForSendNode(Block, JobItem.Node, ArrTx);
if(!Arr.length)
return ;
if(global.DoTxLog)
ToLog("DoJobListTX BlockNum:" + Block.BlockNum + " Arr=" + Arr.length + " to " + NodeName(JobItem.Node))
var SendData = {"Method":"TRANSFERTX", "Context":{}, "Data":{BlockNum:Block.BlockNum, Array:Arr, }};
this.SendF(JobItem.Node, SendData, global.MAX_BLOCK_SIZE + 1000)
}
}
}
FindNodeTicket(Block, Tr, Node, bTt)
{
var Ticket;
if(bTt)
Ticket = Tr
else
Ticket = Block.PowTicketTree.find(Tr)
if(Ticket && Ticket.NodesList)
{
for(var n = 0; n < Ticket.NodesList.length; n++)
{
var NodeItem = Ticket.NodesList[n];
if(NodeItem === Node)
{
return 1;
}
}
}
return 0;
}
FilterArrForSendNode(Block, Node, ArrTx, bTt)
{
var Arr = [];
for(var t = 0; t < ArrTx.length; t++)
{
var Tr = ArrTx[t];
if(this.FindNodeTicket(Block, Tr, Node, bTt))
continue;
Arr.push(Tr)
}
return Arr;
}
CheckEndExchange00(Block)
{
if(Block.EndExchange)
return ;
var CurTime = Date.now();
var CanEnd = 1;
var bSend = 0;
var it = Block.PowTxTree.iterator(), Tr;
while((Tr = it.next()) !== null)
{
if(!Tr.IsTx)
{
if(!Tr.LastProcessTime)
throw "!Tr.LastProcessTime";
var Delta = CurTime - Tr.LastProcessTime;
if(Delta < TX_PROCESS_TIME * 10)
{
bSend = 1
CanEnd = 0
break;
}
else
{
var Stop = 1;
}
}
}
if(CanEnd)
{
if(global.DoTxLog)
ToLog("END:" + Block.BlockNum + " -> CreateTreeHash")
this.CreateTreeHash(Block)
}
else
if(bSend)
{
this.CheckTxExchange(Block, bSend)
}
}
CheckTxExchange(Block)
{
return ;
if(Block.EndExchange)
return ;
if(!Block.PowTxTree)
return ;
var CurTime = Date.now();
var ArrNodesArr = [];
var it = Block.PowTxTree.iterator(), Tr;
while((Tr = it.next()) !== null)
{
if(!Tr.IsTx)
{
if(!Tr.LastProcessTime)
throw "!Tr.LastProcessTime";
var Delta = CurTime - Tr.LastProcessTime;
if(Delta >= TX_PROCESS_TIME)
{
for(var i = 0; i < Tr.Nodes.length; i++)
{
var TrNode = Tr.Nodes[i];
var LocDelta = CurTime - TrNode.Time;
if(!TrNode.WasSend && LocDelta >= TX_PROCESS_TIME)
{
var FindArr = undefined;
for(var n = 0; n < ArrNodesArr.length; n++)
{
var ElArr = ArrNodesArr[n];
if(ElArr.Node === TrNode.Node)
{
FindArr = ElArr
break;
}
}
if(!FindArr)
{
FindArr = {Node:TrNode.Node, Arr:[]}
ArrNodesArr.push(FindArr)
}
Tr.LastProcessTime = CurTime
TrNode.WasSend = 1
FindArr.Arr.push(Tr)
break;
}
}
}
}
}
for(var n = 0; n < ArrNodesArr.length; n++)
{
var ElArr = ArrNodesArr[n];
if(global.DoTxLog)
ToLog("CheckTxExchange BlockNum:" + Block.BlockNum + " Array=" + ElArr.Arr.length + " to " + NodeName(ElArr.Node))
var SendData = {"Method":"GETTRANSFERTX", "Context":{}, "Data":{BlockNum:Block.BlockNum, TicketArray:ElArr.Arr, }};
this.SendF(ElArr.Node, SendData, ElArr.Arr.length * global.TR_TICKET_HASH_LENGTH + 1000)
}
}
GetMaxSumListFromID(Node, MaxSumID, BlockList)
{
var Str0 = "GETBL:" + Node.id;
for(var i = 0; i < BlockList.length; i++)
{
var elemBlockList = BlockList[i];
global.TreeBlockBuf.SaveValue(Str0 + elemBlockList.ID, elemBlockList)
}
var MaxSum = [];
MaxSum:
for(var i = 0; i < MaxSumID.length; i++)
{
var elem = MaxSumID[i];
var Arr = [];
for(var n = 0; n < elem.SumListID.length; n++)
{
var elemBlockList = global.TreeBlockBuf.LoadValue(Str0 + elem.SumListID[n], 1);
if(elemBlockList === undefined)
{
continue MaxSum;
}
Arr.push(elemBlockList)
}
elem.SumList = Arr
MaxSum.push(elem)
}
return MaxSum;
}
CreateTransferBuffer(ArrT, MaxPOWList, MaxSumList, Block, Node)
{
var Data;
var MaxSumID = [];
var BlockList = [];
for(var i = 0; i < MaxSumList.length; i++)
{
var elem0 = MaxSumList[i];
var ArrID = [];
for(var n = 0; n < elem0.SumList.length; n++)
{
var elemBlockList = elem0.SumList[n];
var Str = "BL:" + Node.id + GetHexFromArr(elemBlockList.Hash3);
var ID = global.TreeBlockBuf.LoadValue(Str, 1);
if(ID === undefined)
{
this.SendBlockID++
ID = this.SendBlockID % 65535
global.TreeBlockBuf.SaveValue(Str, ID)
elemBlockList.ID = ID
BlockList.push(elemBlockList)
}
ArrID.push(ID)
}
MaxSumID.push({BlockNum:elem0.BlockNum, SumHash:elem0.SumHash, SumListID:ArrID})
}
var ArrTt, ArrTx;
if(global.USE_TICKET)
{
ArrTt = ArrT
ArrTx = []
}
else
{
ArrTt = []
ArrTx = ArrT
}
Data = {"Version":5, "BlockNum":Block.BlockNum, "Reserv1":0, "MaxPOW":MaxPOWList, "Reserv2":0, "BaseBlockNum":this.CurrentBlockNum - Block.BlockNum,
"MaxSumID":MaxSumID, "BlockList":BlockList, "TicketArray":ArrTt, "TxArray":ArrTx, "NoSendTx":Node.NoSendTx, }
var BufWrite = BufLib.GetBufferFromObject(Data, FORMAT_DATA_TRANSFER, MAX_BLOCK_SIZE + 30000, WorkStructSend);
return BufWrite;
}
static
TRANSFER_F()
{
return FORMAT_DATA_TRANSFER;
}
CheckingMaxPowOther(Block)
{
var POW = Block.MaxPOW;
if(POW && POW.Hash && CompareArr(POW.PowHash, Block.PowHash) < 0)
{
var LoadBlockNum = Block.BlockNum;
var LoadHash = POW.Hash;
var StrKey = this.GetStrFromHashShort(LoadHash);
var StrHashWas = this.GetStrFromHashShort(Block.Hash);
this.StartLoadBlockHeader(LoadHash, LoadBlockNum, "START OTHER:" + StrKey + " WAS:" + StrHashWas, false)
AddInfoBlock(Block, "REQ H: " + StrKey)
}
Block.CheckMaxPow = true
}
AddToMaxPOW(Block, item, Node)
{
if(Block && item)
{
if(!Block.MaxPOW)
Block.MaxPOW = {}
var POW = Block.MaxPOW;
if(!Block.PrevHash)
return ;
item.BlockNum = Block.BlockNum
item.PrevHash = Block.PrevHash
CalcHashBlockFromSeqAddr(item, Block.PrevHash, global.MINING_VERSION_NUM)
if(POW.SeqHash === undefined || CompareArr(item.PowHash, POW.PowHash) < 0)
{
POW.AddrHash = item.AddrHash
POW.Hash = item.Hash
POW.PowHash = item.PowHash
POW.PrevHash = item.PrevHash
POW.TreeHash = item.TreeHash
POW.SeqHash = item.SeqHash
}
if(Block.SeqHash && CompareArr(item.SeqHash, Block.SeqHash) === 0)
{
if(POW.LocalSeqHash === undefined || CompareArr(POW.LocalSeqHash, Block.SeqHash) !== 0 || CompareArr(item.PowHash, POW.PowLocalHash) < 0)
{
POW.LocalAddrHash = item.AddrHash
POW.PowLocalHash = item.PowHash
POW.LocalSeqHash = Block.SeqHash
}
}
var wasLider;
if(POW.MaxTree)
wasLider = POW.MaxTree.min()
this.AddPOWToMaxTree(POW, item)
if(wasLider)
{
var newLider = POW.MaxTree.min();
if(newLider !== wasLider)
{
var Power = GetPowPower(newLider.PowHash);
AddInfoBlock(Block, "MaxPOW: " + Power)
}
}
}
}
AddPOWToMaxTree(POW, item)
{
if(!POW.MaxTree)
{
POW.MaxTree = new RBTree(function (a,b)
{
return CompareArr(a.PowHash, b.PowHash);
})
}
if(!POW.MaxTree.find(item))
{
POW.MaxTree.insert(item)
if(POW.MaxTree.size > 12)
{
var maxitem = POW.MaxTree.max();
POW.MaxTree.remove(maxitem)
}
}
}
GetMaxPOWList()
{
var arr = [];
var start, finish;
start = this.CurrentBlockNum + TIME_START_SAVE - 2
finish = this.CurrentBlockNum
for(var b = start; b < finish; b++)
{
var Block = this.GetBlock(b);
if(Block && Block.Prepared && Block.MaxPOW)
{
if(Block.MaxPOW && Block.MaxPOW.MaxTree)
{
this.RecreateMaxPOW(Block)
var it = Block.MaxPOW.MaxTree.iterator(), Item;
while((Item = it.next()) !== null)
{
arr.push(Item)
}
}
}
}
return arr;
}
ToMaxPOWList(Arr)
{
for(var i = 0; i < Arr.length; i++)
{
var item = Arr[i];
if(item && item.BlockNum >= this.CurrentBlockNum - BLOCK_PROCESSING_LENGTH && item.BlockNum < this.CurrentBlockNum)
{
var Block = this.GetBlock(item.BlockNum);
this.AddToMaxPOW(Block, item)
}
}
}
RecreateMaxPOW(Block)
{
if(Block.MaxPOW && Block.MaxPOW.MaxTree)
{
var Tree = Block.MaxPOW.MaxTree;
var it = Tree.iterator(), Item;
while((Item = it.next()) !== null)
{
if(!Item.PrevHash)
ToLog("NO Item.PrevHash in " + Block.BlockNum)
if(Item.PrevHash && CompareArr(Item.PrevHash, Block.PrevHash) !== 0)
{
Tree.remove(Item)
it = Tree.iterator()
}
}
}
Block.CheckMaxSum = false
}
CheckMaxSum(Block)
{
var POW = Block.MaxSum;
var List = this.GetBlockList(Block.BlockNum);
var SumPow = this.GetSumFromList(List, Block.BlockNum);
if(POW && POW.SumHash && POW.SumPow > SumPow)
{
var LoadBlockNum = Block.BlockNum;
var LoadHash = POW.SumHash;
var StrKey = this.GetStrFromHashShort(LoadHash);
if(this.StartLoadBlockHeader(LoadHash, LoadBlockNum, "START POW:" + POW.SumPow + ">" + SumPow + " SH:" + StrKey, true))
AddInfoBlock(Block, "REQ SH: " + StrKey)
}
Block.CheckMaxSum = true
}
AddToMaxSum(Block, item)
{
if(Block && item)
{
if(!Block.MaxSum)
Block.MaxSum = {}
var POW = Block.MaxSum;
var SumPow = this.GetSumFromList(item.SumList, Block.BlockNum);
if(POW.SumHash === undefined || SumPow > POW.SumPow)
{
POW.SumPow = SumPow
POW.SumHash = item.SumHash
POW.SumList = item.SumList
AddInfoBlock(Block, "SumPow:" + POW.SumPow)
Block.CheckMaxSum = false
}
return SumPow;
}
return 0;
}
GetMaxSumList()
{
var Arr = [];
var start, finish;
start = this.CurrentBlockNum + TIME_START_LOAD - 2
finish = this.CurrentBlockNum
for(var b = start; b <= finish; b++)
{
var Block = this.GetBlock(b);
if(Block && Block.bSave && Block.MaxSum && Block.MaxSum.SumHash)
{
var POW = Block.MaxSum;
var item = {BlockNum:Block.BlockNum, SumHash:POW.SumHash, SumList:POW.SumList, };
Arr.push(item)
}
}
return Arr;
}
ToMaxSumList(Arr)
{
var start, finish;
start = this.CurrentBlockNum + TIME_START_LOAD - 2
finish = this.CurrentBlockNum
for(var i = 0; i < Arr.length; i++)
{
var item = Arr[i];
if(item && item.BlockNum >= start && item.BlockNum <= finish)
{
var Block = this.GetBlock(item.BlockNum);
if(Block)
{
this.AddToMaxSum(Block, item)
this.CheckMaxSum(Block)
}
}
}
}
GetBlockList(CurBlockNum)
{
var arr = [];
for(var b = CurBlockNum - SUM_LIST_LENGTH + 1; b <= CurBlockNum; b++)
{
var Block = this.GetBlock(b);
if(Block && Block.bSave)
{
var item = {AddrHash:Block.AddrHash, SeqHash:Block.SeqHash, };
arr.push(item)
}
else
{
return [];
}
}
return arr;
}
GetSumFromList(arr, CurBlockNum)
{
var SumPow = 0;
if(arr.length !== SUM_LIST_LENGTH)
return SumPow;
var CountLoad = 0;
var BlockNumStart = CurBlockNum - arr.length + 1;
for(var i = 0; i < arr.length; i++)
{
var Item = arr[i];
if(Item)
{
Item.BlockNum = BlockNumStart + i
var Value = GetHashFromSeqAddr(Item.SeqHash, Item.AddrHash, Item.BlockNum, undefined, global.MINING_VERSION_NUM);
SumPow += GetPowPower(Value.PowHash)
Item.Hash3 = Value.Hash
}
else
{
break;
}
}
return SumPow;
}
GetArrayFromTxTree(Block)
{
if(!Block.PowTxTree)
return [];
var BufLength = 0;
var arr = [];
var it = Block.PowTxTree.iterator(), Item;
while((Item = it.next()) !== null)
{
arr.push(Item)
BufLength += Item.body.length
if(BufLength > MAX_BLOCK_SIZE)
break;
}
return arr;
}
GetArrayFromTicketTree(Block)
{
if(!Block.PowTicketTree)
return [];
var arr = [];
var it = Block.PowTicketTree.iterator(), Item;
while((Item = it.next()) !== null)
{
arr.push(Item)
}
return arr;
}
AddToQuote(Tree, Tr)
{
var Tr0 = Tree.find(Tr);
if(Tr0)
{
return 3;
}
else
{
Tree.insert(Tr)
if(Tree.size > MAX_TRANSACTION_LIMIT)
{
var maxitem = Tree.max();
Tree.remove(maxitem)
if(CompareArr(maxitem.HashPow, Tr.HashPow) === 0)
return 0;
}
return 1;
}
}
AddTicketToBlockQuote(Block, Tr)
{
if(Block.PowTicketTree)
{
var Res = this.IsValidTicket(Tr, Block.BlockNum);
if(Res >= 1)
{
Res = this.AddToQuote(Block.PowTicketTree, Tr)
if(Res)
return Block.PowTicketTree.find(Tr);
}
return null;
}
}
AddTrToBlockQuote(Block, Tr, bTTAdd)
{
if(Block.PowTxTree)
{
var Res = this.IsValidTransaction(Tr, Block.BlockNum);
if(Res >= 1)
{
if(bTTAdd)
{
Res = this.AddToQuote(Block.PowTicketTree, Tr)
if(Res <= 0)
return Res;
}
Res = this.AddToQuote(Block.PowTxTree, Tr)
}
return Res;
}
}
GetBlockContext(BlockNum)
{
if(BlockNum === undefined || !this.IsCorrectBlockNum(BlockNum))
return undefined;
var Context = this.GetBlock(BlockNum);
if(!Context || !Context.StartTimeNum)
{
Context = this.CreateBlockContext()
Context.BlockNum = BlockNum
Context.DELTA_CURRENT_TIME = GetDeltaCurrentTime()
Context.StartTimeNum = (BlockNum - 1 + BLOCK_DELTA_ACTIVATE) * CONSENSUS_PERIOD_TIME + START_NETWORK_DATE
this.BlockChain[BlockNum] = Context
}
if(!Context.TransferFromAddr)
{
Context.TransferFromAddr = {}
Context.LevelsTransfer = []
}
return Context;
}
StartBlock(Block)
{
Block.Active = true
}
IsCorrectBlockNum(BlockNum)
{
var start = this.CurrentBlockNum - BLOCK_PROCESSING_LENGTH;
var finish = this.GetLastCorrectBlockNum();
if(BlockNum < start || BlockNum > finish)
{
return false;
}
return true;
}
GetLastCorrectBlockNum()
{
return this.CurrentBlockNum + 4;
}
GetStrSendCount(Block)
{
if(!Block)
return "";
var Str = "";
var Count = 0;
for(var L = 0; L < Block.LevelsTransfer.length; L++)
{
var Transfer = Block.LevelsTransfer[L];
Str = Str + "," + Transfer.SendCount
if(typeof Transfer.SendCount === "number")
Count = Count + Transfer.SendCount
}
return "" + Count + ":[" + Str.substr(1) + "]";
}
GetStrGetCount(Block)
{
if(!Block)
return "";
var Str = "";
var Count = 0;
for(var L = 0; L < Block.LevelsTransfer.length; L++)
{
var Transfer = Block.LevelsTransfer[L];
Str = Str + "," + Transfer.GetCount
Count = Count + Transfer.GetCount
}
return "" + Count + ":[" + Str.substr(1) + "]";
}
ToStrBlocks(DopStr)
{
var num = Math.floor(this.CurrentBlockNum / 3) * 3;
var start = num - BLOCK_PROCESSING_LENGTH2 + 2;
var finish = this.CurrentBlockNum;
if(!DopStr)
DopStr = ""
var Str = "";
for(var b = start; b <= finish; b++)
{
var hashStr = "";
var Block = this.GetBlock(b);
if(Block && Block.ErrRun)
{
if(Block.ErrRun)
hashStr = Block.ErrRun.substr(0, 5)
else
if(Block && Block.TreeHash)
hashStr = "-" + GetHexFromAddres(Block.TreeHash).substr(0, 3) + "-"
}
else
if(Block && Block.TreeHash)
{
hashStr = GetHexFromAddres(Block.TreeHash).substr(0, 5)
}
Str = Str + "|" + (hashStr + " ").substr(0, 5)
}
Str = Str.substr(1)
ToInfo("" + finish + " -> " + Str + " " + DopStr)
}
PreparePOWHash(Block)
{
if(!Block.TreeHash)
Block.TreeHash = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
var PrevHash = this.GetPrevHash(Block);
if(!PrevHash)
{
AddInfoBlock(Block, "-err prev hash-")
return false;
}
Block.PrevHash = PrevHash
Block.SeqHash = this.GetSeqHash(Block.BlockNum, Block.PrevHash, Block.TreeHash)
this.CreatePOWNew(Block)
Block.Prepared = true
if(global.USE_MINING && !Block.StartMining)
{
Block.StartMining = true
AddInfoBlock(Block, "-send mining-")
global.SetCalcPOW(Block, "FastCalcBlock")
}
return true;
}
CalcTreeHashFromArrTr(BlockNum, arrTr)
{
var arrHASH = [];
for(var i = 0; i < arrTr.length; i++)
{
var Tr = arrTr[i];
arrHASH.push(Tr.HASH)
}
var Tree = CalcMerklFromArray(BlockNum, arrHASH);
return Tree.Root;
}
CreateTreeHash(Block)
{
if(Block.EndExchange)
return ;
Block.EndExchange = true
if(Block.bSave)
return ;
var PrevBlock = this.GetBlock(Block.BlockNum - 1);
if(PrevBlock && !PrevBlock.EndExchange && !PrevBlock.bSave)
{
AddInfoBlock(Block, "Prev Not End Exchange")
return ;
}
AddInfoBlock(Block, "End Exchange,N=" + Block.TransferNodesCount)
var arrContent = [];
var arrHASH = [];
var arrTr = this.GetArrayFromTxTree(Block);
this.AddDAppTransactions(Block.BlockNum, arrTr)
for(var i = 0; i < arrTr.length; i++)
{
var Tr = arrTr[i];
arrContent.push(Tr.body)
arrHASH.push(Tr.HASH)
}
var Tree = CalcMerklFromArray(Block.BlockNum, arrHASH);
Block.TreeHash = Tree.Root
Block.arrContent = arrContent
Block.TrCount = Block.arrContent.length
}
WatchdogSaved(BlockNum)
{
var Block = this.GetBlock(BlockNum);
if(!Block)
{
ToLog("#1 WatchdogSaved: no BlockNum=" + BlockNum)
return ;
}
if(Block.bSave)
{
var BlockDB = this.ReadBlockDB(BlockNum);
if(!BlockDB)
{
Block.bSave = false
return ;
}
if(CompareArr(BlockDB.Hash, Block.Hash) !== 0)
{
AddInfoBlock(Block, "=ERR:WATCHDOG=")
ToLog("#3 WatchdogSaved: Error Hash on Num=" + BlockNum)
return ;
}
if(CompareArr(BlockDB.SumHash, Block.SumHash) !== 0)
{
AddInfoBlock(Block, "=ERR:WATCHDOG=")
ToLog("#4 WatchdogSaved: Error SumHash on Num=" + BlockNum)
return ;
}
if(CompareArr(BlockDB.SeqHash, Block.SeqHash) !== 0)
{
AddInfoBlock(Block, "=ERR:WATCHDOG=")
ToLog("#5 WatchdogSaved: Error SeqHash on Num=" + BlockNum)
return ;
}
var PrevHash = this.GetPrevHash(Block);
if(!PrevHash)
{
AddInfoBlock(Block, "=ERR:WATCHDOG=")
ToLog("#6 WatchdogSaved: Error PrevHash on Num=" + BlockNum)
return ;
}
var SeqHash = this.GetSeqHash(Block.BlockNum, PrevHash, Block.TreeHash);
if(CompareArr(SeqHash, Block.SeqHash) !== 0)
{
AddInfoBlock(Block, "=ERR:WATCHDOG=")
ToLog("#7 WatchdogSaved: Error SeqHash on Num=" + BlockNum)
return ;
}
PrevHash = this.GetPrevHashDB(BlockDB)
SeqHash = this.GetSeqHash(BlockDB.BlockNum, PrevHash, BlockDB.TreeHash)
if(CompareArr(SeqHash, BlockDB.SeqHash) !== 0)
{
AddInfoBlock(Block, "=ERR:WATCHDOG=")
ToLog("#8 WatchdogSaved: Error SeqHash on Num=" + BlockNum)
return ;
}
}
}
DoBlockChain()
{
if(glStopNode)
return ;
if(!CAN_START)
return ;
this.StartConsensus()
var CURRENTBLOCKNUM = this.CurrentBlockNum;
if(GrayConnect())
{
if(!this.LoadHistoryMode)
this.StartLoadHistory(undefined, 1)
return ;
}
if(this.LoadHistoryMode)
return ;
var bWasSave = false;
var LoadBlockNum;
var LoadHash;
var start_save = CURRENTBLOCKNUM + TIME_START_SAVE;
for(var BlockNum = CURRENTBLOCKNUM - BLOCK_PROCESSING_LENGTH2; BlockNum > BLOCK_PROCESSING_LENGTH2 && BlockNum < CURRENTBLOCKNUM; BlockNum++)
{
var Block = this.GetBlock(BlockNum);
if(!Block)
{
Block = this.GetBlockContext(BlockNum)
if(!Block)
{
continue;
}
}
if(Block.bSave)
{
var BlockDB = this.ReadBlockDB(BlockNum);
if(!BlockDB)
{
Block.bSave = false
}
}
if(global.WATCHDOG_DEV)
this.WatchdogSaved(Block.BlockNum)
if(Block.bSave)
{
bWasSave = true
if(Block.MaxSum && !Block.CheckMaxSum)
{
AddInfoBlock(Block, "CheckMaxSum")
this.CheckMaxSum(Block)
}
if(BlockNum <= CURRENTBLOCKNUM - BLOCK_PROCESSING_LENGTH * 4)
{
Block.TransferFromAddr = undefined
Block.LevelsTransfer = undefined
Block.mapData = undefined
Block.MaxPOW = undefined
Block.MaxSum = undefined
Block.arrContent = undefined
if(Block.PowTxTree)
{
Block.PowTxTree.clear()
Block.PowTxTree = undefined
}
}
continue;
}
var PrevBlock = this.GetBlock(BlockNum - 1);
if(!PrevBlock)
{
Block.HasErr = 1
AddInfoBlock(Block, "!PrevBlock")
continue;
}
if(BlockNum >= CURRENTBLOCKNUM + TIME_END_EXCHANGE)
{
if(!Block.Active)
{
AddInfoBlock(Block, "WAIT ACTIVATE")
continue;
}
else
if(!Block.EndExchange)
{
AddInfoBlock(Block, "WAIT EXCHANGE")
continue;
}
}
if(BlockNum === CURRENTBLOCKNUM + TIME_START_POW || Block.EndExchange)
if(!Block.Prepared)
{
if(!Block.EndExchange)
this.CreateTreeHash(Block)
AddInfoBlock(Block, "Start POW")
this.PreparePOWHash(Block)
if(!Block.Prepared)
AddInfoBlock(Block, "!!Prepared")
continue;
}
if(!Block.EndExchange)
{
AddInfoBlock(Block, "Not EndExchange")
Block.HasErr = 1
Block.Prepared = 0
this.CreateTreeHash(Block)
}
if(!Block.Prepared)
{
Block.HasErr = 1
AddInfoBlock(Block, "Not was Prepared")
this.PreparePOWHash(Block)
if(!Block.Prepared)
continue;
}
{
var PrevHash = this.GetPrevHash(Block);
if(!PrevHash)
{
Block.HasErr = 1
continue;
}
var SeqHash = this.GetSeqHash(Block.BlockNum, PrevHash, Block.TreeHash);
if(CompareArr(SeqHash, Block.SeqHash) !== 0)
{
Block.HasErr = 1
AddInfoBlock(Block, "New fast pow")
this.PreparePOWHash(Block)
}
if(Block.MaxPOW && Block.MaxPOW.SeqHash && Block.MaxPOW.AddrHash && Block.MaxPOW.LocalSeqHash && CompareArr(Block.SeqHash,
Block.MaxPOW.LocalSeqHash) === 0)
{
if(CompareArr(Block.SeqHash, Block.MaxPOW.LocalSeqHash) === 0 && CompareArr(Block.MaxPOW.PowLocalHash, Block.PowHash) < 0)
{
Block.AddrHash = Block.MaxPOW.LocalAddrHash
CalcHashBlockFromSeqAddr(Block, Block.PrevHash, global.MINING_VERSION_NUM)
AddInfoBlock(Block, "->Local lider:" + GetPowPower(Block.PowHash))
}
if(CompareArr(Block.SeqHash, Block.MaxPOW.SeqHash) === 0 && CompareArr(Block.MaxPOW.AddrHash, Block.AddrHash) !== 0 && CompareArr(Block.MaxPOW.PowHash,
Block.PowHash) < 0)
{
Block.AddrHash = Block.MaxPOW.AddrHash
CalcHashBlockFromSeqAddr(Block, Block.PrevHash, global.MINING_VERSION_NUM)
AddInfoBlock(Block, "->Max lider")
}
}
else
{
Block.HasErr = 1
AddInfoBlock(Block, "ERROR MaxPOW")
}
if(Block.MaxPOW && Block.MaxPOW.SeqHash && !Block.CheckMaxPow && !Block.CheckMaxSum && CompareArr(Block.SeqHash, Block.MaxPOW.SeqHash) !== 0)
{
AddInfoBlock(Block, "CheckMaxPow")
this.CheckingMaxPowOther(Block)
}
if(BlockNum > start_save)
continue;
if(PrevBlock.bSave && this.BlockNumDB + 1 >= Block.BlockNum)
{
this.AddToStatBlockConfirmation(Block)
if(this.WriteBlockDB(Block))
{
if(Block.arrContent && Block.arrContent.length)
ADD_TO_STAT("MAX:TRANSACTION_COUNT", Block.arrContent.length)
AddInfoBlock(Block, "SAVE TO DB: " + GetPowPower(Block.PowHash))
}
else
{
Block.HasErr = 1
AddInfoBlock(Block, "ERROR WRITE DB")
}
this.AddToMaxSum(Block, {SumHash:Block.SumHash, SumList:this.GetBlockList(Block.BlockNum), })
}
else
{
Block.HasErr = 1
if(!PrevBlock.bSave)
AddInfoBlock(Block, "Prev block not saved")
else
AddInfoBlock(Block, "Low BlockNumDB")
}
}
}
for(var BlockNum = CURRENTBLOCKNUM - BLOCK_PROCESSING_LENGTH2; BlockNum > BLOCK_PROCESSING_LENGTH2 && BlockNum < start_save; BlockNum++)
{
var Block = this.GetBlock(BlockNum);
if(Block && !Block.bSave && Block.TrCount && Block.TreeHash && !IsZeroArr(Block.TreeHash) && !Block.WasSaveDataTree)
{
this.SaveDataTreeToDB(Block)
Block.WasSaveDataTree = 1
AddInfoBlock(Block, "*SAVE DATA TREE*")
}
}
this.RelayMode = !bWasSave
this.FREE_MEM_BLOCKS(CURRENTBLOCKNUM - BLOCK_COUNT_IN_MEMORY)
}
CreatePOWNew(Block)
{
CreateHashMinimal(Block, GENERATE_BLOCK_ACCOUNT)
this.AddToMaxPOW(Block, {SeqHash:Block.SeqHash, AddrHash:Block.AddrHash, PrevHash:Block.PrevHash, TreeHash:Block.TreeHash,
})
}
SetNoPOW(BlockNumFrom, bReload, RefBlockNum)
{
var CurNum = BlockNumFrom;
var finish = this.GetLastCorrectBlockNum();
while(true)
{
var BlockMem = this.BlockChain[CurNum];
if(BlockMem)
{
if(BlockMem.Prepared)
{
AddInfoBlock(BlockMem, "-reset POW:" + RefBlockNum + "/" + bReload)
BlockMem.bSave = false
BlockMem.Prepared = false
BlockMem.StartMining = false
this.PreparePOWHash(BlockMem)
}
this.RecreateMaxPOW(BlockMem)
}
if(!BlockMem && CurNum > finish)
break;
CurNum++
}
}
MiningProcess(msg)
{
var BlockMining = this.GetBlock(msg.BlockNum);
if(!BlockMining)
{
return ;
}
if(!BlockMining.StartMining || BlockMining.bSave)
return ;
if(BlockMining && BlockMining.Hash && BlockMining.SeqHash && CompareArr(BlockMining.SeqHash, msg.SeqHash) === 0)
{
var ValueOld = GetHashFromSeqAddr(BlockMining.SeqHash, BlockMining.AddrHash, BlockMining.BlockNum);
var ValueMsg = GetHashFromSeqAddr(msg.SeqHash, msg.AddrHash, BlockMining.BlockNum);
var bWas = 0;
if(CompareArr(ValueOld.Hash1, ValueMsg.Hash1) > 0)
{
var Nonce1 = ReadUintFromArr(msg.AddrHash, 12);
var DeltaNum1 = ReadUint16FromArr(msg.AddrHash, 24);
WriteUintToArrOnPos(BlockMining.AddrHash, Nonce1, 12)
WriteUint16ToArrOnPos(BlockMining.AddrHash, DeltaNum1, 24)
bWas += 1
}
if(CompareArr(ValueOld.Hash2, ValueMsg.Hash2) > 0)
{
var Nonce0 = ReadUintFromArr(msg.AddrHash, 6);
var Nonce2 = ReadUintFromArr(msg.AddrHash, 18);
var DeltaNum2 = ReadUint16FromArr(msg.AddrHash, 26);
WriteUintToArrOnPos(BlockMining.AddrHash, Nonce0, 6)
WriteUintToArrOnPos(BlockMining.AddrHash, Nonce2, 18)
WriteUint16ToArrOnPos(BlockMining.AddrHash, DeltaNum2, 26)
bWas += 2
}
if(!bWas)
return ;
var ValueNew = GetHashFromSeqAddr(BlockMining.SeqHash, BlockMining.AddrHash, BlockMining.BlockNum);
BlockMining.Hash = ValueNew.Hash
BlockMining.PowHash = ValueNew.PowHash
BlockMining.Power = GetPowPower(BlockMining.PowHash)
ADD_TO_STAT("MAX:POWER", BlockMining.Power)
var Power = GetPowPower(BlockMining.PowHash);
2019-02-15 15:56:11 +00:00
var HashCount = Math.pow(2, Power);
2019-02-10 19:53:54 +00:00
ADD_HASH_RATE(HashCount)
AddInfoBlock(BlockMining, "Set POW: " + Power)
this.SetNoPOW(BlockMining.BlockNum + 8, 0, BlockMining.BlockNum)
this.AddToMaxPOW(BlockMining, {SeqHash:BlockMining.SeqHash, AddrHash:BlockMining.AddrHash, PrevHash:BlockMining.PrevHash, TreeHash:BlockMining.TreeHash,
})
}
}
};
global.TreeBlockBuf = new STreeBuffer(50 * 1000, CompareItemHashSimple, "string");
global.GetCurrentBlockNumByTime = function GetCurrentBlockNumByTime()
{
var CurTimeNum = GetCurrentTime() - FIRST_TIME_BLOCK;
var StartBlockNum = Math.trunc((CurTimeNum + CONSENSUS_PERIOD_TIME) / CONSENSUS_PERIOD_TIME);
return StartBlockNum;
};
var PrevTimeIdle = 0;
OnTimeIdle();
function OnTimeIdle()
{
var CurTime = Date.now();
var Delta = CurTime - PrevTimeIdle;
if(Delta <= 51)
{
ADD_TO_STAT("TIME_IDLE", 5);
}
setTimeout(OnTimeIdle, 49);
PrevTimeIdle = CurTime;
};