code: func managementTask(c *asyncConnHdl, ctl workerCtl) (sig *interrupt_code, te *taskStatus) {
  	/* TODO:
  	connected:
  		clearChannels();
  		startWokers();
  	disconnected:
  		?
  	on_fault:
  		disconnect();
  		goto disconnected;
  	on_exit:
  		?
  	*/
  	//	log.Println("MGR: do task ...")
  	select {
  	case stat := <-c.feedback:
  		// do the shutdown for now -- TODO: try reconnect
  		if stat.event == faulted || stat.event == quit_processed {
  			if stat.event == faulted {
  				// REVU - pretty please TODO do the customized log
  				log.Printf("<INFO> - %s (manager task) FAULT EVENT ", c)
  			}
  			// REVU - pretty please TODO do the customized log
  			//			log.Printf("<INFO> %s - (manager task) SHUTTING DOWN ...", c)
  			c.shutdown <- true
  
  			// REVU - pretty please TODO do the customized log
  			//			log.Printf("<INFO> %s - (manager task) RAISING SIGNAL STOP ...", c)
  			go func() { c.reqProcCtl <- stop }()
  			go func() { c.rspProcCtl <- stop }()
  			go func() { c.heartbeatCtl <- stop }()
  			go func() { c.managerCtl <- stop }()
  		}
  	case s := <-ctl:
  		return &s, &ok_status
  	}
  
  	return nil, &ok_status
  }
docs: // ----------------------------------------------------------------------------
  // asynchronous tasks (go routine/workers)
  // ----------------------------------------------------------------------------