3 files changed, 38 insertions, 0 deletions
diff --git a/libcmix-network/CMakeLists.txt b/libcmix-network/CMakeLists.txt
index d819bec..6986eea 100644
--- a/libcmix-network/CMakeLists.txt
+++ b/libcmix-network/CMakeLists.txt
@@ -1,7 +1,9 @@
 find_package(Boost COMPONENTS system REQUIRED)
+find_package(Threads)
 
 add_library(cmix-network
 	acceptor.hpp acceptor.cpp
+	connect.hpp connect.cpp
 	server.hpp server.cpp
 	client.hpp client.cpp
 	nodeclient.hpp nodeclient.cpp
@@ -18,6 +20,7 @@ target_include_directories(cmix-network
 target_link_libraries(cmix-network
 	PRIVATE Boost::boost
 	PUBLIC Boost::system
+	PUBLIC ${CMAKE_THREAD_LIBS_INIT}
 	PRIVATE cmix
 )
 
diff --git a/libcmix-network/connect.cpp b/libcmix-network/connect.cpp
new file mode 100644
index 0000000..679748e
--- /dev/null
+++ b/libcmix-network/connect.cpp
@@ -0,0 +1,29 @@
+#include "connect.hpp"
+
+#include <boost/asio/ip/basic_resolver.hpp>
+
+using namespace boost::asio::ip;
+using boost::asio::io_service;
+
+boost::asio::ip::tcp::socket connect(std::string host, std::string port, io_service& io_service) {
+	
+	boost::asio::ip::basic_resolver<tcp> resolver(io_service);
+	
+	boost::asio::ip::basic_resolver_query<tcp> query(host, port);
+	boost::asio::ip::basic_endpoint<tcp> endpoint;
+	
+	for(auto it = resolver.resolve(query); it != boost::asio::ip::tcp::resolver::iterator(); ++it)
+	{
+		endpoint = *it;
+		boost::system::error_code ec;
+		boost::asio::ip::tcp::socket socket(io_service);
+		socket.connect(endpoint, ec);
+		if(ec) {
+			continue;
+		} else {
+			return socket;
+		}
+	}
+	
+	throw std::runtime_error("None of the supplied endpoints responded");
+}
diff --git a/libcmix-network/connect.hpp b/libcmix-network/connect.hpp
new file mode 100644
index 0000000..7f5b5c3
--- /dev/null
+++ b/libcmix-network/connect.hpp
@@ -0,0 +1,6 @@
+#pragma once
+
+#include <boost/asio/ip/tcp.hpp>
+#include <boost/asio/io_service.hpp>
+
+boost::asio::ip::tcp::socket connect(std::string host, std::string port, boost::asio::io_service& io_service);