Lines Matching refs:txs

50 	txs    []*types.Transaction
382 				func(txs []*types.Transaction) []error {
383 					return make([]error, len(txs))
407 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}, direct: true},
421 				func(txs []*types.Transaction) []error {
422 					return make([]error, len(txs))
446 			doTxEnqueue{peer: "A", txs: []*types.Transaction{}, direct: true},
459 				func(txs []*types.Transaction) []error {
460 					return make([]error, len(txs))
485 …doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}, direct: true}, // This depends on th…
505 				func(txs []*types.Transaction) []error {
506 					return make([]error, len(txs))
531 …doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[1]}, direct: true}, // This depends on th…
543 				func(txs []*types.Transaction) []error {
544 					return make([]error, len(txs))
571 …doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0], testTxs[1], testTxs[2]}, direct: fals…
581 …doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0], testTxs[1], testTxs[2]}, direct: true…
648 				func(txs []*types.Transaction) []error {
649 					return make([]error, len(txs))
695 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}, direct: true},
869 				func(txs []*types.Transaction) []error {
870 					errs := make([]error, len(txs))
887 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0], testTxs[1]}, direct: true},
909 	var txs []*types.Transaction
911 …txs = append(txs, types.NewTransaction(rand.Uint64(), common.Address{byte(rand.Intn(256))}, new(bi…
913 	hashes := make([]common.Hash, len(txs))
914 	for i, tx := range txs {
933 …steps = append(steps, doTxEnqueue{peer: "A", txs: txs[i*maxTxRetrievals : (i+1)*maxTxRetrievals], …
942 				func(txs []*types.Transaction) []error {
943 					errs := make([]error, len(txs))
956 			doTxEnqueue{peer: "A", txs: []*types.Transaction{txs[maxTxUnderpricedSetSize]}, direct: true},
968 				func(txs []*types.Transaction) []error {
969 					return make([]error, len(txs))
978 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}, direct: false},
1001 …doTxEnqueue{peer: "B", txs: []*types.Transaction{testTxs[0], testTxs[1], testTxs[2], testTxs[3]}, …
1021 				func(txs []*types.Transaction) []error {
1022 					return make([]error, len(txs))
1087 				func(txs []*types.Transaction) []error {
1088 					return make([]error, len(txs))
1132 				func(txs []*types.Transaction) []error {
1133 					return make([]error, len(txs))
1142 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}},
1159 				func(txs []*types.Transaction) []error {
1160 					return make([]error, len(txs))
1169 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}},
1188 				func(txs []*types.Transaction) []error {
1189 					return make([]error, len(txs))
1198 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0], testTxs[1]}},
1204 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[1]}, direct: true},
1221 				func(txs []*types.Transaction) []error {
1222 					return make([]error, len(txs))
1234 			doTxEnqueue{peer: "A", txs: []*types.Transaction{testTxs[0]}},
1281 			if err := fetcher.Enqueue(step.peer, step.txs, step.direct); err != nil {