removed unwanted changes related to induced delays during execution

Author: rasamala83

lib/workerbroker.go

@@ -24,7 +24,6 @@ import (
 	"os/signal"
 	"sync"
 	"syscall"
-	"time"
 )
 
 // HeraWorkerType defines the possible worker type
@@ -327,7 +326,6 @@ func (broker *WorkerBroker) startWorkerMonitor() (err error) {
 										logger.GetLogger().Log(logger.Debug, "worker (id=", workerclient.ID, "pid=", workerclient.pid, ") received signal. transits from state ", workerclient.Status, " to terminated.")
 									}
 									workerclient.setState(wsUnset) // Set the state to UNSET to make sure worker does not stay in FNSH state so long
-									time.Sleep(5 * time.Second)
 									pool.RestartWorker(workerclient)
 								}
 							} else {

lib/workerclient.go

@@ -591,7 +591,7 @@ func (worker *WorkerClient) initiateRecover(param int, p *WorkerPool, prior Hera
 			param = common.StrandedSkipBreakHiLoad
 		}
 	} else {
-		rv = time.After(time.Millisecond * 100000)
+		rv = time.After(time.Millisecond * time.Duration(GetConfig().StrandedWorkerTimeoutMs))
 	}
 	buff := []byte{byte(param), byte((worker.rqId & 0xFF000000) >> 24), byte((worker.rqId & 0x00FF0000) >> 16),
 		byte((worker.rqId & 0x0000FF00) >> 8), byte((worker.rqId & 0x000000FF))}

lib/workerpool.go

@@ -193,7 +193,6 @@ func (pool *WorkerPool) RestartWorker(worker *WorkerClient) (err error) {
 	}
 	pool.activeQ.Remove(worker)
 	pool.poolCond.L.Unlock()
-	time.Sleep(time.Millisecond * 3000)
 	go pool.spawnWorker(worker.ID)
 	return nil
 }