aboutsummaryrefslogtreecommitdiffstats
path: root/src/lib/utils/os_utils.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/lib/utils/os_utils.cpp')
-rw-r--r--src/lib/utils/os_utils.cpp264
1 files changed, 0 insertions, 264 deletions
diff --git a/src/lib/utils/os_utils.cpp b/src/lib/utils/os_utils.cpp
index d516e7600..ebfd7fa88 100644
--- a/src/lib/utils/os_utils.cpp
+++ b/src/lib/utils/os_utils.cpp
@@ -12,16 +12,6 @@
#include <botan/mem_ops.h>
#include <chrono>
-#if defined(BOTAN_HAS_BOOST_ASIO)
- /*
- * We don't need serial port support anyway, and asking for it
- * causes macro conflicts with Darwin's termios.h when this
- * file is included in the amalgamation. GH #350
- */
- #define BOOST_ASIO_DISABLE_SERIAL_PORT
- #include <boost/asio.hpp>
-#endif
-
#if defined(BOTAN_TARGET_OS_HAS_EXPLICIT_BZERO)
#include <string.h>
#endif
@@ -34,267 +24,13 @@
#include <setjmp.h>
#include <unistd.h>
#include <errno.h>
-
-#if !defined(BOTAN_HAS_BOOST_ASIO)
- #include <sys/socket.h>
- #include <netinet/in.h>
- #include <netdb.h>
-#endif
-
#elif defined(BOTAN_TARGET_OS_TYPE_IS_WINDOWS)
#define NOMINMAX 1
-#if !defined(BOTAN_HAS_BOOST_ASIO)
- #include <winsock2.h>
- #include <ws2tcpip.h>
-#endif
#include <windows.h>
#endif
namespace Botan {
-namespace {
-
-#if defined(BOTAN_HAS_BOOST_ASIO)
-
-class Asio_Socket final : public OS::Socket
- {
- public:
- Asio_Socket(const std::string& hostname, const std::string& service) :
- m_tcp(m_io)
- {
- boost::asio::ip::tcp::resolver resolver(m_io);
- boost::asio::ip::tcp::resolver::query query(hostname, service);
- boost::asio::connect(m_tcp, resolver.resolve(query));
- }
-
- void write(const uint8_t buf[], size_t len) override
- {
- boost::asio::write(m_tcp, boost::asio::buffer(buf, len));
- }
-
- size_t read(uint8_t buf[], size_t len) override
- {
- boost::system::error_code error;
- size_t got = m_tcp.read_some(boost::asio::buffer(buf, len), error);
-
- if(error)
- {
- if(error == boost::asio::error::eof)
- return 0;
- throw boost::system::system_error(error); // Some other error.
- }
-
- return got;
- }
-
- private:
- boost::asio::io_service m_io;
- boost::asio::ip::tcp::socket m_tcp;
- };
-
-#elif defined(BOTAN_TARGET_OS_TYPE_IS_WINDOWS)
-
-class Winsock_Socket final : public OS::Socket
- {
- public:
- Winsock_Socket(const std::string& hostname, const std::string& service)
- {
- WSAData wsa_data;
- WORD wsa_version = MAKEWORD(2, 2);
-
- if (::WSAStartup(wsa_version, &wsa_data) != 0)
- {
- throw Exception("WSAStartup() failed: " + std::to_string(WSAGetLastError()));
- }
-
- if (LOBYTE(wsa_data.wVersion) != 2 || HIBYTE(wsa_data.wVersion) != 2)
- {
- ::WSACleanup();
- throw Exception("Could not find a usable version of Winsock.dll");
- }
-
- addrinfo hints;
- ::memset(&hints, 0, sizeof(addrinfo));
- hints.ai_family = AF_UNSPEC;
- hints.ai_socktype = SOCK_STREAM;
- addrinfo* res;
-
- if(::getaddrinfo(hostname.c_str(), service.c_str(), &hints, &res) != 0)
- {
- throw Exception("Name resolution failed for " + hostname);
- }
-
- for(addrinfo* rp = res; (m_socket == INVALID_SOCKET) && (rp != nullptr); rp = rp->ai_next)
- {
- m_socket = ::socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol);
-
- // unsupported socket type?
- if(m_socket == INVALID_SOCKET)
- continue;
-
- if(::connect(m_socket, rp->ai_addr, rp->ai_addrlen) != 0)
- {
- ::closesocket(m_socket);
- m_socket = INVALID_SOCKET;
- continue;
- }
- }
-
- ::freeaddrinfo(res);
-
- if(m_socket == INVALID_SOCKET)
- {
- throw Exception("Connecting to " + hostname +
- " for service " + service + " failed");
- }
- }
-
- ~Winsock_Socket()
- {
- ::closesocket(m_socket);
- m_socket = INVALID_SOCKET;
- ::WSACleanup();
- }
-
- void write(const uint8_t buf[], size_t len) override
- {
- size_t sent_so_far = 0;
- while(sent_so_far != len)
- {
- const size_t left = len - sent_so_far;
- int sent = ::send(m_socket,
- cast_uint8_ptr_to_char(buf + sent_so_far),
- static_cast<int>(left),
- 0);
-
- if(sent == SOCKET_ERROR)
- throw Exception("Socket write failed with error " +
- std::to_string(::WSAGetLastError()));
- else
- sent_so_far += static_cast<size_t>(sent);
- }
- }
-
- size_t read(uint8_t buf[], size_t len) override
- {
- int got = ::recv(m_socket,
- cast_uint8_ptr_to_char(buf),
- static_cast<int>(len), 0);
-
- if(got == SOCKET_ERROR)
- throw Exception("Socket read failed with error " +
- std::to_string(::WSAGetLastError()));
- return static_cast<size_t>(got);
- }
-
- private:
- SOCKET m_socket = INVALID_SOCKET;
- };
-
-#elif defined(BOTAN_TARGET_OS_TYPE_IS_UNIX)
-class BSD_Socket final : public OS::Socket
- {
- public:
- BSD_Socket(const std::string& hostname, const std::string& service)
- {
- addrinfo hints;
- ::memset(&hints, 0, sizeof(addrinfo));
- hints.ai_family = AF_UNSPEC;
- hints.ai_socktype = SOCK_STREAM;
- addrinfo* res;
-
- if(::getaddrinfo(hostname.c_str(), service.c_str(), &hints, &res) != 0)
- {
- throw Exception("Name resolution failed for " + hostname);
- }
-
- m_fd = -1;
-
- for(addrinfo* rp = res; (m_fd < 0) && (rp != nullptr); rp = rp->ai_next)
- {
- m_fd = ::socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol);
-
- if(m_fd < 0)
- {
- // unsupported socket type?
- continue;
- }
-
- if(::connect(m_fd, rp->ai_addr, rp->ai_addrlen) != 0)
- {
- ::close(m_fd);
- m_fd = -1;
- continue;
- }
- }
-
- ::freeaddrinfo(res);
-
- if(m_fd < 0)
- {
- throw Exception("Connecting to " + hostname +
- " for service " + service + " failed");
- }
- }
-
- ~BSD_Socket()
- {
- ::close(m_fd);
- m_fd = -1;
- }
-
- void write(const uint8_t buf[], size_t len) override
- {
- size_t sent_so_far = 0;
- while(sent_so_far != len)
- {
- const size_t left = len - sent_so_far;
- ssize_t sent = ::write(m_fd, &buf[sent_so_far], left);
- if(sent < 0)
- throw Exception("Socket write failed with error '" +
- std::string(::strerror(errno)) + "'");
- else
- sent_so_far += static_cast<size_t>(sent);
- }
- }
-
- size_t read(uint8_t buf[], size_t len) override
- {
- ssize_t got = ::read(m_fd, buf, len);
-
- if(got < 0)
- throw Exception("Socket read failed with error '" +
- std::string(::strerror(errno)) + "'");
- return static_cast<size_t>(got);
- }
-
- private:
- int m_fd;
- };
-
-#endif
-
-}
-
-std::unique_ptr<OS::Socket>
-OS::open_socket(const std::string& hostname,
- const std::string& service)
- {
-#if defined(BOTAN_HAS_BOOST_ASIO)
- return std::unique_ptr<OS::Socket>(new Asio_Socket(hostname, service));
-
-#elif defined(BOTAN_TARGET_OS_TYPE_IS_WINDOWS)
- return std::unique_ptr<OS::Socket>(new Winsock_Socket(hostname, service));
-
-#elif defined(BOTAN_TARGET_OS_TYPE_IS_UNIX)
- return std::unique_ptr<OS::Socket>(new BSD_Socket(hostname, service));
-
-#else
- // No sockets for you
- return std::unique_ptr<Socket>();
-#endif
- }
-
// Not defined in OS namespace for historical reasons
void secure_scrub_memory(void* ptr, size_t n)
{
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-27 09:40:47 +0000