(t *testing.T, addressByNodeHostID bool, factory config.TransportFactory)
| 794 | } |
| 795 | |
| 796 | func testAddressByNodeHostID(t *testing.T, |
| 797 | addressByNodeHostID bool, factory config.TransportFactory) { |
| 798 | fs := vfs.GetTestFS() |
| 799 | datadir1 := fs.PathJoin(singleNodeHostTestDir, "nh1") |
| 800 | datadir2 := fs.PathJoin(singleNodeHostTestDir, "nh2") |
| 801 | os.RemoveAll(singleNodeHostTestDir) |
| 802 | defer os.RemoveAll(singleNodeHostTestDir) |
| 803 | addr1 := nodeHostTestAddr1 |
| 804 | addr2 := nodeHostTestAddr2 |
| 805 | nhc1 := config.NodeHostConfig{ |
| 806 | NodeHostDir: datadir1, |
| 807 | RTTMillisecond: getRTTMillisecond(fs, datadir1), |
| 808 | RaftAddress: addr1, |
| 809 | AddressByNodeHostID: addressByNodeHostID, |
| 810 | Expert: config.ExpertConfig{ |
| 811 | FS: fs, |
| 812 | TestGossipProbeInterval: 50 * time.Millisecond, |
| 813 | }, |
| 814 | } |
| 815 | if addressByNodeHostID { |
| 816 | nhc1.Gossip = config.GossipConfig{ |
| 817 | BindAddress: "127.0.0.1:25001", |
| 818 | AdvertiseAddress: "127.0.0.1:25001", |
| 819 | Seed: []string{"127.0.0.1:25002"}, |
| 820 | } |
| 821 | } |
| 822 | nhc2 := config.NodeHostConfig{ |
| 823 | NodeHostDir: datadir2, |
| 824 | RTTMillisecond: getRTTMillisecond(fs, datadir2), |
| 825 | RaftAddress: addr2, |
| 826 | AddressByNodeHostID: addressByNodeHostID, |
| 827 | Expert: config.ExpertConfig{ |
| 828 | FS: fs, |
| 829 | TestGossipProbeInterval: 50 * time.Millisecond, |
| 830 | }, |
| 831 | } |
| 832 | if addressByNodeHostID { |
| 833 | nhc2.Gossip = config.GossipConfig{ |
| 834 | BindAddress: "127.0.0.1:25002", |
| 835 | AdvertiseAddress: "127.0.0.1:25002", |
| 836 | Seed: []string{"127.0.0.1:25001"}, |
| 837 | } |
| 838 | } |
| 839 | nhid1, err := id.ParseNodeHostID(testNodeHostID1) |
| 840 | if err != nil { |
| 841 | t.Fatalf("failed to parse nhid") |
| 842 | } |
| 843 | nhc1.Expert.TestNodeHostID = nhid1.Value() |
| 844 | nhid2, err := id.ParseNodeHostID(testNodeHostID2) |
| 845 | if err != nil { |
| 846 | t.Fatalf("failed to parse nhid") |
| 847 | } |
| 848 | nhc2.Expert.TestNodeHostID = nhid2.Value() |
| 849 | nhc1.Expert.TransportFactory = factory |
| 850 | nhc2.Expert.TransportFactory = factory |
| 851 | nh1, err := NewNodeHost(nhc1) |
| 852 | if err != nil { |
| 853 | t.Fatalf("failed to create nh, %v", err) |
no test coverage detected