summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
e6856ad)
At the end of a flush we report statistics at debug, but that requires
System.nanoTime(). Make that call conditional on debug being enabled.
Change-Id: Ibdf02b93ca12d8930227de059d107aa3c4ccb88d
Signed-off-by: Robert Varga <rovarga@cisco.com>
package org.opendaylight.openflowjava.protocol.impl.core.connection;
package org.opendaylight.openflowjava.protocol.impl.core.connection;
+import com.google.common.base.Preconditions;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.concurrent.EventExecutor;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener;
import io.netty.util.concurrent.EventExecutor;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener;
import java.net.InetSocketAddress;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.net.InetSocketAddress;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import com.google.common.base.Preconditions;
-
/**
* Channel handler which bypasses wraps on top of normal Netty pipeline, allowing
* writes to be enqueued from any thread, it then schedules a task pipeline task,
/**
* Channel handler which bypasses wraps on top of normal Netty pipeline, allowing
* writes to be enqueued from any thread, it then schedules a task pipeline task,
- final long stop = System.nanoTime();
- LOG.debug("Flushed {} messages in {}us to channel {}",
+ if (LOG.isDebugEnabled()) {
+ final long stop = System.nanoTime();
+ LOG.debug("Flushed {} messages in {}us to channel {}",
messages, TimeUnit.NANOSECONDS.toMicros(stop - start), channel);
messages, TimeUnit.NANOSECONDS.toMicros(stop - start), channel);
/*
* We are almost ready to terminate. This is a bit tricky, because
/*
* We are almost ready to terminate. This is a bit tricky, because