Changeset 2175

Timestamp:

Nov 10, 2008, 10:18:33 PM (15 years ago)

Author:

scheusso

Message:

some small adjustment with packetmap mutex
dedicated server tickrate limit works now:
configuration in orxonox.ini under [GSDedicate] → tickrate_

Location:

code/branches/objecthierarchy2/src

Files:

• network/packet/Packet.cc (modified) (2 diffs)
• orxonox/gamestates/GSDedicated.cc (modified) (4 diffs)
• orxonox/gamestates/GSDedicated.h (modified) (2 diffs)

code/branches/objecthierarchy2/src/network/packet/Packet.cc

@@ -129 +129 @@
       return false;
     }
-    // Assures we don't create a packet and destroy it right after in another thread
-    // without having a reference in the packetMap_
-    boost::recursive_mutex::scoped_lock lock(Packet::packetMap_mutex);
     // We deliver ENet the data address so that it doesn't memcpy everything again.
     // --> We have to delete data_ ourselves!
@@ -138 +135 @@
     // Add the packet to a global list so we can access it again once enet calls our
     // deletePacket method. We can of course only give a one argument function to the ENet C library.
-    packetMap_[(size_t)(void*)enetPacket_] = this;
+    {
+      // Assures we don't create a packet and destroy it right after in another thread
+      // without having a reference in the packetMap_
+      boost::recursive_mutex::scoped_lock lock(Packet::packetMap_mutex);
+      packetMap_[(size_t)(void*)enetPacket_] = this;
+    }
   }
 #ifndef NDEBUG

code/branches/objecthierarchy2/src/orxonox/gamestates/GSDedicated.cc

@@ -33 +33 @@
 #include "core/Core.h"
 #include "core/Iterator.h"
+#include "core/CoreIncludes.h"
+#include "core/ConfigValueIncludes.h"
+#include "util/Sleep.h"
 #include "network/Server.h"
 #include "objects/Tickable.h"
+
+const unsigned int  DEFAULT_DEDICATED_SERVER_TICKRATE = 25;
+const float         MIN_WIN32_SLEEP_TIME = 0.01; // scheduler limited
 
 namespace orxonox
@@ -42 +48 @@
         , server_(0)
     {
+        RegisterObject(GSDedicated);
+        
+        this->setConfigValues();
     }
 
@@ -53 +62 @@
 
         this->server_ = new Server(CommandLine::getValue("port"));
-        COUT(0) << "Loading scene in server mode" << std::endl;
+        COUT(0) << "Loading scene in dedicated server mode" << std::endl;
 
         GSLevel::enter(0);
@@ -72 +81 @@
     void GSDedicated::ticked(const Clock& time)
     {
+        static int timeSinceLastTick = 0; // in microseconds
+        const int tickPeriod = 1000000. / this->tickrate_; // in microseconds
+        
         GSLevel::ticked(time);
-        server_->tick(time.getDeltaTime());
+        
+        timeSinceLastTick += time.getDeltaTimeMicroseconds();
+        if ( timeSinceLastTick >= tickPeriod )
+        {
+            server_->tick( timeSinceLastTick );
+            //timeSinceLastTick -= static_cast<unsigned int>( timeSinceLastTick / tickPeriod ) * tickPeriod;
+            timeSinceLastTick = 0;
+        }
+        else
+        {
+            unsigned int sleepTime;
+            
+#if ORXONOX_PLATFORM == ORXONOX_PLATFORM_WIN32
+            if ( tickPeriod-timeSinceLastTick < MIN_WIN32_SLEEP_TIME )
+                sleepTime = MIN_WIN32_SLEEP_TIME*1000000;
+            else
+                sleepTime = tickPeriod - timeSinceLastTick;
+            msleep( sleepTime / 1000 );
+            
+#else /* unix */
+            sleepTime = tickPeriod - timeSinceLastTick;
+            usleep( sleepTime );
+#endif
+            
+        }
+        
         this->tickChild(time);
     }
+    
+    void GSDedicated::setConfigValues()
+    {
+        SetConfigValue ( tickrate_, DEFAULT_DEDICATED_SERVER_TICKRATE );
+    }
 }

code/branches/objecthierarchy2/src/orxonox/gamestates/GSDedicated.h

@@ -39 +39 @@
     class _OrxonoxExport GSDedicated : public GameState<GSRoot>, public GSLevel
     {
+    friend class ClassIdentifier<GSDedicated>;
     public:
         GSDedicated();
         ~GSDedicated();
+        
 
     private:
@@ -47 +49 @@
         void leave();
         void ticked(const Clock& time);
+        
+        void setConfigValues();
 
         Server*      server_;
+        unsigned int tickrate_;
     };
 }