client-side frame interpolation: network updates, interpolation of position

7 files changed, 65 insertions, 26 deletions

diff --git a/src/core/commandbuffer.cc b/src/core/commandbuffer.cc
index ead2a98..56aba16 100644
--- a/src/core/commandbuffer.cc
+++ b/src/core/commandbuffer.cc
@@ -5,10 +5,12 @@
 */
 
 #include <string>
+#include <fstream>
 #include <sstream>
 #include <list>
 
 #include "sys/sys.h"
+#include "filesystem/filesystem.h"
 #include "core/application.h"
 #include "core/commandbuffer.h"
 #include "core/gameconnection.h"
@@ -59,6 +61,16 @@ void func_set(std::string const &args)
 	return;
 }
 
+void func_exec(std::string const &args)
+{
+	std::istringstream argstream(args);
+	std::string filename;
+	if (!(argstream >> filename))
+			return;
+
+	CommandBuffer::exec_file(filename);	
+}
+
 std::stringstream CommandBuffer::cmdbuf(std::stringstream::in | std::stringstream::out);
 
 void CommandBuffer::init()
@@ -77,6 +89,9 @@ void CommandBuffer::init()
 
 	func = Func::add("set", (FuncPtr)func_set);
 	func->set_info("[variable] [str] set variable value");
+
+	func = Func::add("exec", (FuncPtr)exec);
+	func->set_info("[filename] execute commands from file");
 }
 
 void CommandBuffer::shutdown()
@@ -142,7 +157,7 @@ void  CommandBuffer::exec(std::string const &cmdline)
 		return;
 	}
 	
-	// TODO this must get forwarded to the server
+	// this gets forwarded to the server
 	if (connection()) 
 		connection()->forward(cmdline);
 	else
@@ -219,5 +234,33 @@ void CommandBuffer::complete(std::string &input, size_t &pos)
 	
 }
 
+void CommandBuffer::exec_file(std::string const & filename)
+{
+        filesystem::File *f = filesystem::open(filename.c_str());
+        if (!f) {
+                con_warn << "Could not open " << filename << std::endl;
+                return;
+        }
+
+        std::string fn = f->path();
+        fn.append(f->name());
+        filesystem::close(f);
+
+	std::ifstream ifs;
+	ifs.open(fn.c_str());
+        if (!ifs.is_open()) {
+                con_warn << "Could not stream " << fn << "!\n";
+                return;
+        }
+        
+	char line[MAXCMDSIZE];
+        while (ifs.getline(line, MAXCMDSIZE-1)) {
+                if (line[0] && line[0] != '#' && line[0] != ';')
+			exec(std::string(line));
+        }
+
+	ifs.close();
+}
+
 }
 
diff --git a/src/core/commandbuffer.h b/src/core/commandbuffer.h
index 8970d89..7b26211 100644
--- a/src/core/commandbuffer.h
+++ b/src/core/commandbuffer.h
@@ -28,6 +28,9 @@ public:
 	/// clear the command buffer
 	static void clear();
 
+	/// execute commands from a file
+	static void exec_file(std::string const & filename);
+
 	/// global buffer to hold the command stream
 	static std::stringstream cmd;
 
diff --git a/src/core/gameconnection.cc b/src/core/gameconnection.cc
index baf0967..b5ac27d 100644
--- a/src/core/gameconnection.cc
+++ b/src/core/gameconnection.cc
@@ -89,20 +89,21 @@ void GameConnection::frame(float seconds)
 	}
 
 	if (!Cvar::sv_dedicated->value()) {
-		update_clientstate();
+		update_clientstate(seconds);
 	}
 
+	connection_network->frame(seconds);
+
 	connection_frametime += seconds;
 
 	float f = 0;
 	if (core::Cvar::sv_framerate->value()) {		
-		f =  1.0f / core::Cvar::sv_framerate->value();
+		f =  0.5f / core::Cvar::sv_framerate->value();
 		if (connection_frametime < f) {
 			return;
 		}
 	}
 			
-	connection_network->frame(connection_frametime);
 	connection_frametime = 0;
 
 	if (localcontrol() && localcontrol()->dirty()) {
diff --git a/src/core/gameinterface.cc b/src/core/gameinterface.cc
index 8d351a0..d1bc1c3 100644
--- a/src/core/gameinterface.cc
+++ b/src/core/gameinterface.cc
@@ -95,48 +95,40 @@ void GameInterface::clear()
 	game_previousframetime = 0;
 	game_serverframetime = 0;
 	game_clientframetime = 0;
-	game_timestep = 0;
-	game_frames = 0;
 }
 
 void GameInterface::reset_clientstate(float servertime)
 {
-	game_timestep =  (servertime - game_serverframetime);
-
-	if (game_timestep < 0)
-		game_timestep = 0;
-
 	game_previousframetime = game_serverframetime;
-	game_serverframetime = servertime;
-	game_clientframetime = game_previousframetime;
+	game_clientframetime = game_serverframetime;
 
+	game_serverframetime = servertime;
+	
 	std::map<unsigned int, core::Entity *>::iterator it;
 	for (it=core::Entity::registry.begin(); it != core::Entity::registry.end(); it++) {
 		
 		core::Entity *entity = (*it).second;
 
-		if (entity->state() && !(entity->flags() & Entity::Static))
+		if (entity->state() && !(entity->flags() & core::Entity::Static))
 			entity->state()->assign(entity);
 	}
-	
-	game_frames = 0;
 }
 
-void GameInterface::update_clientstate()
+void GameInterface::update_clientstate(float seconds)
 {
-	game_frames++;
-	game_clientframetime += game_timestep;
+	game_clientframetime += seconds;
 
 	if (game_clientframetime > game_serverframetime)
 		game_clientframetime = game_serverframetime;
 }
 
 float GameInterface::timeoffset() {
+
 	float d = game_serverframetime - game_previousframetime;
-	if (d < 0)
-		d = 1;
-	float t = game_serverframetime - game_clientframetime;
+	if (d <= 0)
+		return 0;
 
+	float t = game_clientframetime - game_previousframetime;
 	return t/d;
 }
 
diff --git a/src/core/gameinterface.h b/src/core/gameinterface.h
index 2324bb5..0edcb1b 100644
--- a/src/core/gameinterface.h
+++ b/src/core/gameinterface.h
@@ -55,7 +55,7 @@ public:
 	void reset_clientstate(float servertime);
 
 	/// update the client state timers
-	void update_clientstate();
+	void update_clientstate(float seconds);
 
 /*----- virtual mutators ------------------------------------------ */
 	
@@ -73,7 +73,7 @@ protected:
 	float				game_timestep;
 	float				game_clientframetime;
 
-	unsigned int			game_frames;
+	unsigned int			game_serverframelength;
 };
 
 /// global local player instance
diff --git a/src/core/gameserver.cc b/src/core/gameserver.cc
index 3c126fc..3e5241e 100644
--- a/src/core/gameserver.cc
+++ b/src/core/gameserver.cc
@@ -260,7 +260,7 @@ void GameServer::frame(float seconds)
 	 	localplayer()->update_info();
 
 	if (!Cvar::sv_dedicated->value()) {
-		update_clientstate();
+		update_clientstate(seconds);
 	}
 
 	server_frametime += seconds;
diff --git a/src/core/netserver.cc b/src/core/netserver.cc
index 3005922..e66f63d 100644
--- a/src/core/netserver.cc
+++ b/src/core/netserver.cc
@@ -179,7 +179,7 @@ void NetServer::receive()
 
 	timeval timeout;
 	timeout.tv_sec = 0;
-	timeout.tv_usec = 5000;
+	timeout.tv_usec = 2500;
 	fd_set readset = serverset;
 
 	int nb = select(fd()+1, &readset, NULL, NULL, &timeout);