X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsmallbrain.go;h=4a7cdeb858a7e0c9a79022f07ec5c8f7e3231b6a;hb=a87c91b7d4544703879b7ef6e472b863765e3949;hp=0996d7889ba672af17864f2898a0167040e62ab4;hpb=ff98cdc53bc87b9d4f3215df248c188a84cb2fb1;p=svn42.git diff --git a/go/r3-eventbroker_zmq/smallbrain.go b/go/r3-eventbroker_zmq/smallbrain.go index 0996d78..4a7cdeb 100644 --- a/go/r3-eventbroker_zmq/smallbrain.go +++ b/go/r3-eventbroker_zmq/smallbrain.go @@ -4,8 +4,7 @@ package main import ( zmq "github.com/vaughan0/go-zmq" - "./r3events" - "log" + r3events "svn.spreadspace.org/realraum/go.svn/r3events" ) type hippocampus map[string]interface{} @@ -20,12 +19,12 @@ func BrainCenter( zmq_ctx *zmq.Context, listen_addr string, event_chan <- chan i case event, ec_still_open := <- event_chan: if ! ec_still_open { return } h[r3events.NameOfStruct(event)] = event - log.Printf("Brain: stored %s, %s", r3events.NameOfStruct(event), event) + Debug_.Printf("Brain: stored %s, %s", r3events.NameOfStruct(event), event) case brain_request := <- zbrain_chans.In(): if len(brain_request) == 0 { continue } requested_eventname := string(brain_request[0]) - log.Printf("Brain: received request: %s", requested_eventname) + Debug_.Printf("Brain: received request: %s", requested_eventname) retr_event, is_in_map := h[requested_eventname] if is_in_map { data, err := r3events.MarshalEvent2ByteByte(retr_event) @@ -33,7 +32,8 @@ func BrainCenter( zmq_ctx *zmq.Context, listen_addr string, event_chan <- chan i zbrain_chans.Out() <- data continue } else { - if Syslog_ != nil {Syslog_.Print("BrainCenter", err)} + Syslog_.Print("BrainCenter", err) + Debug_.Print("BrainCenter", err) } } zbrain_chans.Out() <- [][]byte{[]byte("UNKNOWN")}