Committed by
Gerrit Code Review
Assign thread name to HashedWheelTimer
Change-Id: I4805a0c8d93f3a91d9a6dbca5b5c993c574d37a7
Showing
1 changed file
with
4 additions
and
1 deletions
... | @@ -31,6 +31,9 @@ import org.slf4j.LoggerFactory; | ... | @@ -31,6 +31,9 @@ import org.slf4j.LoggerFactory; |
31 | 31 | ||
32 | import javax.net.ssl.SSLContext; | 32 | import javax.net.ssl.SSLContext; |
33 | import javax.net.ssl.SSLEngine; | 33 | import javax.net.ssl.SSLEngine; |
34 | + | ||
35 | +import static org.onlab.util.Tools.groupedThreads; | ||
36 | + | ||
34 | import java.util.concurrent.ThreadPoolExecutor; | 37 | import java.util.concurrent.ThreadPoolExecutor; |
35 | 38 | ||
36 | /** | 39 | /** |
... | @@ -55,7 +58,7 @@ public class OpenflowPipelineFactory | ... | @@ -55,7 +58,7 @@ public class OpenflowPipelineFactory |
55 | super(); | 58 | super(); |
56 | this.controller = controller; | 59 | this.controller = controller; |
57 | this.pipelineExecutor = pipelineExecutor; | 60 | this.pipelineExecutor = pipelineExecutor; |
58 | - this.timer = new HashedWheelTimer(); | 61 | + this.timer = new HashedWheelTimer(groupedThreads("OpenflowPipelineFactory", "timer-%d", log)); |
59 | this.idleHandler = new IdleStateHandler(timer, 20, 25, 0); | 62 | this.idleHandler = new IdleStateHandler(timer, 20, 25, 0); |
60 | this.readTimeoutHandler = new ReadTimeoutHandler(timer, 30); | 63 | this.readTimeoutHandler = new ReadTimeoutHandler(timer, 30); |
61 | this.sslContext = sslContext; | 64 | this.sslContext = sslContext; | ... | ... |
-
Please register or login to post a comment