Function NewDbftService

consensus/dbft/dbft_service.go:63–97

(bkAccount *account.Account, txpool, p2p *actor.PID)

}

func NewDbftService(bkAccount *account.Account, txpool, p2p *actor.PID) (*DbftService, error) {
	service := &DbftService{
		Account:       bkAccount,
		timer:         time.NewTimer(time.Second * 15),
		started:       false,
		ledger:        ledger.DefLedger,
		incrValidator: increment.NewIncrementValidator(20),
		poolActor:     &actorTypes.TxPoolActor{Pool: txpool},
		p2p:           &actorTypes.P2PActor{P2P: p2p},
	}

	if !service.timer.Stop() {
		<-service.timer.C
	}

	go func() {
		for {
			select {
			case <-service.timer.C:
				log.Debug("******Get a timeout notice")
				service.pid.Tell(&actorTypes.TimeOut{})
			}
		}
	}()

	props := actor.FromProducer(func() actor.Actor {
		return service
	})

	pid, err := actor.SpawnNamed(props, "consensus_dbft")
	service.pid = pid

	service.sub = events.NewActorSubscriber(pid)
	return service, err
}

func (this *DbftService) Receive(context actor.Context) {
	if _, ok := context.Message().(*actorTypes.StartConsensus); this.started == false && ok == false {