update

pool-server.go

@@ -57,6 +57,7 @@ func ErrorHandler(fn func(w http.ResponseWriter, r *http.Request) error) func(w
 
 func (s *PoolServer) WriteResult(w http.ResponseWriter, result *FrameWithPayload) error {
 	w.Header().Set("Content-Type", "application/json")
+	w.Header().Set("Access-Control-Allow-Origin", "*")
 	w.Header().Set("X-Pod-Name", s.pod_name)
 	if result.StatusCode != 200 {
 		log.Printf("Call error: %d\n", result.StatusCode)
@@ -117,6 +118,12 @@ func (s *PoolServer) HandleSetDelivery(w http.ResponseWriter, r *http.Request) e
 
 func (s *PoolServer) Serve() *http.ServeMux {
 	mux := http.NewServeMux()
+	mux.HandleFunc("OPTIONS /{id}", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Access-Control-Allow-Origin", "*")
+		w.Header().Set("Access-Control-Allow-Methods", "GET, POST, DELETE")
+		w.Header().Set("Access-Control-Allow-Headers", "Content-Type")
+		w.WriteHeader(http.StatusOK)
+	})
 	mux.HandleFunc("GET /{id}", ErrorHandler(s.HandleGet))
 	mux.HandleFunc("GET /{id}/add/{sku}", ErrorHandler(s.HandleAddSku))
 	mux.HandleFunc("DELETE /{id}/{itemId}", ErrorHandler(s.HandleDeleteItem))

remote-grain.go

@@ -3,9 +3,6 @@ package main
 import (
 	"fmt"
 	"strings"
-
-	"github.com/prometheus/client_golang/prometheus"
-	"github.com/prometheus/client_golang/prometheus/promauto"
 )
 
 func (id CartId) String() string {
@@ -54,33 +51,6 @@ func NewRemoteGrain(id CartId, host string) (*RemoteGrain, error) {
 	}, nil
 }
 
-var (
-	remoteCartLatency = promauto.NewCounter(prometheus.CounterOpts{
-		Name: "cart_remote_grain_calls_total_latency",
-		Help: "The total latency of remote grains",
-	})
-	remoteCartCallsTotal = promauto.NewCounter(prometheus.CounterOpts{
-		Name: "cart_remote_grain_calls_total",
-		Help: "The total number of calls to remote grains",
-	})
-)
-
-// var start time.Time
-
-// func MeasureLatency(fn func() (*CallResult, error)) (*CallResult, error) {
-// 	start = time.Now()
-// 	data, err := fn()
-// 	if err != nil {
-// 		return data, err
-// 	}
-// 	elapsed := time.Since(start).Milliseconds()
-// 	go func() {
-// 		remoteCartLatency.Add(float64(elapsed))
-// 		remoteCartCallsTotal.Inc()
-// 	}()
-// 	return data, nil
-// }
-
 func (g *RemoteGrain) HandleMessage(message *Message, isReplay bool) (*FrameWithPayload, error) {
 
 	data, err := GetData(message.Write)

remote-host.go

@@ -24,7 +24,7 @@ func (h *RemoteHost) Initialize(p *SyncedPool) {
 		return
 	}
 	log.Printf("Remote %s has %d grains\n", h.Host, len(ids))
-	p.mu.Lock()
+
 	local := 0
 	remoteNo := 0
 	for _, id := range ids {
@@ -32,7 +32,7 @@ func (h *RemoteHost) Initialize(p *SyncedPool) {
 		remoteNo++
 	}
 	log.Printf("Removed %d local grains, added %d remote grains\n", local, remoteNo)
-	p.mu.Unlock()
+
 	go p.Negotiate()
 
 }