src/Sockets/StreamSocket.cpp

   1 //#include <stdio.h>
   2
   3 #include "StreamSocket.h"
   4 #include "ISocketHandler.h"
   5
   6
   7 #ifdef SOCKETS_NAMESPACE
   8 namespace SOCKETS_NAMESPACE {
   9 #endif
  10
  11
  12 StreamSocket::StreamSocket(ISocketHandler& h) : Socket(h)
  13 ,m_bConnecting(false)
  14 ,m_connect_timeout(5)
  15 ,m_flush_before_close(true)
  16 ,m_connection_retry(0)
  17 ,m_retries(0)
  18 ,m_call_on_connect(false)
  19 ,m_b_retry_connect(false)
  20 ,m_line_protocol(false)
  21 ,m_shutdown(0)
  22 {
  23 }
  24
  25
  26 StreamSocket::~StreamSocket()
  27 {
  28 }
  29
  30
  31 void StreamSocket::SetConnecting(bool x)
  32 {
  33         if (x != m_bConnecting)
  34         {
  35                 m_bConnecting = x;
  36                 if (x)
  37                 {
  38                         SetTimeout( GetConnectTimeout() );
  39                 }
  40                 else
  41                 {
  42                         SetTimeout( 0 );
  43                 }
  44         }
  45 }
  46
  47
  48 bool StreamSocket::Connecting()
  49 {
  50         return m_bConnecting;
  51 }
  52
  53
  54 bool StreamSocket::Ready()
  55 {
  56         if (GetSocket() != INVALID_SOCKET && !Connecting() && !CloseAndDelete())
  57                 return true;
  58         return false;
  59 }
  60
  61
  62 void StreamSocket::SetConnectTimeout(int x)
  63 {
  64         m_connect_timeout = x;
  65 }
  66
  67
  68 int StreamSocket::GetConnectTimeout()
  69 {
  70         return m_connect_timeout;
  71 }
  72
  73
  74 void StreamSocket::SetFlushBeforeClose(bool x)
  75 {
  76         m_flush_before_close = x;
  77 }
  78
  79
  80 bool StreamSocket::GetFlushBeforeClose()
  81 {
  82         return m_flush_before_close;
  83 }
  84
  85
  86 int StreamSocket::GetConnectionRetry()
  87 {
  88         return m_connection_retry;
  89 }
  90
  91
  92 void StreamSocket::SetConnectionRetry(int x)
  93 {
  94         m_connection_retry = x;
  95 }
  96
  97
  98 int StreamSocket::GetConnectionRetries()
  99 {
 100         return m_retries;
 101 }
 102
 103
 104 void StreamSocket::IncreaseConnectionRetries()
 105 {
 106         m_retries++;
 107 }
 108
 109
 110 void StreamSocket::ResetConnectionRetries()
 111 {
 112         m_retries = 0;
 113 }
 114
 115
 116 void StreamSocket::SetCallOnConnect(bool x)
 117 {
 118         Handler().AddList(GetSocket(), LIST_CALLONCONNECT, x);
 119         m_call_on_connect = x;
 120 }
 121
 122
 123 bool StreamSocket::CallOnConnect()
 124 {
 125         return m_call_on_connect;
 126 }
 127
 128
 129 void StreamSocket::SetRetryClientConnect(bool x)
 130 {
 131         Handler().AddList(GetSocket(), LIST_RETRY, x);
 132         m_b_retry_connect = x;
 133 }
 134
 135
 136 bool StreamSocket::RetryClientConnect()
 137 {
 138         return m_b_retry_connect;
 139 }
 140
 141
 142 void StreamSocket::SetLineProtocol(bool x)
 143 {
 144         m_line_protocol = x;
 145 }
 146
 147
 148 bool StreamSocket::LineProtocol()
 149 {
 150         return m_line_protocol;
 151 }
 152
 153
 154 void StreamSocket::SetShutdown(int x)
 155 {
 156         m_shutdown = x;
 157 }
 158
 159
 160 int StreamSocket::GetShutdown()
 161 {
 162         return m_shutdown;
 163 }
 164
 165
 166
 167
 168 #ifdef SOCKETS_NAMESPACE
 169 } // namespace SOCKETS_NAMESPACE {
 170 #endif