From e234d8b3786d5adfbdf3d1a2123c3e8d91c21880 Mon Sep 17 00:00:00 2001 From: kwolekr Date: Wed, 8 Jul 2015 00:45:24 -0400 Subject: [PATCH] Clean-up Minimap code - Fixed race conditions - Fixed null dereference - Fixed out-of-bounds array access - MinimapMapblock is now allocated and added to update queue only when enabled - Removed dependency on LocalPlayer - Fixed code style - Simplified expressions and program logic - Cleaned minimap object interfaces --- src/client.cpp | 14 +- src/game.cpp | 3 +- src/mapblock_mesh.cpp | 32 +-- src/minimap.cpp | 615 ++++++++++++++++++++++++------------------ src/minimap.h | 142 +++++----- 5 files changed, 429 insertions(+), 377 deletions(-) diff --git a/src/client.cpp b/src/client.cpp index 2f8babfa2..66aac6229 100644 --- a/src/client.cpp +++ b/src/client.cpp @@ -525,18 +525,23 @@ void Client::step(float dtime) while (!m_mesh_update_thread.m_queue_out.empty()) { num_processed_meshes++; + + MinimapMapblock *minimap_mapblock = NULL; + bool do_mapper_update = true; + MeshUpdateResult r = m_mesh_update_thread.m_queue_out.pop_frontNoEx(); MapBlock *block = m_env.getMap().getBlockNoCreateNoEx(r.p); - MinimapMapblock *minimap_mapblock = NULL; if (block) { // Delete the old mesh - if (block->mesh != NULL) { + if (block->mesh != NULL) { delete block->mesh; block->mesh = NULL; } - if (r.mesh) + if (r.mesh) { minimap_mapblock = r.mesh->getMinimapMapblock(); + do_mapper_update = (minimap_mapblock != NULL); + } if (r.mesh && r.mesh->getMesh()->getMeshBufferCount() == 0) { delete r.mesh; @@ -550,7 +555,8 @@ void Client::step(float dtime) minimap_mapblock = NULL; } - m_mapper->addBlock(r.p, minimap_mapblock); + if (do_mapper_update) + m_mapper->addBlock(r.p, minimap_mapblock); if (r.ack_block_to_server) { /* diff --git a/src/game.cpp b/src/game.cpp index 94fb41852..0189143b8 100644 --- a/src/game.cpp +++ b/src/game.cpp @@ -4045,10 +4045,11 @@ void Game::updateFrame(std::vector &highlight_boxes, } /* - Update minimap pos + Update minimap pos and rotation */ if (flags.show_minimap && flags.show_hud) { mapper->setPos(floatToInt(player->getPosition(), BS)); + mapper->setAngle(player->getYaw()); } /* diff --git a/src/mapblock_mesh.cpp b/src/mapblock_mesh.cpp index 0e4831166..145ab40c2 100644 --- a/src/mapblock_mesh.cpp +++ b/src/mapblock_mesh.cpp @@ -1029,7 +1029,7 @@ static void updateAllFastFaceRows(MeshMakeData *data, MapBlockMesh::MapBlockMesh(MeshMakeData *data, v3s16 camera_offset): m_mesh(new scene::SMesh()), - m_minimap_mapblock(new MinimapMapblock), + m_minimap_mapblock(NULL), m_gamedef(data->m_gamedef), m_tsrc(m_gamedef->getTextureSource()), m_shdrsrc(m_gamedef->getShaderSource()), @@ -1044,29 +1044,9 @@ MapBlockMesh::MapBlockMesh(MeshMakeData *data, v3s16 camera_offset): m_enable_highlighting = g_settings->getBool("enable_node_highlighting"); if (g_settings->getBool("enable_minimap")) { - v3s16 blockpos_nodes = data->m_blockpos * MAP_BLOCKSIZE; - for(s16 x = 0; x < MAP_BLOCKSIZE; x++) { - for(s16 z = 0; z < MAP_BLOCKSIZE; z++) { - s16 air_count = 0; - bool surface_found = false; - MinimapPixel* minimap_pixel = &m_minimap_mapblock->data[x + z * MAP_BLOCKSIZE]; - for(s16 y = MAP_BLOCKSIZE -1; y > -1; y--) { - v3s16 p(x, y, z); - MapNode n = data->m_vmanip.getNodeNoEx(blockpos_nodes + p); - if (!surface_found && n.getContent() != CONTENT_AIR) { - minimap_pixel->height = y; - minimap_pixel->id = n.getContent(); - surface_found = true; - } else if (n.getContent() == CONTENT_AIR) { - air_count++; - } - } - if (!surface_found) { - minimap_pixel->id = CONTENT_AIR; - } - minimap_pixel->air_count = air_count; - } - } + m_minimap_mapblock = new MinimapMapblock; + m_minimap_mapblock->getMinimapNodes( + &data->m_vmanip, data->m_blockpos * MAP_BLOCKSIZE); } // 4-21ms for MAP_BLOCKSIZE=16 (NOTE: probably outdated) @@ -1183,7 +1163,7 @@ MapBlockMesh::MapBlockMesh(MeshMakeData *data, v3s16 camera_offset): } if(m_enable_highlighting && p.tile.material_flags & MATERIAL_FLAG_HIGHLIGHTED) - m_highlighted_materials.push_back(i); + m_highlighted_materials.push_back(i); for(u32 j = 0; j < p.vertices.size(); j++) { @@ -1400,7 +1380,7 @@ bool MapBlockMesh::animate(bool faraway, float time, int crack, u32 daynight_rat // Node highlighting if (m_enable_highlighting) { u8 day = m_highlight_mesh_color.getRed(); - u8 night = m_highlight_mesh_color.getGreen(); + u8 night = m_highlight_mesh_color.getGreen(); video::SColor hc; finalColorBlend(hc, day, night, daynight_ratio); float sin_r = 0.07 * sin(1.5 * time); diff --git a/src/minimap.cpp b/src/minimap.cpp index b26f8c665..d37a083ef 100644 --- a/src/minimap.cpp +++ b/src/minimap.cpp @@ -18,6 +18,7 @@ with this program; if not, write to the Free Software Foundation, Inc., */ #include "minimap.h" +#include #include "logoutputbuffer.h" #include "jthread/jmutexautolock.h" #include "jthread/jsemaphore.h" @@ -27,138 +28,125 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "porting.h" #include "util/numeric.h" #include "util/string.h" -#include -QueuedMinimapUpdate::QueuedMinimapUpdate(): - pos(-1337,-1337,-1337), - data(NULL) -{ -} -QueuedMinimapUpdate::~QueuedMinimapUpdate() -{ - delete data; -} - -MinimapUpdateQueue::MinimapUpdateQueue() -{ -} +//// +//// MinimapUpdateThread +//// -MinimapUpdateQueue::~MinimapUpdateQueue() +MinimapUpdateThread::~MinimapUpdateThread() { - JMutexAutoLock lock(m_mutex); + for (std::map::iterator + it = m_blocks_cache.begin(); + it != m_blocks_cache.end(); ++it) { + delete it->second; + } - for (std::list::iterator - i = m_queue.begin(); - i != m_queue.end(); ++i) { - QueuedMinimapUpdate *q = *i; - delete q; + for (std::deque::iterator + it = m_update_queue.begin(); + it != m_update_queue.end(); ++it) { + QueuedMinimapUpdate &q = *it; + delete q.data; } } -bool MinimapUpdateQueue::addBlock(v3s16 pos, MinimapMapblock *data) +bool MinimapUpdateThread::pushBlockUpdate(v3s16 pos, MinimapMapblock *data) { - DSTACK(__FUNCTION_NAME); - - JMutexAutoLock lock(m_mutex); - - /* - Find if block is already in queue. - If it is, update the data and quit. - */ - for (std::list::iterator - i = m_queue.begin(); - i != m_queue.end(); ++i) { - QueuedMinimapUpdate *q = *i; - if (q->pos == pos) { - delete q->data; - q->data = data; + JMutexAutoLock lock(m_queue_mutex); + + // Find if block is already in queue. + // If it is, update the data and quit. + for (std::deque::iterator + it = m_update_queue.begin(); + it != m_update_queue.end(); ++it) { + QueuedMinimapUpdate &q = *it; + if (q.pos == pos) { + delete q.data; + q.data = data; return false; } } - /* - Add the block - */ - QueuedMinimapUpdate *q = new QueuedMinimapUpdate; - q->pos = pos; - q->data = data; - m_queue.push_back(q); + // Add the block + QueuedMinimapUpdate q; + q.pos = pos; + q.data = data; + m_update_queue.push_back(q); + return true; } -QueuedMinimapUpdate * MinimapUpdateQueue::pop() +bool MinimapUpdateThread::popBlockUpdate(QueuedMinimapUpdate *update) { - JMutexAutoLock lock(m_mutex); + JMutexAutoLock lock(m_queue_mutex); - for (std::list::iterator - i = m_queue.begin(); - i != m_queue.end(); i++) { - QueuedMinimapUpdate *q = *i; - m_queue.erase(i); - return q; - } - return NULL; -} + if (m_update_queue.empty()) + return false; -/* - Minimap update thread -*/ + *update = m_update_queue.front(); + m_update_queue.pop_front(); -void MinimapUpdateThread::enqueue_Block(v3s16 pos, MinimapMapblock *data) + return true; +} + +void MinimapUpdateThread::enqueueBlock(v3s16 pos, MinimapMapblock *data) { - m_queue.addBlock(pos, data); + pushBlockUpdate(pos, data); deferUpdate(); } + void MinimapUpdateThread::doUpdate() { - while (m_queue.size()) { - QueuedMinimapUpdate *q = m_queue.pop(); - std::map::iterator it; - it = m_blocks_cache.find(q->pos); - if (q->data) { - m_blocks_cache[q->pos] = q->data; - } else if (it != m_blocks_cache.end()) { - delete it->second; - m_blocks_cache.erase(it); - } - } - if (data->map_invalidated) { - if (data->mode != MINIMAP_MODE_OFF) { - getMap(data->pos, data->map_size, data->scan_height, data->radar); - data->map_invalidated = false; + QueuedMinimapUpdate update; + + while (popBlockUpdate(&update)) { + if (update.data) { + m_blocks_cache[update.pos] = update.data; + } else { + std::map::iterator it; + it = m_blocks_cache.find(update.pos); + if (it != m_blocks_cache.end()) { + delete it->second; + m_blocks_cache.erase(it); + } } } -} -MinimapUpdateThread::~MinimapUpdateThread() -{ - for (std::map::iterator - it = m_blocks_cache.begin(); - it != m_blocks_cache.end(); it++) { - delete it->second; + if (data->map_invalidated && data->mode != MINIMAP_MODE_OFF) { + getMap(data->pos, data->map_size, data->scan_height, data->is_radar); + data->map_invalidated = false; } } -MinimapPixel *MinimapUpdateThread::getMinimapPixel(v3s16 pos, s16 height, s16 &pixel_height) +MinimapPixel *MinimapUpdateThread::getMinimapPixel(v3s16 pos, + s16 scan_height, s16 *pixel_height) { - pixel_height = height - MAP_BLOCKSIZE; + s16 height = scan_height - MAP_BLOCKSIZE; v3s16 blockpos_max, blockpos_min, relpos; - getNodeBlockPosWithOffset(v3s16(pos.X, pos.Y - height / 2, pos.Z), blockpos_min, relpos); - getNodeBlockPosWithOffset(v3s16(pos.X, pos.Y + height / 2, pos.Z), blockpos_max, relpos); - std::map::iterator it; + + getNodeBlockPosWithOffset( + v3s16(pos.X, pos.Y - scan_height / 2, pos.Z), + blockpos_min, relpos); + getNodeBlockPosWithOffset( + v3s16(pos.X, pos.Y + scan_height / 2, pos.Z), + blockpos_max, relpos); + for (s16 i = blockpos_max.Y; i > blockpos_min.Y - 1; i--) { - it = m_blocks_cache.find(v3s16(blockpos_max.X, i, blockpos_max.Z)); + std::map::iterator it = + m_blocks_cache.find(v3s16(blockpos_max.X, i, blockpos_max.Z)); if (it != m_blocks_cache.end()) { - MinimapPixel *pixel = &it->second->data[relpos.X + relpos.Z * MAP_BLOCKSIZE]; + MinimapMapblock *mmblock = it->second; + MinimapPixel *pixel = &mmblock->data[relpos.Z * MAP_BLOCKSIZE + relpos.X]; if (pixel->id != CONTENT_AIR) { - pixel_height += pixel->height; + *pixel_height = height + pixel->height; return pixel; } } - pixel_height -= MAP_BLOCKSIZE; + + height -= MAP_BLOCKSIZE; } + return NULL; } @@ -166,80 +154,100 @@ s16 MinimapUpdateThread::getAirCount(v3s16 pos, s16 height) { s16 air_count = 0; v3s16 blockpos_max, blockpos_min, relpos; - getNodeBlockPosWithOffset(v3s16(pos.X, pos.Y - height / 2, pos.Z), blockpos_min, relpos); - getNodeBlockPosWithOffset(v3s16(pos.X, pos.Y + height / 2, pos.Z), blockpos_max, relpos); - std::map::iterator it; + + getNodeBlockPosWithOffset( + v3s16(pos.X, pos.Y - height / 2, pos.Z), + blockpos_min, relpos); + getNodeBlockPosWithOffset( + v3s16(pos.X, pos.Y + height / 2, pos.Z), + blockpos_max, relpos); + for (s16 i = blockpos_max.Y; i > blockpos_min.Y - 1; i--) { - it = m_blocks_cache.find(v3s16(blockpos_max.X, i, blockpos_max.Z)); + std::map::iterator it = + m_blocks_cache.find(v3s16(blockpos_max.X, i, blockpos_max.Z)); if (it != m_blocks_cache.end()) { - MinimapPixel *pixel = &it->second->data[relpos.X + relpos.Z * MAP_BLOCKSIZE]; + MinimapMapblock *mmblock = it->second; + MinimapPixel *pixel = &mmblock->data[relpos.Z * MAP_BLOCKSIZE + relpos.X]; air_count += pixel->air_count; } } + return air_count; } -void MinimapUpdateThread::getMap(v3s16 pos, s16 size, s16 height, bool radar) +void MinimapUpdateThread::getMap(v3s16 pos, s16 size, s16 height, bool is_radar) { - v3s16 p = v3s16 (pos.X - size / 2, pos.Y, pos.Z - size / 2); - - for (s16 x = 0; x < size; x++) { - for (s16 z = 0; z < size; z++){ - u16 id = CONTENT_AIR; - MinimapPixel* minimap_pixel = &data->minimap_scan[x + z * size]; - if (!radar) { - s16 pixel_height = 0; - MinimapPixel* cached_pixel = - getMinimapPixel(v3s16(p.X + x, p.Y, p.Z + z), height, pixel_height); - if (cached_pixel) { - id = cached_pixel->id; - minimap_pixel->height = pixel_height; - } - } else { - minimap_pixel->air_count = getAirCount (v3s16(p.X + x, p.Y, p.Z + z), height); + v3s16 p = v3s16(pos.X - size / 2, pos.Y, pos.Z - size / 2); + + for (s16 x = 0; x < size; x++) + for (s16 z = 0; z < size; z++) { + u16 id = CONTENT_AIR; + MinimapPixel *mmpixel = &data->minimap_scan[x + z * size]; + + if (!is_radar) { + s16 pixel_height = 0; + MinimapPixel *cached_pixel = + getMinimapPixel(v3s16(p.X + x, p.Y, p.Z + z), height, &pixel_height); + if (cached_pixel) { + id = cached_pixel->id; + mmpixel->height = pixel_height; } - minimap_pixel->id = id; + } else { + mmpixel->air_count = getAirCount(v3s16(p.X + x, p.Y, p.Z + z), height); } + + mmpixel->id = id; } } +//// +//// Mapper +//// + Mapper::Mapper(IrrlichtDevice *device, Client *client) { - this->device = device; - this->client = client; - this->driver = device->getVideoDriver(); - this->tsrc = client->getTextureSource(); - this->player = client->getEnv().getLocalPlayer(); - this->shdrsrc = client->getShaderSource(); + this->driver = device->getVideoDriver(); + this->m_tsrc = client->getTextureSource(); + this->m_shdrsrc = client->getShaderSource(); + this->m_ndef = client->getNodeDefManager(); + // Initialize static settings m_enable_shaders = g_settings->getBool("enable_shaders"); - m_enable_shaders = g_settings->getBool("enable_shaders"); - if (g_settings->getBool("minimap_double_scan_height")) { - m_surface_mode_scan_height = 256; - } else { - m_surface_mode_scan_height = 128; - } + m_surface_mode_scan_height = + g_settings->getBool("minimap_double_scan_height") ? 256 : 128; + + // Initialize minimap data data = new MinimapData; - data->mode = MINIMAP_MODE_OFF; - data->radar = false; + data->mode = MINIMAP_MODE_OFF; + data->is_radar = false; data->map_invalidated = true; data->heightmap_image = NULL; - data->minimap_image = NULL; - data->texture = NULL; + data->minimap_image = NULL; + data->texture = NULL; data->minimap_shape_round = g_settings->getBool("minimap_shape_round"); - std::string fname1 = "minimap_mask_round.png"; - std::string fname2 = "minimap_overlay_round.png"; - data->minimap_mask_round = driver->createImage (tsrc->getTexture(fname1), - core::position2d(0,0), core::dimension2d(512,512)); - data->minimap_overlay_round = tsrc->getTexture(fname2); - fname1 = "minimap_mask_square.png"; - fname2 = "minimap_overlay_square.png"; - data->minimap_mask_square = driver->createImage (tsrc->getTexture(fname1), - core::position2d(0,0), core::dimension2d(512,512)); - data->minimap_overlay_square = tsrc->getTexture(fname2); - data->player_marker = tsrc->getTexture("player_marker.png"); + + // Get round minimap textures + data->minimap_mask_round = driver->createImage( + m_tsrc->getTexture("minimap_mask_round.png"), + core::position2d(0, 0), + core::dimension2d(MINIMAP_MAX_SX, MINIMAP_MAX_SY)); + data->minimap_overlay_round = m_tsrc->getTexture("minimap_overlay_round.png"); + + // Get square minimap textures + data->minimap_mask_square = driver->createImage( + m_tsrc->getTexture("minimap_mask_square.png"), + core::position2d(0, 0), + core::dimension2d(MINIMAP_MAX_SX, MINIMAP_MAX_SY)); + data->minimap_overlay_square = m_tsrc->getTexture("minimap_overlay_square.png"); + + // Create player marker texture + data->player_marker = m_tsrc->getTexture("player_marker.png"); + + // Create mesh buffer for minimap m_meshbuffer = getMinimapMeshBuffer(); - m_minimap_update_thread = new MinimapUpdateThread(device, client); + + // Initialize and start thread + m_minimap_update_thread = new MinimapUpdateThread(); m_minimap_update_thread->data = data; m_minimap_update_thread->Start(); } @@ -248,20 +256,24 @@ Mapper::~Mapper() { m_minimap_update_thread->Stop(); m_minimap_update_thread->Wait(); + m_meshbuffer->drop(); + data->minimap_mask_round->drop(); data->minimap_mask_square->drop(); + driver->removeTexture(data->texture); driver->removeTexture(data->heightmap_texture); driver->removeTexture(data->minimap_overlay_round); driver->removeTexture(data->minimap_overlay_square); + delete data; delete m_minimap_update_thread; } -void Mapper::addBlock (v3s16 pos, MinimapMapblock *data) +void Mapper::addBlock(v3s16 pos, MinimapMapblock *data) { - m_minimap_update_thread->enqueue_Block(pos, data); + m_minimap_update_thread->enqueueBlock(pos, data); } MinimapMode Mapper::getMinimapMode() @@ -271,121 +283,150 @@ MinimapMode Mapper::getMinimapMode() void Mapper::toggleMinimapShape() { + JMutexAutoLock lock(m_mutex); + data->minimap_shape_round = !data->minimap_shape_round; - g_settings->setBool(("minimap_shape_round"), data->minimap_shape_round); + g_settings->setBool("minimap_shape_round", data->minimap_shape_round); m_minimap_update_thread->deferUpdate(); } void Mapper::setMinimapMode(MinimapMode mode) { - static const u16 modeDefs[7 * 3] = { - 0, 0, 0, - 0, m_surface_mode_scan_height, 256, - 0, m_surface_mode_scan_height, 128, - 0, m_surface_mode_scan_height, 64, - 1, 32, 128, - 1, 32, 64, - 1, 32, 32}; + static const MinimapModeDef modedefs[MINIMAP_MODE_COUNT] = { + {false, 0, 0}, + {false, m_surface_mode_scan_height, 256}, + {false, m_surface_mode_scan_height, 128}, + {false, m_surface_mode_scan_height, 64}, + {true, 32, 128}, + {true, 32, 64}, + {true, 32, 32} + }; + + if (mode >= MINIMAP_MODE_COUNT) + return; JMutexAutoLock lock(m_mutex); - data->radar = (bool)modeDefs[(int)mode * 3]; - data->scan_height = modeDefs[(int)mode * 3 + 1]; - data->map_size = modeDefs[(int)mode * 3 + 2]; - data->mode = mode; + + data->is_radar = modedefs[mode].is_radar; + data->scan_height = modedefs[mode].scan_height; + data->map_size = modedefs[mode].map_size; + data->mode = mode; + m_minimap_update_thread->deferUpdate(); } void Mapper::setPos(v3s16 pos) { - JMutexAutoLock lock(m_mutex); - if (pos != data->old_pos) { - data->old_pos = data->pos; - data->pos = pos; + bool do_update = false; + + { + JMutexAutoLock lock(m_mutex); + + if (pos != data->old_pos) { + data->old_pos = data->pos; + data->pos = pos; + do_update = true; + } + } + + if (do_update) m_minimap_update_thread->deferUpdate(); +} + +void Mapper::setAngle(f32 angle) +{ + m_angle = angle; +} + +void Mapper::blitMinimapPixelsToImageRadar(video::IImage *map_image) +{ + for (s16 x = 0; x < data->map_size; x++) + for (s16 z = 0; z < data->map_size; z++) { + MinimapPixel *mmpixel = &data->minimap_scan[x + z * data->map_size]; + + video::SColor c(240, 0, 0, 0); + if (mmpixel->air_count > 0) + c.setGreen(core::clamp(core::round32(32 + mmpixel->air_count * 8), 0, 255)); + + map_image->setPixel(x, data->map_size - z - 1, c); + } +} + +void Mapper::blitMinimapPixelsToImageSurface( + video::IImage *map_image, video::IImage *heightmap_image) +{ + for (s16 x = 0; x < data->map_size; x++) + for (s16 z = 0; z < data->map_size; z++) { + MinimapPixel *mmpixel = &data->minimap_scan[x + z * data->map_size]; + + video::SColor c = m_ndef->get(mmpixel->id).minimap_color; + c.setAlpha(240); + + map_image->setPixel(x, data->map_size - z - 1, c); + + u32 h = mmpixel->height; + heightmap_image->setPixel(x,data->map_size - z - 1, + video::SColor(255, h, h, h)); } } video::ITexture *Mapper::getMinimapTexture() { // update minimap textures when new scan is ready - if (!data->map_invalidated) { - // create minimap and heightmap image - core::dimension2d dim(data->map_size,data->map_size); - video::IImage *map_image = driver->createImage(video::ECF_A8R8G8B8, dim); - video::IImage *heightmap_image = driver->createImage(video::ECF_A8R8G8B8, dim); - video::IImage *minimap_image = driver->createImage(video::ECF_A8R8G8B8, - core::dimension2d(512, 512)); - - video::SColor c; - if (!data->radar) { - // surface mode - for (s16 x = 0; x < data->map_size; x++) { - for (s16 z = 0; z < data->map_size; z++) { - MinimapPixel* minimap_pixel = &data->minimap_scan[x + z * data->map_size]; - const ContentFeatures &f = client->getNodeDefManager()->get(minimap_pixel->id); - c = f.minimap_color; - c.setAlpha(240); - map_image->setPixel(x, data->map_size - z -1, c); - u32 h = minimap_pixel->height; - heightmap_image->setPixel(x,data->map_size -z -1, - video::SColor(255, h, h, h)); - } - } - } else { - // radar mode - c = video::SColor (240, 0 , 0, 0); - for (s16 x = 0; x < data->map_size; x++) { - for (s16 z = 0; z < data->map_size; z++) { - MinimapPixel* minimap_pixel = &data->minimap_scan[x + z * data->map_size]; - if (minimap_pixel->air_count > 0) { - c.setGreen(core::clamp(core::round32(32 + minimap_pixel->air_count * 8), 0, 255)); - } else { - c.setGreen(0); - } - map_image->setPixel(x, data->map_size - z -1, c); - } - } + if (data->map_invalidated) + return data->texture; + + // create minimap and heightmap images in memory + core::dimension2d dim(data->map_size, data->map_size); + video::IImage *map_image = driver->createImage(video::ECF_A8R8G8B8, dim); + video::IImage *heightmap_image = driver->createImage(video::ECF_A8R8G8B8, dim); + video::IImage *minimap_image = driver->createImage(video::ECF_A8R8G8B8, + core::dimension2d(MINIMAP_MAX_SX, MINIMAP_MAX_SY)); + + // Blit MinimapPixels to images + if (data->is_radar) + blitMinimapPixelsToImageRadar(map_image); + else + blitMinimapPixelsToImageSurface(map_image, heightmap_image); + + map_image->copyToScaling(minimap_image); + map_image->drop(); + + video::IImage *minimap_mask = data->minimap_shape_round ? + data->minimap_mask_round : data->minimap_mask_square; + + if (minimap_mask) { + for (s16 y = 0; y < MINIMAP_MAX_SY; y++) + for (s16 x = 0; x < MINIMAP_MAX_SX; x++) { + video::SColor mask_col = minimap_mask->getPixel(x, y); + if (!mask_col.getAlpha()) + minimap_image->setPixel(x, y, video::SColor(0,0,0,0)); } + } - map_image->copyToScaling(minimap_image); - map_image->drop(); + if (data->texture) + driver->removeTexture(data->texture); + if (data->heightmap_texture) + driver->removeTexture(data->heightmap_texture); - video::IImage *minimap_mask; - if (data->minimap_shape_round) { - minimap_mask = data->minimap_mask_round; - } else { - minimap_mask = data->minimap_mask_square; - } - for (s16 x = 0; x < 512; x++) { - for (s16 y = 0; y < 512; y++) { - video::SColor mask_col = minimap_mask->getPixel(x, y); - if (!mask_col.getAlpha()) { - minimap_image->setPixel(x, y, video::SColor(0,0,0,0)); - } - } - } + data->texture = driver->addTexture("minimap__", minimap_image); + data->heightmap_texture = + driver->addTexture("minimap_heightmap__", heightmap_image); + minimap_image->drop(); + heightmap_image->drop(); - if (data->texture) { - driver->removeTexture(data->texture); - } - if (data->heightmap_texture) { - driver->removeTexture(data->heightmap_texture); - } - data->texture = driver->addTexture("minimap__", minimap_image); - data->heightmap_texture = driver->addTexture("minimap_heightmap__", heightmap_image); - minimap_image->drop(); - heightmap_image->drop(); + data->map_invalidated = true; - data->map_invalidated = true; - } return data->texture; } v3f Mapper::getYawVec() { if (data->minimap_shape_round) { - return v3f(cos(player->getYaw()* core::DEGTORAD), - sin(player->getYaw()* core::DEGTORAD), 1.0); + return v3f( + cos(m_angle * core::DEGTORAD), + sin(m_angle * core::DEGTORAD), + 1.0); } else { return v3f(1.0, 0.0, 1.0); } @@ -395,7 +436,7 @@ scene::SMeshBuffer *Mapper::getMinimapMeshBuffer() { scene::SMeshBuffer *buf = new scene::SMeshBuffer(); buf->Vertices.set_used(4); - buf->Indices .set_used(6); + buf->Indices.set_used(6); video::SColor c(255, 255, 255, 255); buf->Vertices[0] = video::S3DVertex(-1, -1, 0, 0, 0, 1, c, 0, 1); @@ -415,59 +456,99 @@ scene::SMeshBuffer *Mapper::getMinimapMeshBuffer() void Mapper::drawMinimap() { + video::ITexture *minimap_texture = getMinimapTexture(); + if (!minimap_texture) + return; + v2u32 screensize = porting::getWindowSize(); - u32 size = 0.25 * screensize.Y; - video::ITexture* minimap_texture = getMinimapTexture(); - core::matrix4 matrix; + const u32 size = 0.25 * screensize.Y; core::rect oldViewPort = driver->getViewPort(); - driver->setViewPort(core::rect(screensize.X - size - 10, 10, - screensize.X - 10, size + 10)); core::matrix4 oldProjMat = driver->getTransform(video::ETS_PROJECTION); - driver->setTransform(video::ETS_PROJECTION, core::matrix4()); core::matrix4 oldViewMat = driver->getTransform(video::ETS_VIEW); + + driver->setViewPort(core::rect( + screensize.X - size - 10, 10, + screensize.X - 10, size + 10)); + driver->setTransform(video::ETS_PROJECTION, core::matrix4()); driver->setTransform(video::ETS_VIEW, core::matrix4()); + + core::matrix4 matrix; matrix.makeIdentity(); - if (minimap_texture) { - video::SMaterial& material = m_meshbuffer->getMaterial(); - material.setFlag(video::EMF_TRILINEAR_FILTER, true); - material.Lighting = false; - material.TextureLayer[0].Texture = minimap_texture; - material.TextureLayer[1].Texture = data->heightmap_texture; - if (m_enable_shaders && !data->radar) { - u16 sid = shdrsrc->getShader("minimap_shader", 1, 1); - material.MaterialType = shdrsrc->getShaderInfo(sid).material; - } else { - material.MaterialType = video::EMT_TRANSPARENT_ALPHA_CHANNEL; - } + video::SMaterial &material = m_meshbuffer->getMaterial(); + material.setFlag(video::EMF_TRILINEAR_FILTER, true); + material.Lighting = false; + material.TextureLayer[0].Texture = minimap_texture; + material.TextureLayer[1].Texture = data->heightmap_texture; - if (data->minimap_shape_round) - matrix.setRotationDegrees(core::vector3df(0, 0, 360 - player->getYaw())); - driver->setTransform(video::ETS_WORLD, matrix); - driver->setMaterial(material); - driver->drawMeshBuffer(m_meshbuffer); - video::ITexture *minimap_overlay; - if (data->minimap_shape_round) { - minimap_overlay = data->minimap_overlay_round; - } else { - minimap_overlay = data->minimap_overlay_square; - } - material.TextureLayer[0].Texture = minimap_overlay; + if (m_enable_shaders && !data->is_radar) { + u16 sid = m_shdrsrc->getShader("minimap_shader", 1, 1); + material.MaterialType = m_shdrsrc->getShaderInfo(sid).material; + } else { material.MaterialType = video::EMT_TRANSPARENT_ALPHA_CHANNEL; + } + + if (data->minimap_shape_round) + matrix.setRotationDegrees(core::vector3df(0, 0, 360 - m_angle)); + + // Draw minimap + driver->setTransform(video::ETS_WORLD, matrix); + driver->setMaterial(material); + driver->drawMeshBuffer(m_meshbuffer); + + // Draw overlay + video::ITexture *minimap_overlay = data->minimap_shape_round ? + data->minimap_overlay_round : data->minimap_overlay_square; + material.TextureLayer[0].Texture = minimap_overlay; + material.MaterialType = video::EMT_TRANSPARENT_ALPHA_CHANNEL; + driver->setMaterial(material); + driver->drawMeshBuffer(m_meshbuffer); + + // If round minimap, draw player marker + if (!data->minimap_shape_round) { + matrix.setRotationDegrees(core::vector3df(0, 0, m_angle)); + material.TextureLayer[0].Texture = data->player_marker; + + driver->setTransform(video::ETS_WORLD, matrix); driver->setMaterial(material); driver->drawMeshBuffer(m_meshbuffer); - - if (!data->minimap_shape_round) { - matrix.setRotationDegrees(core::vector3df(0, 0, player->getYaw())); - driver->setTransform(video::ETS_WORLD, matrix); - material.TextureLayer[0].Texture = data->player_marker; - driver->setMaterial(material); - driver->drawMeshBuffer(m_meshbuffer); - } } + // Reset transformations driver->setTransform(video::ETS_VIEW, oldViewMat); driver->setTransform(video::ETS_PROJECTION, oldProjMat); driver->setViewPort(oldViewPort); } + +//// +//// MinimapMapblock +//// + +void MinimapMapblock::getMinimapNodes(VoxelManipulator *vmanip, v3s16 pos) +{ + + for (s16 x = 0; x < MAP_BLOCKSIZE; x++) + for (s16 z = 0; z < MAP_BLOCKSIZE; z++) { + s16 air_count = 0; + bool surface_found = false; + MinimapPixel *mmpixel = &data[z * MAP_BLOCKSIZE + x]; + + for (s16 y = MAP_BLOCKSIZE -1; y >= 0; y--) { + v3s16 p(x, y, z); + MapNode n = vmanip->getNodeNoEx(pos + p); + if (!surface_found && n.getContent() != CONTENT_AIR) { + mmpixel->height = y; + mmpixel->id = n.getContent(); + surface_found = true; + } else if (n.getContent() == CONTENT_AIR) { + air_count++; + } + } + + if (!surface_found) + mmpixel->id = CONTENT_AIR; + + mmpixel->air_count = air_count; + } +} diff --git a/src/minimap.h b/src/minimap.h index 4ca0451b7..edb491717 100644 --- a/src/minimap.h +++ b/src/minimap.h @@ -20,14 +20,17 @@ with this program; if not, write to the Free Software Foundation, Inc., #ifndef MINIMAP_HEADER #define MINIMAP_HEADER +#include +#include +#include #include "irrlichttypes_extrabloated.h" #include "client.h" #include "voxel.h" #include "jthread/jmutex.h" #include "jthread/jsemaphore.h" -#include -#include -#include + +#define MINIMAP_MAX_SX 512 +#define MINIMAP_MAX_SY 512 enum MinimapMode { MINIMAP_MODE_OFF, @@ -36,31 +39,37 @@ enum MinimapMode { MINIMAP_MODE_SURFACEx4, MINIMAP_MODE_RADARx1, MINIMAP_MODE_RADARx2, - MINIMAP_MODE_RADARx4 + MINIMAP_MODE_RADARx4, + MINIMAP_MODE_COUNT, }; -struct MinimapPixel -{ +struct MinimapModeDef { + bool is_radar; + u16 scan_height; + u16 map_size; +}; + +struct MinimapPixel { u16 id; u16 height; u16 air_count; u16 light; }; -struct MinimapMapblock -{ +struct MinimapMapblock { + void getMinimapNodes(VoxelManipulator *vmanip, v3s16 pos); + MinimapPixel data[MAP_BLOCKSIZE * MAP_BLOCKSIZE]; }; -struct MinimapData -{ - bool radar; +struct MinimapData { + bool is_radar; MinimapMode mode; v3s16 pos; v3s16 old_pos; u16 scan_height; u16 map_size; - MinimapPixel minimap_scan[512 * 512]; + MinimapPixel minimap_scan[MINIMAP_MAX_SX * MINIMAP_MAX_SY]; bool map_invalidated; bool minimap_shape_round; video::IImage *minimap_image; @@ -74,104 +83,79 @@ struct MinimapData video::ITexture *player_marker; }; -struct QueuedMinimapUpdate -{ +struct QueuedMinimapUpdate { v3s16 pos; MinimapMapblock *data; - - QueuedMinimapUpdate(); - ~QueuedMinimapUpdate(); }; -/* - A thread-safe queue of minimap mapblocks update tasks -*/ - -class MinimapUpdateQueue -{ +class MinimapUpdateThread : public UpdateThread { public: - MinimapUpdateQueue(); - - ~MinimapUpdateQueue(); + virtual ~MinimapUpdateThread(); - bool addBlock(v3s16 pos, MinimapMapblock *data); + void getMap(v3s16 pos, s16 size, s16 height, bool radar); + MinimapPixel *getMinimapPixel(v3s16 pos, s16 height, s16 *pixel_height); + s16 getAirCount(v3s16 pos, s16 height); + video::SColor getColorFromId(u16 id); - QueuedMinimapUpdate *pop(); + void enqueueBlock(v3s16 pos, MinimapMapblock *data); - u32 size() - { - JMutexAutoLock lock(m_mutex); - return m_queue.size(); - } - -private: - std::list m_queue; - JMutex m_mutex; -}; + bool pushBlockUpdate(v3s16 pos, MinimapMapblock *data); + bool popBlockUpdate(QueuedMinimapUpdate *update); -class MinimapUpdateThread : public UpdateThread -{ -private: - MinimapUpdateQueue m_queue; - std::map m_blocks_cache; + MinimapData *data; protected: const char *getName() - { return "MinimapUpdateThread"; } - virtual void doUpdate(); - -public: - MinimapUpdateThread(IrrlichtDevice *device, Client *client) { - this->device = device; - this->client = client; - this->driver = device->getVideoDriver(); - this->tsrc = client->getTextureSource(); + return "MinimapUpdateThread"; } - ~MinimapUpdateThread(); - void getMap (v3s16 pos, s16 size, s16 height, bool radar); - MinimapPixel *getMinimapPixel (v3s16 pos, s16 height, s16 &pixel_height); - s16 getAirCount (v3s16 pos, s16 height); - video::SColor getColorFromId(u16 id); - void enqueue_Block(v3s16 pos, MinimapMapblock *data); - IrrlichtDevice *device; - Client *client; - video::IVideoDriver *driver; - ITextureSource *tsrc; - MinimapData *data; -}; + virtual void doUpdate(); -class Mapper -{ private: - MinimapUpdateThread *m_minimap_update_thread; - video::ITexture *minimap_texture; - scene::SMeshBuffer *m_meshbuffer; - bool m_enable_shaders; - u16 m_surface_mode_scan_height; - JMutex m_mutex; + JMutex m_queue_mutex; + std::deque m_update_queue; + std::map m_blocks_cache; +}; +class Mapper { public: Mapper(IrrlichtDevice *device, Client *client); ~Mapper(); void addBlock(v3s16 pos, MinimapMapblock *data); - void setPos(v3s16 pos); - video::ITexture* getMinimapTexture(); + v3f getYawVec(); MinimapMode getMinimapMode(); + + void setPos(v3s16 pos); + void setAngle(f32 angle); void setMinimapMode(MinimapMode mode); void toggleMinimapShape(); + + + video::ITexture *getMinimapTexture(); + + void blitMinimapPixelsToImageRadar(video::IImage *map_image); + void blitMinimapPixelsToImageSurface(video::IImage *map_image, + video::IImage *heightmap_image); + scene::SMeshBuffer *getMinimapMeshBuffer(); void drawMinimap(); - IrrlichtDevice *device; - Client *client; + video::IVideoDriver *driver; - LocalPlayer *player; - ITextureSource *tsrc; - IShaderSource *shdrsrc; MinimapData *data; + +private: + ITextureSource *m_tsrc; + IShaderSource *m_shdrsrc; + INodeDefManager *m_ndef; + MinimapUpdateThread *m_minimap_update_thread; + scene::SMeshBuffer *m_meshbuffer; + bool m_enable_shaders; + u16 m_surface_mode_scan_height; + f32 m_angle; + JMutex m_mutex; }; #endif -- 2.25.1