PoolImpl.h

Go to the documentation of this file.

/*---------------------------------------------------------------------\
|                          ____ _   __ __ ___                          |
|                         |__  / \ / / . \ . \                         |
|                           / / \ V /|  _/  _/                         |
|                          / /__ | | | | | |                           |
|                         /_____||_| |_| |_|                           |
|                                                                      |
\---------------------------------------------------------------------*/
#ifndef ZYPP_POOL_POOLIMPL_H
#define ZYPP_POOL_POOLIMPL_H
 
#include <iosfwd>
#include <utility>
 
#include <zypp/base/Easy.h>
#include <zypp/base/LogTools.h>
#include <zypp/base/SerialNumber.h>
#include <zypp-core/Globals.h>
 
#include <zypp/pool/PoolTraits.h>
#include <zypp/ResPoolProxy.h>
#include <zypp/PoolQueryResult.h>
 
#include <zypp/sat/Pool.h>
#include <zypp/Product.h>
 
using std::endl;

namespace zypp
{ 
 
  namespace resstatus
  {
    struct UserLockQueryManip
    {
      static void setLock( ResStatus & status_r, bool yesno_r )
      {
        status_r.setLock( yesno_r, ResStatus::USER );
        status_r.setUserLockQueryMatch( yesno_r );
      }

      static void reapplyLock( ResStatus & status_r, bool yesno_r )
      {
        if ( yesno_r && ! status_r.isUserLockQueryMatch() )
        {
          status_r.setLock( yesno_r, ResStatus::USER );
          status_r.setUserLockQueryMatch( yesno_r );
        }
      }

      static int diffLock( const ResStatus & status_r )
      {
        bool userLock( status_r.isUserLocked() );
        if ( userLock == status_r.isUserLockQueryMatch() )
          return 0;
        return userLock ? 1 : -1;
      }
 
    };
  }
 
  namespace
  {
    inline PoolQuery makeTrivialQuery( IdString ident_r )
    {
      sat::Solvable::SplitIdent ident( ident_r );
 
      PoolQuery q;
      q.addAttribute( sat::SolvAttr::name, ident.name().asString() );
      q.addKind( ident.kind() );
      q.setMatchExact();
      q.setCaseSensitive(true);
      return q;
   }
 
    inline bool hardLockQueriesRemove( pool::PoolTraits::HardLockQueries & activeLocks_r, IdString ident_r )
    {
      unsigned s( activeLocks_r.size() );
      activeLocks_r.remove( makeTrivialQuery( ident_r ) );
      return( activeLocks_r.size() != s );
    }
 
    inline bool hardLockQueriesAdd( pool::PoolTraits::HardLockQueries & activeLocks_r, IdString ident_r )
    {
      PoolQuery q( makeTrivialQuery( ident_r ) );
      for_( it, activeLocks_r.begin(), activeLocks_r.end() )
      {
        if ( *it == q )
          return false;
      }
      activeLocks_r.push_back( q );
      return true;
    }
  }

  namespace solver {
    namespace detail {
      void establish( sat::Queue & pseudoItems_r, sat::Queue & pseudoFlags_r );    // in solver/detail/SATResolver.cc
    }
  }

  class ResPool::EstablishedStates::Impl
  {
  public:
    Impl()
    { solver::detail::establish( _pseudoItems, _pseudoFlags ); }

    ResPool::EstablishedStates::ChangedPseudoInstalled changedPseudoInstalled() const
    {
      ChangedPseudoInstalled ret;
 
      if ( ! _pseudoItems.empty() )
      {
        for ( sat::Queue::size_type i = 0; i < _pseudoItems.size(); ++i )
        {
          PoolItem pi { sat::Solvable(_pseudoItems[i]) };
          ResStatus::ValidateValue vorig { validateValue( i ) };
          if ( pi.status().validate() != vorig )
            ret[pi] = vorig;
        }
      }
      return ret;
    }
 
  private:
    ResStatus::ValidateValue validateValue( sat::Queue::size_type i ) const
    {
      ResStatus::ValidateValue ret { ResStatus::UNDETERMINED };
      switch ( _pseudoFlags[i] )
      {
        case  0: ret = ResStatus::BROKEN      /*2*/; break;
        case  1: ret = ResStatus::SATISFIED   /*4*/; break;
        case -1: ret = ResStatus::NONRELEVANT /*6*/; break;
      }
      return ret;
    }
 
  private:
    sat::Queue _pseudoItems;
    sat::Queue _pseudoFlags;
  };

  namespace pool
  { 

    //
    //  CLASS NAME : PoolImpl
    //
    class PoolImpl
    {
      friend std::ostream & operator<<( std::ostream & str, const PoolImpl & obj );
 
      public:
        using ContainerT = PoolTraits::ItemContainerT;
        using size_type = PoolTraits::size_type;
        using const_iterator = PoolTraits::const_iterator;
        using Id2ItemT = PoolTraits::Id2ItemT;
 
        using repository_iterator = PoolTraits::repository_iterator;
 
        using SolvableIdType = sat::detail::SolvableIdType;
 
        using EstablishedStatesImpl = ResPool::EstablishedStates::Impl;
 
      public:
        PoolImpl();
        ~PoolImpl();
 
      public:
        const sat::Pool satpool() const
        { return sat::Pool::instance(); }

        const SerialNumber & serial() const
        { return satpool().serial(); }

        //
      public:
        bool empty() const
        { return satpool().solvablesEmpty(); }

        size_type size() const
        { return satpool().solvablesSize(); }
 
        const_iterator begin() const
        { return make_filter_begin( pool::ByPoolItem(), store() ); }
 
        const_iterator end() const
        { return make_filter_end( pool::ByPoolItem(), store() ); }
 
      public:
        PoolItem find( const sat::Solvable & slv_r ) const
        {
          const ContainerT & mystore( store() );
          return( slv_r.id() < mystore.size() ? mystore[slv_r.id()] : PoolItem() );
        }

        //
      public:
        void SaveState( const ResKind & kind_r );
 
        void RestoreState( const ResKind & kind_r );

        //
      public:
        ResPoolProxy proxy( ResPool self ) const
        {
          checkSerial();
          if ( !_poolProxy )
          {
            _poolProxy.reset( new ResPoolProxy( std::move(self), *this ) );
          }
          return *_poolProxy;
        }

        ResPool::EstablishedStates establishedStates() const
        { store(); return ResPool::EstablishedStates( _establishedStates ); }
 
      public:
        size_type knownRepositoriesSize() const
        { checkSerial(); return satpool().reposSize(); }
 
        repository_iterator knownRepositoriesBegin() const
        { checkSerial(); return satpool().reposBegin(); }
 
        repository_iterator knownRepositoriesEnd() const
        { checkSerial(); return satpool().reposEnd(); }
 
        Repository reposFind( const std::string & alias_r ) const
        { checkSerial(); return satpool().reposFind( alias_r ); }

        //
      public:
        using HardLockQueries = PoolTraits::HardLockQueries;
        using hardLockQueries_iterator = PoolTraits::hardLockQueries_iterator;
 
        const HardLockQueries & hardLockQueries() const
        { return _hardLockQueries; }
 
        void reapplyHardLocks() const
        {
          // It is assumed that reapplyHardLocks is called after new
          // items were added to the pool, but the _hardLockQueries
          // did not change since. Action is to be performed only on
          // those items that gained the bit in the UserLockQueryField.
          MIL << "Re-apply " << _hardLockQueries.size() << " HardLockQueries" << endl;
          PoolQueryResult locked;
          for_( it, _hardLockQueries.begin(), _hardLockQueries.end() )
          {
            locked += *it;
          }
          MIL << "HardLockQueries match " << locked.size() << " Solvables." << endl;
          for_( it, begin(), end() )
          {
            // NOTE bsc#1225267: While reapplyLock sets but never unsets a lock,
            // we don't need to care about buddies like in setHardLockQueries.
            resstatus::UserLockQueryManip::reapplyLock( it->status(), locked.contains( *it ) );
          }
        }
 
        void setHardLockQueries( const HardLockQueries & newLocks_r )
        {
          MIL << "Apply " << newLocks_r.size() << " HardLockQueries" << endl;
          _hardLockQueries = newLocks_r;
          // now adjust the pool status
          PoolQueryResult locked;
          for_( it, _hardLockQueries.begin(), _hardLockQueries.end() )
          {
            locked += *it;
          }
          MIL << "HardLockQueries match " << locked.size() << " Solvables." << endl;
          for_( it, begin(), end() )
          {
            // NOTE bsc#1225267: If the item has a buddy (a shared ResStatus), we lock if
            // the item or the buddy is locked. Otherwise the item occurring later in the
            // pool would dictate the status (unsetting a previously set lock).
            bool yesno = locked.contains( *it ) || ( it->buddy() && locked.contains( PoolItem(it->buddy()) ) );
            resstatus::UserLockQueryManip::setLock( it->status(), yesno );
          }
        }
 
        bool getHardLockQueries( HardLockQueries & activeLocks_r )
        {
          activeLocks_r = _hardLockQueries; // current queries
          // Now diff to the pool collecting names only.
          // Thus added and removed locks are not necessarily
          // disjoint. Added locks win.
          typedef std::unordered_set<IdString> IdentSet;
          IdentSet addedLocks;
          IdentSet removedLocks;
          for_( it, begin(), end() )
          {
            switch ( resstatus::UserLockQueryManip::diffLock( it->status() ) )
            {
              case 0:  // unchanged
                break;
              case 1:
                addedLocks.insert( it->satSolvable().ident() );
                break;
              case -1:
                removedLocks.insert( it->satSolvable().ident() );
               break;
            }
          }
          // now the bad part - adjust the queries
          bool setChanged = false;
          for_( it, removedLocks.begin(), removedLocks.end() )
          {
            if ( addedLocks.find( *it ) != addedLocks.end() )
              continue; // Added locks win
            if ( hardLockQueriesRemove( activeLocks_r, *it ) && ! setChanged )
              setChanged = true;
          }
          for_( it, addedLocks.begin(), addedLocks.end() )
          {
            if ( hardLockQueriesAdd( activeLocks_r, *it ) && ! setChanged )
              setChanged = true;
          }
          return setChanged;
       }
 
      public:
        const ContainerT & store() const
        {
          checkSerial();
          if ( _storeDirty )
          {
            sat::Pool pool( satpool() );
            bool addedItems = false;
            bool reusedIDs = _watcherIDs.remember( pool.serialIDs() );
            std::list<PoolItem> addedProducts;
 
            _store.resize( pool.capacity() );
 
            if ( pool.capacity() )
            {
              for ( sat::detail::SolvableIdType i = pool.capacity()-1; i != 0; --i )
              {
                sat::Solvable s( i );
                PoolItem & pi( _store[i] );
                if ( ! s &&  pi )
                {
                  // the PoolItem got invalidated (e.g unloaded repo)
                  pi = PoolItem();
                }
                else if ( reusedIDs || (s && ! pi) )
                {
                  // new PoolItem to add
                  pi = PoolItem::makePoolItem( s ); // the only way to create a new one!
                  // remember products for buddy processing (requires clean store)
                  if ( s.isKind( ResKind::product ) )
                    addedProducts.push_back( pi );
                  if ( !addedItems )
                    addedItems = true;
                }
              }
            }
            _storeDirty = false;
 
            // Now, as the pool is adjusted, ....
 
            // .... we check for product buddies.
            if ( ! addedProducts.empty() )
            {
              for_( it, addedProducts.begin(), addedProducts.end() )
              {
                it->setBuddy( asKind<Product>(*it)->referencePackage() );
              }
            }
 
            // .... we must reapply those query based hard locks.
            if ( addedItems )
            {
              reapplyHardLocks();
            }
 
            // Compute the initial status of Patches etc.
            if ( !_establishedStates )
              _establishedStates.reset( new EstablishedStatesImpl );
          }
          return _store;
        }
 
        const Id2ItemT & id2item () const
        {
          checkSerial();
          if ( _id2itemDirty )
          {
            store();
            _id2item = Id2ItemT( size() );
            for_( it, begin(), end() )
            {
              const sat::Solvable &s = (*it)->satSolvable();
              sat::detail::IdType id = s.ident().id();
              if ( s.isKind( ResKind::srcpackage ) )
                id = -id;
              _id2item.insert( std::make_pair( id, *it ) );
            }
            //INT << _id2item << endl;
            _id2itemDirty = false;
          }
          return _id2item;
        }

        //
      private:
        void checkSerial() const
        {
          if ( _watcher.remember( serial() ) )
            invalidate();
          satpool().prepare(); // always ajust dependencies.
        }
 
        void invalidate() const
        {
          _storeDirty = true;
          _id2itemDirty = true;
          _id2item.clear();
          _poolProxy.reset();
          _establishedStates.reset();
        }
 
      private:
        SerialNumberWatcher                   _watcher;
        SerialNumberWatcher                   _watcherIDs;
        mutable ContainerT                    _store;
        mutable DefaultIntegral<bool,true>    _storeDirty;
        mutable Id2ItemT                      _id2item;
        mutable DefaultIntegral<bool,true>    _id2itemDirty;
 
      private:
        mutable shared_ptr<ResPoolProxy>      _poolProxy;
        mutable shared_ptr<EstablishedStatesImpl> _establishedStates;
 
      private:
        HardLockQueries                       _hardLockQueries;
    };


  } // namespace pool
} // namespace zypp
#endif // ZYPP_POOL_POOLIMPL_H