Source/Core/DolphinWX/Src/NetSockets.h

   1 // Copyright (C) 2003 Dolphin Project.
   2
   3 // This program is free software: you can redistribute it and/or modify
   4 // it under the terms of the GNU General Public License as published by
   5 // the Free Software Foundation, version 2.0.
   6
   7 // This program is distributed in the hope that it will be useful,
   8 // but WITHOUT ANY WARRANTY; without even the implied warranty of
   9 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  10 // GNU General Public License 2.0 for more details.
  11
  12 // A copy of the GPL 2.0 should have been included with the program.
  13 // If not, see http://www.gnu.org/licenses/
  14
  15 // Official SVN repository and contact information can be found at
  16 // http://code.google.com/p/dolphin-emu/
  17
  18 #ifndef _NETSOCKETS_H_
  19 #define _NETSOCKETS_H_
  20
  21 #include <SFML/Network.hpp>
  22
  23 class NetPlay;
  24
  25 #include "Common.h"
  26 #include "NetStructs.h"
  27
  28 #include <wx/wx.h>
  29
  30
  31 struct Clients {
  32         std::string       nick;
  33         sf::SocketTCP     socket;
  34         unsigned short    port;
  35         sf::IPAddress     address;
  36         bool              ready;
  37 };
  38
  39 class NetEvent
  40 {
  41         public:
  42                 NetEvent(NetPlay* netptr) { m_netptr = netptr; }
  43                 ~NetEvent() {};
  44
  45                 void SendEvent(int EventType, std::string="NULL", int=NULL);
  46                 void AppendText(const wxString text);
  47
  48         private:
  49                 NetPlay          *m_netptr;
  50 };
  51
  52 class ServerSide : public wxThread
  53 {
  54         public:
  55                 ServerSide(NetPlay* netptr, sf::SocketTCP, sf::SocketUDP, int netmodel, std::string nick);
  56                 ~ServerSide() {};
  57
  58                 virtual void *Entry();
  59
  60                 void Write(int socknb, const char *data, size_t size, long *ping=NULL);
  61                 void WriteUDP(int socknb, const char *data, size_t size);
  62                 bool isNewPadData(u32 *netValues, bool current, int client=0);
  63
  64         private:
  65                 bool SyncValues(unsigned char, sf::IPAddress);
  66                 bool RecvT(sf::SocketUDP Socket, char * Data, size_t Max, size_t& Recvd, float Time = 0);
  67                 char GetSocket(sf::SocketTCP Socket);
  68                 void OnServerData(int sock, unsigned char data);
  69                 void IsEveryoneReady();
  70
  71                 NetPlay          *m_netptr;
  72                 NetEvent         *Event;
  73
  74                 u32               m_netvalues[3][3];
  75                 bool              m_data_received; // New Pad data received ?
  76
  77                 unsigned char     m_numplayers;
  78                 int               m_netmodel;
  79                 std::string       m_nick;
  80
  81                 Clients           m_client[3];      // Connected client objects
  82                 sf::SelectorTCP   m_selector;
  83                 sf::SocketTCP     m_socket;             // Server 'listening' socket
  84                 sf::SocketUDP     m_socketUDP;
  85
  86                 wxCriticalSection m_CriticalSection;
  87 };
  88
  89 class ClientSide : public wxThread
  90 {
  91         public:
  92                 ClientSide(NetPlay* netptr, sf::SocketTCP, sf::SocketUDP, std::string addr, std::string nick);
  93                 ~ClientSide() {}
  94
  95                 virtual void *Entry();
  96
  97                 void Write(const char *data, size_t size, long *ping=NULL);
  98                 void WriteUDP(const char *data, size_t size);
  99                 bool isNewPadData(u32 *netValues, bool current, bool isVersus=true);
 100
 101         private:
 102                 bool SyncValues();
 103                 void CheckGameFound();
 104                 void OnClientData(unsigned char data);
 105                 bool RecvT(sf::SocketUDP Socket, char * Data, size_t Max, size_t& Recvd, float Time=0);
 106
 107                 NetPlay          *m_netptr;
 108                 NetEvent         *Event;
 109
 110                 u32               m_netvalues[3][3];
 111                 bool              m_data_received; // New Pad data received ?
 112
 113                 unsigned char     m_numplayers;
 114                 int               m_netmodel;
 115                 std::string       m_nick;
 116                 std::string       m_hostnick;
 117                 std::string       m_selectedgame;
 118
 119                 sf::SelectorTCP   m_selector;
 120                 sf::SocketTCP     m_socket;             // Client I/O socket
 121                 sf::SocketUDP     m_socketUDP;
 122                 unsigned short    m_port;
 123                 std::string       m_addr;           // Contains the server addr
 124
 125                 wxCriticalSection m_CriticalSection;
 126 };
 127
 128 #endif