diff options
author | Perttu Ahola <celeron55@gmail.com> | 2012-03-25 11:50:29 +0300 |
---|---|---|
committer | Perttu Ahola <celeron55@gmail.com> | 2012-03-25 11:51:33 +0300 |
commit | f801e16b787f033cea4e473d69b54fe65248a439 (patch) | |
tree | 25cd83a122fd4a1cb74d605aecaa65caa1b5f8a7 /src | |
parent | 4bf5065a9cdaf55a6915e647e9b5de5281d6622f (diff) | |
download | minetest-f801e16b787f033cea4e473d69b54fe65248a439.tar.gz minetest-f801e16b787f033cea4e473d69b54fe65248a439.tar.bz2 minetest-f801e16b787f033cea4e473d69b54fe65248a439.zip |
Texture cache -> Media cache WIP
Diffstat (limited to 'src')
-rw-r--r-- | src/client.cpp | 129 | ||||
-rw-r--r-- | src/client.h | 17 | ||||
-rw-r--r-- | src/clientserver.h | 18 | ||||
-rw-r--r-- | src/filecache.cpp | 43 | ||||
-rw-r--r-- | src/filecache.h | 17 | ||||
-rw-r--r-- | src/game.cpp | 9 | ||||
-rw-r--r-- | src/server.cpp | 224 | ||||
-rw-r--r-- | src/server.h | 19 |
8 files changed, 235 insertions, 241 deletions
diff --git a/src/client.cpp b/src/client.cpp index 3a08b25c2..56555804e 100644 --- a/src/client.cpp +++ b/src/client.cpp @@ -41,16 +41,16 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "filecache.h" #include "sound.h" -static std::string getTextureCacheDir() +static std::string getMediaCacheDir() { - return porting::path_user + DIR_DELIM + "cache" + DIR_DELIM + "textures"; + return porting::path_user + DIR_DELIM + "cache" + DIR_DELIM + "media"; } -struct TextureRequest +struct MediaRequest { std::string name; - TextureRequest(const std::string &name_=""): + MediaRequest(const std::string &name_=""): name(name_) {} }; @@ -256,9 +256,9 @@ Client::Client( m_map_seed(0), m_password(password), m_access_denied(false), - m_texture_cache(getTextureCacheDir()), - m_texture_receive_progress(0), - m_textures_received(false), + m_media_cache(getMediaCacheDir()), + m_media_receive_progress(0), + m_media_received(false), m_itemdef_received(false), m_nodedef_received(false), m_time_of_day_set(false), @@ -1391,7 +1391,7 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) event.deathscreen.camera_point_target_z = camera_point_target.Z; m_client_event_queue.push_back(event); } - else if(command == TOCLIENT_ANNOUNCE_TEXTURES) + else if(command == TOCLIENT_ANNOUNCE_MEDIA) { io::IFileSystem *irrfs = m_device->getFileSystem(); video::IVideoDriver *vdrv = m_device->getVideoDriver(); @@ -1403,33 +1403,36 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) // updating content definitions assert(!m_mesh_update_thread.IsRunning()); - int num_textures = readU16(is); + int num_files = readU16(is); + + verbosestream<<"Client received TOCLIENT_ANNOUNCE_MEDIA (" + <<num_files<<" files)"<<std::endl; - core::list<TextureRequest> texture_requests; + core::list<MediaRequest> file_requests; - for(int i=0; i<num_textures; i++){ + for(int i=0; i<num_files; i++){ - bool texture_found = false; + bool file_found = false; - //read texture from cache + //read file from cache std::string name = deSerializeString(is); - std::string sha1_texture = deSerializeString(is); + std::string sha1_file = deSerializeString(is); - // if name contains illegal characters, ignore the texture + // if name contains illegal characters, ignore the file if(!string_allowed(name, TEXTURENAME_ALLOWED_CHARS)){ - errorstream<<"Client: ignoring illegal texture name " + errorstream<<"Client: ignoring illegal file name " <<"sent by server: \""<<name<<"\""<<std::endl; continue; } - std::string sha1_decoded = base64_decode(sha1_texture); + std::string sha1_decoded = base64_decode(sha1_file); std::ostringstream tmp_os(std::ios_base::binary); - bool tex_in_cache = m_texture_cache.loadByChecksum(name, - tmp_os, sha1_decoded); - m_texture_name_sha1_map.set(name, sha1_decoded); - - if(tex_in_cache) { + bool file_in_cache = m_media_cache.loadByChecksum(sha1_decoded, + tmp_os); + m_media_name_sha1_map.set(name, sha1_decoded); + if(file_in_cache) + { SHA1 sha1; sha1.addBytes(tmp_os.str().c_str(), tmp_os.str().length()); @@ -1437,7 +1440,7 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) std::string digest_string = base64_encode(digest, 20); - if (digest_string == sha1_texture) { + if (digest_string == sha1_file) { // Silly irrlicht's const-incorrectness Buffer<char> data_rw(tmp_os.str().c_str(), tmp_os.str().size()); @@ -1449,7 +1452,7 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) video::IImage *img = vdrv->createImageFromFile(rfile); if(!img){ infostream<<"Client: Cannot create image from data of " - <<"received texture \""<<name<<"\""<<std::endl; + <<"received file \""<<name<<"\""<<std::endl; rfile->drop(); } else { @@ -1457,22 +1460,22 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) img->drop(); rfile->drop(); - texture_found = true; + file_found = true; } } else { - infostream<<"Client::Texture cached sha1 hash not matching server hash: " - <<name << ": server ->"<<sha1_texture <<" client -> "<<digest_string<<std::endl; + infostream<<"Client::Media cached sha1 hash not matching server hash: " + <<name << ": server ->"<<sha1_file <<" client -> "<<digest_string<<std::endl; } free(digest); } - //add texture request - if (!texture_found) { - infostream<<"Client: Adding texture to request list: \"" + //add file request + if (!file_found) { + infostream<<"Client: Adding file to request list: \"" <<name<<"\""<<std::endl; - texture_requests.push_back(TextureRequest(name)); + file_requests.push_back(MediaRequest(name)); } } @@ -1482,11 +1485,11 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) m_client_event_queue.push_back(event); - //send Texture request + //send Media request /* u16 command - u16 number of textures requested - for each texture { + u16 number of files requested + for each file { u16 length of name string name } @@ -1496,15 +1499,15 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) // Write command - writeU16(buf, TOSERVER_REQUEST_TEXTURES); + writeU16(buf, TOSERVER_REQUEST_MEDIA); os.write((char*)buf, 2); - writeU16(buf,texture_requests.size()); + writeU16(buf,file_requests.size()); os.write((char*)buf, 2); - for(core::list<TextureRequest>::Iterator i = texture_requests.begin(); - i != texture_requests.end(); i++) { + for(core::list<MediaRequest>::Iterator i = file_requests.begin(); + i != file_requests.end(); i++) { os<<serializeString(i->name); } @@ -1513,10 +1516,13 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) SharedBuffer<u8> data((u8*)s.c_str(), s.size()); // Send as reliable Send(0, data, true); - infostream<<"Client: Sending request list to server " <<std::endl; + infostream<<"Client: Sending media request list to server (" + <<file_requests.size()<<" files)"<<std::endl; } - else if(command == TOCLIENT_TEXTURES) + else if(command == TOCLIENT_MEDIA) { + verbosestream<<"Client received TOCLIENT_MEDIA"<<std::endl; + io::IFileSystem *irrfs = m_device->getFileSystem(); video::IVideoDriver *vdrv = m_device->getVideoDriver(); @@ -1529,10 +1535,10 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) /* u16 command - u16 total number of texture bunches + u16 total number of file bunches u16 index of this bunch - u32 number of textures in this bunch - for each texture { + u32 number of files in this bunch + for each file { u16 length of name string name u32 length of data @@ -1541,20 +1547,20 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) */ int num_bunches = readU16(is); int bunch_i = readU16(is); - m_texture_receive_progress = (float)bunch_i / (float)(num_bunches - 1); + m_media_receive_progress = (float)bunch_i / (float)(num_bunches - 1); if(bunch_i == num_bunches - 1) - m_textures_received = true; - int num_textures = readU32(is); - infostream<<"Client: Received textures: bunch "<<bunch_i<<"/" - <<num_bunches<<" textures="<<num_textures + m_media_received = true; + int num_files = readU32(is); + infostream<<"Client: Received files: bunch "<<bunch_i<<"/" + <<num_bunches<<" files="<<num_files <<" size="<<datasize<<std::endl; - for(int i=0; i<num_textures; i++){ + for(int i=0; i<num_files; i++){ std::string name = deSerializeString(is); std::string data = deSerializeLongString(is); - // if name contains illegal characters, ignore the texture + // if name contains illegal characters, ignore the file if(!string_allowed(name, TEXTURENAME_ALLOWED_CHARS)){ - errorstream<<"Client: ignoring illegal texture name " + errorstream<<"Client: ignoring illegal file name " <<"sent by server: \""<<name<<"\""<<std::endl; continue; } @@ -1569,22 +1575,25 @@ void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id) video::IImage *img = vdrv->createImageFromFile(rfile); if(!img){ errorstream<<"Client: Cannot create image from data of " - <<"received texture \""<<name<<"\""<<std::endl; + <<"received file \""<<name<<"\""<<std::endl; rfile->drop(); continue; } - fs::CreateAllDirs(getTextureCacheDir()); + bool did = fs::CreateAllDirs(getMediaCacheDir()); + if(!did){ + errorstream<<"Could not create media cache directory" + <<std::endl; + } { core::map<std::string, std::string>::Node *n; - n = m_texture_name_sha1_map.find(name); + n = m_media_name_sha1_map.find(name); if(n == NULL) - errorstream<<"The server sent a texture that has not been announced." - <<std::endl; + errorstream<<"The server sent a file that has not " + <<"been announced."<<std::endl; else - m_texture_cache.updateByChecksum(name, - data, n->getValue()); + m_media_cache.updateByChecksum(n->getValue(), data); } m_tsrc->insertSourceImage(name, img); @@ -2358,11 +2367,11 @@ void Client::afterContentReceived() { assert(m_itemdef_received); assert(m_nodedef_received); - assert(m_textures_received); + assert(m_media_received); // remove the information about which checksum each texture // ought to have - m_texture_name_sha1_map.clear(); + m_media_name_sha1_map.clear(); // Rebuild inherited images and recreate textures m_tsrc->rebuildImagesAndTextures(); diff --git a/src/client.h b/src/client.h index 8d7597e80..b15dbed54 100644 --- a/src/client.h +++ b/src/client.h @@ -290,11 +290,11 @@ public: std::wstring accessDeniedReason() { return m_access_denied_reason; } - float textureReceiveProgress() - { return m_texture_receive_progress; } + float mediaReceiveProgress() + { return m_media_receive_progress; } bool texturesReceived() - { return m_textures_received; } + { return m_media_received; } bool itemdefReceived() { return m_itemdef_received; } bool nodedefReceived() @@ -367,12 +367,11 @@ private: bool m_access_denied; std::wstring m_access_denied_reason; Queue<ClientEvent> m_client_event_queue; - FileCache m_texture_cache; - // a map of the name and SHA1 checksum of each texture; - // cleared after content has been recieved - core::map<std::string, std::string> m_texture_name_sha1_map; - float m_texture_receive_progress; - bool m_textures_received; + FileCache m_media_cache; + // Mapping from media file name to SHA1 checksum + core::map<std::string, std::string> m_media_name_sha1_map; + float m_media_receive_progress; + bool m_media_received; bool m_itemdef_received; bool m_nodedef_received; friend class FarMesh; diff --git a/src/clientserver.h b/src/clientserver.h index 9cbb7a685..8ac0aa877 100644 --- a/src/clientserver.h +++ b/src/clientserver.h @@ -28,7 +28,7 @@ with this program; if not, write to the Free Software Foundation, Inc., PROTOCOL_VERSION 3: Base for writing changes here PROTOCOL_VERSION 4: - Add TOCLIENT_TEXTURES + Add TOCLIENT_MEDIA Add TOCLIENT_TOOLDEF Add TOCLIENT_NODEDEF Add TOCLIENT_CRAFTITEMDEF @@ -215,13 +215,13 @@ enum ToClientCommand v3f1000 camera point target (to point the death cause or whatever) */ - TOCLIENT_TEXTURES = 0x38, + TOCLIENT_MEDIA = 0x38, /* u16 command u16 total number of texture bunches u16 index of this bunch - u32 number of textures in this bunch - for each texture { + u32 number of files in this bunch + for each file { u16 length of name string name u32 length of data @@ -250,11 +250,11 @@ enum ToClientCommand serialized CraftiItemDefManager */ - TOCLIENT_ANNOUNCE_TEXTURES = 0x3c, + TOCLIENT_ANNOUNCE_MEDIA = 0x3c, /* u16 command - u32 number of textures + u32 number of files for each texture { u16 length of name string name @@ -468,11 +468,11 @@ enum ToServerCommand s32[len] sound_id */ - TOSERVER_REQUEST_TEXTURES = 0x40, + TOSERVER_REQUEST_MEDIA = 0x40, /* u16 command - u16 number of textures requested - for each texture { + u16 number of files requested + for each file { u16 length of name string name } diff --git a/src/filecache.cpp b/src/filecache.cpp index 28d6bbc80..5ba8ef5cc 100644 --- a/src/filecache.cpp +++ b/src/filecache.cpp @@ -28,14 +28,13 @@ with this program; if not, write to the Free Software Foundation, Inc., #include <string> #include <iostream> -bool FileCache::loadByPath(const std::string &name, std::ostream &os, - const std::string &path) +bool FileCache::loadByPath(const std::string &path, std::ostream &os) { std::ifstream fis(path.c_str(), std::ios_base::binary); if(!fis.good()){ - infostream<<"FileCache: File not found in cache: " - <<name << " expected it at: "<<path<<std::endl; + verbosestream<<"FileCache: File not found in cache: " + <<path<<std::endl; return false; } @@ -53,15 +52,14 @@ bool FileCache::loadByPath(const std::string &name, std::ostream &os, } } if(bad){ - infostream<<"FileCache: Failed to read file from cache: \"" - <<path<<"\""<<std::endl; + errorstream<<"FileCache: Failed to read file from cache: \"" + <<path<<"\""<<std::endl; } return !bad; } -bool FileCache::updateByPath(const std::string &name, const std::string &data, - const std::string &path) +bool FileCache::updateByPath(const std::string &path, const std::string &data) { std::ofstream file(path.c_str(), std::ios_base::binary | std::ios_base::trunc); @@ -69,7 +67,7 @@ bool FileCache::updateByPath(const std::string &name, const std::string &data, if(!file.good()) { errorstream<<"FileCache: Can't write to file at " - <<path<<std::endl; + <<path<<std::endl; return false; } @@ -82,36 +80,31 @@ bool FileCache::updateByPath(const std::string &name, const std::string &data, bool FileCache::loadByName(const std::string &name, std::ostream &os) { std::string path = m_dir + DIR_DELIM + name; - return loadByPath(name, os, path); + return loadByPath(path, os); } bool FileCache::updateByName(const std::string &name, const std::string &data) { std::string path = m_dir + DIR_DELIM + name; - return updateByPath(name, data, path); + return updateByPath(path, data); } -std::string FileCache::getPathFromChecksum(const std::string &name, - const std::string &checksum) +std::string FileCache::getPathFromChecksum(const std::string &checksum) { std::string checksum_hex = hex_encode(checksum.c_str(), checksum.length()); - size_t dot = name.find_last_of('.');; - std::string ext = (dot == std::string::npos)? "" : - name.substr(dot, std::string::npos); - return m_dir + DIR_DELIM + checksum_hex + ext; + return m_dir + DIR_DELIM + checksum_hex; } -bool FileCache::loadByChecksum(const std::string &name, std::ostream &os, - const std::string &checksum) +bool FileCache::loadByChecksum(const std::string &checksum, std::ostream &os) { - std::string path = getPathFromChecksum(name, checksum); - return loadByPath(name, os, path); + std::string path = getPathFromChecksum(checksum); + return loadByPath(path, os); } -bool FileCache::updateByChecksum(const std::string &name, - const std::string &data, const std::string &checksum) +bool FileCache::updateByChecksum(const std::string &checksum, + const std::string &data) { - std::string path = getPathFromChecksum(name, checksum); - return updateByPath(name, data, path); + std::string path = getPathFromChecksum(checksum); + return updateByPath(path, data); } diff --git a/src/filecache.h b/src/filecache.h index 35ae9aa7d..ae3fbc602 100644 --- a/src/filecache.h +++ b/src/filecache.h @@ -52,28 +52,21 @@ public: Loads a file based on a check sum, which may be any kind of rather unique byte sequence. Returns true, if the file could be written into os, false otherwise. - A file name is required to give the disk file a name that - has the right file name extension (e.g. ".png"). */ - bool loadByChecksum(const std::string &name, std::ostream &os, - const std::string &checksum); + bool loadByChecksum(const std::string &checksum, std::ostream &os); /* Stores a file in the cache based on its checksum. Returns true on success, false otherwise. */ - bool updateByChecksum(const std::string &name, const std::string &data, - const std::string &checksum); + bool updateByChecksum(const std::string &checksum, const std::string &data); private: std::string m_dir; - bool loadByPath(const std::string &name, std::ostream &os, - const std::string &path); - bool updateByPath(const std::string &name, const std::string &data, - const std::string &path); - std::string getPathFromChecksum(const std::string &name, - const std::string &checksum); + bool loadByPath(const std::string &path, std::ostream &os); + bool updateByPath(const std::string &path, const std::string &data); + std::string getPathFromChecksum(const std::string &checksum); }; #endif diff --git a/src/game.cpp b/src/game.cpp index 1dcda043e..eeb5d02e4 100644 --- a/src/game.cpp +++ b/src/game.cpp @@ -56,7 +56,7 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "clientmap.h" #include "sky.h" #include "sound.h" -#if USE_AUDIO +#if USE_SOUND #include "sound_openal.h" #endif #include "event_manager.h" @@ -953,7 +953,7 @@ void the_game( // Sound manager ISoundManager *sound = NULL; bool sound_is_dummy = false; -#if USE_AUDIO +#if USE_SOUND infostream<<"Attempting to use OpenAL audio"<<std::endl; sound = createOpenALSoundManager(&soundfetcher); if(!sound) @@ -1163,9 +1163,8 @@ void the_game( ss<<L" Item definitions\n"; ss<<(client.nodedefReceived()?L"[X]":L"[ ]"); ss<<L" Node definitions\n"; - //ss<<(client.texturesReceived()?L"[X]":L"[ ]"); - ss<<L"["<<(int)(client.textureReceiveProgress()*100+0.5)<<L"%] "; - ss<<L" Textures\n"; + ss<<L"["<<(int)(client.mediaReceiveProgress()*100+0.5)<<L"%] "; + ss<<L" Media\n"; draw_load_screen(ss.str(), driver, font); diff --git a/src/server.cpp b/src/server.cpp index 745e55f83..d6bb14f95 100644 --- a/src/server.cpp +++ b/src/server.cpp @@ -957,7 +957,7 @@ Server::Server( } // Read Textures and calculate sha1 sums - PrepareTextures(); + fillMediaCache(); // Apply item aliases in the node definition manager m_nodedef->updateAliases(m_itemdef); @@ -2183,7 +2183,7 @@ void Server::ProcessData(u8 *data, u32 datasize, u16 peer_id) SendNodeDef(m_con, peer_id, m_nodedef); // Send texture announcement - SendTextureAnnouncement(peer_id); + sendMediaAnnouncement(peer_id); // Send player info to all players //SendPlayerInfos(); @@ -2842,29 +2842,28 @@ void Server::ProcessData(u8 *data, u32 datasize, u16 peer_id) // ActiveObject is added to environment in AsyncRunStep after // the previous addition has been succesfully removed } - else if(command == TOSERVER_REQUEST_TEXTURES) { + else if(command == TOSERVER_REQUEST_MEDIA) { std::string datastring((char*)&data[2], datasize-2); std::istringstream is(datastring, std::ios_base::binary); - - core::list<TextureRequest> tosend; - u16 numtextures = readU16(is); + core::list<MediaRequest> tosend; + u16 numfiles = readU16(is); - infostream<<"Sending "<<numtextures<<" textures to " + infostream<<"Sending "<<numfiles<<" files to " <<getPlayerName(peer_id)<<std::endl; - verbosestream<<"TOSERVER_REQUEST_TEXTURES: "<<std::endl; + verbosestream<<"TOSERVER_REQUEST_MEDIA: "<<std::endl; - for(int i = 0; i < numtextures; i++) { + for(int i = 0; i < numfiles; i++) { std::string name = deSerializeString(is); - tosend.push_back(TextureRequest(name)); - verbosestream<<"TOSERVER_REQUEST_TEXTURES: requested texture " + tosend.push_back(MediaRequest(name)); + verbosestream<<"TOSERVER_REQUEST_MEDIA: requested file " <<name<<std::endl; } - SendTexturesRequested(peer_id, tosend); + sendRequestedMedia(peer_id, tosend); // Now the client should know about everything - // (definitions and textures) + // (definitions and files) getClient(peer_id)->definitions_sent = true; } else if(command == TOSERVER_INTERACT) @@ -3928,32 +3927,32 @@ void Server::SendBlocks(float dtime) } } -void Server::PrepareTextures() +void Server::fillMediaCache() { DSTACK(__FUNCTION_NAME); - infostream<<"Server: Calculating texture checksums"<<std::endl; + infostream<<"Server: Calculating file checksums"<<std::endl; for(core::list<ModSpec>::Iterator i = m_mods.begin(); i != m_mods.end(); i++){ const ModSpec &mod = *i; - std::string texturepath = mod.path + DIR_DELIM + "textures"; - std::vector<fs::DirListNode> dirlist = fs::GetDirListing(texturepath); + std::string filepath = mod.path + DIR_DELIM + "textures"; + std::vector<fs::DirListNode> dirlist = fs::GetDirListing(filepath); for(u32 j=0; j<dirlist.size(); j++){ if(dirlist[j].dir) // Ignode dirs continue; std::string tname = dirlist[j].name; - // if name contains illegal characters, ignore the texture + // if name contains illegal characters, ignore the file if(!string_allowed(tname, TEXTURENAME_ALLOWED_CHARS)){ - errorstream<<"Server: ignoring illegal texture name: \"" + errorstream<<"Server: ignoring illegal file name: \"" <<tname<<"\""<<std::endl; continue; } - std::string tpath = texturepath + DIR_DELIM + tname; + std::string tpath = filepath + DIR_DELIM + tname; // Read data std::ifstream fis(tpath.c_str(), std::ios_base::binary); if(fis.good() == false){ - errorstream<<"Server::PrepareTextures(): Could not open \"" + errorstream<<"Server::fillMediaCache(): Could not open \"" <<tname<<"\" for reading"<<std::endl; continue; } @@ -3972,12 +3971,12 @@ void Server::PrepareTextures() } } if(bad){ - errorstream<<"Server::PrepareTextures(): Failed to read \"" + errorstream<<"Server::fillMediaCache(): Failed to read \"" <<tname<<"\""<<std::endl; continue; } if(tmp_os.str().length() == 0){ - errorstream<<"Server::PrepareTextures(): Empty file \"" + errorstream<<"Server::fillMediaCache(): Empty file \"" <<tpath<<"\""<<std::endl; continue; } @@ -3991,60 +3990,60 @@ void Server::PrepareTextures() free(digest); // Put in list - this->m_Textures[tname] = TextureInformation(tpath,digest_string); + this->m_media[tname] = MediaInfo(tpath,digest_string); verbosestream<<"Server: sha1 for "<<tname<<"\tis "<<std::endl; } } } -struct SendableTextureAnnouncement - { - std::string name; - std::string sha1_digest; +struct SendableMediaAnnouncement +{ + std::string name; + std::string sha1_digest; - SendableTextureAnnouncement(const std::string name_="", - const std::string sha1_digest_=""): - name(name_), - sha1_digest(sha1_digest_) - { - } - }; + SendableMediaAnnouncement(const std::string name_="", + const std::string sha1_digest_=""): + name(name_), + sha1_digest(sha1_digest_) + {} +}; -void Server::SendTextureAnnouncement(u16 peer_id){ +void Server::sendMediaAnnouncement(u16 peer_id) +{ DSTACK(__FUNCTION_NAME); - verbosestream<<"Server: Announcing textures to id("<<peer_id<<")" + verbosestream<<"Server: Announcing files to id("<<peer_id<<")" <<std::endl; - core::list<SendableTextureAnnouncement> texture_announcements; - - for (std::map<std::string,TextureInformation>::iterator i = m_Textures.begin();i != m_Textures.end(); i++ ) { + core::list<SendableMediaAnnouncement> file_announcements; + for(std::map<std::string, MediaInfo>::iterator i = m_media.begin(); + i != m_media.end(); i++){ // Put in list - texture_announcements.push_back( - SendableTextureAnnouncement(i->first, i->second.sha1_digest)); + file_announcements.push_back( + SendableMediaAnnouncement(i->first, i->second.sha1_digest)); } - //send announcements + // Make packet + std::ostringstream os(std::ios_base::binary); /* u16 command - u32 number of textures + u32 number of files for each texture { u16 length of name string name - u16 length of digest string + u16 length of sha1_digest string sha1_digest } */ - std::ostringstream os(std::ios_base::binary); - - writeU16(os, TOCLIENT_ANNOUNCE_TEXTURES); - writeU16(os, texture_announcements.size()); + + writeU16(os, TOCLIENT_ANNOUNCE_MEDIA); + writeU16(os, file_announcements.size()); - for(core::list<SendableTextureAnnouncement>::Iterator - j = texture_announcements.begin(); - j != texture_announcements.end(); j++){ + for(core::list<SendableMediaAnnouncement>::Iterator + j = file_announcements.begin(); + j != file_announcements.end(); j++){ os<<serializeString(j->name); os<<serializeString(j->sha1_digest); } @@ -4058,13 +4057,13 @@ void Server::SendTextureAnnouncement(u16 peer_id){ } -struct SendableTexture +struct SendableMedia { std::string name; std::string path; std::string data; - SendableTexture(const std::string &name_="", const std::string path_="", + SendableMedia(const std::string &name_="", const std::string path_="", const std::string &data_=""): name(name_), path(path_), @@ -4072,36 +4071,40 @@ struct SendableTexture {} }; -void Server::SendTexturesRequested(u16 peer_id,core::list<TextureRequest> tosend) { +void Server::sendRequestedMedia(u16 peer_id, + const core::list<MediaRequest> &tosend) +{ DSTACK(__FUNCTION_NAME); - verbosestream<<"Server::SendTexturesRequested(): " - <<"Sending textures to client"<<std::endl; + verbosestream<<"Server::sendRequestedMedia(): " + <<"Sending files to client"<<std::endl; - /* Read textures */ + /* Read files */ // Put 5kB in one bunch (this is not accurate) u32 bytes_per_bunch = 5000; - core::array< core::list<SendableTexture> > texture_bunches; - texture_bunches.push_back(core::list<SendableTexture>()); + core::array< core::list<SendableMedia> > file_bunches; + file_bunches.push_back(core::list<SendableMedia>()); - u32 texture_size_bunch_total = 0; + u32 file_size_bunch_total = 0; - for(core::list<TextureRequest>::Iterator i = tosend.begin(); i != tosend.end(); i++) { - if(m_Textures.find(i->name) == m_Textures.end()){ - errorstream<<"Server::SendTexturesRequested(): Client asked for " - <<"unknown texture \""<<(i->name)<<"\""<<std::endl; + for(core::list<MediaRequest>::ConstIterator i = tosend.begin(); + i != tosend.end(); i++) + { + if(m_media.find(i->name) == m_media.end()){ + errorstream<<"Server::sendRequestedMedia(): Client asked for " + <<"unknown file \""<<(i->name)<<"\""<<std::endl; continue; } //TODO get path + name - std::string tpath = m_Textures[(*i).name].path; + std::string tpath = m_media[(*i).name].path; // Read data std::ifstream fis(tpath.c_str(), std::ios_base::binary); if(fis.good() == false){ - errorstream<<"Server::SendTexturesRequested(): Could not open \"" + errorstream<<"Server::sendRequestedMedia(): Could not open \"" <<tpath<<"\" for reading"<<std::endl; continue; } @@ -4112,7 +4115,7 @@ void Server::SendTexturesRequested(u16 peer_id,core::list<TextureRequest> tosend fis.read(buf, 1024); std::streamsize len = fis.gcount(); tmp_os.write(buf, len); - texture_size_bunch_total += len; + file_size_bunch_total += len; if(fis.eof()) break; if(!fis.good()){ @@ -4121,67 +4124,66 @@ void Server::SendTexturesRequested(u16 peer_id,core::list<TextureRequest> tosend } } if(bad){ - errorstream<<"Server::SendTexturesRequested(): Failed to read \"" + errorstream<<"Server::sendRequestedMedia(): Failed to read \"" <<(*i).name<<"\""<<std::endl; continue; } - /*infostream<<"Server::SendTexturesRequested(): Loaded \"" + /*infostream<<"Server::sendRequestedMedia(): Loaded \"" <<tname<<"\""<<std::endl;*/ // Put in list - texture_bunches[texture_bunches.size()-1].push_back( - SendableTexture((*i).name, tpath, tmp_os.str())); + file_bunches[file_bunches.size()-1].push_back( + SendableMedia((*i).name, tpath, tmp_os.str())); // Start next bunch if got enough data - if(texture_size_bunch_total >= bytes_per_bunch){ - texture_bunches.push_back(core::list<SendableTexture>()); - texture_size_bunch_total = 0; + if(file_size_bunch_total >= bytes_per_bunch){ + file_bunches.push_back(core::list<SendableMedia>()); + file_size_bunch_total = 0; } } /* Create and send packets */ - u32 num_bunches = texture_bunches.size(); - for(u32 i=0; i<num_bunches; i++) - { - /* - u16 command - u16 total number of texture bunches - u16 index of this bunch - u32 number of textures in this bunch - for each texture { - u16 length of name - string name - u32 length of data - data - } - */ - std::ostringstream os(std::ios_base::binary); - - writeU16(os, TOCLIENT_TEXTURES); - writeU16(os, num_bunches); - writeU16(os, i); - writeU32(os, texture_bunches[i].size()); + u32 num_bunches = file_bunches.size(); + for(u32 i=0; i<num_bunches; i++) + { + std::ostringstream os(std::ios_base::binary); - for(core::list<SendableTexture>::Iterator - j = texture_bunches[i].begin(); - j != texture_bunches[i].end(); j++){ - os<<serializeString(j->name); - os<<serializeLongString(j->data); + /* + u16 command + u16 total number of texture bunches + u16 index of this bunch + u32 number of files in this bunch + for each file { + u16 length of name + string name + u32 length of data + data } + */ - // Make data buffer - std::string s = os.str(); - verbosestream<<"Server::SendTexturesRequested(): bunch " - <<i<<"/"<<num_bunches - <<" textures="<<texture_bunches[i].size() - <<" size=" <<s.size()<<std::endl; - SharedBuffer<u8> data((u8*)s.c_str(), s.size()); - // Send as reliable - m_con.Send(peer_id, 0, data, true); - } + writeU16(os, TOCLIENT_MEDIA); + writeU16(os, num_bunches); + writeU16(os, i); + writeU32(os, file_bunches[i].size()); + for(core::list<SendableMedia>::Iterator + j = file_bunches[i].begin(); + j != file_bunches[i].end(); j++){ + os<<serializeString(j->name); + os<<serializeLongString(j->data); + } + // Make data buffer + std::string s = os.str(); + verbosestream<<"Server::sendRequestedMedia(): bunch " + <<i<<"/"<<num_bunches + <<" files="<<file_bunches[i].size() + <<" size=" <<s.size()<<std::endl; + SharedBuffer<u8> data((u8*)s.c_str(), s.size()); + // Send as reliable + m_con.Send(peer_id, 0, data, true); + } } /* diff --git a/src/server.h b/src/server.h index ae50af15b..6c789f7b5 100644 --- a/src/server.h +++ b/src/server.h @@ -253,21 +253,21 @@ struct PrioritySortedBlockTransfer u16 peer_id; }; -struct TextureRequest +struct MediaRequest { std::string name; - TextureRequest(const std::string &name_=""): + MediaRequest(const std::string &name_=""): name(name_) {} }; -struct TextureInformation +struct MediaInfo { std::string path; std::string sha1_digest; - TextureInformation(const std::string path_="", + MediaInfo(const std::string path_="", const std::string sha1_digest_=""): path(path_), sha1_digest(sha1_digest_) @@ -644,11 +644,10 @@ private: // Sends blocks to clients (locks env and con on its own) void SendBlocks(float dtime); - void PrepareTextures(); - - void SendTextureAnnouncement(u16 peer_id); - - void SendTexturesRequested(u16 peer_id,core::list<TextureRequest> tosend); + void fillMediaCache(); + void sendMediaAnnouncement(u16 peer_id); + void sendRequestedMedia(u16 peer_id, + const core::list<MediaRequest> &tosend); /* Something random @@ -832,7 +831,7 @@ private: friend class EmergeThread; friend class RemoteClient; - std::map<std::string,TextureInformation> m_Textures; + std::map<std::string,MediaInfo> m_media; /* Sounds |