Method
PostData
(event_type EventType, type_id ProtoTypeID, agent Agent, data interface{})
Source from the content-addressed store, hash-verified
| 106 | } |
| 107 | |
| 108 | func (this *module) PostData(event_type EventType, type_id ProtoTypeID, agent Agent, data interface{}) { |
| 109 | event := this.data_msg_pool.Get().(*DataEventMsg) |
| 110 | event.MsgType = event_type |
| 111 | event.Sender = agent |
| 112 | event.TypeID = type_id |
| 113 | event.MsgData = data |
| 114 | this.ev_queue.Push(event) |
| 115 | } |
| 116 | |
| 117 | func (this *module) RpcCall(name string, args ...interface{}) { |
| 118 | rpc_msg := this.rpc_msg_pool.Get().(*RpcEventMsg) |
Tested by
no test coverage detected