additional event

roadrunner-server · Jun 13, 2018 · 87fff67 · 87fff67
1 parent 1073eae
commit 87fff67
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/pool.go b/pool.go
@@ -13,6 +13,9 @@ const (
 	// EventWorkerError thrown any worker related even happen (passed with WorkerError)
 	EventWorkerError
 
+	// EventWorkerDead thrown when worker stops worker for any reason.
+	EventWorkerDead
+
 	// EventPoolError caused on pool wide errors
 	EventPoolError
 )

diff --git a/static_pool.go b/static_pool.go
@@ -239,6 +239,7 @@ func (p *StaticPool) destroyWorker(w *Worker, caused interface{}) {
 // watchWorker watches worker state and replaces it if worker fails.
 func (p *StaticPool) watchWorker(w *Worker) {
 	err := w.Wait()
+	p.throw(EventWorkerDead, w)
 
 	// detaching
 	p.muw.Lock()