Refactoring

[invirt/third/libt4.git] / rpc / rpc.cc

diff --git a/rpc/rpc.cc b/rpc/rpc.cc
index a08e287..abbe470 100644 (file)
--- a/rpc/rpc.cc
+++ b/rpc/rpc.cc
@@ -264,7 +264,7 @@ rpcc::get_refconn(shared_ptr<connection> & ch)
 {
     lock ml(chan_m_);
     if (!chan_ || chan_->isdead())
 {
     lock ml(chan_m_);
     if (!chan_ || chan_->isdead())

-        chan_ = connect_to_dst(dst_, this, lossytest_);
+        chan_ = connection::to_dst(dst_, this, lossytest_);

 
     if (chan_)
         ch = chan_;
 
     if (chan_)
         ch = chan_;

@@ -342,7 +342,7 @@ rpcs::rpcs(in_port_t p1, size_t count)
     IF_LEVEL(2) LOG("created with nonce " << nonce_);
 
     reg(rpc_const::bind, &rpcs::rpcbind, this);
     IF_LEVEL(2) LOG("created with nonce " << nonce_);
 
     reg(rpc_const::bind, &rpcs::rpcbind, this);

-    dispatchpool_ = unique_ptr<ThrPool>(new ThrPool(6, false));
+    dispatchpool_ = unique_ptr<thread_pool>(new thread_pool(6, false));

 }
 
 void rpcs::start() {
 }
 
 void rpcs::start() {