Function TestTransport_Send

transport_test.go:73–162

(t *testing.T)

}

func TestTransport_Send(t *testing.T) {
	net := &MockNetwork{}

	t1 := net.NewTransport("node1")
	d1 := &MockDelegate{}

	c1 := DefaultLANConfig()
	c1.Name = "node1"
	c1.Transport = t1
	c1.Delegate = d1
	m1, err := Create(c1)
	if err != nil {
		t.Fatalf("err: %v", err)
	}
	if err := m1.setAlive(); err != nil {
		t.Fatalf("err: %v", err)
	}
	m1.schedule()
	defer func() {
		if err := m1.Shutdown(); err != nil {
			t.Fatalf("err: %v", err)
		}
	}()

	c2 := DefaultLANConfig()
	c2.Name = "node2"
	c2.Transport = net.NewTransport("node2")
	m2, err := Create(c2)
	if err != nil {
		t.Fatalf("err: %v", err)
	}
	if err := m2.setAlive(); err != nil {
		t.Fatalf("err: %v", err)
	}
	m2.schedule()
	defer func() {
		if err := m2.Shutdown(); err != nil {
			t.Fatalf("err: %v", err)
		}
	}()

	num, err := m2.Join([]string{c1.Name + "/" + t1.addr.String()})
	if num != 1 {
		t.Fatalf("bad: %d", num)
	}
	if err != nil {
		t.Fatalf("err: %v", err)
	}

	if err := m2.SendTo(t1.addr, []byte("SendTo")); err != nil {
		t.Fatalf("err: %v", err)
	}

	var n1 *Node
	for _, n := range m2.Members() {
		if n.Name == c1.Name {
			n1 = n
			break