*** empty log message ***
git-svn-id: svn://svn.code.sf.net/p/actiongame/code/trunk/ac@481 e016b1c5-ed68-44aa-a2f7-31cac88cffde
This commit is contained in:
Lee Salzman
@@ -1,367 +0,0 @@
|
||||
// client.cpp, mostly network related client game code
|
||||
|
||||
#include "cube.h"
|
||||
|
||||
ENetHost *clienthost = NULL;
|
||||
int connecting = 0;
|
||||
int connattempts = 0;
|
||||
int disconnecting = 0;
|
||||
int clientnum = -1; // our client id in the game
|
||||
bool c2sinit = false; // whether we need to tell the other clients our stats
|
||||
|
||||
int getclientnum() { return clientnum; };
|
||||
|
||||
bool multiplayer()
|
||||
{
|
||||
// check not correct on listen server?
|
||||
if(clienthost) conoutf("operation not available in multiplayer");
|
||||
return clienthost!=NULL;
|
||||
};
|
||||
|
||||
bool allowedittoggle()
|
||||
{
|
||||
bool allow = !clienthost || gamemode==1;
|
||||
if(!allow) conoutf("editing in multiplayer requires coopedit mode (1)");
|
||||
return allow;
|
||||
};
|
||||
|
||||
VARF(rate, 0, 0, 25000, if(clienthost && (!rate || rate>1000)) enet_host_bandwidth_limit (clienthost, rate, rate));
|
||||
|
||||
void throttle();
|
||||
|
||||
VARF(throttle_interval, 0, 5, 30, throttle());
|
||||
VARF(throttle_accel, 0, 2, 32, throttle());
|
||||
VARF(throttle_decel, 0, 2, 32, throttle());
|
||||
|
||||
void throttle()
|
||||
{
|
||||
if(!clienthost || connecting) return;
|
||||
ASSERT(ENET_PEER_PACKET_THROTTLE_SCALE==32);
|
||||
enet_peer_throttle_configure(clienthost->peers, throttle_interval*1000, throttle_accel, throttle_decel);
|
||||
};
|
||||
|
||||
void ctf_team(char *name)
|
||||
{
|
||||
bool isvalidteam = strcmp(name, "RVSF") == 0 || strcmp(name, "CLA") == 0;
|
||||
if(strcmp(name, player1->team) == 0 && isvalidteam) return;
|
||||
c2sinit = false;
|
||||
ctf_death();
|
||||
if(isvalidteam) strcpy(player1->team, name);
|
||||
else strcpy(player1->team, rb_team_string(rnd(2)));
|
||||
player1->lastaction = lastmillis;
|
||||
player1->state = CS_DEAD;
|
||||
};
|
||||
|
||||
void newname(char *name) { c2sinit = false; s_strncpy(player1->name, name, 16); };
|
||||
void newskin(int skin) { player1->nextskin = max(0, min(skin, (rb_team_int(player1->team)==TEAM_CLA ? 3 : 5))); };
|
||||
void newteam(char *name)
|
||||
{
|
||||
if(m_teammode) ctf_team(name);
|
||||
else { s_strncpy(player1->team, name, 5); c2sinit=false; };
|
||||
};
|
||||
|
||||
COMMANDN(team, newteam, ARG_1STR);
|
||||
COMMANDN(name, newname, ARG_1STR);
|
||||
COMMANDN(skin, newskin, ARG_1INT);
|
||||
|
||||
void connects(char *servername)
|
||||
{
|
||||
disconnect(1); // reset state
|
||||
|
||||
ENetAddress address;
|
||||
address.port = CUBE_SERVER_PORT;
|
||||
|
||||
if(servername)
|
||||
{
|
||||
addserver(servername);
|
||||
conoutf("attempting to connect to %s", servername);
|
||||
if(!resolverwait(servername, &address))
|
||||
{
|
||||
conoutf("could not resolve server %s", servername);
|
||||
return;
|
||||
};
|
||||
}
|
||||
else
|
||||
{
|
||||
conoutf("attempting to connect over LAN");
|
||||
address.host = ENET_HOST_BROADCAST;
|
||||
};
|
||||
|
||||
clienthost = enet_host_create(NULL, 1, rate, rate);
|
||||
|
||||
if(clienthost)
|
||||
{
|
||||
enet_host_connect(clienthost, &address, 4);
|
||||
enet_host_flush(clienthost);
|
||||
connecting = lastmillis;
|
||||
connattempts = 0;
|
||||
}
|
||||
else
|
||||
{
|
||||
conoutf("could not connect to server");
|
||||
disconnect();
|
||||
};
|
||||
};
|
||||
|
||||
void disconnect(int onlyclean, int async)
|
||||
{
|
||||
if(clienthost)
|
||||
{
|
||||
if(!connecting && !disconnecting)
|
||||
{
|
||||
enet_peer_disconnect(clienthost->peers, DISC_NONE);
|
||||
enet_host_flush(clienthost);
|
||||
disconnecting = lastmillis;
|
||||
};
|
||||
if(clienthost->peers->state != ENET_PEER_STATE_DISCONNECTED)
|
||||
{
|
||||
if(async) return;
|
||||
enet_peer_reset(clienthost->peers);
|
||||
};
|
||||
enet_host_destroy(clienthost);
|
||||
};
|
||||
|
||||
if(clienthost && !connecting) conoutf("disconnected");
|
||||
clienthost = NULL;
|
||||
connecting = 0;
|
||||
connattempts = 0;
|
||||
disconnecting = 0;
|
||||
clientnum = -1;
|
||||
c2sinit = false;
|
||||
player1->lifesequence = 0;
|
||||
loopv(players) zapdynent(players[i]);
|
||||
|
||||
localdisconnect();
|
||||
|
||||
if(!onlyclean) { stop(); localconnect(); };
|
||||
};
|
||||
|
||||
void trydisconnect()
|
||||
{
|
||||
if(!clienthost)
|
||||
{
|
||||
conoutf("not connected");
|
||||
return;
|
||||
};
|
||||
if(connecting)
|
||||
{
|
||||
conoutf("aborting connection attempt");
|
||||
disconnect();
|
||||
return;
|
||||
};
|
||||
conoutf("attempting to disconnect...");
|
||||
disconnect(0, !disconnecting);
|
||||
};
|
||||
|
||||
void toserver(char *text) { conoutf("%s:\f %s", player1->name, text); addmsg(SV_TEXT, "rs", text); };
|
||||
void echo(char *text) { conoutf("%s", text); };
|
||||
|
||||
void lanconnect()
|
||||
{
|
||||
connects(0);
|
||||
};
|
||||
|
||||
COMMAND(echo, ARG_VARI);
|
||||
COMMANDN(say, toserver, ARG_VARI);
|
||||
COMMANDN(connect, connects, ARG_1STR);
|
||||
COMMAND(lanconnect, ARG_NONE);
|
||||
COMMANDN(disconnect, trydisconnect, ARG_NONE);
|
||||
|
||||
// collect c2s messages conveniently
|
||||
|
||||
vector<uchar> messages;
|
||||
|
||||
void addmsg(int type, const char *fmt, ...)
|
||||
{
|
||||
if(demoplayback) return;
|
||||
static uchar buf[MAXTRANS];
|
||||
ucharbuf p(buf, MAXTRANS);
|
||||
putint(p, type);
|
||||
int numi = 1, nums = 0;
|
||||
bool reliable = false;
|
||||
if(fmt)
|
||||
{
|
||||
va_list args;
|
||||
va_start(args, fmt);
|
||||
while(*fmt) switch(*fmt++)
|
||||
{
|
||||
case 'r': reliable = true; break;
|
||||
case 'i':
|
||||
{
|
||||
int n = isdigit(*fmt) ? *fmt++-'0' : 1;
|
||||
loopi(n) putint(p, va_arg(args, int));
|
||||
numi += n;
|
||||
break;
|
||||
};
|
||||
case 's': sendstring(va_arg(args, const char *), p); nums++; break;
|
||||
};
|
||||
va_end(args);
|
||||
};
|
||||
int num = nums?0:numi;
|
||||
if(num!=msgsizelookup(type)) { s_sprintfd(s)("inconsistant msg size for %d (%d != %d)", type, num, msgsizelookup(type)); fatal(s); };
|
||||
int len = p.length();
|
||||
messages.add(len&0xFF);
|
||||
messages.add((len>>8)|(reliable ? 0x80 : 0));
|
||||
loopi(len) messages.add(buf[i]);
|
||||
};
|
||||
|
||||
int lastupdate = 0, lastping = 0;
|
||||
bool senditemstoserver = false; // after a map change, since server doesn't have map data
|
||||
|
||||
string clientpassword;
|
||||
char *toserverpwd = NULL;
|
||||
void password(char *p) { s_strcpy(clientpassword, p); };
|
||||
COMMAND(password, ARG_1STR);
|
||||
|
||||
bool netmapstart() { senditemstoserver = true; return clienthost!=NULL; };
|
||||
|
||||
void initclientnet()
|
||||
{
|
||||
clientpassword[0] = 0;
|
||||
newname("unnamed");
|
||||
ctf_team("red");
|
||||
};
|
||||
|
||||
void sendpackettoserv(int chan, ENetPacket *packet)
|
||||
{
|
||||
if(clienthost) { enet_host_broadcast(clienthost, chan, packet); enet_host_flush(clienthost); }
|
||||
else localclienttoserver(chan, packet);
|
||||
}
|
||||
|
||||
void c2skeepalive()
|
||||
{
|
||||
if(clientnum<0 || !clienthost) return;
|
||||
if(lastmillis-lastupdate<40) return;
|
||||
|
||||
ENetEvent event;
|
||||
while(clienthost!=NULL && enet_host_service(clienthost, &event, 0)>0) {}; // fixme
|
||||
|
||||
lastupdate = SDL_GetTicks();
|
||||
};
|
||||
|
||||
extern string masterpwd;
|
||||
|
||||
void c2sinfo(dynent *d) // send update to the server
|
||||
{
|
||||
if(clientnum<0) return; // we haven't had a welcome message from the server yet
|
||||
if(lastmillis-lastupdate<40) return; // don't update faster than 25fps
|
||||
ENetPacket *packet = enet_packet_create(NULL, 100, 0);
|
||||
ucharbuf q(packet->data, packet->dataLength);
|
||||
|
||||
putint(q, SV_POS);
|
||||
putint(q, clientnum);
|
||||
putuint(q, (int)(d->o.x*DMF)); // quantize coordinates to 1/16th of a cube, between 1 and 3 bytes
|
||||
putuint(q, (int)(d->o.y*DMF));
|
||||
putuint(q, (int)(d->o.z*DMF));
|
||||
putuint(q, (int)(d->yaw*DAF));
|
||||
putint(q, (int)(d->pitch*DAF));
|
||||
putint(q, (int)(d->roll*DAF));
|
||||
putint(q, (int)(d->vel.x*DVF)); // quantize to 1/100, almost always 1 byte
|
||||
putint(q, (int)(d->vel.y*DVF));
|
||||
putint(q, (int)(d->vel.z*DVF));
|
||||
// pack rest in 1 byte: strafe:2, move:2, onfloor:1, state:3
|
||||
putint(q, (d->strafe&3) | ((d->move&3)<<2) | (((int)d->onfloor)<<4) | ((editmode ? CS_EDITING : d->state)<<5) );
|
||||
|
||||
enet_packet_resize(packet, q.length());
|
||||
incomingdemodata(0, q.buf, q.length(), true);
|
||||
sendpackettoserv(0, packet);
|
||||
|
||||
bool serveriteminitdone = false;
|
||||
if(gun_changed || senditemstoserver || !c2sinit || messages.length() || lastmillis-lastping>250)
|
||||
{
|
||||
packet = enet_packet_create (NULL, MAXTRANS, 0);
|
||||
ucharbuf p(packet->data, packet->dataLength);
|
||||
|
||||
if(gun_changed)
|
||||
{
|
||||
packet->flags = ENET_PACKET_FLAG_RELIABLE;
|
||||
putint(p, SV_WEAPCHANGE);
|
||||
putint(p, player1->gunselect);
|
||||
gun_changed = false;
|
||||
};
|
||||
if(senditemstoserver)
|
||||
{
|
||||
packet->flags = ENET_PACKET_FLAG_RELIABLE;
|
||||
putint(p, SV_ITEMLIST);
|
||||
if(!m_noitems) putitems(p);
|
||||
putint(p, -1);
|
||||
senditemstoserver = false;
|
||||
serveriteminitdone = true;
|
||||
};
|
||||
if(!c2sinit) // tell other clients who I am
|
||||
{
|
||||
packet->flags = ENET_PACKET_FLAG_RELIABLE;
|
||||
c2sinit = true;
|
||||
putint(p, SV_INITC2S);
|
||||
sendstring(player1->name, p);
|
||||
sendstring(player1->team, p);
|
||||
putint(p, player1->skin);
|
||||
putint(p, player1->lifesequence);
|
||||
};
|
||||
int i = 0;
|
||||
while(i < messages.length()) // send messages collected during the previous frames
|
||||
{
|
||||
int len = messages[i] | ((messages[i+1]&0x7F)<<8);
|
||||
if(p.remaining() < len) break;
|
||||
if(messages[i+1]&0x80) packet->flags = ENET_PACKET_FLAG_RELIABLE;
|
||||
p.put(&messages[i+2], len);
|
||||
i += 2 + len;
|
||||
};
|
||||
messages.remove(0, i);
|
||||
if(lastmillis-lastping>250)
|
||||
{
|
||||
putint(p, SV_PING);
|
||||
putint(p, lastmillis);
|
||||
lastping = lastmillis;
|
||||
};
|
||||
if(!p.length()) enet_packet_destroy(packet);
|
||||
else
|
||||
{
|
||||
enet_packet_resize(packet, p.length());
|
||||
sendpackettoserv(1, packet);
|
||||
};
|
||||
};
|
||||
lastupdate = lastmillis;
|
||||
if(serveriteminitdone) loadgamerest(); // hack
|
||||
};
|
||||
|
||||
void gets2c() // get updates from the server
|
||||
{
|
||||
ENetEvent event;
|
||||
if(!clienthost) return;
|
||||
if(connecting && lastmillis/3000 > connecting/3000)
|
||||
{
|
||||
conoutf("attempting to connect...");
|
||||
connecting = lastmillis;
|
||||
++connattempts;
|
||||
if(connattempts > 3)
|
||||
{
|
||||
conoutf("could not connect to server");
|
||||
disconnect();
|
||||
return;
|
||||
};
|
||||
};
|
||||
while(clienthost!=NULL && enet_host_service(clienthost, &event, 0)>0)
|
||||
switch(event.type)
|
||||
{
|
||||
case ENET_EVENT_TYPE_CONNECT:
|
||||
conoutf("connected to server");
|
||||
connecting = 0;
|
||||
throttle();
|
||||
break;
|
||||
|
||||
case ENET_EVENT_TYPE_RECEIVE:
|
||||
if(disconnecting)
|
||||
conoutf("attempting to disconnect...");
|
||||
else localservertoclient(event.channelID, event.packet->data, event.packet->dataLength);
|
||||
enet_packet_destroy(event.packet);
|
||||
break;
|
||||
|
||||
case ENET_EVENT_TYPE_DISCONNECT:
|
||||
extern char *disc_reasons[];
|
||||
if(event.data>DISC_MAXCLIENTS) event.data = DISC_NONE;
|
||||
if(!disconnecting || event.data) conoutf("\fserver network error, disconnecting (%s) ...", disc_reasons[event.data]);
|
||||
disconnect();
|
||||
return;
|
||||
}
|
||||
};
|
||||
Reference in New Issue
Block a user