Skip to content
Snippets Groups Projects
Select Git revision
  • b34d538ffd851b0f587877fe5985a68cf573ec39
  • release default protected
  • master protected
  • hotfix/GrpcParameters
  • XX-4441
  • tls-websockets
  • hotfix/allow-web-creds
  • hotfix/nilCert
  • XX-3566_const_time_token_compare
  • AceVentura/AccountBackup
  • dev
  • waitingRoundsRewrite
  • fullRateLimit
  • XX-3564/TlsCipherSuite
  • XX-3563/DisableTlsCheck
  • notls
  • url-repo-rename
  • perftuning
  • Anne/CI2
  • AddedGossipLogging
  • hotfix/connectionReduction
  • v0.0.6
  • v0.0.4
  • v0.0.5
  • v0.0.3
  • v0.0.2
  • v0.0.1
27 results

connection_test.go

Blame
  • roundTracking_test.go 1.18 KiB
    ////////////////////////////////////////////////////////////////////////////////
    // Copyright © 2022 xx foundation                                             //
    //                                                                            //
    // Use of this source code is governed by a license that can be found in the  //
    // LICENSE file.                                                              //
    ////////////////////////////////////////////////////////////////////////////////
    
    package cmix
    
    import (
    	"gitlab.com/xx_network/primitives/id"
    	"testing"
    )
    
    func TestRoundTracker(t *testing.T) {
    	rt := NewRoundTracker()
    	rid := id.Round(2)
    	rt.denote(rid, MessageAvailable)
    	if rt.state[rid] != MessageAvailable {
    		t.Errorf("Round %d is not in expected state\n\tExpected: %s\n\tReceived: %s\n", rid, MessageAvailable, rt.state[rid])
    	}
    	rt.denote(rid, Unchecked)
    	if rt.state[rid] != MessageAvailable {
    		t.Errorf("Round %d is not in expected state\n\tExpected: %s\n\tReceived: %s\n", rid, MessageAvailable, rt.state[rid])
    	}
    	rt.denote(rid, Abandoned)
    	if rt.state[rid] != Abandoned {
    		t.Errorf("Round %d is not in expected state\n\tExpected: %s\n\tReceived: %s\n", rid, Abandoned, rt.state[rid])
    	}
    }