(cherry picked from commit f68f1a4578
)
Co-authored-by: zhengchenyu <zhengchenyu16@gmail.com>
This commit is contained in:
parent
c9f2c45209
commit
60b37bbdf7
@ -1284,8 +1284,7 @@ private class Listener extends Thread {
|
|||||||
bind(acceptChannel.socket(), address, backlogLength, conf, portRangeConfig);
|
bind(acceptChannel.socket(), address, backlogLength, conf, portRangeConfig);
|
||||||
//Could be an ephemeral port
|
//Could be an ephemeral port
|
||||||
this.listenPort = acceptChannel.socket().getLocalPort();
|
this.listenPort = acceptChannel.socket().getLocalPort();
|
||||||
Thread.currentThread().setName("Listener at " +
|
LOG.info("Listener at {}:{}", bindAddress, this.listenPort);
|
||||||
bindAddress + "/" + this.listenPort);
|
|
||||||
// create a selector;
|
// create a selector;
|
||||||
selector= Selector.open();
|
selector= Selector.open();
|
||||||
readers = new Reader[readThreads];
|
readers = new Reader[readThreads];
|
||||||
|
Loading…
Reference in New Issue
Block a user