aboutsummaryrefslogtreecommitdiff
path: root/dep/src/sockets/StreamSocket.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'dep/src/sockets/StreamSocket.cpp')
-rw-r--r--dep/src/sockets/StreamSocket.cpp26
1 files changed, 26 insertions, 0 deletions
diff --git a/dep/src/sockets/StreamSocket.cpp b/dep/src/sockets/StreamSocket.cpp
index 84bcf7bdca1..c8a3c32e496 100644
--- a/dep/src/sockets/StreamSocket.cpp
+++ b/dep/src/sockets/StreamSocket.cpp
@@ -1,10 +1,12 @@
#include "StreamSocket.h"
#include "ISocketHandler.h"
+
#ifdef SOCKETS_NAMESPACE
namespace SOCKETS_NAMESPACE {
#endif
+
StreamSocket::StreamSocket(ISocketHandler& h) : Socket(h)
,m_bConnecting(false)
,m_connect_timeout(5)
@@ -18,10 +20,12 @@ StreamSocket::StreamSocket(ISocketHandler& h) : Socket(h)
{
}
+
StreamSocket::~StreamSocket()
{
}
+
void StreamSocket::SetConnecting(bool x)
{
if (x != m_bConnecting)
@@ -38,11 +42,13 @@ void StreamSocket::SetConnecting(bool x)
}
}
+
bool StreamSocket::Connecting()
{
return m_bConnecting;
}
+
bool StreamSocket::Ready()
{
if (GetSocket() != INVALID_SOCKET && !Connecting() && !CloseAndDelete())
@@ -50,95 +56,115 @@ bool StreamSocket::Ready()
return false;
}
+
void StreamSocket::SetConnectTimeout(int x)
{
m_connect_timeout = x;
}
+
int StreamSocket::GetConnectTimeout()
{
return m_connect_timeout;
}
+
void StreamSocket::SetFlushBeforeClose(bool x)
{
m_flush_before_close = x;
}
+
bool StreamSocket::GetFlushBeforeClose()
{
return m_flush_before_close;
}
+
int StreamSocket::GetConnectionRetry()
{
return m_connection_retry;
}
+
void StreamSocket::SetConnectionRetry(int x)
{
m_connection_retry = x;
}
+
int StreamSocket::GetConnectionRetries()
{
return m_retries;
}
+
void StreamSocket::IncreaseConnectionRetries()
{
m_retries++;
}
+
void StreamSocket::ResetConnectionRetries()
{
m_retries = 0;
}
+
void StreamSocket::SetCallOnConnect(bool x)
{
Handler().AddList(GetSocket(), LIST_CALLONCONNECT, x);
m_call_on_connect = x;
}
+
bool StreamSocket::CallOnConnect()
{
return m_call_on_connect;
}
+
void StreamSocket::SetRetryClientConnect(bool x)
{
Handler().AddList(GetSocket(), LIST_RETRY, x);
m_b_retry_connect = x;
}
+
bool StreamSocket::RetryClientConnect()
{
return m_b_retry_connect;
}
+
void StreamSocket::SetLineProtocol(bool x)
{
m_line_protocol = x;
}
+
bool StreamSocket::LineProtocol()
{
return m_line_protocol;
}
+
void StreamSocket::SetShutdown(int x)
{
m_shutdown = x;
}
+
int StreamSocket::GetShutdown()
{
return m_shutdown;
}
+
+
#ifdef SOCKETS_NAMESPACE
} // namespace SOCKETS_NAMESPACE {
#endif
+