Search Site ~Sockets~  C++ Sockets   Tutorial   Classes   License   Java Sockets  ~Examples~  SMTPProxy   PortProxy   ChatServer   Small MUD   ClientServer   HttpGet   DChat   WebServer   UDP   ICMP  ~Contact~ message board  email author

MasterSocket Class Reference #include <MasterSocket.h> Inheritance diagram for MasterSocket: [legend]Collaboration diagram for MasterSocket: [legend]List of all members. Public Member Functions   MasterSocket (ISocketHandler &)   ~MasterSocket () void  Init () void  InitSSLServer () void  OnAccept () void  OnSSLAccept () void  OnDelete () void  OnRead () void  SendToExt () void  CloseExtConn () Private Member Functions   MasterSocket (const MasterSocket &s) MasterSocket &  operator= (const MasterSocket &) Private Attributes unsigned short  m_ip short  m_command short  m_length char  m_packet [PACKETSIZE] size_t  m_packet_ptr int  m_state Detailed Description Definition at line 9 of file MasterSocket.h. Constructor & Destructor Documentation MasterSocket::MasterSocket ( ISocketHandler &   )  Definition at line 9 of file MasterSocket.cpp. :BaseSocket(h) ,m_state(0) { } MasterSocket::~MasterSocket (  )  Definition at line 16 of file MasterSocket.cpp. { } MasterSocket::MasterSocket ( const MasterSocket &  s  )  [inline, private] Definition at line 27 of file MasterSocket.h. : BaseSocket(s) {} // copy constructor Member Function Documentation void MasterSocket::Init (  )  Definition at line 21 of file MasterSocket.cpp. { EnableSSL(); } void MasterSocket::InitSSLServer (  )  Definition at line 27 of file MasterSocket.cpp. { InitializeContext("master", "comb.pem", "", SSLv23_method()); } void MasterSocket::OnAccept (  )  Definition at line 203 of file MasterSocket.cpp. { TcpSocket::OnAccept(); printf("Incoming connection from: %s:%u\n", GetRemoteAddress().c_str(), GetRemotePort()); // check valid ip if (GetRemoteAddress() != static_cast<MHandler&>(Handler()).GetValidIP()) { printf("Refusing IP: %s\n", GetRemoteAddress().c_str()); SetCloseAndDelete(); } } void MasterSocket::OnSSLAccept (  )  Definition at line 197 of file MasterSocket.cpp. { TcpSocket::OnSSLAccept(); } void MasterSocket::OnDelete (  )  Definition at line 216 of file MasterSocket.cpp. { printf("Lost connection to: %s:%u\n", GetRemoteAddress().c_str(), GetRemotePort()); } void MasterSocket::OnRead (  )  Definition at line 33 of file MasterSocket.cpp. References CloseExtConn(), m_command, m_ip, m_length, m_packet, m_packet_ptr, m_state, PACKETSIZE, BaseSocket::printmsg(), S2M_CONNECT, S2M_DATA, S2M_DISCONNECTED, and SendToExt(). { TcpSocket::OnRead(); bool need_more = false; while (!need_more && !CloseAndDelete()) { size_t l = ibuf.GetLength(); switch (m_state) { case 0: // to id (2 bytes) if (l >= 2) { ibuf.Read( (char *)&m_ip, 2); m_ip = ntohs(m_ip); m_state = 2; } else need_more = true; break; case 2: // command (open, close) if (l >= 2) { ibuf.Read( (char *)&m_command, 2); m_command = ntohs(m_command); m_state = 3; } else need_more = true; break; case 3: // length (2 bytes) if (l >= 2) { ibuf.Read( (char *)&m_length, 2); m_length = ntohs(m_length); if (m_length > PACKETSIZE) { printf("Incoming length (%d) larger than local buffer (%d) - terminating connection\n", m_length, PACKETSIZE); SetCloseAndDelete(); } m_packet_ptr = 0; m_state = 4; } else need_more = true; break; case 4: // read data (length bytes) if (m_length) { if (m_packet_ptr + l > PACKETSIZE) { printf("Trying to read beyond local buffer size (%d + %d > %d) - terminating connection\n", m_packet_ptr, l, PACKETSIZE); SetCloseAndDelete(); break; } if (l < m_length - m_packet_ptr) // not enough { ibuf.Read(m_packet + m_packet_ptr, l); m_packet_ptr += l; need_more = true; } else { ibuf.Read(m_packet + m_packet_ptr, m_length - m_packet_ptr); m_packet_ptr += m_length - m_packet_ptr; } } if (m_length == (short)m_packet_ptr) { slavecmd_t cmd = static_cast<slavecmd_t>(m_command); printmsg(m_ip, cmd, m_length); switch (cmd) { case S2M_CONNECT: // connect break; case S2M_DISCONNECTED: // disconnected CloseExtConn(); break; case S2M_DATA: // data SendToExt(); break; /* case S2M_PROXY_HEADER: // proxy header { unsigned short id; memcpy(&id, &m_ip, 2); ProxyInSocket *p = static_cast<MHandler&>(Handler()).GetProxySocket(id); if (p) p -> SendBuf(m_packet, m_packet_ptr); } break; case S2M_PROXY_DATA: // proxy data { unsigned short id; memcpy(&id, &m_ip, 2); ProxyInSocket *p = static_cast<MHandler&>(Handler()).GetProxySocket(id); if (p) p -> SendBuf(m_packet, m_packet_ptr); } break; case S2M_PROXY_CONNECT: // proxy connect { unsigned short id; memcpy(&id, &m_ip, 2); ProxyInSocket *p = static_cast<MHandler&>(Handler()).GetProxySocket(id); if (p) { p -> Send("HTTP/1.0 200 Connection Established\r\n\r\n"); } } break; case S2M_PROXY_CONNECT_FAILED: // proxy connect failed { unsigned short id; memcpy(&id, &m_ip, 2); ProxyInSocket *p = static_cast<MHandler&>(Handler()).GetProxySocket(id); if (p) { p -> Send("HTTP/1.0 404 Failed\r\n\r\n"); } } break; case S2M_PROXY_CLOSE: // close { unsigned short id; memcpy(&id, &m_ip, 2); ProxyInSocket *p = static_cast<MHandler&>(Handler()).GetProxySocket(id); if (p) p -> SetCloseAndDelete(); } break; */ } m_state = 0; } break; default: printf("MasterSocket: Bad state (%d)\n", m_state); assert(0); SetCloseAndDelete(); break; } } // while (!need_more) } void MasterSocket::SendToExt (  )  Definition at line 181 of file MasterSocket.cpp. References m_ip, m_length, and m_packet. Referenced by OnRead(). { unsigned short id; memcpy(&id, &m_ip, 2); static_cast<MHandler&>(Handler()).SendToExt(id, m_packet, m_length); } void MasterSocket::CloseExtConn (  )  Definition at line 189 of file MasterSocket.cpp. References m_ip. Referenced by OnRead(). { unsigned short id; memcpy(&id, &m_ip, 2); static_cast<MHandler&>(Handler()).CloseExtConn(id); } MasterSocket& MasterSocket::operator= ( const MasterSocket &   )  [inline, private] Definition at line 28 of file MasterSocket.h. { return *this; } // assignment operator Member Data Documentation unsigned short MasterSocket::m_ip [private] Definition at line 29 of file MasterSocket.h. Referenced by CloseExtConn(), OnRead(), and SendToExt(). short MasterSocket::m_command [private] Definition at line 30 of file MasterSocket.h. Referenced by OnRead(). short MasterSocket::m_length [private] Definition at line 31 of file MasterSocket.h. Referenced by OnRead(), and SendToExt(). char MasterSocket::m_packet[PACKETSIZE] [private] Definition at line 32 of file MasterSocket.h. Referenced by OnRead(), and SendToExt(). size_t MasterSocket::m_packet_ptr [private] Definition at line 33 of file MasterSocket.h. Referenced by OnRead(). int MasterSocket::m_state [private] Definition at line 34 of file MasterSocket.h. Referenced by OnRead(). The documentation for this class was generated from the following files: MasterSocket.h MasterSocket.cpp

Page, code, and content Copyright (C) 2006 by Anders Hedström

---