oss/luanti
oss/luanti
1
0
Fork 0
mirror of https://github.com/luanti-org/luanti.git synced 2025-06-27 16:36:03 +00:00
Code Wiki Activity

Add an active object step time budget #6721

Browse source 
This can be set via the active_object_interval option.
This commit is contained in:
Lars Hofhansl 2017-12-06 12:21:46 -08:00
parent e049405fdc
commit 9c669016d1
7 changed files with 68 additions and 38 deletions
Download patch file Download diff file Expand all files Collapse all files

85
src/serverenvironment.cpp
View file

@ -279,17 +279,17 @@ void LBMManager::applyLBMs(ServerEnvironment *env, MapBlock *block, u32 stamp)
void fillRadiusBlock(v3s16 p0, s16 r, std::set<v3s16> &list)
{
const s16 r2 = r * r;
v3s16 p;
for(p.X=p0.X-r; p.X<=p0.X+r; p.X++)
for(p.Y=p0.Y-r; p.Y<=p0.Y+r; p.Y++)
for(p.Z=p0.Z-r; p.Z<=p0.Z+r; p.Z++)
{
// limit to a sphere
if (p.getDistanceFrom(p0) <= r) {
// Set in list
list.insert(p);
}
}
for (p.X = p0.X - r; p.X <= p0.X + r; p.X++)
for (p.Y = p0.Y - r; p.Y <= p0.Y + r; p.Y++)
for (p.Z = p0.Z - r; p.Z <= p0.Z + r; p.Z++) {
// limit to a sphere
if (p.getDistanceFromSQ(p0) <= r2) {
// Set in list
list.insert(p);
}
}
}
void fillViewConeBlock(v3s16 p0,
@ -364,10 +364,7 @@ void ActiveBlockList::update(std::vector<PlayerSAO*> &active_players,
/*
Update m_list
*/
m_list.clear();
for (v3s16 p : newlist) {
m_list.insert(p);
}
m_list = newlist;
}
/*
@ -1230,14 +1227,16 @@ void ServerEnvironment::step(float dtime)
}
}
// placeholder for the "real" time passed
float elapsed_time;
/*
Mess around in active blocks
*/
if (m_active_blocks_nodemetadata_interval.step(dtime, m_cache_nodetimer_interval)) {
if (m_active_blocks_nodemetadata_interval.step(dtime, m_cache_nodetimer_interval,
&elapsed_time)) {
ScopeProfiler sp(g_profiler, "SEnv: mess in act. blocks avg per interval", SPT_AVG);
float dtime = m_cache_nodetimer_interval;
for (const v3s16 &p: m_active_blocks.m_list) {
MapBlock *block = m_map->getBlockNoCreateNoEx(p);
if (!block)
@ -1255,7 +1254,7 @@ void ServerEnvironment::step(float dtime)
MOD_REASON_BLOCK_EXPIRED);
// Run node timers
std::vector<NodeTimer> elapsed_timers = block->m_node_timers.step(dtime);
std::vector<NodeTimer> elapsed_timers = block->m_node_timers.step(elapsed_time);
if (!elapsed_timers.empty()) {
MapNode n;
v3s16 p2;
@ -1271,18 +1270,14 @@ void ServerEnvironment::step(float dtime)
}
}
if (m_active_block_modifier_interval.step(dtime, m_cache_abm_interval))
if (m_active_block_modifier_interval.step(dtime,
m_cache_abm_interval * m_active_block_interval_overload_skip, &elapsed_time))
do { // breakable
if (m_active_block_interval_overload_skip > 0) {
ScopeProfiler sp(g_profiler, "SEnv: ABM overload skips");
m_active_block_interval_overload_skip--;
break;
}
ScopeProfiler sp(g_profiler, "SEnv: modify in blocks avg per interval", SPT_AVG);
TimeTaker timer("modify in active blocks per interval");
// Initialize handling of ActiveBlockModifiers
ABMHandler abmhandler(m_abms, m_cache_abm_interval, this, true);
ABMHandler abmhandler(m_abms, elapsed_time, this, true);
for (const v3s16 &p : m_active_blocks.m_abm_list) {
MapBlock *block = m_map->getBlockNoCreateNoEx(p);
@ -1296,13 +1291,16 @@ void ServerEnvironment::step(float dtime)
abmhandler.apply(block);
}
u32 time_ms = timer.stop(true);
u32 max_time_ms = 200;
const u32 time_ms = timer.stop(true);
// allow up to 10% of the budget interval
const u32 max_time_ms = m_cache_abm_interval * 1000.0f * 0.1f;
if (time_ms > max_time_ms) {
warningstream<<"active block modifiers took "
<<time_ms<<"ms (longer than "
<<max_time_ms<<"ms)"<<std::endl;
m_active_block_interval_overload_skip = (time_ms / max_time_ms) + 1;
warningstream << "active block modifiers took "
<< time_ms << "ms (longer than "
<< max_time_ms << "ms)" << std::endl;
m_active_block_interval_overload_skip = ((float)time_ms / max_time_ms);
} else {
m_active_block_interval_overload_skip = 1.0f;
}
}while(0);
@ -1314,15 +1312,17 @@ void ServerEnvironment::step(float dtime)
/*
Step active objects
*/
{
if (m_active_object_interval.step(dtime,
m_cache_ao_interval * m_active_object_interval_overload_skip, &elapsed_time)) {
ScopeProfiler sp(g_profiler, "SEnv: step act. objs avg", SPT_AVG);
//TimeTaker timer("Step active objects");
TimeTaker timer("Step active objects");
g_profiler->avg("SEnv: num of objects", m_active_objects.size());
// This helps the objects to send data at the same time
bool send_recommended = false;
m_send_recommended_timer += dtime;
m_send_recommended_timer += elapsed_time;
if(m_send_recommended_timer > getSendRecommendedInterval())
{
m_send_recommended_timer -= getSendRecommendedInterval();
@ -1335,13 +1335,28 @@ void ServerEnvironment::step(float dtime)
continue;
// Step object
obj->step(dtime, send_recommended);
obj->step(elapsed_time, send_recommended);
// Read messages from object
while (!obj->m_messages_out.empty()) {
m_active_object_messages.push(obj->m_messages_out.front());
obj->m_messages_out.pop();
}
}
// calculate a simple moving average
m_avg_ao_time = m_avg_ao_time * 0.9f + timer.stop(true) * 0.1f;
// allow up to 20% of the budget interval
const float max_time_ms = m_cache_ao_interval * 1000.0f * 0.2f;
if (m_avg_ao_time > max_time_ms) {
warningstream << "active objects took "
<< m_avg_ao_time << "ms (longer than "
<< max_time_ms << "ms)" << std::endl;
// skip a few steps
m_active_object_interval_overload_skip = m_avg_ao_time / max_time_ms;
} else {
m_active_object_interval_overload_skip = 1.0f;
}
}
/*