aboutsummaryrefslogtreecommitdiffstats
path: root/src/archive/Iso9660ArchivePlugin.cxx
diff options
context:
space:
mode:
authorMax Kellermann <max@duempel.org>2014-01-24 00:09:37 +0100
committerMax Kellermann <max@duempel.org>2014-01-24 00:09:37 +0100
commit4aa6d39fd8dfbb822db2f156ba371c1a5000f35c (patch)
tree4075b83e9da4a196e0f84d8fdcbaed8177f2dce1 /src/archive/Iso9660ArchivePlugin.cxx
parent51adaf2c47761e3f2095a52a7037cd8458b77990 (diff)
downloadmpd-4aa6d39fd8dfbb822db2f156ba371c1a5000f35c.tar.gz
mpd-4aa6d39fd8dfbb822db2f156ba371c1a5000f35c.tar.xz
mpd-4aa6d39fd8dfbb822db2f156ba371c1a5000f35c.zip
archive/*: move to archive/plugins/
Diffstat (limited to 'src/archive/Iso9660ArchivePlugin.cxx')
-rw-r--r--src/archive/Iso9660ArchivePlugin.cxx275
1 files changed, 0 insertions, 275 deletions
diff --git a/src/archive/Iso9660ArchivePlugin.cxx b/src/archive/Iso9660ArchivePlugin.cxx
deleted file mode 100644
index 120070cc1..000000000
--- a/src/archive/Iso9660ArchivePlugin.cxx
+++ /dev/null
@@ -1,275 +0,0 @@
-/*
- * 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 <cdio/iso9660.h>
-
-#include <stdlib.h>
-#include <string.h>
-
-#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,
-};