activity.hpp

Go to the documentation of this file.

/* -*- mode: C++; c-basic-offset: 2; indent-tabs-mode: nil -*- */
/*
 *  Main authors:
 *     Christian Schulte <schulte@gecode.org>
 *
 *  Copyright:
 *     Christian Schulte, 2012
 *
 *  Last modified:
 *     $Date: 2013-07-27 00:49:48 +0200 (Sat, 27 Jul 2013) $ by $Author: tack $
 *     $Revision: 13949 $
 *
 *  This file is part of Gecode, the generic constraint
 *  development environment:
 *     http://www.gecode.org
 *
 *  Permission is hereby granted, free of charge, to any person obtaining
 *  a copy of this software and associated documentation files (the
 *  "Software"), to deal in the Software without restriction, including
 *  without limitation the rights to use, copy, modify, merge, publish,
 *  distribute, sublicense, and/or sell copies of the Software, and to
 *  permit persons to whom the Software is furnished to do so, subject to
 *  the following conditions:
 *
 *  The above copyright notice and this permission notice shall be
 *  included in all copies or substantial portions of the Software.
 *
 *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 *  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 *  MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 *  NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
 *  LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 *  OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 *  WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 *
 */

namespace Gecode {

  class Activity {
  protected:
    template<class View>
    class Recorder;
    class Storage {
    public:
      Support::Mutex m;
      unsigned int use_cnt;
      double* a;
      int n;
      double d;
      template<class View>
      Storage(Home home, ViewArray<View>& x, double d,
              typename BranchTraits<typename View::VarType>::Merit bm);
      ~Storage(void);
      static void* operator new(size_t s);
      static void  operator delete(void* p);
    };

    Storage* storage;
    void update(int i);
    void decay(int i);
    void acquire(void);
    void release(void);
  public:


    Activity(void);
    GECODE_KERNEL_EXPORT
    Activity(const Activity& a);
    GECODE_KERNEL_EXPORT
    Activity& operator =(const Activity& a);
    template<class View>
    Activity(Home home, ViewArray<View>& x, double d,
             typename BranchTraits<typename View::VarType>::Merit bm);
    template<class View>
    void init(Home home, ViewArray<View>& x, double d,
             typename BranchTraits<typename View::VarType>::Merit bm);
    bool initialized(void) const;
    GECODE_KERNEL_EXPORT
    void set(Space& home, double a=0.0);
    GECODE_KERNEL_EXPORT static const Activity def;



    GECODE_KERNEL_EXPORT
    void update(Space& home, bool share, Activity& a);
    GECODE_KERNEL_EXPORT
    ~Activity(void);
    


    double operator [](int i) const;
    int size(void) const;



    GECODE_KERNEL_EXPORT
    void decay(Space& home, double d);
    GECODE_KERNEL_EXPORT
    double decay(const Space& home) const;
  };

  template<class View>
  class Activity::Recorder : public NaryPropagator<View,PC_GEN_NONE> {
  protected:
    using NaryPropagator<View,PC_GEN_NONE>::x;
    class Idx : public Advisor {
    protected:
      int _info;
    public:
      Idx(Space& home, Propagator& p, Council<Idx>& c, int i);
      Idx(Space& home, bool share, Idx& a);
      void mark(void);
      void unmark(void);
      bool marked(void) const;
      int idx(void) const;
    };
    Activity a;
    Council<Idx> c;
    Recorder(Space& home, bool share, Recorder<View>& p);
  public:
    Recorder(Home home, ViewArray<View>& x, Activity& a);
    virtual Propagator* copy(Space& home, bool share);
    virtual PropCost cost(const Space& home, const ModEventDelta& med) const;
    virtual ExecStatus advise(Space& home, Advisor& a, const Delta& d);
    virtual ExecStatus propagate(Space& home, const ModEventDelta& med);
    virtual size_t dispose(Space& home);
    static ExecStatus post(Home home, ViewArray<View>& x, Activity& a);
  };
    
  template<class Char, class Traits>
  std::basic_ostream<Char,Traits>&
  operator <<(std::basic_ostream<Char,Traits>& os,
             const Activity& a);


  /*
   * Advisor for activity recorder
   *
   */
  template<class View>
  forceinline
  Activity::Recorder<View>::Idx::Idx(Space& home, Propagator& p, 
                                     Council<Idx>& c, int i)
    : Advisor(home,p,c), _info(i << 1) {}
  template<class View>
  forceinline
  Activity::Recorder<View>::Idx::Idx(Space& home, bool share, Idx& a)
    : Advisor(home,share,a), _info(a._info) {
  }
  template<class View>
  forceinline void
  Activity::Recorder<View>::Idx::mark(void) {
    _info |= 1;
  }
  template<class View>
  forceinline void
  Activity::Recorder<View>::Idx::unmark(void) {
    _info &= ~1;
  }
  template<class View>
  forceinline bool
  Activity::Recorder<View>::Idx::marked(void) const {
    return (_info & 1) != 0;
  }
  template<class View>
  forceinline int
  Activity::Recorder<View>::Idx::idx(void) const {
    return _info >> 1;
  }



  /*
   * Posting of activity recorder propagator
   *
   */
  template<class View>
  forceinline
  Activity::Recorder<View>::Recorder(Home home, ViewArray<View>& x, 
                                     Activity& a0)
    : NaryPropagator<View,PC_GEN_NONE>(home,x), a(a0), c(home) {
    home.notice(*this,AP_DISPOSE);
    for (int i=x.size(); i--; )
      if (!x[i].assigned())
        x[i].subscribe(home,*new (home) Idx(home,*this,c,i));
  }

  template<class View>
  forceinline ExecStatus
  Activity::Recorder<View>::post(Home home, ViewArray<View>& x, 
                                 Activity& a) {
    (void) new (home) Recorder<View>(home,x,a);
    return ES_OK;
  }


  /*
   * Activity value storage
   *
   */
  forceinline void*
  Activity::Storage::operator new(size_t s) {
    return Gecode::heap.ralloc(s);
  }
  forceinline void
  Activity::Storage::operator delete(void* p) {
    Gecode::heap.rfree(p);
  }
  template<class View>
  forceinline
  Activity::Storage::Storage(Home home, ViewArray<View>& x, double d0,
                             typename 
                             BranchTraits<typename View::VarType>::Merit bm)
    : use_cnt(1), a(heap.alloc<double>(x.size())), n(x.size()), d(d0) {
    if (bm != NULL)
      for (int i=n; i--; ) {
        typename View::VarType xi(x[i].varimp());
        a[i] = bm(home,xi,i);
      }
    else
      for (int i=n; i--; )
        a[i] = 0.0;
  }
  forceinline
  Activity::Storage::~Storage(void) {
    heap.free<double>(a,n);
  }


  /*
   * Activity
   *
   */

  forceinline void
  Activity::update(int i) {
    assert(storage != NULL);
    assert((i >= 0) && (i < storage->n));
    storage->a[i] += 1.0;
  }
  forceinline void
  Activity::decay(int i) {
    assert(storage != NULL);
    assert((i >= 0) && (i < storage->n));
    storage->a[i] *= storage->d;
  }
  forceinline double
  Activity::operator [](int i) const {
    assert(storage != NULL);
    assert((i >= 0) && (i < storage->n));
    return storage->a[i];
  }
  forceinline int
  Activity::size(void) const {
    return storage->n;
  }
  forceinline void
  Activity::acquire(void) {
    storage->m.acquire();
  }
  forceinline void
  Activity::release(void) {
    storage->m.release();
  }


  forceinline
  Activity::Activity(void) : storage(NULL) {}

  forceinline bool
  Activity::initialized(void) const {
    return storage != NULL;
  }

  template<class View>
  forceinline
  Activity::Activity(Home home, ViewArray<View>& x, double d,
                     typename BranchTraits<typename View::VarType>::Merit bm) {
    assert(storage == NULL);
    storage = new Storage(home,x,d,bm);
    (void) Recorder<View>::post(home,x,*this);
  }
  template<class View>
  forceinline void
  Activity::init(Home home, ViewArray<View>& x, double d,
                 typename BranchTraits<typename View::VarType>::Merit bm) {
    assert(storage == NULL);
    storage = new Storage(home,x,d,bm);
    (void) Recorder<View>::post(home,x,*this);
  }

  template<class Char, class Traits>
  std::basic_ostream<Char,Traits>&
  operator <<(std::basic_ostream<Char,Traits>& os,
              const Activity& a) {
    std::basic_ostringstream<Char,Traits> s;
    s.copyfmt(os); s.width(0);
    s << '{';
    if (a.size() > 0) {
      s << a[0];
      for (int i=1; i<a.size(); i++)
        s << ", " << a[i];
    }
    s << '}';
    return os << s.str();
  }
  

  /*
   * Propagation for activity recorder
   *
   */
  template<class View>
  forceinline
  Activity::Recorder<View>::Recorder(Space& home, bool share,
                                     Recorder<View>& p) 
    : NaryPropagator<View,PC_GEN_NONE>(home,share,p) {
    a.update(home, share, p.a);
    c.update(home, share, p.c);
  }

  template<class View>
  Propagator*
  Activity::Recorder<View>::copy(Space& home, bool share) {
    return new (home) Recorder<View>(home, share, *this);
  }

  template<class View>
  inline size_t
  Activity::Recorder<View>::dispose(Space& home) {
    // Delete access to activity information
    home.ignore(*this,AP_DISPOSE);
    a.~Activity();
    // Cancel remaining advisors
    for (Advisors<Idx> as(c); as(); ++as)
      x[as.advisor().idx()].cancel(home,as.advisor());
    c.dispose(home);
    (void) NaryPropagator<View,PC_GEN_NONE>::dispose(home);
    return sizeof(*this);
  }

  template<class View>
  PropCost 
  Activity::Recorder<View>::cost(const Space&, const ModEventDelta&) const {
    return PropCost::crazy(PropCost::HI,1000);
  }

  template<class View>
  ExecStatus
  Activity::Recorder<View>::advise(Space&, Advisor& a, const Delta&) {
    static_cast<Idx&>(a).mark();
    return ES_NOFIX;
  }

  template<class View>
  ExecStatus
  Activity::Recorder<View>::propagate(Space& home, const ModEventDelta&) {
    // Lock activity information
    a.acquire();
    for (Advisors<Idx> as(c); as(); ++as) {
      int i = as.advisor().idx();
      if (as.advisor().marked()) {
        as.advisor().unmark();
        a.update(i);
        if (x[i].assigned())
          as.advisor().dispose(home,c);
      } else {
        assert(!x[i].assigned());
        a.decay(i);
      }
    }
    a.release();
    return c.empty() ? home.ES_SUBSUMED(*this) : ES_FIX;
  }
  
}

// STATISTICS: kernel-branch