/* * Copyright (C) 2003-2014 The Music Player Daemon Project * http://www.musicpd.org * * 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. */ /** * iso archive handling (requires cdio, and iso9660) */ #include "config.h" #include "Iso9660ArchivePlugin.hxx" #include "../ArchivePlugin.hxx" #include "../ArchiveFile.hxx" #include "../ArchiveVisitor.hxx" #include "InputStream.hxx" #include "InputPlugin.hxx" #include "util/RefCount.hxx" #include "util/Error.hxx" #include "util/Domain.hxx" #include #include #include #define CEILING(x, y) ((x+(y-1))/y) class Iso9660ArchiveFile final : public ArchiveFile { RefCount ref; iso9660_t *iso; public: Iso9660ArchiveFile(iso9660_t *_iso) :ArchiveFile(iso9660_archive_plugin), iso(_iso) {} ~Iso9660ArchiveFile() { iso9660_close(iso); } void Ref() { ref.Increment(); } void Unref() { if (ref.Decrement()) delete this; } long SeekRead(void *ptr, lsn_t start, long int i_size) const { return iso9660_iso_seek_read(iso, ptr, start, i_size); } void Visit(const char *path, ArchiveVisitor &visitor); virtual void Close() override { Unref(); } virtual void Visit(ArchiveVisitor &visitor) override; virtual InputStream *OpenStream(const char *path, Mutex &mutex, Cond &cond, Error &error) override; }; extern const InputPlugin iso9660_input_plugin; static constexpr Domain iso9660_domain("iso9660"); /* archive open && listing routine */ inline void Iso9660ArchiveFile::Visit(const char *psz_path, ArchiveVisitor &visitor) { CdioList_t *entlist; CdioListNode_t *entnode; iso9660_stat_t *statbuf; char pathname[4096]; entlist = iso9660_ifs_readdir (iso, psz_path); if (!entlist) { return; } /* Iterate over the list of nodes that iso9660_ifs_readdir gives */ _CDIO_LIST_FOREACH (entnode, entlist) { statbuf = (iso9660_stat_t *) _cdio_list_node_data (entnode); strcpy(pathname, psz_path); strcat(pathname, statbuf->filename); if (iso9660_stat_s::_STAT_DIR == statbuf->type ) { if (strcmp(statbuf->filename, ".") && strcmp(statbuf->filename, "..")) { strcat(pathname, "/"); Visit(pathname, visitor); } } else { //remove leading / visitor.VisitArchiveEntry(pathname + 1); } } _cdio_list_free (entlist, true); } static ArchiveFile * iso9660_archive_open(const char *pathname, Error &error) { /* open archive */ auto iso = iso9660_open(pathname); if (iso == nullptr) { error.Format(iso9660_domain, "Failed to open ISO9660 file %s", pathname); return nullptr; } return new Iso9660ArchiveFile(iso); } void Iso9660ArchiveFile::Visit(ArchiveVisitor &visitor) { Visit("/", visitor); } /* single archive handling */ class Iso9660InputStream { InputStream base; Iso9660ArchiveFile &archive; iso9660_stat_t *statbuf; public: Iso9660InputStream(Iso9660ArchiveFile &_archive, const char *uri, Mutex &mutex, Cond &cond, iso9660_stat_t *_statbuf) :base(iso9660_input_plugin, uri, mutex, cond), archive(_archive), statbuf(_statbuf) { base.ready = true; base.size = statbuf->size; archive.Ref(); } ~Iso9660InputStream() { free(statbuf); archive.Unref(); } InputStream *Get() { return &base; } size_t Read(void *ptr, size_t size, Error &error); }; InputStream * Iso9660ArchiveFile::OpenStream(const char *pathname, Mutex &mutex, Cond &cond, Error &error) { auto statbuf = iso9660_ifs_stat_translate(iso, pathname); if (statbuf == nullptr) { error.Format(iso9660_domain, "not found in the ISO file: %s", pathname); return nullptr; } Iso9660InputStream *iis = new Iso9660InputStream(*this, pathname, mutex, cond, statbuf); return iis->Get(); } static void iso9660_input_close(InputStream *is) { Iso9660InputStream *iis = (Iso9660InputStream *)is; delete iis; } inline size_t Iso9660InputStream::Read(void *ptr, size_t size, Error &error) { int readed = 0; int no_blocks, cur_block; size_t left_bytes = statbuf->size - base.offset; if (left_bytes < size) { no_blocks = CEILING(left_bytes,ISO_BLOCKSIZE); } else { no_blocks = size / ISO_BLOCKSIZE; } if (no_blocks == 0) return 0; cur_block = base.offset / ISO_BLOCKSIZE; readed = archive.SeekRead(ptr, statbuf->lsn + cur_block, no_blocks); if (readed != no_blocks * ISO_BLOCKSIZE) { error.Format(iso9660_domain, "error reading ISO file at lsn %lu", (unsigned long)cur_block); return 0; } if (left_bytes < size) { readed = left_bytes; } base.offset += readed; return readed; } static size_t iso9660_input_read(InputStream *is, void *ptr, size_t size, Error &error) { Iso9660InputStream *iis = (Iso9660InputStream *)is; return iis->Read(ptr, size, error); } static bool iso9660_input_eof(InputStream *is) { return is->offset == is->size; } /* exported structures */ static const char *const iso9660_archive_extensions[] = { "iso", nullptr }; const InputPlugin iso9660_input_plugin = { nullptr, nullptr, nullptr, nullptr, iso9660_input_close, nullptr, nullptr, nullptr, nullptr, iso9660_input_read, iso9660_input_eof, nullptr, }; const struct archive_plugin iso9660_archive_plugin = { "iso", nullptr, nullptr, iso9660_archive_open, iso9660_archive_extensions, };