blob: 07a27a67455e1f8e4f22483762b64eb31bcc0260 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
/*
core/gameconnection.cc
This file is part of the Osirion project and is distributed under
the terms of the GNU General Public License version 2
*/
#include <string>
#include <sstream>
#include "sys/sys.h"
#include "net/net.h"
#include "core/cvar.h"
#include "core/gameconnection.h"
namespace core
{
GameConnection* GameConnection::connection_instance = 0;
GameConnection::GameConnection(std::string const &connectionstr)
{
connection_instance = this;
connection_network = 0;
connection_running = false;
unsigned int port = net::DEFAULTPORT;
std::string host(connectionstr);
size_t found = host.find(':');
if (found != std::string::npos) {
std::istringstream str(host.substr(found+1));
if (str >> port) {
host.erase(found, std::string::npos);
} else {
con_print << "Invalid hostname '" << host << "'\n";
abort();
return;
}
}
connection_network = new NetConnection();
connection_network->connect(host, port);
if (!connection_network->connected()) {
abort();
return;
}
connection_frametime = 0;
connection_running = true;
}
GameConnection::~GameConnection()
{
if (connection_network) {
connection_network->disconnect();
delete connection_network;
}
connection_instance = 0;
}
void GameConnection::abort()
{
connection_running = false;
}
void GameConnection::forward(std::string const &cmdline)
{
if (!connection_network->connected())
return;
std::string netmessage("cmd ");
netmessage.append(cmdline);
netmessage += '\n';
connection_network->send(netmessage);
}
void GameConnection::frame(float seconds)
{
if (!running())
return;
if (!connection_network->connected()) {
abort();
return;
}
float f = 0;
if (core::Cvar::sv_framerate->value()) {
connection_frametime += seconds;
f = 1.0f / core::Cvar::sv_framerate->value();
if (connection_frametime < f) {
// run client prediction
std::map<unsigned int, Entity *>::iterator it;
for (it=Entity::registry.begin(); it != Entity::registry.end(); it++) {
Entity *entity = (*it).second;
if ((entity->type() == Entity::Controlable) || (entity->type() == Entity::Dynamic)) {
entity->frame(seconds);
}
}
return;
}
} else {
connection_frametime = seconds;
}
connection_network->frame(connection_frametime);
if (localcontrol() && localcontrol()->dirty()) {
std::ostringstream netmsg;
netmsg << "cup " << localcontrol()->id() << " ";
localcontrol()->serialize_client_update(netmsg);
netmsg << "\n";
connection_network->send(netmsg.str());
localcontrol()->entity_dirty = false;
//con_debug << netmsg.str();
}
connection_frametime += f;
}
}
|
