Commit 3eb808df authored by Simon Esposito's avatar Simon Esposito
Browse files

Make benchmark tests output more reliable

parent 2d259cd6

server/matchmaker.go

+1 −1
Original line number Diff line number Diff line
@@ -639,7 +639,7 @@ func (m *LocalMatchmaker) Process() { 
		m.matchedEntriesFn(matchedEntries)

	}



	m.logger.Warn("matchmaker process elapsed time", zap.Duration("elapsed_time_sec", time.Now().Sub(t)), zap.Uint32("active_tickets", m.active.Load()), zap.Int("indices", len(m.activeIndexes)))

	m.logger.Debug("matchmaker process elapsed time", zap.Duration("elapsed_time_sec", time.Now().Sub(t)), zap.Int("active_tickets", len(m.activeIndexes)), zap.Int("indices", len(m.indexes)))

}



func (m *LocalMatchmaker) Add(presences []*MatchmakerPresence, sessionID, partyId, query string, minCount, maxCount, countMultiple int, stringProperties map[string]string, numericProperties map[string]float64) (string, int64, error) {

server/matchmaker_test.go

+196 −158
Original line number Diff line number Diff line
@@ -20,7 +20,6 @@ import ( 
	"go.uber.org/atomic"

	"io/ioutil"

	"os"

	"sync"

	"testing"

	"time"
@@ -35,7 +34,7 @@ import ( 
// should only add to matchmaker

func TestMatchmakerAddOnly(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, nil)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, nil)

	if err != nil {

		t.Fatalf("error creating test matchmaker: %v", err)

	}
@@ -63,7 +62,7 @@ func TestMatchmakerAddOnly(t *testing.T) { 


func TestMatchmakerAddRemoveRepeated(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, nil)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, nil)

	if err != nil {

		t.Fatalf("error creating test matchmaker: %v", err)

	}
@@ -161,7 +160,7 @@ func TestMatchmakerAddRemoveRepeated(t *testing.T) { 


func TestMatchmakerPropertyRegexSubmatch(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, nil)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, nil)

	if err != nil {

		t.Fatalf("error creating test matchmaker: %v", err)

	}
@@ -287,7 +286,7 @@ func TestMatchmakerPropertyRegexSubmatch(t *testing.T) { 


func TestMatchmakerPropertyRegexSubmatchMultiple(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, nil)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, nil)

	if err != nil {

		t.Fatalf("error creating test matchmaker: %v", err)

	}
@@ -380,7 +379,7 @@ func TestMatchmakerPropertyRegexSubmatchMultiple(t *testing.T) { 
// should add and remove from matchmaker

func TestMatchmakerAddAndRemove(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, nil)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, nil)

	if err != nil {

		t.Fatalf("error creating test matchmaker: %v", err)

	}
@@ -415,8 +414,7 @@ func TestMatchmakerAddAndRemove(t *testing.T) { 
func TestMatchmakerAddWithBasicMatch(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -527,8 +525,7 @@ func TestMatchmakerAddWithBasicMatch(t *testing.T) { 
func TestMatchmakerAddWithMatchOnStar(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -645,8 +642,7 @@ func TestMatchmakerAddWithMatchOnStar(t *testing.T) { 
func TestMatchmakerAddWithMatchOnRange(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -763,8 +759,7 @@ func TestMatchmakerAddWithMatchOnRange(t *testing.T) { 
func TestMatchmakerAddWithMatchOnRangeAndValue(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -890,8 +885,7 @@ func TestMatchmakerAddWithMatchOnRangeAndValue(t *testing.T) { 
func TestMatchmakerAddRemoveNotMatch(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -938,8 +932,7 @@ func TestMatchmakerAddRemoveNotMatch(t *testing.T) { 
func TestMatchmakerAddButNotMatch(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1009,8 +1002,7 @@ func TestMatchmakerAddButNotMatch(t *testing.T) { 
func TestMatchmakerAddButNotMatchOnRange(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1086,8 +1078,7 @@ func TestMatchmakerAddButNotMatchOnRange(t *testing.T) { 
func TestMatchmakerAddButNotMatchOnRangeAndValue(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1162,8 +1153,7 @@ func TestMatchmakerAddButNotMatchOnRangeAndValue(t *testing.T) { 
func TestMatchmakerAddMultipleAndSomeMatch(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1265,8 +1255,7 @@ func TestMatchmakerAddMultipleAndSomeMatch(t *testing.T) { 
func TestMatchmakerAddMultipleAndSomeMatchWithBoost(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1384,8 +1373,7 @@ func TestMatchmakerAddMultipleAndSomeMatchWithBoost(t *testing.T) { 
func TestMatchmakerAddMultipleAndSomeMatchOptionalTextAlteringScore(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1487,8 +1475,7 @@ func TestMatchmakerAddMultipleAndSomeMatchOptionalTextAlteringScore(t *testing.T 
func TestMatchmakerAddAndMatchAuthoritative(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1611,8 +1598,7 @@ func TestMatchmakerAddAndMatchAuthoritative(t *testing.T) { 
//

// the returned cleanup function should be executed after all test operations are complete

// to ensure proper resource management

func createTestMatchmaker(t fatalable, logger *zap.Logger,

	messageCallback func(presences []*PresenceID, envelope *rtapi.Envelope)) (*LocalMatchmaker, func() error, error) {

func createTestMatchmaker(t fatalable, logger *zap.Logger, tickerActive bool, messageCallback func(presences []*PresenceID, envelope *rtapi.Envelope)) (*LocalMatchmaker, func() error, error) {

	cfg := NewConfig(logger)

	cfg.Database.Addresses = []string{"postgres:postgres@localhost:5432/nakama"}

	cfg.Matchmaker.IntervalSec = 1
@@ -1675,7 +1661,7 @@ func createTestMatchmaker(t fatalable, logger *zap.Logger, 
		return res, true, nil

	}



	matchMaker := NewLocalMatchmaker(logger, logger, cfg, messageRouter, runtime)

	matchMaker := NewLocalBenchMatchmaker(logger, logger, cfg, messageRouter, runtime, tickerActive)



	return matchMaker.(*LocalMatchmaker), func() error {

		matchMaker.Stop()
@@ -1684,6 +1670,54 @@ func createTestMatchmaker(t fatalable, logger *zap.Logger, 
	}, nil

}



// Create a new matchmaker with an additional argument to make the ticker optional

func NewLocalBenchMatchmaker(logger, startupLogger *zap.Logger, config Config, router MessageRouter, runtime *Runtime, tickerActive bool) Matchmaker {

	cfg := BlugeInMemoryConfig()

	indexWriter, err := bluge.OpenWriter(cfg)

	if err != nil {

		startupLogger.Fatal("Failed to create matchmaker index", zap.Error(err))

	}



	ctx, ctxCancelFn := context.WithCancel(context.Background())



	m := &LocalMatchmaker{

		logger:  logger,

		node:    config.GetName(),

		config:  config,

		router:  router,

		runtime: runtime,



		active:      atomic.NewUint32(1),

		stopped:     atomic.NewBool(false),

		ctx:         ctx,

		ctxCancelFn: ctxCancelFn,



		batch:          bluge.NewBatch(),

		indexWriter:    indexWriter,

		sessionTickets: make(map[string]map[string]struct{}),

		partyTickets:   make(map[string]map[string]struct{}),

		entries:        make(map[string][]*MatchmakerEntry),

		indexes:        make(map[string]*MatchmakerIndex),

		activeIndexes:  make(map[string]*MatchmakerIndex),

	}



	if tickerActive {

		go func() {

			ticker := time.NewTicker(time.Duration(config.GetMatchmaker().IntervalSec) * time.Second)

			for {

				select {

				case <-ctx.Done():

					return

				case <-ticker.C:

					m.Process()

				}

			}

		}()

	}



	return m

}



// should add to matchmaker and NOT match due to not having mutual matching queries/properties

// ticktet 2 satisfies what ticket 1 is looking for

// but ticket 1 does NOT satisfy what ticket 2 is looking for
@@ -1691,8 +1725,7 @@ func createTestMatchmaker(t fatalable, logger *zap.Logger, 
func TestMatchmakerRequireMutualMatch(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1774,8 +1807,7 @@ func TestMatchmakerRequireMutualMatch(t *testing.T) { 
func TestMatchmakerRequireMutualMatchLarger(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -1877,8 +1909,7 @@ func TestMatchmakerRequireMutualMatchLarger(t *testing.T) { 
func TestMatchmakerRequireMutualMatchLargerReversed(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -2077,7 +2108,7 @@ func BenchmarkMatchmakerProcessMediumSomeNonMutualBiggerGroupAndDifficultMatch(b 
func benchmarkMatchmakerHelper(b *testing.B, activeCount, minCount, maxCount, countMultiple int,

	withQueryAndProps func(i int) (string, map[string]string)) {

	consoleLogger := loggerForBenchmark(b)

	matchMaker, cleanup, err := createTestMatchmaker(b, consoleLogger, nil)

	matchMaker, cleanup, err := createTestMatchmaker(b, consoleLogger, true, nil)

	if err != nil {

		b.Fatalf("error creating test matchmaker: %v", err)

	}
@@ -2135,8 +2166,7 @@ var benchmarkPropsFew = map[string]string{ 
func TestMatchmakerMaxPartyTracking(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -2217,8 +2247,7 @@ func TestMatchmakerMaxPartyTracking(t *testing.T) { 
func TestMatchmakerMaxSessionTracking(t *testing.T) {

	consoleLogger := loggerForTest(t)

	matchesSeen := make(map[string]*rtapi.MatchmakerMatched)

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(t, consoleLogger, true, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if len(presences) == 1 {

			matchesSeen[presences[0].SessionID.String()] = envelope.GetMatchmakerMatched()

		}
@@ -2299,15 +2328,14 @@ func TestMatchmakerMaxSessionTracking(t *testing.T) { 
	}

}



func benchmarkMatchmakerProcessTickets(ticketsMax int32, b *testing.B) {

func benchmarkMatchmakerProcessTickets(ticketsMax int32, minCount, maxCount int, b *testing.B) {

	consoleLogger := loggerForBenchmark(b)

	consoleLogger.Info("Benchmark running")



	processedTicketsCount := atomic.NewInt32(0)

	ctx, cancel := context.WithCancel(context.Background())



	matchMaker, cleanup, err := createTestMatchmaker(b, consoleLogger,

		func(presences []*PresenceID, envelope *rtapi.Envelope) {

	matchMaker, cleanup, err := createTestMatchmaker(b, consoleLogger, false, func(presences []*PresenceID, envelope *rtapi.Envelope) {

		if processedTicketsCount.Inc() >= ticketsMax {

			cancel()

		}
@@ -2318,12 +2346,9 @@ func benchmarkMatchmakerProcessTickets(ticketsMax int32, b *testing.B) { 
	defer cleanup()



	b.ResetTimer()



	waitGroup := sync.WaitGroup{}

	waitGroup.Add(int(ticketsMax))

	for n := 0; n < b.N; n++ {

		b.StopTimer()

		for i := 0; i < int(ticketsMax); i++ {

			go func() {

			sessionID, _ := uuid.NewV4()

			sessionIDStr := sessionID.String()

			userID, _ := uuid.NewV4()
@@ -2339,34 +2364,47 @@ func benchmarkMatchmakerProcessTickets(ticketsMax int32, b *testing.B) { 
				},

			}, sessionIDStr, "",

				"*",

					2, 2, 1, map[string]string{},

				minCount, maxCount, 1, map[string]string{},

				map[string]float64{},

			)

			if err != nil {

				b.Fatalf("error matchmaker add: %v", err)

			}

				waitGroup.Done()

			}()

		}



		b.StartTimer()

		matchMaker.Process()



		select {

		case <-ctx.Done():

			return

		}

		<-ctx.Done()

		processedTicketsCount.Store(0)

		ctx, cancel = context.WithCancel(context.Background())

	}

}



func BenchmarkMatchmakerProcessElapsedTimeTickets100(b *testing.B) {

	benchmarkMatchmakerProcessTickets(10, b)

func BenchmarkMatchmakerProcessTickets100_min2_max2(b *testing.B) {

	benchmarkMatchmakerProcessTickets(100, 2, 2, b)

}

func BenchmarkMatchmakerProcessTickets1_000_min2_max2(b *testing.B) {

	benchmarkMatchmakerProcessTickets(1_000, 2, 2, b)

}

func BenchmarkMatchmakerProcessElapsedTimeTickets1_000(b *testing.B) {

	benchmarkMatchmakerProcessTickets(1_000, b)

func BenchmarkMatchmakerProcessTickets10_000_min2_max2(b *testing.B) {

	benchmarkMatchmakerProcessTickets(10_000, 2, 2, b)

}

func BenchmarkMatchmakerProcessElapsedTimeTickets10_000(b *testing.B) {

	benchmarkMatchmakerProcessTickets(10_000, b)



/*func BenchmarkMatchmakerProcessTickets100_000_min2_max2(b *testing.B) {

	benchmarkMatchmakerProcessTickets(100_000, 2, 2, b)

}*/



func BenchmarkMatchmakerProcessTickets100_min4_max4(b *testing.B) {

	benchmarkMatchmakerProcessTickets(100, 4, 4, b)

}

func BenchmarkMatchmakerProcessElapsedTimeTickets100_000(b *testing.B) {

	benchmarkMatchmakerProcessTickets(100_000, b)

func BenchmarkMatchmakerProcessTickets1_000_min4_max4(b *testing.B) {

	benchmarkMatchmakerProcessTickets(1_000, 4, 4, b)

}

func BenchmarkMatchmakerProcessTickets10_000_min4_max4(b *testing.B) {

	benchmarkMatchmakerProcessTickets(10_000, 4, 4, b)

}



/*func BenchmarkMatchmakerProcessTickets100_000(b *testing.B) {

	benchmarkMatchmakerProcessTickets(100_000, 4, 4, b)

}*/

server/party_handler_test.go

+1 −1
Original line number Diff line number Diff line
@@ -59,7 +59,7 @@ func createTestPartyHandler(t *testing.T, logger *zap.Logger) (*PartyHandler, fu 


	node := "node1"



	mm, cleanup, _ := createTestMatchmaker(t, logger, nil)

	mm, cleanup, _ := createTestMatchmaker(t, logger, true, nil)

	tt := testTracker{}

	tsm := testStreamManager{}

	dmr := DummyMessageRouter{}