--- /dev/null
+#include <stdio.h>
+#include <iostream>
+#include <boost/test/unit_test.hpp>
+#include <boost/test/parameterized_test.hpp>
+#include <boost/test/unit_test_log.hpp>
+
+#include "zypp/MediaSetAccess.h"
+#include "zypp/Url.h"
+
+using std::cout;
+using std::endl;
+using std::string;
+using namespace zypp;
+using namespace zypp::media;
+using namespace boost::unit_test;
+
+
+class SimpleVerifier : public zypp::media::MediaVerifierBase
+{
+public:
+
+ SimpleVerifier( const std::string &id )
+ {
+ _media_id = id;
+ }
+
+ virtual bool isDesiredMedia(const media::MediaAccessRef &ref)
+ {
+ return ref->doesFileExist(Pathname("/." + _media_id ));
+ }
+
+private:
+ std::string _media_id;
+};
+
+bool check_file_exists(const Pathname &path)
+{
+ FILE *file;
+
+ if ((file = fopen(path.asString().c_str(), "r")) == NULL) return false;
+
+ fclose(file);
+ return true;
+}
+
+/*
+ * Check how MediaSetAccess::rewriteUrl() works.
+ */
+void msa_url_rewrite()
+{
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("iso:/?iso=/path/to/CD1.iso"), 1).asString(),
+ Url("iso:/?iso=/path/to/CD1.iso").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("iso:/?iso=/path/to/CD1.iso"), 2).asString(),
+ Url("iso:/?iso=/path/to/CD2.iso").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("iso:/?iso=/path/to/CD1.iso"), 13).asString(),
+ Url("iso:/?iso=/path/to/CD13.iso").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("iso:/?iso=/path/to/cd1.iso"), 2).asString(),
+ Url("iso:/?iso=/path/to/cd2.iso").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("iso:/?iso=/path/to/cd2.iso"), 1).asString(),
+ Url("iso:/?iso=/path/to/cd1.iso").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("iso:/?iso=/path/to/dvd1.iso"), 2).asString(),
+ Url("iso:/?iso=/path/to/dvd2.iso").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("dir:/path/to/CD1"), 2).asString(),
+ Url("dir:/path/to/CD2").asString());
+
+ // trailing slash check
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("dir:/path/to/CD1/"), 2).asString(),
+ Url("dir:/path/to/CD2/").asString());
+
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("nfs://nfs-server/exported/path/to/dvd1"), 2).asString(),
+ Url("nfs://nfs-server/exported/path/to/dvd2").asString());
+
+ // single media check shouldn't this fail somehow??
+ BOOST_CHECK_EQUAL(
+ MediaSetAccess::rewriteUrl(Url("http://ftp.opensuse.org/pub/opensuse/distribution/SL-OSS-factory/inst-source"), 2).asString(),
+ Url("http://ftp.opensuse.org/pub/opensuse/distribution/SL-OSS-factory/inst-source").asString());
+}
+
+/*
+ * Provide files from set without verifiers.
+ */
+void msa_provide_files_set(const string &url)
+{
+ MediaSetAccess setaccess(Url(url), "/");
+
+ Pathname file1 = setaccess.provideFile("/test.txt", 1);
+ BOOST_CHECK(check_file_exists(file1) == true);
+
+ Pathname file2 = setaccess.provideFile("/test.txt", 2);
+ BOOST_CHECK(check_file_exists(file2) == true);
+
+ Pathname file3 = setaccess.provideFile("/test.txt", 3);
+ BOOST_CHECK(check_file_exists(file3) == true);
+}
+
+/*
+ * Provide files from set with verifiers.
+ */
+void msa_provide_files_set_verified(const string &url)
+{
+ MediaSetAccess setaccess(Url(url), "/");
+
+ setaccess.setVerifier(1, media::MediaVerifierRef(new SimpleVerifier("media1")));
+ setaccess.setVerifier(2, media::MediaVerifierRef(new SimpleVerifier("media2")));
+ setaccess.setVerifier(3, media::MediaVerifierRef(new SimpleVerifier("media3")));
+
+ // provide file from media1
+ Pathname file1 = setaccess.provideFile("/test.txt", 1);
+ BOOST_CHECK(check_file_exists(file1) == true);
+
+ // provide file from invalid media
+ BOOST_CHECK_THROW(setaccess.provideFile("/test.txt", 2),
+ zypp::media::MediaNotDesiredException);
+
+ // provide file from media3
+ Pathname file3 = setaccess.provideFile("/test.txt", 3);
+ BOOST_CHECK(check_file_exists(file3) == true);
+}
+
+/*
+ * Provide file from single media with verifier.
+ */
+void msa_provide_files_single(const string &url)
+{
+ MediaSetAccess setaccess(Url(url), "/");
+ setaccess.setVerifier(1, media::MediaVerifierRef(new SimpleVerifier("media")));
+
+ // provide file from media
+ Pathname file = setaccess.provideFile("/test.txt", 1);
+ BOOST_CHECK(check_file_exists(file) == true);
+}
+
+
+/*
+ *
+ * test data dir structure:
+ *
+ * src1/
+ * src1/cd1/
+ * src1/cd1/test.txt
+ * src1/cd1/.media1
+ * src1/cd2/
+ * src1/cd2/test.txt
+ * src1/cd2/.mediabad
+ * src1/cd3/
+ * src1/cd3/test.txt
+ * src1/cd3/.media3
+ * src2
+ * src2/test.txt
+ * src2/.media
+ *
+ */
+
+test_suite*
+init_unit_test_suite( int argc, char *argv[] )
+{
+ if (argc < 2)
+ {
+ cout << "mediasetaccesstest:"
+ " path to directory with test data required as parameter" << endl;
+ return (test_suite *)0;
+ }
+
+ test_suite* test= BOOST_TEST_SUITE("MediaSetAccessTest");
+
+ // urls to test
+ string datadir = argv[1];
+ std::string const params[] = {"dir:" + datadir + "/src1/cd1"};
+ std::string const params_single[] = {"dir:" + datadir + "/src2"};
+
+ // url rewrite
+ test->add(BOOST_TEST_CASE(&msa_url_rewrite));
+
+ // provide files from media set
+ test->add(BOOST_PARAM_TEST_CASE(&msa_provide_files_set,
+ (std::string const*)params, params+1));
+
+ // provide files from media set with verifier
+ test->add(BOOST_PARAM_TEST_CASE(&msa_provide_files_set_verified,
+ (std::string const*)params, params+1));
+
+ // provide file from single media
+ test->add(BOOST_PARAM_TEST_CASE(&msa_provide_files_single,
+ (std::string const*)params_single, params_single+1));
+
+ return test;
+}
+
+// vim: set ts=2 sts=2 sw=2 ai et:
{
try
{
- DBG << "Going to try provide file " << file << " from " << media_nr << endl;
+ DBG << "Going to try to provide file " << file
+ << " from media number " << media_nr << endl;
// try to attach the media
if ( ! media_mgr.isAttached(media) )
media_mgr.attach(media);
MIL << "Failed to release media " << media << endl;
}
- MIL << "Releasing all _medias of all sources" << endl;
+ /*MIL << "Releasing all _medias of all sources" << endl;
try
{
//zypp::SourceManager::sourceManager()->releaseAllSources();
{
ZYPP_CAUGHT(excpt_r);
ERR << "Failed to release all sources" << endl;
- }
+ }*/
// set up the reason
media::MediaChangeReport::Error reason = media::MediaChangeReport::INVALID;
typeid(excp) == typeid( media::MediaNotAFileException ) )
{
reason = media::MediaChangeReport::NOT_FOUND;
- }
+ }
else if( typeid(excp) == typeid( media::MediaNotDesiredException) ||
typeid(excp) == typeid( media::MediaNotAttachedException) )
{
{
if (_verifiers.find(medianr) != _verifiers.end())
{
- // there is a setted verifier for this media
+ // a verifier is set for this media
// FIXME check the case where the verifier exists
// but we have no access id for the media
media::MediaAccessId id = _medias[medianr];
return id;
}
+
Url MediaSetAccess::rewriteUrl (const Url & url_r, const media::MediaNr medianr)
{
std::string scheme = url_r.getScheme();
std::ostream & MediaSetAccess::dumpOn( std::ostream & str ) const
{
+ str << "MediaSetAccess (URL='" << _url << "', path='" << _path << "')";
return str;
}
///////////////////////////////////////////////////////////////////
//
- // CLASS NAME : SourceCache
+ // CLASS NAME : MediaSetAccess
//
/**
- * The
+ * Media access layer responsible for handling media distributed as a set.
+ *
+ * This is provided as a means to handle CD or DVD sets accessible through
+ * dir, iso, nfs or other URL schemes other than cd/dvd (see
+ * \ref MediaManager for info on different implemented media backends).
+ * Currently it handles URLs containing cdN, CDN, dvdN, and DVDN strings,
+ * where N is the number of particular media in the set.
+ *
+ * Examples:
+ * \code
+ * "iso:/?iso=/path/to/iso/images/openSUSE-10.3-Alpha2plus-DVD-x86_64-DVD1.iso"
+ * "dir:/path/to/cdset/sources/openSUSE-10.3/Alpha2plus/CD1"
+ * \endcode
+ *
+ * MediaSetAccess accesses files on desired media by rewriting
+ * the original URL, replacing the digit (usually) 1 with requested media
+ * number and uses \ref MediaManager to get the files from the new URL.
+ *
+ * Additionaly, each media number can be assined a media verifier which
+ * checks if the media we are trying to access is the desired one. See
+ * \ref MediaVerifierBase for more info.
+ *
+ * Code example:
+ * \code
+ * Url url("dir:/path/to/cdset/sources/openSUSE-10.3/Alpha2plus/CD1");
+ *
+ * MediaSetAccess access(url, "/");
+ *
+ * access.setVerifier(1, media1VerifierRef);
+ * access.setVerifier(2, media2VerifierRef);
+ *
+ * Pathname file1 = "/some/file/on/media1";
+ * access.provideFile(1, file1);
+ * Pathname file2 = "/some/file/on/media2";
+ * access.provideFile(2, file1);
+ *
+ * \endcode
*/
class MediaSetAccess : public base::ReferenceCounted, private base::NonCopyable
{
Pathname provideFile(const Pathname & file, unsigned media_nr = 1 );
Pathname provideFile(const Pathname & file, unsigned media_nr, const FileChecker checker );
-
+
+ static Url rewriteUrl (const Url & url_r, const media::MediaNr medianr);
+
protected:
Pathname provideFileInternal(const Pathname & file, unsigned media_nr, bool checkonly, bool cached);
- Url rewriteUrl (const Url & url_r, const media::MediaNr medianr);
media::MediaAccessId getMediaAccessId (media::MediaNr medianr);
virtual std::ostream & dumpOn( std::ostream & str ) const;
+
private:
+ /** Media or media set URL */
Url _url;
+ /** Path on the media relative to _url */
Pathname _path;
+
typedef std::map<media::MediaNr, media::MediaAccessId> MediaMap;
typedef std::map<media::MediaNr, media::MediaVerifierRef > VerifierMap;
- /** Mapping between each CD and Media Access ID */
+
+ /** Mapping between media number and Media Access ID */
MediaMap _medias;
+ /** Mapping between media number and corespondent verifier */
VerifierMap _verifiers;
};
///////////////////////////////////////////////////////////////////
projects / platform / upstream / libzypp.git / commitdiff