You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by co...@apache.org on 2017/07/21 11:27:03 UTC
[16/50] [abbrv] directory-kerby git commit: DIRKRB-562 KDC virtual
memory used increases with the requestes processed. Contributed by Wei.
DIRKRB-562 KDC virtual memory used increases with the requestes processed. Contributed by Wei.
Project: http://git-wip-us.apache.org/repos/asf/directory-kerby/repo
Commit: http://git-wip-us.apache.org/repos/asf/directory-kerby/commit/b9a11ae0
Tree: http://git-wip-us.apache.org/repos/asf/directory-kerby/tree/b9a11ae0
Diff: http://git-wip-us.apache.org/repos/asf/directory-kerby/diff/b9a11ae0
Branch: refs/heads/gssapi
Commit: b9a11ae0449cab835fa5e2f9a3d7cfb155dfa886
Parents: 5cb6d17
Author: plusplusjiajia <ji...@intel.com>
Authored: Wed May 4 09:28:29 2016 +0800
Committer: Colm O hEigeartaigh <co...@apache.org>
Committed: Fri Jul 21 12:25:02 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/kerby/kerberos/kdc/impl/NettyKdcNetwork.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/directory-kerby/blob/b9a11ae0/kerby-kdc/src/main/java/org/apache/kerby/kerberos/kdc/impl/NettyKdcNetwork.java
----------------------------------------------------------------------
diff --git a/kerby-kdc/src/main/java/org/apache/kerby/kerberos/kdc/impl/NettyKdcNetwork.java b/kerby-kdc/src/main/java/org/apache/kerby/kerberos/kdc/impl/NettyKdcNetwork.java
index 86160a9..cfa4adb 100644
--- a/kerby-kdc/src/main/java/org/apache/kerby/kerberos/kdc/impl/NettyKdcNetwork.java
+++ b/kerby-kdc/src/main/java/org/apache/kerby/kerberos/kdc/impl/NettyKdcNetwork.java
@@ -51,6 +51,7 @@ public class NettyKdcNetwork {
private EventLoopGroup bossGroup;
private EventLoopGroup workerGroup;
private EventLoopGroup group;
+ private DefaultEventExecutorGroup executorGroup;
private static final Logger LOG = LoggerFactory.getLogger(NettyKdcNetwork.class);
public void init(KdcContext kdcContext) {
@@ -58,6 +59,7 @@ public class NettyKdcNetwork {
// Configure the server.
bossGroup = new NioEventLoopGroup(1);
workerGroup = new NioEventLoopGroup();
+ executorGroup = new DefaultEventExecutorGroup(10); //TODO: to configure.
}
public void listen(InetSocketAddress tcpAddress,
@@ -110,7 +112,7 @@ public class NettyKdcNetwork {
public void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast(new KrbMessageDecoder());
- p.addLast(new DefaultEventExecutorGroup(10), //TODO: to configure.
+ p.addLast(executorGroup,
"KDC_HANDLER",
new NettyKdcHandler(kdcContext));
}