IndexServer Class Reference

#include <index_server.h>

List of all members.

Public Member Functions
	IndexServer ()
	~IndexServer ()
bool	Connect ()
void	SetHiddenServer ()
void	SendServerStatus ()
void	Disconnect ()
std::list< address_pair >	GetHostList ()
Private Member Functions
void	Send (const int &nbr)
void	Send (const std::string &str)
int	ReceiveInt ()
std::string	ReceiveStr ()
bool	GetServerList ()
bool	GetServerAddress (std::string &address, int &port)
bool	ConnectTo (const std::string &address, const int &port)
bool	HandShake ()
Private Attributes
TCPsocket	socket
IPaddress	ip
std::map< std::string, int >	server_lst
std::map< std::string, int >::iterator	first_server
std::map< std::string, int >::iterator	current_server
bool	hidden_server
bool	connected

---

Detailed Description

Definition at line 34 of file index_server.h.

---

Constructor & Destructor Documentation

IndexServer::IndexServer

(

)

Definition at line 38 of file index_server.cpp.

{
  hidden_server = false;
  connected = false;
  server_lst.clear();
  first_server = server_lst.end();
  current_server = server_lst.end();
}

IndexServer::~IndexServer

(

)

Definition at line 47 of file index_server.cpp.

{
  server_lst.clear();
  if(connected)
    Disconnect();
}

Here is the call graph for this function:

---

Member Function Documentation

bool IndexServer::Connect

(

)

Definition at line 55 of file index_server.cpp.

{
  MSG_DEBUG("index_server", "Connecting..");
  assert(!connected);

  if( hidden_server )
    return true;

  if( !GetServerList() )
    return false;

  std::string addr;
  int port;

  // Cycle through the list of server
  // Until we find one running
  while( GetServerAddress( addr, port) )
  {
    if( ConnectTo( addr, port) )
      return true;
  }

  Question question;
  question.Set(_("Unable to contact an index server!"),1,0);
  question.Ask();

  return false;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool IndexServer::ConnectTo	(	const std::string &	address,
		const int &	port
	)			[private]

Definition at line 84 of file index_server.cpp.

{
  MSG_DEBUG("index_server", "Connecting to %s %i", address.c_str(), port);
  Question question;
  question.Set(_("Contacting main server..."),1,0);
  question.Draw();
  AppWormux::GetInstance()->video.Flip();

  network.Init(); // To get SDL_net initialized

  MSG_DEBUG("index_server", "Opening connection");

//  if( SDLNet_ResolveHost(&ip, "localhost" , port) == -1 )
  if( SDLNet_ResolveHost(&ip, address.c_str() , port) == -1 )
  {
    question.Set(_("Invalid index server adress!"),1,0);
    question.Ask();
    printf("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
    return false;
  }

  socket = SDLNet_TCP_Open(&ip);

  if(!socket)
  {
    printf("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
    return false;
  }

  connected = true;

  return HandShake();
}

Here is the call graph for this function:

Here is the caller graph for this function:

void IndexServer::Disconnect

(

)

Definition at line 118 of file index_server.cpp.

{
  if( hidden_server )
  {
    hidden_server = false;
    return;
  }

  if( !connected )
    return;

  MSG_DEBUG("index_server", "Closing connection");
  first_server = server_lst.end();
  current_server = server_lst.end();

  SDLNet_TCP_Close(socket);
  connected = false;
}

Here is the caller graph for this function:

std::list< address_pair > IndexServer::GetHostList

(

)

Definition at line 315 of file index_server.cpp.

{
  Send(TS_MSG_GET_LIST);
  int lst_size = ReceiveInt();
  std::list<address_pair> lst;
  while(lst_size--)
  {
    IPaddress ip;
    ip.host = ReceiveInt();
    ip.port = ReceiveInt();
    const char* addr = SDLNet_ResolveIP(&ip);
    char port[10];
    sprintf(port, "%d", ip.port);

    address_pair addr_pair;
    addr_pair.second = std::string(port);

    if(addr == NULL)
    {
      // We can't resolve the hostname, so just show the ip address
      unsigned char* str_ip = (unsigned char*)&ip.host;
      char formated_ip[16];
      snprintf(formated_ip, 16, "%i.%i.%i.%i", (int)str_ip[0],
                                           (int)str_ip[1],
                                           (int)str_ip[2],
                                           (int)str_ip[3]);
      addr_pair.first = std::string(formated_ip);
    }
    else
      addr_pair.first = std::string(addr);
    lst.push_back(addr_pair);
  }
  return lst;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool IndexServer::GetServerAddress	(	std::string &	address,
		int &	port
	)			[private]

Definition at line 196 of file index_server.cpp.

{
  MSG_DEBUG("index_server", "Trying a new server");
  // Cycle through the server list to find the first one
  // accepting connection
  if( first_server == server_lst.end() )
  {
    // First try :
    // Randomly select a server in the list
    int nbr = randomObj.GetLong( 0, server_lst.size()-1 );
    first_server = server_lst.begin();
    while(nbr--)
      ++first_server;

    assert(first_server != server_lst.end());

    current_server = first_server;

    address = current_server->first;
    port = current_server->second;
    return true;
  }

  ++current_server;
  if( current_server == server_lst.end() )
    current_server = server_lst.begin();

  address = current_server->first;
  port = current_server->second;

  return (current_server != first_server);
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool IndexServer::GetServerList

(

)

[private]

Definition at line 146 of file index_server.cpp.

{
  MSG_DEBUG("index_server", "Retrieving server list");
  // If we already have it, no need to redownload it
  if(server_lst.size() != 0)
    return true;

  // Download the list of user
  const std::string server_file = Config::GetInstance()->GetPersonalDir() + "server_list";

  if( !downloader.Get(server_list_url.c_str(), server_file.c_str()) )
    return false;

  // Parse the file
  std::ifstream fin;
  fin.open(server_file.c_str(), std::ios::in);
  if(!fin)
        return false;

  /*char * line = NULL;
  size_t len = 0;*/
  ssize_t read;
  std::string line;
 
  // GNU getline isn't available on *BSD and Win32, so we use a new function, see getline above
  while ((read = getline(line, fin)) >= 0)
  {
    if(line.at(0) == '#' || line.at(0) == '\n' || line.at(0) == '\0')
      continue;

    std::string::size_type port_pos = line.find(':', 0);
    if(port_pos == std::string::npos)
      continue;

    std::string hostname = line.substr(0, port_pos);
    std::string portstr = line.substr(port_pos+1);
    int port = atoi(portstr.c_str());

    server_lst[ hostname ] = port;
  }

  fin.close();

  first_server = server_lst.end();
  current_server = server_lst.end();
  MSG_DEBUG("index_server", "Server list retrieved. %i servers are running", server_lst.size());

  return (server_lst.size() != 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool IndexServer::HandShake

(

)

[private]

Definition at line 283 of file index_server.cpp.

{
  Send(TS_MSG_VERSION);
  Send(Constants::VERSION);

  int msg = ReceiveInt();
  std::string sign;

  if(msg == TS_MSG_VERSION)
    sign = ReceiveStr();

  if(msg != TS_MSG_VERSION || sign != "MassMurder!")
  {
    Question question;
    question.Set(_("It doesn't seem to be a valid Wormux server..."),1,0);
    question.Ask();
    Disconnect();
    return false;
  }
  return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int IndexServer::ReceiveInt

(

)

[private]

Definition at line 246 of file index_server.cpp.

{
  char packet[4];
  if( SDLNet_TCP_Recv(socket, packet, sizeof(packet)) < 1 )
  {
    Disconnect();
    return 0;
  }

  Uint32 u_nbr = SDLNet_Read32(packet);
  int nbr = *((int*)&u_nbr);
  return nbr;
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string IndexServer::ReceiveStr

(

)

[private]

Definition at line 260 of file index_server.cpp.

{
  int size = ReceiveInt();

  if(!connected)
    return "";

  assert(size > 0);
  char* str = new char[size+1];

  if( SDLNet_TCP_Recv(socket, str, size) < 1 )
  {
    Disconnect();
    return "";
  }

  str[size] = '\0';

  std::string st(str);
  delete []str;
  return st;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void IndexServer::Send

(

const std::string &

str

)

[private]

Definition at line 240 of file index_server.cpp.

{
  Send(str.size());
  SDLNet_TCP_Send(socket, (void*)str.c_str(), str.size());
}

Here is the call graph for this function:

void IndexServer::Send

(

const int &

nbr

)

[private]

Definition at line 230 of file index_server.cpp.

{
  char packet[4];
  // this is not cute, but we don't want an int -> uint conversion here
  Uint32 u_nbr = *((Uint32*)&nbr);

  SDLNet_Write32(u_nbr, packet);
  SDLNet_TCP_Send(socket, packet, sizeof(packet));
}

Here is the caller graph for this function:

void IndexServer::SendServerStatus

(

)

Definition at line 305 of file index_server.cpp.

{
  assert(network.IsServer());

  if(hidden_server)
    return;
  Send(TS_MSG_HOSTING);
  Send(network.GetPort());
}

Here is the call graph for this function:

Here is the caller graph for this function:

void IndexServer::SetHiddenServer

(

)

[inline]

Definition at line 76 of file index_server.h.

{ hidden_server = true; };

Here is the caller graph for this function:

---

Member Data Documentation

bool IndexServer::connected [private]

Definition at line 50 of file index_server.h.

std::map<std::string, int>::iterator IndexServer::current_server [private]

Definition at line 45 of file index_server.h.

std::map<std::string, int>::iterator IndexServer::first_server [private]

Definition at line 43 of file index_server.h.

bool IndexServer::hidden_server [private]

Definition at line 48 of file index_server.h.

IPaddress IndexServer::ip [private]

Definition at line 38 of file index_server.h.

std::map<std::string, int> IndexServer::server_lst [private]

Definition at line 41 of file index_server.h.

TCPsocket IndexServer::socket [private]

Definition at line 37 of file index_server.h.

---

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

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

---