blender/source/gameengine/Network/TerraplayNetwork/NG_TerraplayNetworkDeviceInterface.cpp
Kent Mein 209a2ede2c Last of the config.h mods...
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

added to these files.

Kent
--
mein@cs.umn.edu
2002-11-25 15:29:57 +00:00

197 lines
5.1 KiB
C++

/*
* $Id$
*
* ***** BEGIN GPL/BL DUAL LICENSE BLOCK *****
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version. The Blender
* Foundation also sells licenses for use in proprietary software under
* the Blender License. See http://www.blender.org/BL/ for information
* about this.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software Foundation,
* Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* The Original Code is Copyright (C) 2001-2002 by NaN Holding BV.
* All rights reserved.
*
* The Original Code is: all of this file.
*
* Contributor(s): none yet.
*
* ***** END GPL/BL DUAL LICENSE BLOCK *****
* TerraplayNetworkDeviceInterface derived from NG_NetworkDeviceInterface
*/
#include "NG_TerraplayNetworkDeviceInterface.h"
#include "NG_NetworkMessage.h"
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
//---- relocate these
void NG_TerraplayNetworkDeviceInterface::interface_error(char *str, GASResult error) {
GASRString err_str = GAS->ErrorTranslate(error);
if (err_str.result == GASOK)
printf("%s: %s\n",str,err_str.ptr);
else
printf("%s: UNKNOWN (Error code %d)", error);
}
//---- END relocate these
NG_TerraplayNetworkDeviceInterface::NG_TerraplayNetworkDeviceInterface()
{
group_id = GASCLIENTIDNULL;
group_id_request_valid = false;
this->Offline();
if ((GAS = new GASInterface()) == NULL) {
// terror
printf("ERROR GAS Common Network Interface NOT created\n");
// do something useful
} else {
printf("GAS Common Network Interface created\n");
}
}
NG_TerraplayNetworkDeviceInterface::~NG_TerraplayNetworkDeviceInterface()
{
if (GAS != NULL) {
delete GAS;
printf("GAS Common Network Interface deleted\n");
}
}
bool NG_TerraplayNetworkDeviceInterface::Connect(char *GAS_address,
unsigned int GAS_port, char *GAS_password, unsigned int localport,
unsigned int timeout)
{
GASResult result;
printf("Establishing connection to GAS...\n");
result = GAS->ConnectionRequest(GAS_address, GAS_port,
GAS_password,localport, timeout);
if (result == GASOK) {
this->Online();
GASRClientId client_id = GAS->Connected();
if (client_id.result != GASOK) {
printf("... connected, but no client ID\n");
return false;
} else {
printf("Connected with client ID %d\n",
client_id.clientid);
return true;
}
} else {
interface_error("Connection", result);
return false;
}
}
bool NG_TerraplayNetworkDeviceInterface::Disconnect(void)
{
int i = 0;
printf("Disconnecting...\n");
if (! this->IsOnline()) {
printf("ehh... /me was not connected\n");
return false;
}
GASRRequestId req = GAS->ConnectionClose();
if (req.result != GASWAITING) {
interface_error("ConnectionClose",req.result);
this->~NG_TerraplayNetworkDeviceInterface();
}
this->Offline();
// dit is erg fout :( ik wil helemaal geen ~NG_ hier
while (true) {
GASRMessage gas_message;
GASResult result = GAS->GasActivity(GASBLOCK, 100);
if (++i>5000) {
printf("\nGiving up on waiting for connection close\n");
this->~NG_TerraplayNetworkDeviceInterface();
}
switch (result) {
case GASCONNECTIONOK:
break;
case GASGASMESSAGE:
gas_message = GAS->GasMessageGetNext();
if (gas_message.type == GASRCONNECTIONCLOSE) {
if (gas_message.result == GASOK ||
gas_message.result == GASALREADYDONE) {
return true;
} else {
interface_error("GasMessageGetNext",
gas_message.result);
return false;
}
}
// no break ...
default:
interface_error("GasActivity",result);
}
}
return true;
}
STR_String NG_TerraplayNetworkDeviceInterface::GetNetworkVersion()
{
GASRString version = GAS->Version();
if (version.result != GASOK) {
interface_error("GetNetworkVersion", version.result);
return NULL;
} else {
return version.ptr;
}
}
int NG_TerraplayNetworkDeviceInterface::mytest() {
return (3);
}
void NG_TerraplayNetworkDeviceInterface::SendNetworkMessage(NG_NetworkMessage* nwmsg)
{
GASPayload payload;
GASResult result;
STR_String mystring;
if (group_id == GASCLIENTIDNULL) {
printf("Oops, no group to send to yet\n");
return;
}
mystring = nwmsg->GetMessageText().ReadPtr();
payload.ptr = (void *) mystring.Ptr();
payload.size = mystring.Length() + 1;
result = GAS->ClientMessageSend(group_id, payload, GASBESTEFFORT);
switch (result) {
case GASOK:
break;
default:
interface_error("ClientMessageSend",result);
}
// NOTE. You shall NOT free the payload with PayloadFree().
// This is your own payload, allocated and freed by yourself
// anyway you want.
}
vector <NG_NetworkMessage*> NG_TerraplayNetworkDeviceInterface::RetrieveNetworkMessages()
{
vector <NG_NetworkMessage*> messages;
//todo: spend your expensive time here!
return messages;
}