     # read through messages to see if anyone finished, if all finished, or if anyone is dead
 
     for message_id, message of @queue
-      if message.name is 'MAP_DONE'
+      if message.name is 'MAPPER_DONE'
         node = message.worker_id
         @mapStatus[node].done = true
         @doneMappers.push node

    failed_reducers = []
    now = new Date().now()
    for reducer in @reducers
      if now - @clientMap[reducer].last_update > 4 * constants.HEARTBEAT_INTERVAL
        #dis fucker dead
        failed_reducers.push reducer


      @startReducer reducer

  startReducer: (reducer) ->
    @send reducer { name: 'START_REDUCE', number_of_mappers: @mappers.length }

  checkReducers: () ->
    # see if anyone finished
