diff --git a/packages/daemon/daemon.go b/packages/daemon/daemon.go
index 404fccd00b25674bc39961c87bcd7ffcc6ca7994..d6961424582e40699ebe97b69f56593b5b61d9d8 100644
--- a/packages/daemon/daemon.go
+++ b/packages/daemon/daemon.go
@@ -5,29 +5,53 @@ import (
)
var (
- running bool
- wg sync.WaitGroup
- ShutdownSignal = make(chan int, 1)
- backgroundWorkers = make([]func(), 0)
- lock = sync.Mutex{}
+ running bool
+ wg sync.WaitGroup
+ ShutdownSignal = make(chan int, 1)
+ backgroundWorkers = make([]func(), 0)
+ backgroundWorkerNames = make([]string, 0)
+ runningBackgroundWorkers = make(map[string]bool)
+ lock = sync.Mutex{}
)
-func runBackgroundWorker(backgroundWorker func()) {
+func GetRunningBackgroundWorkers() []string {
+ lock.Lock()
+
+ result := make([]string, 0)
+ for runningBackgroundWorker := range runningBackgroundWorkers {
+ result = append(result, runningBackgroundWorker)
+ }
+
+ lock.Unlock()
+
+ return result
+}
+
+func runBackgroundWorker(name string, backgroundWorker func()) {
wg.Add(1)
go func() {
+ lock.Lock()
+ runningBackgroundWorkers[name] = true
+ lock.Unlock()
+
backgroundWorker()
+ lock.Lock()
+ delete(runningBackgroundWorkers, name)
+ lock.Unlock()
+
wg.Done()
}()
}
-func BackgroundWorker(handler func()) {
+func BackgroundWorker(name string, handler func()) {
lock.Lock()
if IsRunning() {
- runBackgroundWorker(handler)
+ runBackgroundWorker(name, handler)
} else {
+ backgroundWorkerNames = append(backgroundWorkerNames, name)
backgroundWorkers = append(backgroundWorkers, handler)
}
@@ -45,8 +69,8 @@ func Run() {
Events.Run.Trigger()
- for _, backgroundWorker := range backgroundWorkers {
- runBackgroundWorker(backgroundWorker)
+ for i, backgroundWorker := range backgroundWorkers {
+ runBackgroundWorker(backgroundWorkerNames[i], backgroundWorker)
}
}
diff --git a/packages/node/plugin.go b/packages/node/plugin.go
index a98a22beff880d7b73b210c14e38f0f6730a1ce1..1a6cb527a5eb3d5cd3aa0488e3ce22d2b7fb74e5 100644
--- a/packages/node/plugin.go
+++ b/packages/node/plugin.go
@@ -55,3 +55,16 @@ func (plugin *Plugin) LogFailure(message string) {
func (plugin *Plugin) LogDebug(message string) {
plugin.Node.LogDebug(plugin.Name, message)
}
+
+var TestNode = &Node{
+ loggers: make([]*Logger, 0),
+ wg: &sync.WaitGroup{},
+ loadedPlugins: make([]*Plugin, 0),
+}
+
+func (plugin *Plugin) InitTest() {
+ plugin.Node = TestNode
+
+ plugin.Events.Configure.Trigger(plugin)
+ plugin.Events.Run.Trigger(plugin)
+}
diff --git a/packages/transactionspammer/transactionspammer.go b/packages/transactionspammer/transactionspammer.go
index 503a0f5af72c6f3120b0749ebb30bf5778ba3cd5..c59c6f544f888b83025376fc9b4e0793fb5e83ad 100644
--- a/packages/transactionspammer/transactionspammer.go
+++ b/packages/transactionspammer/transactionspammer.go
@@ -23,7 +23,7 @@ func Start(tps int64) {
shutdownSignal = make(chan int, 1)
func(shutdownSignal chan int) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Transaction Spammer", func() {
for {
start := time.Now()
sentCounter := int64(0)
diff --git a/plugins/analysis/client/plugin.go b/plugins/analysis/client/plugin.go
index 3a42c55ae0a0af094e138b446b3ddcadb5f11e73..b73dba38dec66d241a32edf020c8946101b384ed 100644
--- a/plugins/analysis/client/plugin.go
+++ b/plugins/analysis/client/plugin.go
@@ -21,7 +21,7 @@ import (
)
func Run(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Analysis Client", func() {
shuttingDown := false
for !shuttingDown {
diff --git a/plugins/analysis/server/plugin.go b/plugins/analysis/server/plugin.go
index 86522f1cda3bd0388c24ab1b0a3a065480b8e39f..cbcbb7259b81acf2e4177bc91fa4a7435b321363 100644
--- a/plugins/analysis/server/plugin.go
+++ b/plugins/analysis/server/plugin.go
@@ -36,7 +36,7 @@ func Configure(plugin *node.Plugin) {
}
func Run(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Analysis Server", func() {
plugin.LogInfo("Starting Server (port " + strconv.Itoa(*SERVER_PORT.Value) + ") ...")
server.Listen(*SERVER_PORT.Value)
diff --git a/plugins/analysis/webinterface/httpserver/plugin.go b/plugins/analysis/webinterface/httpserver/plugin.go
index 6f5edbb8ea736c8be04d5176ce5bf9e24f2b324d..a6b62cbb12f33087fbdf7e58b2b2eb2dfacd8833 100644
--- a/plugins/analysis/webinterface/httpserver/plugin.go
+++ b/plugins/analysis/webinterface/httpserver/plugin.go
@@ -32,7 +32,7 @@ func Configure(plugin *node.Plugin) {
}
func Run(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Analysis HTTP Server", func() {
httpServer.ListenAndServe()
})
}
diff --git a/plugins/autopeering/instances/neighborhood/instance.go b/plugins/autopeering/instances/neighborhood/instance.go
index 5a94afd36cdc4f2906a51593c6b2f5ea06e7aa18..d5791d22dd74e273906d892b2b887ff27491c29a 100644
--- a/plugins/autopeering/instances/neighborhood/instance.go
+++ b/plugins/autopeering/instances/neighborhood/instance.go
@@ -35,7 +35,7 @@ func Configure(plugin *node.Plugin) {
}
func Run(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Neighborhood Updater", func() {
timeutil.Ticker(updateNeighborHood, 1*time.Second)
})
}
diff --git a/plugins/autopeering/protocol/outgoing_request_processor.go b/plugins/autopeering/protocol/outgoing_request_processor.go
index cec618cb4827d68a59239e0d8d4dff916969da4c..31fb40cf38a562cabba789b1a121b32958563c2b 100644
--- a/plugins/autopeering/protocol/outgoing_request_processor.go
+++ b/plugins/autopeering/protocol/outgoing_request_processor.go
@@ -41,7 +41,11 @@ func createOutgoingRequestProcessor(plugin *node.Plugin) func() {
func sendOutgoingRequests(plugin *node.Plugin) {
for _, chosenNeighborCandidate := range chosenneighbors.CANDIDATES.Clone() {
- time.Sleep(5 * time.Second)
+ select {
+ case <-daemon.ShutdownSignal:
+ return
+ case <-time.After(5 * time.Second):
+ }
if candidateShouldBeContacted(chosenNeighborCandidate) {
if dialed, err := chosenNeighborCandidate.Send(outgoingrequest.INSTANCE.Marshal(), types.PROTOCOL_TYPE_TCP, true); err != nil {
diff --git a/plugins/autopeering/protocol/plugin.go b/plugins/autopeering/protocol/plugin.go
index fce222652b9d551a6aa84c8c15617795e68ba592..a1b175fc871798bd195e5b63e055f0792611cdf6 100644
--- a/plugins/autopeering/protocol/plugin.go
+++ b/plugins/autopeering/protocol/plugin.go
@@ -20,8 +20,8 @@ func Configure(plugin *node.Plugin) {
}
func Run(plugin *node.Plugin) {
- daemon.BackgroundWorker(createChosenNeighborDropper(plugin))
- daemon.BackgroundWorker(createAcceptedNeighborDropper(plugin))
- daemon.BackgroundWorker(createOutgoingRequestProcessor(plugin))
- daemon.BackgroundWorker(createOutgoingPingProcessor(plugin))
+ daemon.BackgroundWorker("Autopeering Chosen Neighbor Dropper", createChosenNeighborDropper(plugin))
+ daemon.BackgroundWorker("Autopeering Accepted Neighbor Dropper", createAcceptedNeighborDropper(plugin))
+ daemon.BackgroundWorker("Autopeering Outgoing Request Processor", createOutgoingRequestProcessor(plugin))
+ daemon.BackgroundWorker("Autopeering Outgoing Ping Processor", createOutgoingPingProcessor(plugin))
}
diff --git a/plugins/autopeering/saltmanager/saltmanager.go b/plugins/autopeering/saltmanager/saltmanager.go
index 5127646aeb0c3da71350732861d9fbb70c0a381e..0004b7f68791561edf5833dea36d130c126f0a86 100644
--- a/plugins/autopeering/saltmanager/saltmanager.go
+++ b/plugins/autopeering/saltmanager/saltmanager.go
@@ -68,7 +68,7 @@ func scheduleUpdateForSalt(saltToUpdate *salt.Salt, settingsKey []byte, lifeSpan
if saltToUpdate.ExpirationTime.Before(now) {
updatePublicSalt(saltToUpdate, settingsKey, lifeSpan, callback)
} else {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Salt Updater", func() {
select {
case <-time.After(saltToUpdate.ExpirationTime.Sub(now)):
updatePublicSalt(saltToUpdate, settingsKey, lifeSpan, callback)
diff --git a/plugins/autopeering/server/tcp/server.go b/plugins/autopeering/server/tcp/server.go
index 3d4977aa395efac4ca5a0326dc9bc0f54c3b87ff..165c098e56290c712655513414017c99c53f3a5b 100644
--- a/plugins/autopeering/server/tcp/server.go
+++ b/plugins/autopeering/server/tcp/server.go
@@ -37,7 +37,7 @@ func ConfigureServer(plugin *node.Plugin) {
}
func RunServer(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Autopeering TCP Server", func() {
if *parameters.ADDRESS.Value == "0.0.0.0" {
plugin.LogInfo("Starting TCP Server (port " + strconv.Itoa(*parameters.PORT.Value) + ") ...")
} else {
diff --git a/plugins/autopeering/server/udp/server.go b/plugins/autopeering/server/udp/server.go
index 01e66fade4fab0bad39baa0785d751511dec4189..9d01a18977262c393608c46bcfdfbc63d34d983d 100644
--- a/plugins/autopeering/server/udp/server.go
+++ b/plugins/autopeering/server/udp/server.go
@@ -41,7 +41,7 @@ func ConfigureServer(plugin *node.Plugin) {
}
func RunServer(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Autopeering UDP Server", func() {
if *parameters.ADDRESS.Value == "0.0.0.0" {
plugin.LogInfo("Starting UDP Server (port " + strconv.Itoa(*parameters.PORT.Value) + ") ...")
} else {
diff --git a/plugins/bundleprocessor/bundleprocessor.go b/plugins/bundleprocessor/bundleprocessor.go
index 9e21e1662a86aee2145d92314e399567537c9377..8f49b8d5ee7c51193bf68069127551bb0f9825c6 100644
--- a/plugins/bundleprocessor/bundleprocessor.go
+++ b/plugins/bundleprocessor/bundleprocessor.go
@@ -28,7 +28,7 @@ func ProcessSolidBundleHead(headTransaction *value_transaction.ValueTransaction)
if currentTransaction.IsHead() && currentTransaction != headTransaction {
newBundle.SetTransactionHashes(mapTransactionsToTransactionHashes(bundleTransactions))
- Events.InvalidBundleReceived.Trigger(newBundle, bundleTransactions)
+ Events.InvalidBundle.Trigger(newBundle, bundleTransactions)
return nil, ErrProcessBundleFailed.Derive(errors.New("invalid bundle found"), "missing bundle tail")
}
@@ -52,11 +52,7 @@ func ProcessSolidBundleHead(headTransaction *value_transaction.ValueTransaction)
if currentTransaction.IsTail() {
newBundle.SetTransactionHashes(mapTransactionsToTransactionHashes(bundleTransactions))
- if newBundle.IsValueBundle() {
- Events.ValueBundleReceived.Trigger(newBundle, bundleTransactions)
- } else {
- Events.DataBundleReceived.Trigger(newBundle, bundleTransactions)
- }
+ Events.BundleSolid.Trigger(newBundle, bundleTransactions)
return newBundle, nil
}
diff --git a/plugins/bundleprocessor/bundleprocessor_test.go b/plugins/bundleprocessor/bundleprocessor_test.go
new file mode 100644
index 0000000000000000000000000000000000000000..f2132dc94a610ccb2fd013f0b993e6d5b1bbc05f
--- /dev/null
+++ b/plugins/bundleprocessor/bundleprocessor_test.go
@@ -0,0 +1,41 @@
+package bundleprocessor
+
+import (
+ "fmt"
+ "testing"
+
+ "github.com/iotaledger/goshimmer/packages/events"
+ "github.com/iotaledger/goshimmer/packages/model/bundle"
+ "github.com/iotaledger/goshimmer/packages/model/value_transaction"
+ "github.com/iotaledger/goshimmer/packages/ternary"
+ "github.com/iotaledger/goshimmer/plugins/tangle"
+ "github.com/magiconair/properties/assert"
+)
+
+func TestProcessSolidBundleHead(t *testing.T) {
+ tangle.PLUGIN.InitTest()
+
+ tx := value_transaction.New()
+ tx.SetTail(true)
+ tx.SetValue(3)
+
+ tx1 := value_transaction.New()
+ tx1.SetTrunkTransactionHash(tx.GetHash())
+ tx1.SetHead(true)
+
+ tangle.StoreTransaction(tx)
+ tangle.StoreTransaction(tx1)
+
+ Events.BundleSolid.Attach(events.NewClosure(func(bundle *bundle.Bundle, transactions []*value_transaction.ValueTransaction) {
+ fmt.Println("IT HAPPENED")
+ fmt.Println(bundle.GetHash())
+ }))
+
+ result, err := ProcessSolidBundleHead(tx1)
+ if err != nil {
+ t.Error(err)
+ } else {
+ assert.Equal(t, result.GetHash(), ternary.Trytes("UFWJYEWKMEQDNSQUCUWBGOFRHVBGHVVYEZCLCGRDTRQSMAFALTIPMJEEYFDPMQCNJWLXUWFMBZGHQRO99"), "invalid bundle hash")
+ assert.Equal(t, result.IsValueBundle(), true, "invalid value bundle status")
+ }
+}
diff --git a/plugins/bundleprocessor/events.go b/plugins/bundleprocessor/events.go
index 19f4ca0424b193c179d092af2bb18ad64b37c919..2d67f5da2020893b66a6fdcc6bf6df8ff1a01c6b 100644
--- a/plugins/bundleprocessor/events.go
+++ b/plugins/bundleprocessor/events.go
@@ -7,15 +7,13 @@ import (
)
var Events = pluginEvents{
- DataBundleReceived: events.NewEvent(bundleEventCaller),
- ValueBundleReceived: events.NewEvent(bundleEventCaller),
- InvalidBundleReceived: events.NewEvent(bundleEventCaller),
+ BundleSolid: events.NewEvent(bundleEventCaller),
+ InvalidBundle: events.NewEvent(bundleEventCaller),
}
type pluginEvents struct {
- DataBundleReceived *events.Event
- ValueBundleReceived *events.Event
- InvalidBundleReceived *events.Event
+ BundleSolid *events.Event
+ InvalidBundle *events.Event
}
func bundleEventCaller(handler interface{}, params ...interface{}) {
diff --git a/plugins/bundleprocessor/plugin.go b/plugins/bundleprocessor/plugin.go
index 44e110035c536d846d4b675841835b4701817921..cec87804d3c1fa95ad0e51d025f1e84d1e19ad76 100644
--- a/plugins/bundleprocessor/plugin.go
+++ b/plugins/bundleprocessor/plugin.go
@@ -34,7 +34,7 @@ func configure(plugin *node.Plugin) {
func run(plugin *node.Plugin) {
plugin.LogInfo("Starting Bundle Processor ...")
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Bundle Processor", func() {
plugin.LogSuccess("Starting Bundle Processor ... done")
workerPool.Run()
diff --git a/plugins/gossip/neighbors.go b/plugins/gossip/neighbors.go
index f61e08d86a6d0eac60eff86fe65df56acb75105c..87577a6669dcab45675e3a787ff4e8ac21f1b64a 100644
--- a/plugins/gossip/neighbors.go
+++ b/plugins/gossip/neighbors.go
@@ -47,7 +47,7 @@ func runNeighbors(plugin *node.Plugin) {
}
func manageConnection(plugin *node.Plugin, neighbor *Neighbor) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Connection Manager ("+neighbor.Identity.StringIdentifier+")", func() {
failedConnectionAttempts := 0
for _, exists := GetNeighbor(neighbor.Identity.StringIdentifier); exists && failedConnectionAttempts < CONNECTION_MAX_ATTEMPTS; {
diff --git a/plugins/gossip/send_queue.go b/plugins/gossip/send_queue.go
index 354c0c3bf0557265e7806d249a20b38e294ef667..9894910edde22b7e50e980ff176de408b62984b7 100644
--- a/plugins/gossip/send_queue.go
+++ b/plugins/gossip/send_queue.go
@@ -26,7 +26,7 @@ func configureSendQueue(plugin *node.Plugin) {
func runSendQueue(plugin *node.Plugin) {
plugin.LogInfo("Starting Send Queue Dispatcher ...")
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Gossip Send Queue Dispatcher", func() {
plugin.LogSuccess("Starting Send Queue Dispatcher ... done")
for {
@@ -54,7 +54,7 @@ func runSendQueue(plugin *node.Plugin) {
connectedNeighborsMutex.Lock()
for _, neighborQueue := range neighborQueues {
- startNeighborSendQueue(neighborQueue)
+ startNeighborSendQueue(neighborQueue.protocol.Neighbor, neighborQueue)
}
connectedNeighborsMutex.Unlock()
}
@@ -104,13 +104,13 @@ func setupEventHandlers(neighbor *Neighbor) {
}))
if daemon.IsRunning() {
- startNeighborSendQueue(queue)
+ startNeighborSendQueue(neighbor, queue)
}
}))
}
-func startNeighborSendQueue(neighborQueue *neighborQueue) {
- daemon.BackgroundWorker(func() {
+func startNeighborSendQueue(neighbor *Neighbor, neighborQueue *neighborQueue) {
+ daemon.BackgroundWorker("Gossip Send Queue ("+neighbor.Identity.StringIdentifier+")", func() {
for {
select {
case <-daemon.ShutdownSignal:
diff --git a/plugins/gossip/server.go b/plugins/gossip/server.go
index 37ebc20ddd75f018ad016cb641ce9e87816d02c2..07804ad02702be929ec022dbc0e7efe3009fb5c7 100644
--- a/plugins/gossip/server.go
+++ b/plugins/gossip/server.go
@@ -73,7 +73,7 @@ func configureServer(plugin *node.Plugin) {
func runServer(plugin *node.Plugin) {
plugin.LogInfo("Starting TCP Server (port " + strconv.Itoa(*PORT.Value) + ") ...")
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Gossip TCP Server", func() {
plugin.LogSuccess("Starting TCP Server (port " + strconv.Itoa(*PORT.Value) + ") ... done")
TCPServer.Listen(*PORT.Value)
diff --git a/plugins/gracefulshutdown/plugin.go b/plugins/gracefulshutdown/plugin.go
index babf75718afa7bd702d3dd1e17e29d51f15fa171..ee3a074c18f7b7d078be19689b70c8192994977f 100644
--- a/plugins/gracefulshutdown/plugin.go
+++ b/plugins/gracefulshutdown/plugin.go
@@ -4,6 +4,7 @@ import (
"os"
"os/signal"
"strconv"
+ "strings"
"syscall"
"time"
@@ -31,7 +32,13 @@ var PLUGIN = node.NewPlugin("Graceful Shutdown", func(plugin *node.Plugin) {
secondsSinceStart := x.Sub(start).Seconds()
if secondsSinceStart <= WAIT_TO_KILL_TIME_IN_SECONDS {
- plugin.LogWarning("Received shutdown request - waiting (max " + strconv.Itoa(WAIT_TO_KILL_TIME_IN_SECONDS-int(secondsSinceStart)) + " seconds) to finish processing ...")
+ processList := ""
+ runningBackgroundWorkers := daemon.GetRunningBackgroundWorkers()
+ if len(runningBackgroundWorkers) >= 1 {
+ processList = "(" + strings.Join(runningBackgroundWorkers, ", ") + ") "
+ }
+
+ plugin.LogWarning("Received shutdown request - waiting (max " + strconv.Itoa(WAIT_TO_KILL_TIME_IN_SECONDS-int(secondsSinceStart)) + " seconds) to finish processing " + processList + "...")
} else {
plugin.LogFailure("Background processes did not terminate in time! Forcing shutdown ...")
diff --git a/plugins/statusscreen-tps/plugin.go b/plugins/statusscreen-tps/plugin.go
index eabb868f15e786ecea795ceac8173f2984d4a31c..9b73392c93acbe5d71a52a9ab6b3b3339cd83a3a 100644
--- a/plugins/statusscreen-tps/plugin.go
+++ b/plugins/statusscreen-tps/plugin.go
@@ -36,7 +36,7 @@ var PLUGIN = node.NewPlugin("Statusscreen TPS", func(plugin *node.Plugin) {
return "TPS", strconv.FormatUint(atomic.LoadUint64(&receivedTps), 10) + " received / " + strconv.FormatUint(atomic.LoadUint64(&solidTps), 10) + " new"
})
}, func(plugin *node.Plugin) {
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Statusscreen TPS Tracker", func() {
ticker := time.NewTicker(time.Second)
for {
diff --git a/plugins/statusscreen/statusscreen.go b/plugins/statusscreen/statusscreen.go
index 31b00d08edc337ddb5afccb897e3fc39322c243d..5c6d13e27a7162126eef3a69798110f6758ff059 100644
--- a/plugins/statusscreen/statusscreen.go
+++ b/plugins/statusscreen/statusscreen.go
@@ -100,7 +100,7 @@ func run(plugin *node.Plugin) {
return false
})
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Statusscreen Refresher", func() {
for {
select {
case <-daemon.ShutdownSignal:
@@ -111,7 +111,7 @@ func run(plugin *node.Plugin) {
}
})
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Statusscreen App", func() {
if err := app.SetRoot(frame, true).SetFocus(frame).Run(); err != nil {
panic(err)
}
diff --git a/plugins/tangle/solidifier.go b/plugins/tangle/solidifier.go
index bffbb046a5e08af0a64341ea9f063969e3c29864..2837dd64392805ec55ea6248abdd702c930c583c 100644
--- a/plugins/tangle/solidifier.go
+++ b/plugins/tangle/solidifier.go
@@ -37,7 +37,7 @@ func configureSolidifier(plugin *node.Plugin) {
func runSolidifier(plugin *node.Plugin) {
plugin.LogInfo("Starting Solidifier ...")
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("Tangle Solidifier", func() {
plugin.LogSuccess("Starting Solidifier ... done")
workerPool.Run()
diff --git a/plugins/webapi/plugin.go b/plugins/webapi/plugin.go
index ee2010c4de024d622b2da51705db47604c581e4c..4d80bdad8550809452b03c53e786f0836b0da6b5 100644
--- a/plugins/webapi/plugin.go
+++ b/plugins/webapi/plugin.go
@@ -33,7 +33,7 @@ func configure(plugin *node.Plugin) {
func run(plugin *node.Plugin) {
plugin.LogInfo("Starting Web Server ...")
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("WebAPI Server", func() {
plugin.LogSuccess("Starting Web Server ... done")
if err := Server.Start(":8080"); err != nil {
diff --git a/plugins/zeromq/plugin.go b/plugins/zeromq/plugin.go
index 7d4472cd88a51446bd85fa5281a79b1dce7f3024..aa3f584f75068650d3a988ec06db7f13423ec609 100644
--- a/plugins/zeromq/plugin.go
+++ b/plugins/zeromq/plugin.go
@@ -45,7 +45,7 @@ func run(plugin *node.Plugin) {
plugin.LogInfo("Starting ZeroMQ Publisher (port " + strconv.Itoa(*PORT.Value) + ") ...")
- daemon.BackgroundWorker(func() {
+ daemon.BackgroundWorker("ZeroMQ Publisher", func() {
if err := startPublisher(plugin); err != nil {
plugin.LogFailure("Stopping ZeroMQ Publisher: " + err.Error())
} else {