summaryrefslogtreecommitdiff
path: root/http.go
diff options
context:
space:
mode:
Diffstat (limited to 'http.go')
-rw-r--r--http.go21
1 files changed, 20 insertions, 1 deletions
diff --git a/http.go b/http.go
index 5fb63f6..1572fc8 100644
--- a/http.go
+++ b/http.go
@@ -67,6 +67,25 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
return
}
+ if tmp == "/cluster" {
+ log.Info("/cluster jcarr actually doing START")
+ fmt.Fprintln(w, "/cluster jcarr actually doing START")
+ var c *pb.Cluster
+ c = new(pb.Cluster)
+
+ fmt.Fprintln(w, "START len(msg) =", len(msg))
+ err = c.UnmarshalJSON(msg)
+ if err != nil {
+ fmt.Fprintln(w, "START FAILED")
+ fmt.Fprintln(w, "error =", err)
+ }
+ for _, dir := range c.Dirs {
+ log.Info("append dir", dir)
+ fmt.Fprintln(w, "append dir", dir)
+ me.dirs = append(me.dirs, dir)
+ }
+ }
+
if tmp == "/start" {
log.Info("/start jcarr actually doing START")
fmt.Fprintln(w, "/start jcarr actually doing START")
@@ -93,7 +112,7 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
fmt.Fprintln(w, "START len(msg) =", len(msg))
err = d.UnmarshalJSON(msg)
if d.Hostname == "" {
- fmt.Fprintln(w,"START hostname is blank")
+ fmt.Fprintln(w, "START hostname is blank")
log.Info("START hostname is blank")
return
}