MCPcopy Create free account
hub / github.com/Cyinx/einx / handle_data_event

Method handle_data_event

module/module.go:249–262  ·  view source on GitHub ↗
(event_msg EventMsg)

Source from the content-addressed store, hash-verified

247}
248
249func (this *module) handle_data_event(event_msg EventMsg) {
250 data_event := event_msg.(*DataEventMsg)
251 handler, ok := this.msg_handler_map[data_event.TypeID]
252 if ok == true {
253 ctx := this.context
254 ctx.s = data_event.Sender
255 handler(ctx, data_event.MsgData)
256 ctx.Reset()
257 } else {
258 slog.LogError("module", "module [%s] unregister msg handler msg type id[%d] %v!", this.name, data_event.TypeID, ok)
259 }
260 event_msg.Reset()
261 this.data_msg_pool.Put(event_msg)
262}
263
264func (this *module) handle_component_event(event_msg EventMsg) {
265 com_event := event_msg.(*ComponentEventMsg)

Callers 1

handle_eventMethod · 0.95

Calls 2

ResetMethod · 0.65
PutMethod · 0.45

Tested by

no test coverage detected