CommitPackageCacheReadAhead.h

Go to the documentation of this file.

/*---------------------------------------------------------------------\
|                          ____ _   __ __ ___                          |
|                         |__  / \ / / . \ . \                         |
|                           / / \ V /|  _/  _/                         |
|                          / /__ | | | | | |                           |
|                         /_____||_| |_| |_|                           |
|                                                                      |
\---------------------------------------------------------------------*/
#ifndef ZYPP_TARGET_COMMITPACKAGECACHEREADAHEAD_H
#define ZYPP_TARGET_COMMITPACKAGECACHEREADAHEAD_H

#include <map>

#include "zypp/base/Logger.h"
#include "zypp/base/Exception.h"
#include "zypp/base/DefaultIntegral.h"

#include "zypp/Repository.h"
#include "zypp/TmpPath.h"
#include "zypp/target/CommitPackageCacheImpl.h"

namespace zypp
{ 

  namespace target
  { 

    //
    //  CLASS NAME : IMediaKey
    //
    struct IMediaKey
    {
      IMediaKey()
      {}

      explicit
      IMediaKey( const ResObject::constPtr & obj_r )
      : _repository( obj_r->repository() )
      , _mediaNr( obj_r->mediaNr() )
      {}

      IMediaKey( const Repository & repo, unsigned mediaNr_r )
      : _repository( repo )
      , _mediaNr( mediaNr_r )
      {}

      bool operator==( const IMediaKey & rhs ) const
      { return( _repository == rhs._repository && _mediaNr == rhs._mediaNr ); }

      bool operator!=( const IMediaKey & rhs ) const
      { return ! operator==( rhs ); }

      bool operator<( const IMediaKey & rhs ) const
      {
        return( _repository.numericId() < rhs._repository.numericId()
                || ( _repository.numericId() == rhs._repository.numericId()
                     && _mediaNr < rhs._mediaNr ) );
      }

      Repository                  _repository;
      DefaultIntegral<unsigned,0> _mediaNr;
    };

    std::ostream & operator<<( std::ostream & str, const IMediaKey & obj );

    //
    //  CLASS NAME : CommitPackageCacheReadAhead
    //
    class CommitPackageCacheReadAhead : public CommitPackageCache::Impl
    {
      typedef std::map<PoolItem,ManagedFile>     CacheMap;

    public:
      CommitPackageCacheReadAhead( const_iterator          begin_r,
                                   const_iterator          end_r,
                                   const Pathname &        rootDir_r,
                                   const PackageProvider & packageProvider_r );

    public:
      virtual ManagedFile get( const_iterator citem_r );

    private:
      bool onInteractiveMedia( const PoolItem & pi ) const;

    private:
      void cacheLastInteractive( const_iterator citem_r );

      void doCacheLastInteractive( const_iterator citem_r );

    private:
      DefaultIntegral<unsigned,0> _dbgChanges;

      const_iterator       _commitListEnd;
      IMediaKey            _lastInteractive;

      Pathname                       _rootDir;
      shared_ptr<filesystem::TmpDir> _cacheDir;
      CacheMap                       _cacheMap;
    };

  } // namespace target
} // namespace zypp
#endif // ZYPP_TARGET_COMMITPACKAGECACHEREADAHEAD_H

---