eth/fetcher/tx_fetcher_test.go

41 …testTxsHashes = []common.Hash{testTxs[0].Hash(), testTxs[1].Hash(), testTxs[2].Hash(), testTxs[3].…
46 	hashes []common.Hash
60 type isWaiting map[string][]common.Hash
62 	tracking map[string][]common.Hash
63 	fetching map[string][]common.Hash
64 	dangling map[string][]common.Hash
81 				func(common.Hash) bool { return false },
83 				func(string, []common.Hash) error { return nil },
88 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}, {0x02}}},
89 			isWaiting(map[string][]common.Hash{
93 			doTxNotify{peer: "B", hashes: []common.Hash{{0x03}, {0x04}}},
94 			isWaiting(map[string][]common.Hash{
99 			doTxNotify{peer: "C", hashes: []common.Hash{{0x01}, {0x04}}},
100 			isWaiting(map[string][]common.Hash{
106 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}, {0x03}, {0x05}}},
107 			isWaiting(map[string][]common.Hash{
119 				tracking: map[string][]common.Hash{
124 				fetching: map[string][]common.Hash{ // Depends on deterministic test randomizer
131 			doTxNotify{peer: "C", hashes: []common.Hash{{0x06}, {0x07}}},
132 			isWaiting(map[string][]common.Hash{
137 				tracking: map[string][]common.Hash{
142 				fetching: map[string][]common.Hash{
147 			doTxNotify{peer: "D", hashes: []common.Hash{{0x06}, {0x07}}},
149 				tracking: map[string][]common.Hash{
155 				fetching: map[string][]common.Hash{
171 				func(common.Hash) bool { return false },
173 				func(string, []common.Hash) error { return nil },
178 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}, {0x02}}},
179 			isWaiting(map[string][]common.Hash{
187 				tracking: map[string][]common.Hash{
190 				fetching: map[string][]common.Hash{
196 			doTxNotify{peer: "A", hashes: []common.Hash{{0x02}, {0x03}}},
197 			isWaiting(map[string][]common.Hash{
201 				tracking: map[string][]common.Hash{
204 				fetching: map[string][]common.Hash{
210 			doTxNotify{peer: "B", hashes: []common.Hash{{0x02}, {0x03}, {0x04}}},
211 			isWaiting(map[string][]common.Hash{
216 				tracking: map[string][]common.Hash{
220 				fetching: map[string][]common.Hash{
234 				func(common.Hash) bool { return false },
236 				func(string, []common.Hash) error { return nil },
241 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}, {0x02}}},
242 			isWaiting(map[string][]common.Hash{
250 				tracking: map[string][]common.Hash{
253 				fetching: map[string][]common.Hash{
259 			doTxNotify{peer: "A", hashes: []common.Hash{{0x03}, {0x04}}},
260 			isWaiting(map[string][]common.Hash{
264 				tracking: map[string][]common.Hash{
267 				fetching: map[string][]common.Hash{
274 				tracking: map[string][]common.Hash{
277 				fetching: map[string][]common.Hash{
283 			doTxNotify{peer: "B", hashes: []common.Hash{{0x02}, {0x03}, {0x05}, {0x06}}},
284 			isWaiting(map[string][]common.Hash{
288 				tracking: map[string][]common.Hash{
292 				fetching: map[string][]common.Hash{
311 				func(common.Hash) bool { return false },
313 				func(origin string, hashes []common.Hash) error {
321 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}, {0x02}}},
322 			isWaiting(map[string][]common.Hash{
330 				tracking: map[string][]common.Hash{
333 				fetching: map[string][]common.Hash{
339 			doTxNotify{peer: "B", hashes: []common.Hash{{0x02}}},
342 				tracking: map[string][]common.Hash{
346 				fetching: map[string][]common.Hash{
358 				tracking: map[string][]common.Hash{
361 				fetching: map[string][]common.Hash{
381 				func(common.Hash) bool { return false },
385 				func(string, []common.Hash) error { return nil },
390 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
391 			isWaiting(map[string][]common.Hash{
399 				tracking: map[string][]common.Hash{
402 				fetching: map[string][]common.Hash{
420 				func(common.Hash) bool { return false },
424 				func(string, []common.Hash) error { return nil },
429 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
430 			isWaiting(map[string][]common.Hash{
438 				tracking: map[string][]common.Hash{
441 				fetching: map[string][]common.Hash{
458 				func(common.Hash) bool { return false },
462 				func(string, []common.Hash) error { return nil },
467 …doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0], testTxsHashes[1], testTxsHashes[2]}},
468 			isWaiting(map[string][]common.Hash{
476 				tracking: map[string][]common.Hash{
479 				fetching: map[string][]common.Hash{
487 				tracking: map[string][]common.Hash{
490 				fetching: map[string][]common.Hash{
504 				func(common.Hash) bool { return false },
508 				func(string, []common.Hash) error { return nil },
513 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0], testTxsHashes[1]}},
514 			isWaiting(map[string][]common.Hash{
522 				tracking: map[string][]common.Hash{
525 				fetching: map[string][]common.Hash{
542 				func(common.Hash) bool { return false },
546 				func(string, []common.Hash) error { return nil },
551 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
553 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[1]}},
555 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[2]}},
557 			isWaiting(map[string][]common.Hash{
561 				tracking: map[string][]common.Hash{
564 				fetching: map[string][]common.Hash{
576 				dangling: map[string][]common.Hash{
592 				func(common.Hash) bool { return false },
594 				func(string, []common.Hash) error { return nil },
598 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}}},
599 			isWaiting(map[string][]common.Hash{
604 			isWaiting(map[string][]common.Hash{
609 			doTxNotify{peer: "A", hashes: []common.Hash{{0x02}}},
610 			isWaiting(map[string][]common.Hash{
615 			isWaiting(map[string][]common.Hash{
619 				tracking: map[string][]common.Hash{
622 				fetching: map[string][]common.Hash{
630 				tracking: map[string][]common.Hash{
633 				fetching: map[string][]common.Hash{
647 				func(common.Hash) bool { return false },
651 				func(string, []common.Hash) error { return nil },
656 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
657 			isWaiting(map[string][]common.Hash{
665 				tracking: map[string][]common.Hash{
668 				fetching: map[string][]common.Hash{
678 				dangling: map[string][]common.Hash{
683 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[1]}},
686 				tracking: map[string][]common.Hash{
690 				dangling: map[string][]common.Hash{
698 				tracking: map[string][]common.Hash{
701 				fetching: map[string][]common.Hash{
714 				func(common.Hash) bool { return false },
716 				func(string, []common.Hash) error { return nil },
720 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}}},
722 			doTxNotify{peer: "B", hashes: []common.Hash{{0x02}}},
727 				tracking: map[string][]common.Hash{
731 				fetching: map[string][]common.Hash{
738 				tracking: map[string][]common.Hash{
741 				fetching: map[string][]common.Hash{
744 				dangling: map[string][]common.Hash{
752 				dangling: map[string][]common.Hash{
765 	var hashes []common.Hash
767 		hashes = append(hashes, common.Hash{byte(i / 256), byte(i % 256)})
773 				func(common.Hash) bool { return false },
775 				func(string, []common.Hash) error { return nil },
785 				tracking: map[string][]common.Hash{
788 				fetching: map[string][]common.Hash{
800 	var hashesA []common.Hash
802 		hashesA = append(hashesA, common.Hash{0x01, byte(i / 256), byte(i % 256)})
804 	var hashesB []common.Hash
806 		hashesB = append(hashesB, common.Hash{0x02, byte(i / 256), byte(i % 256)})
811 				func(common.Hash) bool { return false },
813 				func(string, []common.Hash) error { return nil },
827 			isWaiting(map[string][]common.Hash{
832 				tracking: map[string][]common.Hash{
836 				fetching: map[string][]common.Hash{
838 …"B": append(append([]common.Hash{}, hashesB[maxTxAnnounces/2-3:maxTxAnnounces/2-1]...), hashesB[:m…
842 			doTxNotify{peer: "A", hashes: []common.Hash{hashesA[maxTxAnnounces]}},
845 			isWaiting(map[string][]common.Hash{
850 				tracking: map[string][]common.Hash{
854 				fetching: map[string][]common.Hash{
856 …"B": append(append([]common.Hash{}, hashesB[maxTxAnnounces/2-3:maxTxAnnounces/2-1]...), hashesB[:m…
868 				func(common.Hash) bool { return false },
880 				func(string, []common.Hash) error { return nil },
885 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0], testTxsHashes[1]}},
891 …doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0], testTxsHashes[1], testTxsHashes[2]}}…
892 			isWaiting(map[string][]common.Hash{
913 	hashes := make([]common.Hash, len(txs))
915 		hashes[i] = tx.Hash()
921 		steps = append(steps, isWaiting(map[string][]common.Hash{
926 			tracking: map[string][]common.Hash{
929 			fetching: map[string][]common.Hash{
941 				func(common.Hash) bool { return false },
949 				func(string, []common.Hash) error { return nil },
954 			doTxNotify{peer: "A", hashes: []common.Hash{hashes[maxTxUnderpricedSetSize]}},
967 				func(common.Hash) bool { return false },
971 				func(string, []common.Hash) error { return nil },
983 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
985 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[1]}},
987 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[2]}},
989 			isWaiting(map[string][]common.Hash{
993 				tracking: map[string][]common.Hash{
996 				fetching: map[string][]common.Hash{
1006 				dangling: map[string][]common.Hash{
1020 				func(common.Hash) bool { return false },
1024 				func(string, []common.Hash) error { return nil },
1029 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}}},
1031 			doTxNotify{peer: "A", hashes: []common.Hash{{0x02}}},
1033 			doTxNotify{peer: "A", hashes: []common.Hash{{0x03}}},
1035 			isWaiting(map[string][]common.Hash{
1039 				tracking: map[string][]common.Hash{
1042 				fetching: map[string][]common.Hash{
1052 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
1056 				tracking: map[string][]common.Hash{
1059 				fetching: map[string][]common.Hash{
1068 				dangling: map[string][]common.Hash{
1086 				func(common.Hash) bool { return false },
1090 				func(string, []common.Hash) error { return nil },
1095 			doTxNotify{peer: "A", hashes: []common.Hash{{0x01}}},
1097 			doTxNotify{peer: "B", hashes: []common.Hash{{0x01}}},
1101 				tracking: map[string][]common.Hash{
1105 				fetching: map[string][]common.Hash{
1113 				tracking: map[string][]common.Hash{
1116 				fetching: map[string][]common.Hash{
1131 				func(common.Hash) bool { return false },
1135 				func(string, []common.Hash) error { return nil },
1140 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
1145 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
1158 				func(common.Hash) bool { return false },
1162 				func(string, []common.Hash) error { return nil },
1167 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
1172 			doTxNotify{peer: "B", hashes: []common.Hash{testTxsHashes[0]}},
1187 				func(common.Hash) bool { return false },
1191 				func(string, []common.Hash) error { return nil },
1196 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0], testTxsHashes[1]}},
1201 			doTxNotify{peer: "B", hashes: []common.Hash{testTxsHashes[0]}},
1220 				func(common.Hash) bool { return false },
1224 				func(string, []common.Hash) error {
1232 			doTxNotify{peer: "A", hashes: []common.Hash{testTxsHashes[0]}},
1237 			doTxNotify{peer: "B", hashes: []common.Hash{testTxsHashes[0]}},
1476 			var queued []common.Hash
1521 func containsHash(slice []common.Hash, hash common.Hash) bool {