1 files changed, 181 insertions, 0 deletions
diff --git a/src/platforms/windows/windowsSocket.cpp b/src/platforms/windows/windowsSocket.cpp
new file mode 100644
index 00000000..a572a271
--- /dev/null
+++ b/src/platforms/windows/windowsSocket.cpp
@@ -0,0 +1,181 @@
+//
+// VMime library (http://vmime.sourceforge.net)
+// Copyright (C) 2002-2005 Vincent Richard <[email protected]>
+//
+// This program is free software; you can redistribute it and/or
+// modify it under the terms of the GNU General Public License as
+// published by the Free Software Foundation; either version 2 of
+// the License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+// General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program; if not, write to the Free Software
+// Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+//
+
+#pragma warning(disable: 4267)
+
+#include "vmime/platforms/windows/windowsSocket.hpp"
+
+#include "vmime/exception.hpp"
+
+#if VMIME_HAVE_MESSAGING_FEATURES
+
+namespace vmime {
+namespace platforms {
+namespace windows {
+
+
+//
+// posixSocket
+//
+
+windowsSocket::windowsSocket()
+	: m_desc(-1)
+{
+	WSAData wsaData;
+	WSAStartup(MAKEWORD(1, 1), &wsaData);
+}
+
+
+windowsSocket::~windowsSocket()
+{
+	if (m_desc != -1)
+		::closesocket(m_desc);
+	WSACleanup();
+}
+
+
+void windowsSocket::connect(const vmime::string& address, const vmime::port_t port)
+{
+	// Close current connection, if any
+	if (m_desc != -1)
+	{
+		::closesocket(m_desc);
+		m_desc = -1;
+	}
+
+	// Resolve address
+	::sockaddr_in addr;
+
+	memset(&addr, 0, sizeof(addr));
+
+	addr.sin_family = AF_INET;
+	addr.sin_port = htons(static_cast <unsigned short>(port));
+	addr.sin_addr.s_addr = ::inet_addr(address.c_str());
+
+	if (addr.sin_addr.s_addr == static_cast <int>(-1))
+	{
+		::hostent* hostInfo = ::gethostbyname(address.c_str());
+
+		if (hostInfo == NULL)
+		{
+			// Error: cannot resolve address
+			throw vmime::exceptions::connection_error("Cannot resolve address.");
+		}
+	
+		memcpy(reinterpret_cast <char*>(&addr.sin_addr), hostInfo->h_addr, hostInfo->h_length);
+	}
+
+	// Get a new socket
+	m_desc = ::socket(AF_INET, SOCK_STREAM, 0);
+
+	if (m_desc == -1)
+		throw vmime::exceptions::connection_error("Error while creating socket.");
+
+	// Start connection
+	if (::connect(m_desc, reinterpret_cast <sockaddr*>(&addr), sizeof(addr)) == -1)
+	{
+		::closesocket(m_desc);
+		m_desc = -1;
+
+		// Error
+		throw vmime::exceptions::connection_error("Error while connecting socket.");
+	}
+}
+
+
+const bool windowsSocket::isConnected() const
+{
+	return (m_desc != -1);
+}
+
+
+void windowsSocket::disconnect()
+{
+	if (m_desc != -1)
+	{
+		::shutdown(m_desc, SD_BOTH);
+		::closesocket(m_desc);
+
+		m_desc = -1;
+	}
+}
+
+
+void windowsSocket::receive(vmime::string& buffer)
+{
+	int ret = ::recv(m_desc, m_buffer, sizeof(m_buffer), 0);
+
+	if (ret == -1)
+	{
+		// Error or no data
+		return;
+	}
+	else if (ret > 0)
+	{
+		buffer = vmime::string(m_buffer, ret);
+	}
+}
+
+
+const int windowsSocket::receiveRaw(char* buffer, const int count)
+{
+	int ret = ::recv(m_desc, buffer, count, 0);
+
+	if (ret == -1)
+	{
+		// Error or no data
+		return (0);
+	}
+	else
+	{
+		return (ret);
+	}
+}
+
+
+void windowsSocket::send(const vmime::string& buffer)
+{
+	::send(m_desc, buffer.data(), buffer.length(), 0);
+}
+
+
+void windowsSocket::sendRaw(const char* buffer, const int count)
+{
+	::send(m_desc, buffer, count, 0);
+}
+
+
+
+
+//
+// posixSocketFactory
+//
+
+vmime::messaging::socket* windowsSocketFactory::create()
+{
+	return new windowsSocket();
+}
+
+
+} // posix
+} // platforms
+} // vmime
+
+
+#endif // VMIME_HAVE_MESSAGING_FEATURES