MCorange/wings
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove debug lines

Browse Source
This commit is contained in:
Dane Everitt 2020-09-12 20:17:36 -07:00
parent d02e37620d
commit d7fbf29cc1
No known key found for this signature in database
GPG Key ID: EEA66103B3D71F53
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
events/events.go
View File

@ -2,7 +2,6 @@ package events
import ( import (
"encoding/json" "encoding/json"
"fmt"
"github.com/gammazero/workerpool" "github.com/gammazero/workerpool"
"github.com/pkg/errors" "github.com/pkg/errors"
"strings" "strings"
@ -61,9 +60,7 @@ func (e *EventBus) Publish(topic string, data string) {
// us to call publish without blocking any of the other pathways. // us to call publish without blocking any of the other pathways.
// //
// @see https://github.com/pterodactyl/panel/issues/2303 // @see https://github.com/pterodactyl/panel/issues/2303
fmt.Println("pre-submit for topic:", evt.Topic)
cp.pool.Submit(func() { cp.pool.Submit(func() {
fmt.Println("executing callback for event:", evt.Topic)
c(evt) 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 // Check if this topic has been registered at least once for the event listener, and if
// not create an empty struct for the topic. // not create an empty struct for the topic.
if _, exists := e.pools[topic]; !exists { if _, exists := e.pools[topic]; !exists {
fmt.Println("no pool for topic, creating:", topic)
e.pools[topic] = &CallbackPool{ e.pools[topic] = &CallbackPool{
callbacks: make([]*func(Event), 0), callbacks: make([]*func(Event), 0),
pool: workerpool.New(1), pool: workerpool.New(1),
@ -119,7 +115,6 @@ func (e *EventBus) Destroy() {
e.mu.Lock() e.mu.Lock()
defer e.mu.Unlock() defer e.mu.Unlock()
fmt.Println("destroying pool for event bus")
// Stop every pool that exists for a given callback topic. // Stop every pool that exists for a given callback topic.
for _, cp := range e.pools { for _, cp := range e.pools {
cp.pool.Stop() cp.pool.Stop()