diff options
| -rw-r--r-- | dub.json | 27 | ||||
| -rw-r--r-- | lib/d/src/thrift/server/base.d | 44 | ||||
| -rw-r--r-- | lib/d/src/thrift/server/nonblocking.d | 10 |
3 files changed, 70 insertions, 11 deletions
diff --git a/dub.json b/dub.json new file mode 100644 index 000000000..0558781b1 --- /dev/null +++ b/dub.json @@ -0,0 +1,27 @@ +{ + "name": "apache-thrift", + "description": "Apache Thrift D library", + "authors": [ + "Apache Thrift Developers <dev@thrift.apache.org>" + ], + "homepage": "http://thrift.apache.org", + "license": "Apache-2.0", + "dependencies": { + "libevent": { + "version": "*" + }, + "openssl": { + "version": "*" + } + }, + "targetType": "library", + "sourcePaths": [ + "lib/d/src" + ], + "importPaths": [ + "lib/d/src" + ], + "excludedSourceFiles": [ + "src/thrift/index.d" + ] +} diff --git a/lib/d/src/thrift/server/base.d b/lib/d/src/thrift/server/base.d index b19768e62..a23b1c7f2 100644 --- a/lib/d/src/thrift/server/base.d +++ b/lib/d/src/thrift/server/base.d @@ -112,12 +112,44 @@ protected: outputProtocolFactory_ = outputProtocolFactory; } - public TProcessorFactory processorFactory_; - public TServerTransport serverTransport_; - public TTransportFactory inputTransportFactory_; - public TTransportFactory outputTransportFactory_; - public TProtocolFactory inputProtocolFactory_; - public TProtocolFactory outputProtocolFactory_; + TProcessorFactory processorFactory_; + TServerTransport serverTransport_; + TTransportFactory inputTransportFactory_; + TTransportFactory outputTransportFactory_; + TProtocolFactory inputProtocolFactory_; + TProtocolFactory outputProtocolFactory_; + +public: + + @property TProcessorFactory processorFactory() + { + return processorFactory_; + } + + @property TServerTransport serverTransport() + { + return serverTransport_; + } + + @property TTransportFactory inputTransportFactory() + { + return inputTransportFactory_; + } + + @property TTransportFactory outputTransportFactory() + { + return outputTransportFactory_; + } + + @property TProtocolFactory inputProtocolFactory() + { + return inputProtocolFactory_; + } + + @property TProtocolFactory outputProtocolFactory() + { + return outputProtocolFactory_; + } } /** diff --git a/lib/d/src/thrift/server/nonblocking.d b/lib/d/src/thrift/server/nonblocking.d index 02167996e..5860c0c42 100644 --- a/lib/d/src/thrift/server/nonblocking.d +++ b/lib/d/src/thrift/server/nonblocking.d @@ -893,14 +893,14 @@ private { callsSinceResize_ = 0; factoryInputTransport_ = - server_.inputTransportFactory_.getTransport(inputTransport_); + server_.inputTransportFactory.getTransport(inputTransport_); factoryOutputTransport_ = - server_.outputTransportFactory_.getTransport(outputTransport_); + server_.outputTransportFactory.getTransport(outputTransport_); inputProtocol_ = - server_.inputProtocolFactory_.getProtocol(factoryInputTransport_); + server_.inputProtocolFactory.getProtocol(factoryInputTransport_); outputProtocol_ = - server_.outputProtocolFactory_.getProtocol(factoryOutputTransport_); + server_.outputProtocolFactory.getProtocol(factoryOutputTransport_); if (server_.eventHandler) { connectionContext_ = @@ -908,7 +908,7 @@ private { } auto info = TConnectionInfo(inputProtocol_, outputProtocol_, socket_); - processor_ = server_.processorFactory_.getProcessor(info); + processor_ = server_.processorFactory.getProcessor(info); } ~this() { |