arp_req_rcv_notification,
arp_req_rcv_notification_rejected;
- private OccurenceCounter counter;
+ private final OccurenceCounter counter;
ArpUtilCounters() {
counter = new OccurenceCounter(getClass().getSimpleName(), name(), name());
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.JdkFutureAdapters;
import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.util.concurrent.SettableFuture;
import java.io.UnsupportedEncodingException;
import java.math.BigInteger;
public void onSuccess(RpcResult<Void> result) {
LOG.trace("Successfully sent the arp pkt out for ip {}", dstIpAddress);
}
- });
+ }, MoreExecutors.directExecutor());
macAddrs.put(dstIpAddress, ft);
return ft;
byte[] payload;
String interfaceName = null;
byte[] srcIpBytes;
- byte[] dstIpBytes = null;
- byte[] srcMac = null;
+ byte[] dstIpBytes;
+ byte[] srcMac;
RpcResultBuilder<Void> failureBuilder = RpcResultBuilder.failed();
RpcResultBuilder<Void> successBuilder = RpcResultBuilder.success();
}
private class MacResponderTask implements Runnable {
- ARP arp;
+ final ARP arp;
MacResponderTask(ARP arp) {
this.arp = arp;