tools

func (*CycleQueue) Consumer ¶

func (cq *CycleQueue) Consumer() []interface{}

func (*CycleQueue) Count ¶

func (cq *CycleQueue) Count() uint64

func (*CycleQueue) GetGpos ¶

func (cq *CycleQueue) GetGpos() uint64

func (*CycleQueue) GetPpos ¶

func (cq *CycleQueue) GetPpos() uint64

func (*CycleQueue) Producer ¶

func (cq *CycleQueue) Producer(value interface{})

func pirntInfo(value interface{}, put bool, c *CycleQueue) {
	tx := value.(*types.Transaction)
	if put {
		log.Debug("put item[%d]: %d and hash is %x.",
			c.ppos, tx.Data.AccountNonce, common.TxHash(tx))
	} else {
		log.Debug("get item[%d]: %d and hash is %x.",
			c.gpos, tx.Data.AccountNonce, common.TxHash(tx))
	}
}