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() {
|
func (d *eventDispatcher) close() {
|
||||||
d.closed = true
|
if d.closed {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
close(d.in)
|
close(d.in)
|
||||||
|
d.closed = true
|
||||||
}
|
}
|
||||||
|
|
||||||
func (d *eventDispatcher) In(msg bus.Message) (err error) {
|
func (d *eventDispatcher) In(msg bus.Message) (err error) {
|
||||||
|
@ -2,6 +2,7 @@ package module
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"time"
|
||||||
|
|
||||||
"forge.cadoles.com/arcad/edge/pkg/app"
|
"forge.cadoles.com/arcad/edge/pkg/app"
|
||||||
"github.com/dop251/goja"
|
"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)
|
call(nil)
|
||||||
|
duration := time.Since(start)
|
||||||
|
logger.Debug(ctx, "executed app onInit() function", logger.F("duration", duration.String()))
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user