     blocked (ms) ->
         # record that something blocked for over 10ms
         winston.debug("BLOCKED for #{ms}ms")
-
 
     async.series([
         (cb) ->

                    g("timed out")
            setTimeout(f, 15000) # timeout after some seconds

        @push_data_to_client(JSON_CHANNEL, to_json(mesg))
        if not listen
            cb?()
            return


exports.start_server = start_server = (cb) ->
    # the order of init below is important
    winston.debug("port = #{program.port}, proxy_port=#{program.proxy_port}")
    winston.info("Using keyspace #{program.keyspace}")
    hosts = program.database_nodes.split(',')
