4 files changed, 473 insertions, 473 deletions

diff --git a/source/OSSupport/GZipFile.cpp b/source/OSSupport/GZipFile.cpp
index c57de5198..cbf6be6c4 100644
--- a/source/OSSupport/GZipFile.cpp
+++ b/source/OSSupport/GZipFile.cpp
@@ -1,107 +1,107 @@
-

-// GZipFile.cpp

-

-// Implements the cGZipFile class representing a RAII wrapper over zlib's GZip file routines

-

-#include "Globals.h"

-#include "GZipFile.h"

-

-

-

-

-

-cGZipFile::cGZipFile(void) :

-	m_File(NULL)

-{

-}

-

-

-

-

-

-cGZipFile::~cGZipFile()

-{

-	Close();

-}

-

-

-

-

-

-bool cGZipFile::Open(const AString & a_FileName, eMode a_Mode)

-{

-	if (m_File != NULL)

-	{

-		ASSERT(!"A file is already open in this object");

-		return false;

-	}

-	m_File = gzopen(a_FileName.c_str(), (a_Mode == fmRead) ? "r" : "w");

-	m_Mode = a_Mode;

-	return (m_File != NULL);

-}

-

-

-

-

-

-void cGZipFile::Close(void)

-{

-	if (m_File != NULL)

-	{

-		gzclose(m_File);

-		m_File = NULL;

-	}

-}

-

-

-

-

-

-int cGZipFile::ReadRestOfFile(AString & a_Contents)

-{

-	if (m_File == NULL)

-	{

-		ASSERT(!"No file has been opened");

-		return -1;

-	}

-	

-	if (m_Mode != fmRead)

-	{

-		ASSERT(!"Bad file mode, cannot read");

-		return -1;

-	}

-	

-	// Since the gzip format doesn't really support getting the uncompressed length, we need to read incrementally. Yuck!

-	int NumBytesRead = 0;

-	char Buffer[64 KiB];

-	while ((NumBytesRead = gzread(m_File, Buffer, sizeof(Buffer))) > 0)

-	{

-		a_Contents.append(Buffer, NumBytesRead);

-	}

-	return NumBytesRead;

-}

-

-

-

-

-

-bool cGZipFile::Write(const char * a_Contents, int a_Size)

-{

-	if (m_File == NULL)

-	{

-		ASSERT(!"No file has been opened");

-		return false;

-	}

-

-	if (m_Mode != fmWrite)

-	{

-		ASSERT(!"Bad file mode, cannot write");

-		return false;

-	}

-

-	return (gzwrite(m_File, a_Contents, a_Size) != 0);

-}

-

-

-

-

+
+// GZipFile.cpp
+
+// Implements the cGZipFile class representing a RAII wrapper over zlib's GZip file routines
+
+#include "Globals.h"
+#include "GZipFile.h"
+
+
+
+
+
+cGZipFile::cGZipFile(void) :
+	m_File(NULL)
+{
+}
+
+
+
+
+
+cGZipFile::~cGZipFile()
+{
+	Close();
+}
+
+
+
+
+
+bool cGZipFile::Open(const AString & a_FileName, eMode a_Mode)
+{
+	if (m_File != NULL)
+	{
+		ASSERT(!"A file is already open in this object");
+		return false;
+	}
+	m_File = gzopen(a_FileName.c_str(), (a_Mode == fmRead) ? "r" : "w");
+	m_Mode = a_Mode;
+	return (m_File != NULL);
+}
+
+
+
+
+
+void cGZipFile::Close(void)
+{
+	if (m_File != NULL)
+	{
+		gzclose(m_File);
+		m_File = NULL;
+	}
+}
+
+
+
+
+
+int cGZipFile::ReadRestOfFile(AString & a_Contents)
+{
+	if (m_File == NULL)
+	{
+		ASSERT(!"No file has been opened");
+		return -1;
+	}
+	
+	if (m_Mode != fmRead)
+	{
+		ASSERT(!"Bad file mode, cannot read");
+		return -1;
+	}
+	
+	// Since the gzip format doesn't really support getting the uncompressed length, we need to read incrementally. Yuck!
+	int NumBytesRead = 0;
+	char Buffer[64 KiB];
+	while ((NumBytesRead = gzread(m_File, Buffer, sizeof(Buffer))) > 0)
+	{
+		a_Contents.append(Buffer, NumBytesRead);
+	}
+	return NumBytesRead;
+}
+
+
+
+
+
+bool cGZipFile::Write(const char * a_Contents, int a_Size)
+{
+	if (m_File == NULL)
+	{
+		ASSERT(!"No file has been opened");
+		return false;
+	}
+
+	if (m_Mode != fmWrite)
+	{
+		ASSERT(!"Bad file mode, cannot write");
+		return false;
+	}
+
+	return (gzwrite(m_File, a_Contents, a_Size) != 0);
+}
+
+
+
+
diff --git a/source/OSSupport/GZipFile.h b/source/OSSupport/GZipFile.h
index f20b4d11e..e5aa68afa 100644
--- a/source/OSSupport/GZipFile.h
+++ b/source/OSSupport/GZipFile.h
@@ -1,52 +1,52 @@
-

-// GZipFile.h

-

-// Declares the cGZipFile class representing a RAII wrapper over zlib's GZip file routines

-

-

-

-

-

-#pragma once

-

-#include "zlib.h"

-

-

-

-

-

-class cGZipFile

-{

-public:

-	enum eMode

-	{

-		fmRead,      // Read-only. If the file doesn't exist, object will not be valid

-		fmWrite,     // Write-only. If the file already exists, it will be overwritten

-	} ;

-	

-	cGZipFile(void);

-	~cGZipFile();

-	

-	/// Opens the file. Returns true if successful. Fails if a file has already been opened through this object.

-	bool Open(const AString & a_FileName, eMode a_Mode);

-	

-	/// Closes the file, flushing all buffers. This object may be then reused for a different file and / or mode

-	void Close(void);

-	

-	/// Reads the rest of the file and decompresses it into a_Contents. Returns the number of decompressed bytes, <0 for error

-	int ReadRestOfFile(AString & a_Contents);

-	

-	/// Writes a_Contents into file, compressing it along the way. Returns true if successful. Multiple writes are supported.

-	bool Write(const AString & a_Contents) { return Write(a_Contents.data(), (int)(a_Contents.size())); }

-	

-	bool Write(const char * a_Data, int a_Size);

-	

-protected:

-	gzFile m_File;

-	eMode  m_Mode;

-} ;

-

-

-

-

-

+
+// GZipFile.h
+
+// Declares the cGZipFile class representing a RAII wrapper over zlib's GZip file routines
+
+
+
+
+
+#pragma once
+
+#include "zlib.h"
+
+
+
+
+
+class cGZipFile
+{
+public:
+	enum eMode
+	{
+		fmRead,      // Read-only. If the file doesn't exist, object will not be valid
+		fmWrite,     // Write-only. If the file already exists, it will be overwritten
+	} ;
+	
+	cGZipFile(void);
+	~cGZipFile();
+	
+	/// Opens the file. Returns true if successful. Fails if a file has already been opened through this object.
+	bool Open(const AString & a_FileName, eMode a_Mode);
+	
+	/// Closes the file, flushing all buffers. This object may be then reused for a different file and / or mode
+	void Close(void);
+	
+	/// Reads the rest of the file and decompresses it into a_Contents. Returns the number of decompressed bytes, <0 for error
+	int ReadRestOfFile(AString & a_Contents);
+	
+	/// Writes a_Contents into file, compressing it along the way. Returns true if successful. Multiple writes are supported.
+	bool Write(const AString & a_Contents) { return Write(a_Contents.data(), (int)(a_Contents.size())); }
+	
+	bool Write(const char * a_Data, int a_Size);
+	
+protected:
+	gzFile m_File;
+	eMode  m_Mode;
+} ;
+
+
+
+
+
diff --git a/source/OSSupport/ListenThread.cpp b/source/OSSupport/ListenThread.cpp
index 89aa6ea75..4542326ef 100644
--- a/source/OSSupport/ListenThread.cpp
+++ b/source/OSSupport/ListenThread.cpp
@@ -1,231 +1,231 @@
-

-// ListenThread.cpp

-

-// Implements the cListenThread class representing the thread that listens for client connections

-

-#include "Globals.h"

-#include "ListenThread.h"

-

-

-

-

-

-cListenThread::cListenThread(cCallback & a_Callback, cSocket::eFamily a_Family, const AString & a_ServiceName) :

-	super(Printf("ListenThread %s", a_ServiceName.c_str())),

-	m_Callback(a_Callback),

-	m_Family(a_Family),

-	m_ShouldReuseAddr(false),

-	m_ServiceName(a_ServiceName)

-{

-}

-

-

-

-

-

-cListenThread::~cListenThread()

-{

-	// TODO

-}

-

-

-

-

-

-bool cListenThread::Initialize(const AString & a_PortsString)

-{

-	ASSERT(m_Sockets.empty());  // Not yet started

-	

-	if (!CreateSockets(a_PortsString))

-	{

-		return false;

-	}

-	

-	return true;

-}

-

-

-

-

-

-bool cListenThread::Start(void)

-{

-	if (m_Sockets.empty())

-	{

-		// There are no sockets listening, either forgotten to initialize or the user specified no listening ports

-		// Report as successful, though

-		return true;

-	}

-	return super::Start();

-}

-

-

-

-

-

-void cListenThread::Stop(void)

-{

-	if (m_Sockets.empty())

-	{

-		// No sockets means no thread was running in the first place

-		return;

-	}

-

-	m_ShouldTerminate = true;

-	

-	// Close one socket to wake the thread up from the select() call

-	m_Sockets[0].CloseSocket();

-	

-	// Wait for the thread to finish

-	super::Wait();

-	

-	// Clean up all sockets

-	m_Sockets.clear();

-}

-

-

-

-

-

-void cListenThread::SetReuseAddr(bool a_Reuse)

-{

-	ASSERT(m_Sockets.empty());  // Must not have been Initialize()d yet

-	

-	m_ShouldReuseAddr = a_Reuse;

-}

-

-

-

-

-

-bool cListenThread::CreateSockets(const AString & a_PortsString)

-{

-	AStringVector Ports = StringSplitAndTrim(a_PortsString, ",");

-	

-	if (Ports.empty())

-	{

-		return false;

-	}

-	

-	AString FamilyStr = m_ServiceName;

-	switch (m_Family)

-	{

-		case cSocket::IPv4: FamilyStr.append(" IPv4"); break;

-		case cSocket::IPv6: FamilyStr.append(" IPv6"); break;

-		default:

-		{

-			ASSERT(!"Unknown address family");

-			break;

-		}

-	}

-	

-	for (AStringVector::const_iterator itr = Ports.begin(), end = Ports.end(); itr != end; ++itr)

-	{

-		int Port = atoi(itr->c_str());

-		if ((Port <= 0) || (Port > 65535))

-		{

-			LOGWARNING("%s: Invalid port specified: \"%s\".", FamilyStr.c_str(), itr->c_str());

-			continue;

-		}

-		m_Sockets.push_back(cSocket::CreateSocket(m_Family));

-		if (!m_Sockets.back().IsValid())

-		{

-			LOGWARNING("%s: Cannot create listening socket for port %d: \"%s\"", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());

-			m_Sockets.pop_back();

-			continue;

-		}

-

-		if (m_ShouldReuseAddr)

-		{

-			if (!m_Sockets.back().SetReuseAddress())

-			{

-				LOG("%s: Port %d cannot reuse addr, syscall failed: \"%s\".", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());

-			}

-		}

-		

-		// Bind to port:

-		bool res = false;

-		switch (m_Family)

-		{

-			case cSocket::IPv4: res = m_Sockets.back().BindToAnyIPv4(Port); break;

-			case cSocket::IPv6: res = m_Sockets.back().BindToAnyIPv6(Port); break;

-			default:

-			{

-				ASSERT(!"Unknown address family");

-				res = false;

-			}

-		}

-		if (!res)

-		{

-			LOGWARNING("%s: Cannot bind port %d: \"%s\".", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());

-			m_Sockets.pop_back();

-			continue;

-		}

-		

-		if (!m_Sockets.back().Listen())

-		{

-			LOGWARNING("%s: Cannot listen on port %d: \"%s\".", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());

-			m_Sockets.pop_back();

-			continue;

-		}

-		

-		LOGINFO("%s: Port %d is open for connections", FamilyStr.c_str(), Port);

-	}  // for itr - Ports[]

-	

-	return !(m_Sockets.empty());

-}

-

-

-

-

-

-void cListenThread::Execute(void)

-{

-	if (m_Sockets.empty())

-	{

-		LOGD("Empty cListenThread, ending thread now.");

-		return;

-	}

-	

-	// Find the highest socket number:

-	cSocket::xSocket Highest = m_Sockets[0].GetSocket();

-	for (cSockets::iterator itr = m_Sockets.begin(), end = m_Sockets.end(); itr != end; ++itr)

-	{

-		if (itr->GetSocket() > Highest)

-		{

-			Highest = itr->GetSocket();

-		}

-	}  // for itr - m_Sockets[]

-

-	while (!m_ShouldTerminate)

-	{

-		// Put all sockets into a FD set:

-		fd_set fdRead;

-		FD_ZERO(&fdRead);

-		for (cSockets::iterator itr = m_Sockets.begin(), end = m_Sockets.end(); itr != end; ++itr)

-		{

-			FD_SET(itr->GetSocket(), &fdRead);

-		}  // for itr - m_Sockets[]

-		

-		timeval tv;  // On Linux select() doesn't seem to wake up when socket is closed, so let's kinda busy-wait:

-		tv.tv_sec = 1;

-		tv.tv_usec = 0;

-		if (select(Highest + 1, &fdRead, NULL, NULL, &tv) == -1)

-		{

-			LOG("select(R) call failed in cListenThread: \"%s\"", cSocket::GetLastErrorString().c_str());

-			continue;

-		}

-		for (cSockets::iterator itr = m_Sockets.begin(), end = m_Sockets.end(); itr != end; ++itr)

-		{

-			if (itr->IsValid() && FD_ISSET(itr->GetSocket(), &fdRead))

-			{

-				cSocket Client = (m_Family == cSocket::IPv4) ? itr->AcceptIPv4() : itr->AcceptIPv6();

-				m_Callback.OnConnectionAccepted(Client);

-			}

-		}  // for itr - m_Sockets[]

-	}  // while (!m_ShouldTerminate)

-}

-

-

-

-

+
+// ListenThread.cpp
+
+// Implements the cListenThread class representing the thread that listens for client connections
+
+#include "Globals.h"
+#include "ListenThread.h"
+
+
+
+
+
+cListenThread::cListenThread(cCallback & a_Callback, cSocket::eFamily a_Family, const AString & a_ServiceName) :
+	super(Printf("ListenThread %s", a_ServiceName.c_str())),
+	m_Callback(a_Callback),
+	m_Family(a_Family),
+	m_ShouldReuseAddr(false),
+	m_ServiceName(a_ServiceName)
+{
+}
+
+
+
+
+
+cListenThread::~cListenThread()
+{
+	// TODO
+}
+
+
+
+
+
+bool cListenThread::Initialize(const AString & a_PortsString)
+{
+	ASSERT(m_Sockets.empty());  // Not yet started
+	
+	if (!CreateSockets(a_PortsString))
+	{
+		return false;
+	}
+	
+	return true;
+}
+
+
+
+
+
+bool cListenThread::Start(void)
+{
+	if (m_Sockets.empty())
+	{
+		// There are no sockets listening, either forgotten to initialize or the user specified no listening ports
+		// Report as successful, though
+		return true;
+	}
+	return super::Start();
+}
+
+
+
+
+
+void cListenThread::Stop(void)
+{
+	if (m_Sockets.empty())
+	{
+		// No sockets means no thread was running in the first place
+		return;
+	}
+
+	m_ShouldTerminate = true;
+	
+	// Close one socket to wake the thread up from the select() call
+	m_Sockets[0].CloseSocket();
+	
+	// Wait for the thread to finish
+	super::Wait();
+	
+	// Clean up all sockets
+	m_Sockets.clear();
+}
+
+
+
+
+
+void cListenThread::SetReuseAddr(bool a_Reuse)
+{
+	ASSERT(m_Sockets.empty());  // Must not have been Initialize()d yet
+	
+	m_ShouldReuseAddr = a_Reuse;
+}
+
+
+
+
+
+bool cListenThread::CreateSockets(const AString & a_PortsString)
+{
+	AStringVector Ports = StringSplitAndTrim(a_PortsString, ",");
+	
+	if (Ports.empty())
+	{
+		return false;
+	}
+	
+	AString FamilyStr = m_ServiceName;
+	switch (m_Family)
+	{
+		case cSocket::IPv4: FamilyStr.append(" IPv4"); break;
+		case cSocket::IPv6: FamilyStr.append(" IPv6"); break;
+		default:
+		{
+			ASSERT(!"Unknown address family");
+			break;
+		}
+	}
+	
+	for (AStringVector::const_iterator itr = Ports.begin(), end = Ports.end(); itr != end; ++itr)
+	{
+		int Port = atoi(itr->c_str());
+		if ((Port <= 0) || (Port > 65535))
+		{
+			LOGWARNING("%s: Invalid port specified: \"%s\".", FamilyStr.c_str(), itr->c_str());
+			continue;
+		}
+		m_Sockets.push_back(cSocket::CreateSocket(m_Family));
+		if (!m_Sockets.back().IsValid())
+		{
+			LOGWARNING("%s: Cannot create listening socket for port %d: \"%s\"", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());
+			m_Sockets.pop_back();
+			continue;
+		}
+
+		if (m_ShouldReuseAddr)
+		{
+			if (!m_Sockets.back().SetReuseAddress())
+			{
+				LOG("%s: Port %d cannot reuse addr, syscall failed: \"%s\".", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());
+			}
+		}
+		
+		// Bind to port:
+		bool res = false;
+		switch (m_Family)
+		{
+			case cSocket::IPv4: res = m_Sockets.back().BindToAnyIPv4(Port); break;
+			case cSocket::IPv6: res = m_Sockets.back().BindToAnyIPv6(Port); break;
+			default:
+			{
+				ASSERT(!"Unknown address family");
+				res = false;
+			}
+		}
+		if (!res)
+		{
+			LOGWARNING("%s: Cannot bind port %d: \"%s\".", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());
+			m_Sockets.pop_back();
+			continue;
+		}
+		
+		if (!m_Sockets.back().Listen())
+		{
+			LOGWARNING("%s: Cannot listen on port %d: \"%s\".", FamilyStr.c_str(), Port, cSocket::GetLastErrorString().c_str());
+			m_Sockets.pop_back();
+			continue;
+		}
+		
+		LOGINFO("%s: Port %d is open for connections", FamilyStr.c_str(), Port);
+	}  // for itr - Ports[]
+	
+	return !(m_Sockets.empty());
+}
+
+
+
+
+
+void cListenThread::Execute(void)
+{
+	if (m_Sockets.empty())
+	{
+		LOGD("Empty cListenThread, ending thread now.");
+		return;
+	}
+	
+	// Find the highest socket number:
+	cSocket::xSocket Highest = m_Sockets[0].GetSocket();
+	for (cSockets::iterator itr = m_Sockets.begin(), end = m_Sockets.end(); itr != end; ++itr)
+	{
+		if (itr->GetSocket() > Highest)
+		{
+			Highest = itr->GetSocket();
+		}
+	}  // for itr - m_Sockets[]
+
+	while (!m_ShouldTerminate)
+	{
+		// Put all sockets into a FD set:
+		fd_set fdRead;
+		FD_ZERO(&fdRead);
+		for (cSockets::iterator itr = m_Sockets.begin(), end = m_Sockets.end(); itr != end; ++itr)
+		{
+			FD_SET(itr->GetSocket(), &fdRead);
+		}  // for itr - m_Sockets[]
+		
+		timeval tv;  // On Linux select() doesn't seem to wake up when socket is closed, so let's kinda busy-wait:
+		tv.tv_sec = 1;
+		tv.tv_usec = 0;
+		if (select(Highest + 1, &fdRead, NULL, NULL, &tv) == -1)
+		{
+			LOG("select(R) call failed in cListenThread: \"%s\"", cSocket::GetLastErrorString().c_str());
+			continue;
+		}
+		for (cSockets::iterator itr = m_Sockets.begin(), end = m_Sockets.end(); itr != end; ++itr)
+		{
+			if (itr->IsValid() && FD_ISSET(itr->GetSocket(), &fdRead))
+			{
+				cSocket Client = (m_Family == cSocket::IPv4) ? itr->AcceptIPv4() : itr->AcceptIPv6();
+				m_Callback.OnConnectionAccepted(Client);
+			}
+		}  // for itr - m_Sockets[]
+	}  // while (!m_ShouldTerminate)
+}
+
+
+
+
diff --git a/source/OSSupport/ListenThread.h b/source/OSSupport/ListenThread.h
index c29140ed3..4e337d814 100644
--- a/source/OSSupport/ListenThread.h
+++ b/source/OSSupport/ListenThread.h
@@ -1,83 +1,83 @@
-

-// ListenThread.h

-

-// Declares the cListenThread class representing the thread that listens for client connections

-

-

-

-

-

-#pragma once

-

-#include "IsThread.h"

-#include "Socket.h"

-

-

-

-

-

-// fwd:

-class cServer;

-

-

-

-

-

-class cListenThread :

-	public cIsThread

-{

-	typedef cIsThread super;

-	

-public:

-	/// Used as the callback for connection events

-	class cCallback

-	{

-	public:

-		/// This callback is called whenever a socket connection is accepted

-		virtual void OnConnectionAccepted(cSocket & a_Socket) = 0;

-	} ;

-	

-	cListenThread(cCallback & a_Callback, cSocket::eFamily a_Family, const AString & a_ServiceName = "");

-	~cListenThread();

-	

-	/// Creates all the sockets, returns trus if successful, false if not.

-	bool Initialize(const AString & a_PortsString);

-	

-	bool Start(void);

-	

-	void Stop(void);

-	

-	/// Call before Initialize() to set the "reuse" flag on the sockets

-	void SetReuseAddr(bool a_Reuse = true);

-	

-protected:

-	typedef std::vector<cSocket> cSockets;

-

-	/// The callback which to notify of incoming connections	

-	cCallback & m_Callback;

-	

-	/// Socket address family to use

-	cSocket::eFamily m_Family;

-	

-	/// Sockets that are being monitored

-	cSockets m_Sockets;

-	

-	/// If set to true, the SO_REUSEADDR socket option is set to true

-	bool m_ShouldReuseAddr;

-	

-	/// Name of the service that's listening on the ports; for logging purposes only

-	AString m_ServiceName;

-	

-	

-	/** Fills in m_Sockets with individual sockets, each for one port specified in a_PortsString.

-	Returns true if successful and at least one socket has been created

-	*/

-	bool CreateSockets(const AString & a_PortsString);

-	

-	// cIsThread override:

-	virtual void Execute(void) override;

-} ;

-

-

-

-

+
+// ListenThread.h
+
+// Declares the cListenThread class representing the thread that listens for client connections
+
+
+
+
+
+#pragma once
+
+#include "IsThread.h"
+#include "Socket.h"
+
+
+
+
+
+// fwd:
+class cServer;
+
+
+
+
+
+class cListenThread :
+	public cIsThread
+{
+	typedef cIsThread super;
+	
+public:
+	/// Used as the callback for connection events
+	class cCallback
+	{
+	public:
+		/// This callback is called whenever a socket connection is accepted
+		virtual void OnConnectionAccepted(cSocket & a_Socket) = 0;
+	} ;
+	
+	cListenThread(cCallback & a_Callback, cSocket::eFamily a_Family, const AString & a_ServiceName = "");
+	~cListenThread();
+	
+	/// Creates all the sockets, returns trus if successful, false if not.
+	bool Initialize(const AString & a_PortsString);
+	
+	bool Start(void);
+	
+	void Stop(void);
+	
+	/// Call before Initialize() to set the "reuse" flag on the sockets
+	void SetReuseAddr(bool a_Reuse = true);
+	
+protected:
+	typedef std::vector<cSocket> cSockets;
+
+	/// The callback which to notify of incoming connections	
+	cCallback & m_Callback;
+	
+	/// Socket address family to use
+	cSocket::eFamily m_Family;
+	
+	/// Sockets that are being monitored
+	cSockets m_Sockets;
+	
+	/// If set to true, the SO_REUSEADDR socket option is set to true
+	bool m_ShouldReuseAddr;
+	
+	/// Name of the service that's listening on the ports; for logging purposes only
+	AString m_ServiceName;
+	
+	
+	/** Fills in m_Sockets with individual sockets, each for one port specified in a_PortsString.
+	Returns true if successful and at least one socket has been created
+	*/
+	bool CreateSockets(const AString & a_PortsString);
+	
+	// cIsThread override:
+	virtual void Execute(void) override;
+} ;
+
+
+
+