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

SlaveSocket Class Reference #include <SlaveSocket.h> Inheritance diagram for SlaveSocket: [legend]Collaboration diagram for SlaveSocket: [legend]List of all members. Public Member Functions   SlaveSocket (ISocketHandler &)   ~SlaveSocket () void  OnConnect () void  OnRead () void  OpenConnection () void  CloseConnection () void  SendPacket () InternalSocket *  GetSock (unsigned short id) port_t  GetHostPort (const std::string &header, std::string &host) Private Member Functions   SlaveSocket (const SlaveSocket &s) SlaveSocket &  operator= (const SlaveSocket &) Private Attributes unsigned short  m_ip short  m_command short  m_length char  m_packet [32000] size_t  m_packet_ptr int  m_state Detailed Description Definition at line 9 of file SlaveSocket.h. Constructor & Destructor Documentation SlaveSocket::SlaveSocket ( ISocketHandler &   )  Definition at line 13 of file SlaveSocket.cpp. :BaseSocket(h) ,m_state(0) { } SlaveSocket::~SlaveSocket (  )  Definition at line 20 of file SlaveSocket.cpp. { } SlaveSocket::SlaveSocket ( const SlaveSocket &  s  )  [inline, private] Definition at line 30 of file SlaveSocket.h. : BaseSocket(s) {} // copy constructor Member Function Documentation void SlaveSocket::OnConnect (  )  [inline] Definition at line 15 of file SlaveSocket.h. { printf("Connected to %s:%u\n", GetRemoteAddress().c_str(), GetRemotePort()); TcpSocket::OnConnect(); } void SlaveSocket::OnRead (  )  Definition at line 25 of file SlaveSocket.cpp. References CloseConnection(), M2S_CLOSE, M2S_DATA, M2S_OPEN, m_command, m_ip, m_length, m_packet, m_packet_ptr, m_state, OpenConnection(), BaseSocket::printmsg(), and SendPacket(). { 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); m_packet_ptr = 0; m_state = 4; } else need_more = true; break; case 4: // read data (length bytes) if (m_length) { 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_packet_ptr == (size_t)m_length) { mastercmd_t cmd = static_cast<mastercmd_t>(m_command); printmsg(m_ip, cmd, m_length); switch (cmd) { case M2S_OPEN: // open OpenConnection(); break; case M2S_CLOSE: // close CloseConnection(); break; case M2S_DATA: // data SendPacket(); break; /* case M2S_PROXY_HEADER: // http proxy header // m_ip - proxy session id# // m_port - 0 m_packet[m_length] = 0; { std::string header = m_packet; std::string host; port_t port = GetHostPort(header, host); unsigned short id; memcpy(&id, &m_ip, 2); ProxyOutSocket *p = new ProxyOutSocket(Handler(), id, false); // false - no connect p -> SetDeleteByHandler(); p -> Open(host, port); Handler().Add(p); p -> Send(header); } break; case M2S_PROXY_BODY: // http proxy body // m_ip - proxy session id# // m_port - 0 { unsigned short id; memcpy(&id, &m_ip, 2); TcpSocket *p = static_cast<SlaveHandler&>(Handler()).GetProxySocket(id); if (p) { p -> SendBuf(m_packet, m_length); } } break; case M2S_PROXY_CONNECT: // proxy connect // m_ip - proxy session id# // m_port - 0 m_packet[m_length] = 0; { std::string header = m_packet; std::string host; port_t port = GetHostPort(header, host); unsigned short id; memcpy(&id, &m_ip, 2); ProxyBinSocket *p = new ProxyBinSocket(Handler(), id); p -> SetDeleteByHandler(); p -> Open(host, port); Handler().Add(p); } break; */ } // switch (command) m_state = 0; } // length == packet_ptr break; default: printf("SlaveSocket: Bad state (%d)\n", m_state); assert(0); SetCloseAndDelete(); break; } } // while (!need_more) } void SlaveSocket::OpenConnection (  )  Definition at line 157 of file SlaveSocket.cpp. References m_ip, m_length, and m_packet. Referenced by OnRead(). { unsigned short id; memcpy(&id, &m_ip, 2); m_packet[m_length] = 0; printf(" payload: %s\n", m_packet); Parse pa(m_packet, ":"); std::string host = pa.getword(); port_t port = pa.getvalue(); printf(" host: %s port: %u\n", host.c_str(), port); InternalSocket *p = new InternalSocket(Handler(), this, id); p -> SetDeleteByHandler(); p -> Open(host, port); Handler().Add(p); } void SlaveSocket::CloseConnection (  )  Definition at line 174 of file SlaveSocket.cpp. References GetSock(), and m_ip. Referenced by OnRead(). { unsigned short id; memcpy(&id, &m_ip, 2); InternalSocket *p = GetSock(id); if (p) p -> SetCloseAndDelete(); } void SlaveSocket::SendPacket (  )  Definition at line 184 of file SlaveSocket.cpp. References GetSock(), m_ip, m_length, and m_packet. Referenced by OnRead(). { unsigned short id; memcpy(&id, &m_ip, 2); InternalSocket *p = GetSock(id); if (p) p -> SendBuf(m_packet, m_length); } InternalSocket * SlaveSocket::GetSock ( unsigned short  id  )  Definition at line 194 of file SlaveSocket.cpp. Referenced by CloseConnection(), and SendPacket(). { return static_cast<SlaveHandler&>(Handler()).GetSock(id); } port_t SlaveSocket::GetHostPort ( const std::string &  header, std::string &  host   ) Definition at line 200 of file SlaveSocket.cpp. { size_t i = 0; port_t port = 0; while (i < header.size()) { size_t x = i; while (header[i] != 13 && header[i] != 10 && i < header.size()) { i++; } std::string line = header.substr(x, i - x); while (i < header.size() && (header[i] == 13 || header[i] == 10)) { i++; } Parse pa(line, ":"); std::string key = pa.getword(); if (!strcasecmp(key.c_str(), "host")) { Parse pa2(pa.getrest(), ":"); host = pa2.getword(); port = pa2.getvalue(); if (!port) port = 80; return port; } } return 0; } SlaveSocket& SlaveSocket::operator= ( const SlaveSocket &   )  [inline, private] Definition at line 31 of file SlaveSocket.h. { return *this; } // assignment operator Member Data Documentation unsigned short SlaveSocket::m_ip [private] Definition at line 32 of file SlaveSocket.h. Referenced by CloseConnection(), OnRead(), OpenConnection(), and SendPacket(). short SlaveSocket::m_command [private] Definition at line 33 of file SlaveSocket.h. Referenced by OnRead(). short SlaveSocket::m_length [private] Definition at line 34 of file SlaveSocket.h. Referenced by OnRead(), OpenConnection(), and SendPacket(). char SlaveSocket::m_packet[32000] [private] Definition at line 35 of file SlaveSocket.h. Referenced by OnRead(), OpenConnection(), and SendPacket(). size_t SlaveSocket::m_packet_ptr [private] Definition at line 36 of file SlaveSocket.h. Referenced by OnRead(). int SlaveSocket::m_state [private] Definition at line 37 of file SlaveSocket.h. Referenced by OnRead(). The documentation for this class was generated from the following files: SlaveSocket.h SlaveSocket.cpp

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

---