integrate contract tracer (#2106)

[bytom/bytom.git] / contract / trace_scheduler.go

diff --git a/contract/trace_scheduler.go b/contract/trace_scheduler.go
index c79b220..5dbe9bf 100644 (file)
--- a/contract/trace_scheduler.go
+++ b/contract/trace_scheduler.go
@@ -27,10 +27,14 @@ func newTraceScheduler(infra *Infrastructure) *traceScheduler {
                instances: new(sync.Map),
                infra:     infra,
        }
-       go scheduler.processLoop()
        return scheduler
 }
 
+func (t *traceScheduler) start(service *TracerService) {
+       t.tracerService = service
+       go t.processLoop()
+}
+
 func (t *traceScheduler) addNewJob(instance *Instance) error {
        if !t.weighted.TryAcquire(1) {
                return errInstQueueOverflow