                         if that._error_thresh
                             error_timer   = setTimeout(error_too_long,   that._error_thresh*1000)
 
-                        winston.debug("[#{that._concurrent_queries} concurrent]  rethink: query -- '#{query_string}'")
-                        if that._concurrent_queries > that._concurrent_warn
-                            winston.debug("rethink: *** concurrent_warn *** CONCURRENT WARN THRESHOLD EXCEEDED!")
                         g = (err, x) ->
                             report_time = ->
                                 that._concurrent_queries -= 1

                        that._concurrent_queries ?= 0
                        that._concurrent_queries += 1

                        # choose a random connection
                        id = misc.random_choice(misc.keys(that._conn))
                        conn = that._conn[id]

        @_error_thresh     = opts.error
        @_mod_warn         = opts.mod_warn
        @_concurrent_warn  = opts.concurrent_warn
        @_concurrent_error = opts.concurrent_error
        @_all_hosts        = opts.all_hosts
        @_stats_cached     = undefined
        @_user_query_stats = new UserQueryStats(@dbg("user_query_stats"))
