130 class PredicatedMutexedWriteOp : public MutexedWriteOp<Operation> {

   130 class PredicatedMutexedWriteOp : public MutexedWriteOp<Operation> {

   131  private:

   131  private:

   132   Predicate& _predicate;

   132   Predicate& _predicate;

   133  public:

   133  public:

   134   PredicatedMutexedWriteOp(Operation& operation, Predicate& predicate) :

   134   PredicatedMutexedWriteOp(Operation& operation, Predicate& predicate) :

   136   bool process(typename Operation::Type* t) {

   136   bool process(typename Operation::Type* t) {

   137     return _predicate.process(t) ? MutexedWriteOp<Operation>::process(t) : true;

   137     return _predicate.process(t) ? MutexedWriteOp<Operation>::process(t) : true;

   138   }

   138   }

   139 };

   139 };

   140 

   140 

   154 class PredicatedConcurrentWriteOp : public ConcurrentWriteOp<Operation> {

   154 class PredicatedConcurrentWriteOp : public ConcurrentWriteOp<Operation> {

   155  private:

   155  private:

   156   Predicate& _predicate;

   156   Predicate& _predicate;

   157  public:

   157  public:

   158   PredicatedConcurrentWriteOp(Operation& operation, Predicate& predicate) :

   158   PredicatedConcurrentWriteOp(Operation& operation, Predicate& predicate) :

   160   bool process(typename Operation::Type* t) {

   160   bool process(typename Operation::Type* t) {

   161     return _predicate.process(t) ? ConcurrentWriteOp<Operation>::process(t) : true;

   161     return _predicate.process(t) ? ConcurrentWriteOp<Operation>::process(t) : true;

   162   }

   162   }

   163 };

   163 };

   164 

   164