X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsmallbrain.go;h=cdd0c5a11812f6753249bdb73c80a7f8ac6fcae8;hp=0996d7889ba672af17864f2898a0167040e62ab4;hb=0d2bd96d2c019a7c0e0282898809fb03962ca701;hpb=a8e0651d52192d208758ae9a59e21af313685da4 diff --git a/go/r3-eventbroker_zmq/smallbrain.go b/go/r3-eventbroker_zmq/smallbrain.go index 0996d78..cdd0c5a 100644 --- a/go/r3-eventbroker_zmq/smallbrain.go +++ b/go/r3-eventbroker_zmq/smallbrain.go @@ -5,7 +5,6 @@ package main import ( zmq "github.com/vaughan0/go-zmq" "./r3events" - "log" ) 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")}