|
|
|
@ -591,7 +591,7 @@ public:
@@ -591,7 +591,7 @@ public:
|
|
|
|
|
bool connect(const std::string& server, const std::string& port) |
|
|
|
|
{ |
|
|
|
|
#if (BOOST_VERSION >= 107000) // boost >= 1.70
|
|
|
|
|
ip::tcp::resolver resolver(*rpc_io_service); |
|
|
|
|
ip::tcp::resolver resolver(stream.get_executor ()); |
|
|
|
|
#else |
|
|
|
|
ip::tcp::resolver resolver(stream.get_io_service()); |
|
|
|
|
#endif |
|
|
|
@ -629,8 +629,14 @@ template <typename Protocol>
@@ -629,8 +629,14 @@ template <typename Protocol>
|
|
|
|
|
class AcceptedConnectionImpl : public AcceptedConnection |
|
|
|
|
{ |
|
|
|
|
public: |
|
|
|
|
#if (BOOST_VERSION >= 107000) // boost >= 1.70
|
|
|
|
|
template<typename Executor> |
|
|
|
|
AcceptedConnectionImpl( |
|
|
|
|
Executor io_service, |
|
|
|
|
#else |
|
|
|
|
AcceptedConnectionImpl( |
|
|
|
|
asio::io_service& io_service, |
|
|
|
|
#endif |
|
|
|
|
ssl::context &context, |
|
|
|
|
bool fUseSSL) : |
|
|
|
|
sslStream(io_service, context), |
|
|
|
@ -682,7 +688,7 @@ static void RPCListen(boost::shared_ptr< basic_socket_acceptor<Protocol, SocketA
@@ -682,7 +688,7 @@ static void RPCListen(boost::shared_ptr< basic_socket_acceptor<Protocol, SocketA
|
|
|
|
|
{ |
|
|
|
|
// Accept connection
|
|
|
|
|
#if (BOOST_VERSION >= 107000) // boost >= 1.70
|
|
|
|
|
AcceptedConnectionImpl<Protocol>* conn = new AcceptedConnectionImpl<Protocol>(*rpc_io_service, context, fUseSSL); |
|
|
|
|
AcceptedConnectionImpl<Protocol>* conn = new AcceptedConnectionImpl<Protocol>(acceptor->get_executor (), context, fUseSSL); |
|
|
|
|
#else |
|
|
|
|
AcceptedConnectionImpl<Protocol>* conn = new AcceptedConnectionImpl<Protocol>(acceptor->get_io_service(), context, fUseSSL); |
|
|
|
|
#endif |
|
|
|
|