Function NewMockOrderer

integration/smartbft/mock_orderer.go:252–283

(address string, ledgerArray []*cb.Block, options comm.SecureOptions)

}

func NewMockOrderer(address string, ledgerArray []*cb.Block, options comm.SecureOptions) (*MockOrderer, error) {
	sc := comm.ServerConfig{
		SecOpts: options,
	}

	logger := flogging.MustGetLogger("mockorderer")
	grpcServer, err := comm.NewGRPCServer(address, sc)
	if err != nil {
		logger.Errorf("Error creating GRPC server: %s", err)
	}

	mo := &MockOrderer{
		address:        address,
		ledgerArray:    ledgerArray,
		logger:         logger,
		grpcServer:     grpcServer,
		censorDataMode: false,
		sentCount:      0,
		censorAfter:    math.MaxInt,
	}

	ab.RegisterAtomicBroadcastServer(grpcServer.Server(), mo)

	go func() {
		err := grpcServer.Start()
		if err != nil {
			panic("Orderer mock failed to start")
		}
	}()

	return mo, nil
}