Distributed-ANA/main.go at master · evscott/Distributed-ANA · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
package main

import (
	"fmt"
	"net"
	"strings"
	"time"

	"github.com/evscott/Distributed-ANA/Node"
)

// main is the entry point for this distributed system.
func main() {
	ipAddr, err := net.InterfaceAddrs()
	if err != nil {
		fmt.Print(err)
		return
	}
	ip := strings.Split(ipAddr[0].String(), "/")[0]

	runExample(ip)
}

func logSystemTraffic(n1, n2, n3, n4, n5 *Node.Info) {
	if n1.ObjectPresent {
		fmt.Printf("Object at Node %s\n", n1.Port)
	} else if n2.ObjectPresent {
		fmt.Printf("Object at Node %s\n", n2.Port)
	} else if n3.ObjectPresent {
		fmt.Printf("Object at Node %s\n", n3.Port)
	} else if n4.ObjectPresent {
		fmt.Printf("Object at Node %s\n", n2.Port)
	} else if n5.ObjectPresent {
		fmt.Printf("Object at Node %s\n", n3.Port)
	}

	for i := 0; i < 10; i++ {
		time.Sleep(time.Millisecond)
		if n1.ObjectPresent {
			fmt.Printf("Object at Node %s\n", n1.Port)
		} else if n2.ObjectPresent {
			fmt.Printf("Object at Node %s\n", n2.Port)
		} else if n3.ObjectPresent {
			fmt.Printf("Object at Node %s\n", n3.Port)
		} else if n4.ObjectPresent {
			fmt.Printf("Object at Node %s\n", n2.Port)
		} else if n5.ObjectPresent {
			fmt.Printf("Object at Node %s\n", n3.Port)
		}
	}
}

func runExample(ip string) {
	// Create & start nodes with initial knowledge
	n1 := Node.CreateWithObject(ip, "8001", "8001")
	n2 := Node.Create(ip, "8002", "8001")
	n3 := Node.Create(ip, "8003", "8001")
	n4 := Node.Create(ip, "8004", "8001")
	n5 := Node.Create(ip, "8005", "8001")
	go n1.ListenOnPort()
	go n2.ListenOnPort()
	go n3.ListenOnPort()
	go n4.ListenOnPort()
	go n5.ListenOnPort()
	time.Sleep(time.Millisecond)

	go logSystemTraffic(n1, n2, n3, n4, n5)

	go n2.AcquireObject()
	time.Sleep(time.Millisecond)
	go n3.AcquireObject()
	time.Sleep(time.Millisecond)
	go n4.AcquireObject()
	time.Sleep(time.Millisecond)
	go n2.ReleaseObject()
	time.Sleep(time.Millisecond)
	go n2.AcquireObject()

	time.Sleep(time.Second)
	fmt.Printf("{ Node %s, Parent: %s, Next: %s }\n", n1.Port, n1.Parent, n1.Next)
	fmt.Printf("{ Node %s, Parent: %s, Next: %s }\n", n2.Port, n2.Parent, n2.Next)
	fmt.Printf("{ Node %s, Parent: %s, Next: %s }\n", n3.Port, n3.Parent, n3.Next)
	fmt.Printf("{ Node %s, Parent: %s, Next: %s }\n", n4.Port, n4.Parent, n4.Next)
	fmt.Printf("{ Node %s, Parent: %s, Next: %s }\n", n5.Port, n5.Parent, n5.Next)
}