Commented out code, the threaded server impl.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/bf074ef9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/bf074ef9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/bf074ef9 Branch: refs/heads/0.1.5 Commit: bf074ef9bae8f91bfdccf85c8c130e8c9adcb0d7 Parents: eb3f8f7 Author: Aaron McCurry <[email protected]> Authored: Sat Mar 30 21:44:05 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Sat Mar 30 21:44:05 2013 -0400 ---------------------------------------------------------------------- .../java/org/apache/blur/thrift/ThriftServer.java | 9 +++++++++ 1 files changed, 9 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/bf074ef9/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java index ad1537b..71eaa64 100644 --- a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java @@ -99,6 +99,15 @@ public class ThriftServer { public void start() throws TTransportException { Blur.Processor<Blur.Iface> processor = new Blur.Processor<Blur.Iface>(_iface); + // TServerSocket serverTransport = new + // TServerSocket(getBindInetSocketAddress(_configuration)); + // + // TThreadPoolServer.Args args = new + // TThreadPoolServer.Args(serverTransport); + // args.processor(processor); + // args.transportFactory(new TFramedTransport.Factory()); + // args.protocolFactory(new TBinaryProtocol.Factory(true, true)); + // _server = new TThreadPoolServer(args); TNonblockingServerSocket serverTransport = new TNonblockingServerSocket(getBindInetSocketAddress(_configuration)); Args args = new Args(serverTransport);
