code: def getCollectDServer(queue, cfg):
      
      server = CollectDServerMP if cfg.collectd_workers > 1 else CollectDServer
      return server(queue, cfg)
docs: Get the appropriate collectd server (multi processed or not)