Unverified Commit c5ff6f9a authored by Dennis Jenkins's avatar Dennis Jenkins Committed by GitHub

Merge pull request #406 from knowledge4igor/delete_obosolete_transport_field

Delete obsolete transport_ field in Client class
parents 0a950855 963c9e6a
...@@ -358,7 +358,6 @@ private: ...@@ -358,7 +358,6 @@ private:
std::shared_ptr<Aio::Reactor> reactor_; std::shared_ptr<Aio::Reactor> reactor_;
ConnectionPool pool; ConnectionPool pool;
std::shared_ptr<Transport> transport_;
Aio::Reactor::Key transportKey; Aio::Reactor::Key transportKey;
std::atomic<uint64_t> ioIndex; std::atomic<uint64_t> ioIndex;
......
...@@ -699,7 +699,6 @@ Client::Options::maxConnectionsPerHost(int val) { ...@@ -699,7 +699,6 @@ Client::Options::maxConnectionsPerHost(int val) {
Client::Client() Client::Client()
: reactor_(Aio::Reactor::create()) : reactor_(Aio::Reactor::create())
, pool() , pool()
, transport_()
, transportKey() , transportKey()
, ioIndex(0) , ioIndex(0)
, queuesLock() , queuesLock()
...@@ -719,9 +718,8 @@ Client::options() { ...@@ -719,9 +718,8 @@ Client::options() {
void void
Client::init(const Client::Options& options) { Client::init(const Client::Options& options) {
pool.init(options.maxConnectionsPerHost_); pool.init(options.maxConnectionsPerHost_);
transport_ = std::make_shared<Transport>();
reactor_->init(Aio::AsyncContext(options.threads_)); reactor_->init(Aio::AsyncContext(options.threads_));
transportKey = reactor_->addHandler(transport_); transportKey = reactor_->addHandler(std::make_shared<Transport>());
reactor_->run(); reactor_->run();
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment