/Desktop/MGS-MultithreadedGameServer/Player.cc

Vai alla documentazione di questo file.

//
// File: Player.cc
// Created by: <Detro /> aka Ivan De Marino 
// <detro@mandolinux.org, demarino@studenti.unina.it, demarino@na.astro.it>
// Created on: Wed Oct 27 21:36:55 2004
//

#include "Player.h"

/**
 * Costruttore della Classe Player.
 *
 * @param newName Nome/Nick del Player
 * @param newStream <code>TCPStream</code> 
 *    contenente la Connessione dell'utente */
Player::Player(const string &newName, 
   const TCPStream &newStream, 
   Thread *newThread) : 
TCPStream(newStream), name(newName), ConnectionHandlerThread(newThread) {}

/** Distruttore Classe Player */
Player::~Player(void) {}

/** Ritorna il nome/nick del Player */
string Player::getName(void) const {return name;}

/**
 * Invia un messaggio all'Utente (overloaded). 
 *
 * @param message Stringa contenente il messaggio */
void Player::say(const string &message) {
   try {
      *tcp() << message;
      TCPStream::sync();
   }
   catch (iostream::failure *stream) {
      cout << "<Player msg> Exception Raised during IOSTREAM write." << endl;
   }
}

/**
 * Invia un numero all'Utente (overloaded).
 *
 * @param number Valore(double) da inviare all'Utente */
void Player::say(const double number) {
   try {
      *tcp() << number;
      TCPStream::sync();
   }
   catch (iostream::failure *stream) {
      cout << "<Player msg> Exception Raised during IOSTREAM write." << endl;
   }
}

/**
 * Invia un numero all'Utente (overloaded).
 *
 * @param number Valore(int) da inviare all'Utente */
void Player::say(const int number) {
   say((double) number);
}

/**
 * Riceve un messaggio dall'Utente.
 * Attende un determinato numero di millisecondi
 * che l'utente invii un messaggio.
 * Nota: il messaggio inviato viene ripulito del "Carriage Return" 
 * finale (il carattere di escape @c "\n").
 *
 * @param timeout Tempo di attesa per il messaggio - 
 *    <code>default = TIMEOUT_INF</code> attende indeterminatamente 
 * @return Ritorna una string contenete il Messaggio digitato dall'Utente */
string Player::hear(const timeout_t timeout) {  
   char *message;
   message = new char[MESSAGE_MAX_LENGTH];

   if( isPending(Socket::pendingInput, timeout) ) {
      try {
         /* Il metodo "getline()" dovrebbe, da solo, eliminare lo "\n"
          * al termine della stringa... ma non lo fa. */
         tcp()->getline(message, MESSAGE_MAX_LENGTH);
         message[strlen(message)-1] = '\0';
         TCPStream::sync();
      }
      catch (iostream::failure *stream) {
         cout << "<Player msg> Exception Raised during IOSTREAM read." << endl;
      }
   }
   
   return (string (message));
}

/**
 * Sospendi il Thread @b "ConnectionHandler" che gestisce
 * la connessione dell'Utente con MGS */
void Player::suspendConnHandler(void) {
   try {
      ConnectionHandlerThread->suspend();
   }
   catch(Thread *t) {
      cout << "<Player msg> Exception Raised during ConnHeandler Suspending."
         << endl;
   }
}

/**
 * Riattiva il Thread @b "ConnectionHandler" che gestisce
 * la connessione dell'Utente con MGS */
void Player::resumeConnHandler(void) {
   try {
      ConnectionHandlerThread->resume();
   }
   catch(Thread *t) {
      cout << "<Player msg> Exception Raised during ConnHeandler Resuming." 
         << endl;
   }
}

---