From d7fbf29cc19a89b3cb5c9a31ad8e175e74e7de7d Mon Sep 17 00:00:00 2001 From: Dane Everitt Date: Sat, 12 Sep 2020 20:17:36 -0700 Subject: [PATCH] Remove debug lines --- events/events.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/events/events.go b/events/events.go index 884f8a8..a752a3c 100644 --- a/events/events.go +++ b/events/events.go @@ -2,7 +2,6 @@ package events import ( "encoding/json" - "fmt" "github.com/gammazero/workerpool" "github.com/pkg/errors" "strings" @@ -61,9 +60,7 @@ func (e *EventBus) Publish(topic string, data string) { // us to call publish without blocking any of the other pathways. // // @see https://github.com/pterodactyl/panel/issues/2303 - fmt.Println("pre-submit for topic:", evt.Topic) cp.pool.Submit(func() { - fmt.Println("executing callback for event:", evt.Topic) c(evt) }) } @@ -91,7 +88,6 @@ func (e *EventBus) On(topic string, callback *func(Event)) { // Check if this topic has been registered at least once for the event listener, and if // not create an empty struct for the topic. if _, exists := e.pools[topic]; !exists { - fmt.Println("no pool for topic, creating:", topic) e.pools[topic] = &CallbackPool{ callbacks: make([]*func(Event), 0), pool: workerpool.New(1), @@ -119,7 +115,6 @@ func (e *EventBus) Destroy() { e.mu.Lock() defer e.mu.Unlock() - fmt.Println("destroying pool for event bus") // Stop every pool that exists for a given callback topic. for _, cp := range e.pools { cp.pool.Stop()