Compare commits
2 Commits
2023.10.20
...
2023.10.21
Author | SHA1 | Date | |
---|---|---|---|
0cfb132b65 | |||
de4ab0d02c |
@ -83,8 +83,12 @@ func (d *eventDispatcher) Close() {
|
||||
}
|
||||
|
||||
func (d *eventDispatcher) close() {
|
||||
d.closed = true
|
||||
if d.closed {
|
||||
return
|
||||
}
|
||||
|
||||
close(d.in)
|
||||
d.closed = true
|
||||
}
|
||||
|
||||
func (d *eventDispatcher) In(msg bus.Message) (err error) {
|
||||
|
@ -2,6 +2,7 @@ package module
|
||||
|
||||
import (
|
||||
"context"
|
||||
"time"
|
||||
|
||||
"forge.cadoles.com/arcad/edge/pkg/app"
|
||||
"github.com/dop251/goja"
|
||||
@ -41,7 +42,11 @@ func (m *LifecycleModule) OnInit(ctx context.Context, rt *goja.Runtime) (err err
|
||||
}
|
||||
}()
|
||||
|
||||
logger.Debug(ctx, "executing app onInit() function")
|
||||
start := time.Now()
|
||||
call(nil)
|
||||
duration := time.Since(start)
|
||||
logger.Debug(ctx, "executed app onInit() function", logger.F("duration", duration.String()))
|
||||
|
||||
return nil
|
||||
}
|
||||
|
Reference in New Issue
Block a user