filtering MNs

lastrelease.txt

@@ -1 +1 @@
-0.4.2Da2 0.4.2Da2 x {LastOfficial} {LastBeta} {TestNet}
+0.4.3Aa1 0.4.2Da2 x {LastOfficial} {LastBeta} {TestNet}

mpblock.pas

@@ -308,6 +308,7 @@ implementation
    FillNodeList;
    ClearMNsChecks();
    ClearMNsList();
+   ClearReceivedMNs();
    if numero >= MNBlockStart then
       begin
       SetLength(MNsAddressess,0);

mpred.pas

@@ -731,7 +731,7 @@ function CerrarClientes(ServerToo:Boolean=True):string;
    end;
 
 // *** Request reported MNs
-if ( (StrToIntDef(GetConsensus(9),0)>GetMNsListLength) and (LastTimeMNsRequested+5<UTCTime)
+if ( (StrToIntDef(GetConsensus(9),0)>GetMNsListLength) and (LastTimeMNsRequested+15<UTCTime)
            and (LengthWaitingMNs = 0) and (BlockAge>30) and (IsAllSynced=0) ) then
    begin
    if GetValidSlotForSeed(ValidSlot) then

nosomasternodes.pas

@@ -79,6 +79,10 @@   TThreadMNVerificator = class(TThread)
   Procedure SetMNsHash();
   Function GetMNsHash():String;
 
+  Function LengthReceivedMNs():Integer;
+  Procedure ClearReceivedMNs();
+  Function IsMNIPReceived(DataSource:String):boolean;
+
   Function LengthWaitingMNs():Integer;
   Procedure AddWaitingMNs(Linea:String);
   Function GetWaitingMNs():String;
@@ -132,6 +136,9 @@   TThreadMNVerificator = class(TThread)
   ArrWaitMNs          : array of String;
   CSWaitingMNs        : TRTLCriticalSection;
 
+  ArrReceivedMNs      : array of String;
+  CSReceivedMNs       : TRTLCriticalSection;
+
 IMPLEMENTATION
 
 Procedure SetMasternodesFilename(LText:String);
@@ -711,6 +718,46 @@ function IsMyMNListed(LocalIP:String):boolean;
 
 {$ENDREGION MNs hash}
 
+{$REGION Received Masternodes}
+
+Function LengthReceivedMNs():Integer;
+Begin
+  EnterCriticalSection(CSReceivedMNs);
+  result := Length(ArrReceivedMNs);
+  LeaveCriticalSection(CSReceivedMNs);
+End;
+
+Procedure ClearReceivedMNs();
+Begin
+  EnterCriticalSection(CSReceivedMNs);
+  setlength(ArrReceivedMNs,0);
+  LeaveCriticalSection(CSReceivedMNs);
+End;
+
+Function IsMNIPReceived(DataSource:String):boolean;
+var
+  counter : integer;
+Begin
+  Result := false;
+  DataSource := Parameter(DataSource,5);
+  EnterCriticalSection(CSReceivedMNs);
+  for counter := 0 to length(ArrReceivedMNs)-1 do
+    begin
+    if ArrReceivedMNs[counter] = DataSource then
+      begin
+      Result := true;
+      Break
+      end;
+    end;
+  if not result then
+    begin
+    Insert(DataSource,ArrReceivedMNs,LEngth(ArrReceivedMNs))
+    end;
+  LeaveCriticalSection(CSReceivedMNs);
+End;
+
+{$ENDREGION Received Masternodes}
+
 {$REGION Waiting Masternodes}
 
 Function LengthWaitingMNs():Integer;
@@ -722,6 +769,7 @@ function IsMyMNListed(LocalIP:String):boolean;
 
 Procedure AddWaitingMNs(Linea:String);
 Begin
+  if IsMNIPReceived(linea) then exit;;
   EnterCriticalSection(CSWaitingMNs);
   Insert(Linea,ArrWaitMNs,Length(ArrWaitMNs));
   LeaveCriticalSection(CSWaitingMNs);
@@ -872,6 +920,7 @@ function IsMyMNListed(LocalIP:String):boolean;
 SetLength(ArrMNChecks,0);
 SetLength(ArrayMNsData,0);
 Setlength(ArrWaitMNs,0);
+Setlength(ArrReceivedMNs,0);
 InitCriticalSection(CSMNsIPProc);
 InitCriticalSection(CSMNsList);
 InitCriticalSection(CSVerNodes);
@@ -882,6 +931,7 @@ function IsMyMNListed(LocalIP:String):boolean;
 InitCriticalSection(CSWaitingMNs);
 InitCriticalSection(CSMN_FileText);
 InitCriticalSection(CSMNsChecks);
+InitCriticalSection(CSReceivedMNs);
 
 
 FINALIZATION
@@ -895,6 +945,7 @@ function IsMyMNListed(LocalIP:String):boolean;
 DoneCriticalSection(CSWaitingMNs);
 DoneCriticalSection(CSMN_FileText);
 DoneCriticalSection(CSMNsChecks);
+DoneCriticalSection(CSReceivedMNs);
 
 
 END. // End unit