Network Class Reference

#include <network.h>

Collaboration diagram for Network:

[legend]List of all members.

Public Types
	NETWORK_NOT_CONNECTED
	NETWORK_OPTION_SCREEN
	NETWORK_INIT_GAME
	NETWORK_READY_TO_PLAY
	NETWORK_PLAYING
enum	network_state_t {   NETWORK_NOT_CONNECTED, NETWORK_OPTION_SCREEN, NETWORK_INIT_GAME, NETWORK_READY_TO_PLAY,   NETWORK_PLAYING }
Public Member Functions
	Network ()
	~Network ()
void	Init ()
const bool	IsConnected () const
const bool	IsLocal () const
const bool	IsServer () const
const bool	IsClient () const
const uint	GetPort () const
void	Disconnect ()
void	SendAction (Action *action)
void	SendPacket (char *packet, int size)
void	ReceiveActions ()
void	ClientConnect (const std::string &host, const std::string &port)
void	ServerStart (const std::string &port)
void	AcceptIncoming ()
void	RejectIncoming ()
std::list< DistantComputer * >::iterator	CloseConnection (std::list< DistantComputer * >::iterator closed)
void	SendChatMessage (std::string txt)
Public Attributes
NetworkMenu *	network_menu
network_state_t	state
std::list< DistantComputer * >	cpu
uint	max_player_number
uint	connected_player
uint	client_inited
bool	sync_lock
std::string	nickname
Protected Attributes
bool	m_is_connected
bool	m_is_server
bool	m_is_client
TCPsocket	server_socket
SDL_Thread *	thread
SDLNet_SocketSet	socket_set
IPaddress	ip
Private Attributes
bool	inited
Friends
class	DistantComputer

---

Detailed Description

Definition at line 37 of file network.h.

---

Member Enumeration Documentation

enum Network::network_state_t

Enumerator:

NETWORK_NOT_CONNECTED
NETWORK_OPTION_SCREEN
NETWORK_INIT_GAME
NETWORK_READY_TO_PLAY
NETWORK_PLAYING

Definition at line 62 of file network.h.

    {
      NETWORK_NOT_CONNECTED,
      NETWORK_OPTION_SCREEN,
      NETWORK_INIT_GAME,
      NETWORK_READY_TO_PLAY,
      NETWORK_PLAYING
    } network_state_t;

---

Constructor & Destructor Documentation

Network::Network

(

)

Definition at line 45 of file network.cpp.

{
  max_player_number = 0;
  m_is_connected = false;
  m_is_server = false;
  m_is_client = false;
  state = NETWORK_NOT_CONNECTED;
  inited = false;
  sync_lock = false;
  network_menu = NULL;

  //Set nickname
#ifdef WIN32
  nickname = getenv("USERNAME");
#else
  nickname = getenv("USER");
#endif
}

Network::~Network

(

)

Definition at line 92 of file network.cpp.

{
  Disconnect();
  if(inited)
  {
    SDLNet_Quit();
#if defined(DEBUG) && not defined(WIN32)
    close(fin);
    close(fout);
#endif
  }
}

Here is the call graph for this function:

---

Member Function Documentation

void Network::AcceptIncoming

(

)

Definition at line 234 of file network.cpp.

{
  assert(m_is_server);
  if(state != NETWORK_OPTION_SCREEN) return;

  server_socket = SDLNet_TCP_Open(&ip);
  if(!server_socket)
  {
    Question question;
    question.Set(_("Unable to listen for client!"),1,0);
    question.Ask();
    printf("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
    return;
  }
  printf("\nStart listening");
}

Here is the call graph for this function:

Here is the caller graph for this function:

void Network::ClientConnect	(	const std::string &	host,
		const std::string &	port
	)

Definition at line 134 of file network.cpp.

{
  MSG_DEBUG("network", "Client connect to %s:%s", host.c_str(), port.c_str());

  int prt=0;
  sscanf(port.c_str(),"%i",&prt);
  prt = htons(prt);

  if(SDLNet_ResolveHost(&ip,host.c_str(),prt)==-1)
  {
    Question question;
    question.Set(_("Invalid server adress!"),1,0);
    question.Ask();
    printf("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
    return;
  }

  ip.port = prt;

  TCPsocket socket = SDLNet_TCP_Open(&ip);

  if(!socket)
  {
    Question question;
    question.Set(_("Unable to contact server!"),1,0);
    question.Ask();
    printf("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
    return;
  }

  m_is_client = true;
  m_is_server = false;
  state = NETWORK_OPTION_SCREEN;
  m_is_connected = true;

  socket_set = SDLNet_AllocSocketSet(1);
  connected_player = 1;
  cpu.push_back(new DistantComputer(socket));
  //Send nickname to server
  Action a(Action::ACTION_NICKNAME, nickname);
  network.SendAction(&a);

  //Control to net_thread_func
  thread = SDL_CreateThread(net_thread_func,NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::list< DistantComputer * >::iterator Network::CloseConnection

(

std::list< DistantComputer * >::iterator

closed

)

Definition at line 218 of file network.cpp.

{
  printf("Client disconnected\n");
  delete *closed;
  if(m_is_server && connected_player == max_player_number)
  {
    // A new player will be able to connect, so we reopen the socket
    // For incoming connections
    printf("Allowing new connections\n");
    AcceptIncoming();
  }

  connected_player--;
  return cpu.erase(closed);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void Network::Disconnect

(

)

Definition at line 107 of file network.cpp.

{
  if(!m_is_connected) return;

  m_is_connected = false; // To make the threads terminate

  SDL_WaitThread(thread,NULL);
  printf("Network thread finished\n");
  for(std::list<DistantComputer*>::iterator client = cpu.begin();
      client != cpu.end();
      client++)
  {
    delete *client;
  }
  cpu.clear();
  SDLNet_FreeSocketSet(socket_set);

  if(m_is_server)
    SDLNet_TCP_Close(server_socket);

  m_is_server = false;
  m_is_client = false;
}

Here is the caller graph for this function:

const uint Network::GetPort

(

)

const

Definition at line 414 of file network.cpp.

{ return ntohs(ip.port); }

Here is the caller graph for this function:

void Network::Init

(

)

Definition at line 74 of file network.cpp.

{
  if(inited) return;
  if (SDLNet_Init()) {
      Error(_("Failed to initialize network library!"));
  }
  inited = true;
  max_player_number = GameMode::GetInstance()->max_teams;
  connected_player = 0;

#if defined(DEBUG) && not defined(WIN32)
  fin = open("./network.in", O_RDWR | O_CREAT | O_SYNC, S_IRWXU | S_IRWXG);
  fout = open("./network.out", O_RDWR | O_CREAT | O_SYNC, S_IRWXU | S_IRWXG);
#endif
}

Here is the call graph for this function:

Here is the caller graph for this function:

const bool Network::IsClient

(

)

const

Definition at line 413 of file network.cpp.

{ return m_is_client; }

Here is the caller graph for this function:

const bool Network::IsConnected

(

)

const

Definition at line 410 of file network.cpp.

{ return m_is_connected; }

Here is the caller graph for this function:

const bool Network::IsLocal

(

)

const

Definition at line 411 of file network.cpp.

{ return !m_is_server && !m_is_client; }

Here is the caller graph for this function:

const bool Network::IsServer

(

)

const

Definition at line 412 of file network.cpp.

{ return m_is_server; }

Here is the caller graph for this function:

void Network::ReceiveActions

(

)

Definition at line 263 of file network.cpp.

{
  char* packet;

  while(m_is_connected && (cpu.size()==1 || m_is_server))
  {
    if(state == NETWORK_PLAYING && cpu.size() == 0)
    {
      // If while playing everybody disconnected, just quit
      break;
    }

    while(SDLNet_CheckSockets(socket_set, 100) == 0 && m_is_connected) //Loop while nothing is received
    if(m_is_server && server_socket)
    {
      // Check for an incoming connection
      TCPsocket incoming;
      incoming = SDLNet_TCP_Accept(server_socket);
      if(incoming)
      {
        cpu.push_back(new DistantComputer(incoming));
        connected_player++;
        printf("New client connected\n");
        if(connected_player >= max_player_number)
          RejectIncoming();
        ActionHandler::GetInstance()->NewAction(new Action(Action::ACTION_ASK_VERSION));
      }
    }

    std::list<DistantComputer*>::iterator dst_cpu = cpu.begin();
    while(dst_cpu != cpu.end() && m_is_connected)
    {
      if((*dst_cpu)->SocketReady()) // Check if this socket contains data to receive
      {
        // Read the size of the packet
        int packet_size = (*dst_cpu)->ReceiveDatas(packet);
        if( packet_size <= 0)
        {
          dst_cpu = CloseConnection(dst_cpu);
          continue;
        }

#if defined(DEBUG) && not defined(WIN32)
        int tmp = 0xFFFFFFFF;
        write(fin, &packet_size, 4);
        write(fin, packet, packet_size);
        write(fin, &tmp, 4);
#endif

        Action* a = new Action(packet);
        MSG_DEBUG("network.traffic","Received action %s",
                ActionHandler::GetInstance()->GetActionName(a->GetType()).c_str());

        //Add relation between nickname and socket
        if( a->GetType() == Action::ACTION_NICKNAME){
          std::string nickname = a->PopString();
          std::cout<<"New nickname: " + nickname<< std::endl;
          (*dst_cpu)->nickname = nickname;
          delete a;
          break;
        }

        if( a->GetType() == Action::ACTION_NEW_TEAM
        ||  a->GetType() == Action::ACTION_DEL_TEAM)
        {
          (*dst_cpu)->ManageTeam(a);
          delete a;
        }
        else
        if(a->GetType() == Action::ACTION_CHAT_MESSAGE)
        {
          (*dst_cpu)->SendChatMessage(a);
          delete a;
        }
        else
        {
          ActionHandler::GetInstance()->NewAction(a, false);
        }

        // Repeat the packet to other clients:
        if(a->GetType() != Action::ACTION_SEND_VERSION
        && a->GetType() != Action::ACTION_CHANGE_STATE
        && a->GetType() != Action::ACTION_CHAT_MESSAGE)
        for(std::list<DistantComputer*>::iterator client = cpu.begin();
            client != cpu.end();
            client++)
        if(client != dst_cpu)
        {
          (*client)->SendDatas(packet, packet_size);
        }
        free(packet);
      }
      dst_cpu++;
    }
  }
  Game::GetInstance()->SetEndOfGameStatus( true );
}

Here is the call graph for this function:

Here is the caller graph for this function:

void Network::RejectIncoming

(

)

Definition at line 251 of file network.cpp.

{
  assert(m_is_server);
  if(!server_socket) return;
  SDLNet_TCP_Close(server_socket);
  server_socket = NULL;
  printf("\nStop listening");
}

Here is the caller graph for this function:

void Network::SendAction

(

Action *

action

)

Definition at line 362 of file network.cpp.

{
  if (!m_is_connected) return;

  MSG_DEBUG("network.traffic","Send action %s",
        ActionHandler::GetInstance()->GetActionName(a->GetType()).c_str());

  int size;
  char* packet;
  a->WritePacket(packet, size);

  assert(*((int*)packet) != 0 );
  SendPacket(packet, size);

  free(packet);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void Network::SendChatMessage

(

std::string

txt

)

Definition at line 395 of file network.cpp.

{
  if(IsServer())
  {
    ActionHandler::GetInstance()->NewAction(new Action(Action::ACTION_CHAT_MESSAGE, nickname + std::string("> ") + txt));
  }
  else
  {
    Action a(Action::ACTION_CHAT_MESSAGE, txt);
    network.SendAction(&a);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void Network::SendPacket	(	char *	packet,
		int	size
	)

Definition at line 379 of file network.cpp.

{
#if defined(DEBUG) && not defined(WIN32)
        int tmp = 0xFFFFFFFF;
        write(fout, &size, 4);
        write(fout, packet, size);
        write(fout, &tmp, 4);
#endif
  for(std::list<DistantComputer*>::iterator client = cpu.begin();
      client != cpu.end();
      client++)
  {
    (*client)->SendDatas(packet, size);
  }
}

Here is the caller graph for this function:

void Network::ServerStart

(

const std::string &

port

)

Definition at line 184 of file network.cpp.

{
  // The server starts listening for clients
  MSG_DEBUG("network", "Start server on port %s", port.c_str());

  cpu.clear();
  // Convert port number (std::string port) into SDL port number format:
  int prt;
  sscanf(port.c_str(),"%i",&prt);
  prt = htons(prt);

  if(SDLNet_ResolveHost(&ip,NULL,prt)==-1)
  {
    Question question;
    question.Set(_("Invalid port!"),1,0);
    question.Ask();
    printf("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
    return;
  }
  ip.port = prt;

  m_is_server = true;
  m_is_client = false;
  m_is_connected = true;

  // Open the port to listen to
  state = NETWORK_OPTION_SCREEN;
  AcceptIncoming();
  connected_player = 1;
  printf("\nConnected\n");
  socket_set = SDLNet_AllocSocketSet(GameMode::GetInstance()->max_teams);
  thread = SDL_CreateThread(net_thread_func,NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

Friends And Related Function Documentation

friend class DistantComputer [friend]

Definition at line 39 of file network.h.

---

Member Data Documentation

uint Network::client_inited

Definition at line 75 of file network.h.

uint Network::connected_player

Definition at line 74 of file network.h.

std::list<DistantComputer*> Network::cpu

Definition at line 72 of file network.h.

bool Network::inited [private]

Definition at line 41 of file network.h.

IPaddress Network::ip [protected]

Definition at line 56 of file network.h.

bool Network::m_is_client [protected]

Definition at line 51 of file network.h.

bool Network::m_is_connected [protected]

Definition at line 49 of file network.h.

bool Network::m_is_server [protected]

Definition at line 50 of file network.h.

uint Network::max_player_number

Definition at line 73 of file network.h.

NetworkMenu* Network::network_menu

Definition at line 60 of file network.h.

std::string Network::nickname

Definition at line 77 of file network.h.

TCPsocket Network::server_socket [protected]

Definition at line 53 of file network.h.

SDLNet_SocketSet Network::socket_set [protected]

Definition at line 55 of file network.h.

network_state_t Network::state

Definition at line 70 of file network.h.

bool Network::sync_lock

Definition at line 76 of file network.h.

SDL_Thread* Network::thread [protected]

Definition at line 54 of file network.h.

---

The documentation for this class was generated from the following files:

• src/network/network.h
• src/network/network.cpp

---