lab2 - final

common/consistenthash/consistenthash.go

@@ -22,6 +22,20 @@ func (r *Ring) search(key string) int {
     // YOUR CODE GOES HERE //
     /////////////////////////
 
+    hash := hashId(key)
+    id := 0
+    for _, node := range r.Nodes {
+	//A partir do hash da chave ele verifica qual node fica imediatamente a 
+	//direita no anel(primeiro que aparece seguindo no sentido horário)
+	//Ou seja, qual node possui hash maior que o seu
+        if hash < node.HashId {
+            return id
+        }
+        id++
+    }
+    //Se não houver ninguém com um hash maior que o seu, significa q tem q dar a volta no anel
+    //Ou seja o node com o menor hash se torna o node mais a direita (primeiro 
+    //que aparece seguindo no sentido horário)
     return 0
 }
 

dynamo/cache.go

@@ -12,6 +12,7 @@ import (
 // Cache is the struct that handle all the data storage for the dynamo server.
 type Cache struct {
     data map[string]string
+    timestamps map[string]int64
     sync.Mutex
 }
 
@@ -20,6 +21,7 @@ func NewCache() *Cache {
     var s Cache
 
     s.data = make(map[string]string)
+    s.timestamps = make(map[string]int64)
 
     return &s
 }
@@ -29,7 +31,7 @@ func NewCache() *Cache {
 func (cache *Cache) Get(key string) (value string, timestamp int64) {
     cache.Lock()
     value = cache.data[key]
-    timestamp = 0
+    timestamp = cache.timestamps[key]
     cache.Unlock()
 
     log.Printf("[CACHE] Getting Key '%v' with Value '%v' @ timestamp '%v'\n", key, value, timestamp)
@@ -43,6 +45,7 @@ func (cache *Cache) Put(key string, value string, timestamp int64) {
 
     cache.Lock()
     cache.data[key] = value
+    cache.timestamps[key] = timestamp
     cache.Unlock()
 
     return
@@ -52,6 +55,6 @@ func (cache *Cache) Put(key string, value string, timestamp int64) {
 // except for testing purposes.
 func (cache *Cache) getAll() (data map[string]string, timestamps map[string]int64) {
     data = cache.data
-    timestamps = make(map[string]int64)
+    timestamps = cache.timestamps
     return data, timestamps
 }

dynamo/coordinator.go

@@ -186,13 +186,26 @@ func (server *Server) Voting(key string, quorum int) (string, error) {
 
 // aggregateVotes will select the right value from the votes received.
 func aggregateVotes(votes []*vote) (result string) {
+
+	count := 0
+	vencedor := 0
+	//temp recebe o timestamp do primeiro voto
+	temp := votes[0].timestamp
+	//vai percorrer cada voto verificando se tem um timestamp maior que temp
+	//quando acha um vencedor até o momento, salva o índice em vencedor 
+	//e salva o timestamp em temp
 	for _, vote := range votes {
 		log.Printf("[COORDINATOR] Vote: %v\n", vote.value)
+		if vote.timestamp > temp {
+			vencedor = count
+			temp = vote.timestamp
+		}
+		count++
 	}
 
 	/////////////////////////
 	// YOUR CODE GOES HERE //
 	/////////////////////////
-	result = votes[0].value
+	result = votes[vencedor].value
 	return
 }