projects
/
svn42.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
ManualMovementEvent
[svn42.git]
/
go
/
r3-eventbroker_zmq
/
smallbrain.go
diff --git
a/go/r3-eventbroker_zmq/smallbrain.go
b/go/r3-eventbroker_zmq/smallbrain.go
index
0996d78
..
4a7cdeb
100644
(file)
--- 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"
import (
zmq "github.com/vaughan0/go-zmq"
- "./r3events"
- "log"
+ r3events "svn.spreadspace.org/realraum/go.svn/r3events"
)
type hippocampus map[string]interface{}
)
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
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])
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)
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 {
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")}
}
}
zbrain_chans.Out() <- [][]byte{[]byte("UNKNOWN")}