blob: 4f1e5cb9992275905ca8a78ea60c9869a9bc0671 [file] [log] [blame]
package org.apache.hadoop.yarn.server.resourcemanager.resourcetracker;
import org.apache.hadoop.yarn.event.AsyncDispatcher;
import org.apache.hadoop.yarn.event.Event;
import org.apache.hadoop.yarn.event.EventHandler;
class InlineDispatcher extends AsyncDispatcher {
private class InlineEventHandler implements EventHandler {
private final InlineDispatcher dispatcher;
public InlineEventHandler(InlineDispatcher dispatcher) {
this.dispatcher = dispatcher;
}
@Override
public void handle(Event event) {
this.dispatcher.dispatch(event);
}
}
public void dispatch(Event event) {
super.dispatch(event);
}
@Override
public EventHandler getEventHandler() {
return new InlineEventHandler(this);
}
static class EmptyEventHandler implements EventHandler<Event> {
@Override
public void handle(Event event) {
; // ignore
}
}
}