/* Minetest-c55 Copyright (C) 2010 celeron55, Perttu Ahola This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include "voxel.h" #include "map.h" // For TimeTaker #include "main.h" #include "utility.h" /* Debug stuff */ u32 addarea_time = 0; u32 emerge_time = 0; u32 emerge_load_time = 0; u32 clearflag_time = 0; //u32 getwaterpressure_time = 0; //u32 spreadwaterpressure_time = 0; u32 updateareawaterpressure_time = 0; u32 flowwater_pre_time = 0; VoxelManipulator::VoxelManipulator(): m_data(NULL), m_flags(NULL) { } VoxelManipulator::~VoxelManipulator() { clear(); if(m_data) delete[] m_data; if(m_flags) delete[] m_flags; } void VoxelManipulator::clear() { // Reset area to volume=0 m_area = VoxelArea(); if(m_data) delete[] m_data; m_data = NULL; if(m_flags) delete[] m_flags; m_flags = NULL; } void VoxelManipulator::print(std::ostream &o, VoxelPrintMode mode) { v3s16 em = m_area.getExtent(); v3s16 of = m_area.MinEdge; o<<"size: "<=m_area.MinEdge.Y; y--) { if(em.X >= 3 && em.Y >= 3) { if (y==m_area.MinEdge.Y+2) o<<"^ "; else if(y==m_area.MinEdge.Y+1) o<<"| "; else if(y==m_area.MinEdge.Y+0) o<<"y x-> "; else o<<" "; } for(s32 z=m_area.MinEdge.Z; z<=m_area.MaxEdge.Z; z++) { for(s32 x=m_area.MinEdge.X; x<=m_area.MaxEdge.X; x++) { u8 f = m_flags[m_area.index(x,y,z)]; char c; if(f & VOXELFLAG_NOT_LOADED) c = 'N'; else if(f & VOXELFLAG_INEXISTENT) c = 'I'; else { c = 'X'; u8 m = m_data[m_area.index(x,y,z)].d; u8 pr = m_data[m_area.index(x,y,z)].pressure; if(mode == VOXELPRINT_MATERIAL) { if(m <= 9) c = m + '0'; } else if(mode == VOXELPRINT_WATERPRESSURE) { if(m == MATERIAL_WATER) { c = 'w'; if(pr <= 9) c = pr + '0'; } else if(m == MATERIAL_AIR) { c = ' '; } else { c = '#'; } } } o< buf(area.getVolume()); for(s32 z=area.MinEdge.Z; z<=area.MaxEdge.Z; z++) for(s32 y=area.MinEdge.Y; y<=area.MaxEdge.Y; y++) for(s32 x=area.MinEdge.X; x<=area.MaxEdge.X; x++) { v3s16 p(x,y,z); v3s16 dirs[] = { v3s16(1,1,0), v3s16(1,0,1), v3s16(1,-1,0), v3s16(1,0,-1), v3s16(-1,1,0), v3s16(-1,0,1), v3s16(-1,-1,0), v3s16(-1,0,-1), }; //const v3s16 *dirs = g_26dirs; s16 total = 0; s16 airness = 0; u8 m = MATERIAL_IGNORE; for(s16 i=0; i<8; i++) //for(s16 i=0; i<26; i++) { v3s16 p2 = p + dirs[i]; u8 f = m_flags[m_area.index(p2)]; assert(!(f & VOXELFLAG_NOT_LOADED)); if(f & VOXELFLAG_INEXISTENT) continue; MapNode &n = m_data[m_area.index(p2)]; airness += (n.d == MATERIAL_AIR) ? 1 : -1; total++; if(m == MATERIAL_IGNORE && n.d != MATERIAL_AIR) m = n.d; } // 1 if air, 0 if not buf[area.index(p)] = airness > -total/2 ? MATERIAL_AIR : m; //buf[area.index(p)] = airness > -total ? MATERIAL_AIR : m; //buf[area.index(p)] = airness >= -7 ? MATERIAL_AIR : m; } for(s32 z=area.MinEdge.Z; z<=area.MaxEdge.Z; z++) for(s32 y=area.MinEdge.Y; y<=area.MaxEdge.Y; y++) for(s32 x=area.MinEdge.X; x<=area.MaxEdge.X; x++) { v3s16 p(x,y,z); m_data[m_area.index(p)].d = buf[area.index(p)]; } } void VoxelManipulator::clearFlag(u8 flags) { // 0-1ms on moderate area TimeTaker timer("clearFlag", g_device, &clearflag_time); v3s16 s = m_area.getExtent(); /*dstream<<"clearFlag clearing area of size " <<""< highest_y) highest_y = p.Y; recur_count++; if(recur_count > 30) throw ProcessingLimitException ("getWaterPressure recur_count limit reached"); v3s16 dirs[6] = { v3s16(0,1,0), // top v3s16(-1,0,0), // left v3s16(1,0,0), // right v3s16(0,0,-1), // front v3s16(0,0,1), // back v3s16(0,-1,0), // bottom }; // Load neighboring nodes // TODO: A bigger area would be better emerge(VoxelArea(p - v3s16(1,1,1), p + v3s16(1,1,1))); s32 i; for(i=0; i<6; i++) { v3s16 p2 = p + dirs[i]; u8 f = m_flags[m_area.index(p2)]; // Ignore inexistent or checked nodes if(f & (VOXELFLAG_INEXISTENT | VOXELFLAG_CHECKED2)) continue; MapNode &n = m_data[m_area.index(p2)]; // Ignore non-liquid nodes if(material_liquid(n.d) == false) continue; int pr; // If at surface /*if(n.pressure == 1) { pr = 1; } // Otherwise recurse more else*/ { pr = getWaterPressure(p2, highest_y, recur_count); if(pr == -1) continue; } // If block is at top, pressure here is one higher if(i == 0) { if(pr < 255) pr++; } // If block is at bottom, pressure here is one lower else if(i == 5) { if(pr > 1) pr--; } // Node is on the pressure route m_flags[m_area.index(p)] |= VOXELFLAG_CHECKED4; // Got pressure return pr; } // Nothing useful found return -1; } void VoxelManipulator::spreadWaterPressure(v3s16 p, int pr, VoxelArea request_area, core::map &active_nodes, int recur_count) { recur_count++; if(recur_count > 10000) throw ProcessingLimitException ("spreadWaterPressure recur_count limit reached"); m_flags[m_area.index(p)] |= VOXELFLAG_CHECKED3; m_data[m_area.index(p)].pressure = pr; v3s16 dirs[6] = { v3s16(0,1,0), // top v3s16(-1,0,0), // left v3s16(1,0,0), // right v3s16(0,0,-1), // front v3s16(0,0,1), // back v3s16(0,-1,0), // bottom }; // Load neighboring nodes emerge(VoxelArea(p - v3s16(1,1,1), p + v3s16(1,1,1))); s32 i; for(i=0; i<6; i++) { v3s16 p2 = p + dirs[i]; u8 f = m_flags[m_area.index(p2)]; // Ignore inexistent and checked nodes if(f & (VOXELFLAG_INEXISTENT | VOXELFLAG_CHECKED3)) continue; MapNode &n = m_data[m_area.index(p2)]; /* If material is air: add to active_nodes if there is flow-causing pressure. NOTE: Do not remove anything from there. We cannot know here if some other neighbor of it causes flow. */ if(n.d == MATERIAL_AIR) { bool pressure_causes_flow = false; // If block is at top if(i == 0) { if(pr >= 3) pressure_causes_flow = true; } // If block is at bottom else if(i == 5) { pressure_causes_flow = true; } // If block is at side else { if(pr >= 2) pressure_causes_flow = true; } if(pressure_causes_flow) { active_nodes[p2] = 1; } continue; } // Ignore non-liquid nodes if(material_liquid(n.d) == false) continue; int pr2 = pr; // If block is at top, pressure there is lower if(i == 0) { if(pr2 > 0) pr2--; } // If block is at bottom, pressure there is higher else if(i == 5) { if(pr2 < 255) pr2++; } // Ignore if correct pressure is already set and is not on // request_area if(n.pressure == pr2 && request_area.contains(p2) == false) continue; spreadWaterPressure(p2, pr2, request_area, active_nodes, recur_count); } } void VoxelManipulator::updateAreaWaterPressure(VoxelArea a, core::map &active_nodes, bool checked3_is_clear) { TimeTaker timer("updateAreaWaterPressure", g_device, &updateareawaterpressure_time); emerge(a); bool checked2_clear = false; if(checked3_is_clear == false) { //clearFlag(VOXELFLAG_CHECKED3); clearFlag(VOXELFLAG_CHECKED3 | VOXELFLAG_CHECKED2); checked2_clear = true; } for(s32 z=a.MinEdge.Z; z<=a.MaxEdge.Z; z++) for(s32 y=a.MinEdge.Y; y<=a.MaxEdge.Y; y++) for(s32 x=a.MinEdge.X; x<=a.MaxEdge.X; x++) { v3s16 p(x,y,z); u8 f = m_flags[m_area.index(p)]; // Ignore inexistent or checked nodes if(f & (VOXELFLAG_INEXISTENT | VOXELFLAG_CHECKED3)) continue; MapNode &n = m_data[m_area.index(p)]; // Ignore non-liquid nodes if(material_liquid(n.d) == false) continue; if(checked2_clear == false) { clearFlag(VOXELFLAG_CHECKED2); checked2_clear = true; } checked2_clear = false; s16 highest_y = -32768; int recur_count = 0; int pr = -1; try { // 0-1ms @ recur_count <= 100 //TimeTaker timer("getWaterPressure", g_device); pr = getWaterPressure(p, highest_y, recur_count); } catch(ProcessingLimitException &e) { //dstream<<"getWaterPressure ProcessingLimitException"< 255) pr = 255; /*dstream<<"WARNING: Pressure at (" < &active_nodes, int recursion_depth, bool debugprint, int *counter, int counterlimit) { v3s16 dirs[6] = { v3s16(0,1,0), // top v3s16(-1,0,0), // left v3s16(1,0,0), // right v3s16(0,0,-1), // front v3s16(0,0,1), // back v3s16(0,-1,0), // bottom }; recursion_depth++; v3s16 p; // Randomize horizontal order static s32 cs = 0; if(cs < 3) cs++; else cs = 0; s16 s1 = (cs & 1) ? 1 : -1; s16 s2 = (cs & 2) ? 1 : -1; //dstream<<"s1="<= 3) break; continue; } // Else block is at some side. Select it if it has enough pressure if(n.pressure >= 2) { break; } } // If there is nothing to move, return if(i==6) return false; // Switch nodes at p and removed_pos u8 m = m_data[m_area.index(p)].d; u8 f = m_flags[m_area.index(p)]; m_data[m_area.index(p)].d = m_data[m_area.index(removed_pos)].d; m_flags[m_area.index(p)] = m_flags[m_area.index(removed_pos)]; m_data[m_area.index(removed_pos)].d = m; m_flags[m_area.index(removed_pos)] = f; // Mark removed_pos checked m_flags[m_area.index(removed_pos)] |= VOXELFLAG_CHECKED; // If block was dropped from surface, increase pressure if(i == 0 && m_data[m_area.index(removed_pos)].pressure == 1) { m_data[m_area.index(removed_pos)].pressure = 2; } /*if(debugprint) { dstream<<"VoxelManipulator::flowWater(): Moved bubble:"<=0; i--) { //v3s16 p = removed_pos + dirs[i]; p = removed_pos + v3s16(s1*dirs[i].X, dirs[i].Y, s2*dirs[i].Z); u8 f = m_flags[m_area.index(p)]; // Water can't move to inexistent nodes if(f & VOXELFLAG_INEXISTENT) continue; MapNode &n = m_data[m_area.index(p)]; // Water can only move to air if(n.d != MATERIAL_AIR) continue; // Flow water to node bool moved = flowWater(p, active_nodes, recursion_depth, debugprint, counter, counterlimit); if(moved) { // Search again from all neighbors goto find_again; } } if(counter != NULL) { (*counter)++; if((*counter) % 10 == 0) dstream<<"flowWater(): moved "<<(*counter)<<" nodes" < counterlimit) { dstream<<"Counter limit reached; returning"< &active_nodes, int recursion_depth, bool debugprint, int counterlimit) { addarea_time = 0; emerge_time = 0; emerge_load_time = 0; clearflag_time = 0; updateareawaterpressure_time = 0; flowwater_pre_time = 0; TimeTaker timer1("flowWater (active_nodes)", g_device); dstream<<"active_nodes.size() = "<::Node *n = active_nodes.getIterator().getNode(); #endif #if 1 // Take random one s32 k = (s32)rand() % (s32)active_nodes.size(); //s32 k = 0; core::map::Iterator i = active_nodes.getIterator().getNode(); for(s32 j=0; j::Node *n = i.getNode(); #endif v3s16 p = n->getKey(); active_nodes.remove(p); flowWater(p, active_nodes, recursion_depth, debugprint, &counter, counterlimit); } } catch(ProcessingLimitException &e) { //dstream<<"getWaterPressure ProcessingLimitException"<