Permalink
Browse files

Using both gemfire region flows as !cflowbelow arguments

  • Loading branch information...
1 parent e539393 commit 6c263ff2e0772197396ff51a1027cc4ea8df432d lgoldstein committed Dec 23, 2012
View
35 ...re/src/main/java/com/springsource/insight/plugin/gemfire/GemFireRegionCollectionAspect.aj
@@ -22,23 +22,32 @@ import com.gemstone.gemfire.cache.Region;
import com.springsource.insight.intercept.operation.Operation;
public aspect GemFireRegionCollectionAspect extends AbstractGemFireCollectionAspect {
-
- public pointcut readWriteFlow () : execution(* Region.get(..)) || execution(* Region.getAll(..)) || execution(* Region.getEntry(..)) || execution(* Region.selectValue(..)) || execution(* Region.values())
- || execution(* Region.put(..)) || execution(* Region.putAll(..)) || execution(* Region.putIfAbsent(..)) || execution(* Region.query(..))
- || execution(* Region.remove(..)) || execution(* Region.replace(..));
-
- public pointcut otherFlow () : execution(* Region.clear()) || execution(* Region.containsKey*(..)) || execution(* Region.containsValue*(..))
- || execution(* Region.create*(..)) || execution(* Region.destroy*(..))
- || execution(* Region.entr*(..)) || execution(* Region.existsValue(..)) || execution(* Region.isEmpty())
- || execution(* Region.invalidate*(..)) || execution(* Region.key*(..))
- || execution(* Region.loadSnapshot*(..)) || execution(* Region.local*(..)) || execution(* Region.saveSnapshot*(..));
-
- public pointcut collectionPoint () : (readWriteFlow() || otherFlow()) && !cflowbelow(readWriteFlow());
-
public GemFireRegionCollectionAspect() {
super(GemFireDefenitions.TYPE_REGION);
}
+ public pointcut readWriteFlow ()
+ : execution(* Region.get(..)) || execution(* Region.getAll(..)) || execution(* Region.getEntry(..))
+ || execution(* Region.selectValue(..)) || execution(* Region.values())
+ || execution(* Region.put(..)) || execution(* Region.putAll(..)) || execution(* Region.putIfAbsent(..))
+ || execution(* Region.query(..))
+ || execution(* Region.remove(..))
+ || execution(* Region.replace(..))
+ ;
+
+ public pointcut otherFlow ()
+ : execution(* Region.clear())
+ || execution(* Region.containsKey*(..)) || execution(* Region.containsValue*(..))
+ || execution(* Region.create*(..)) || execution(* Region.destroy*(..))
+ || execution(* Region.entr*(..)) || execution(* Region.existsValue(..)) || execution(* Region.isEmpty())
+ || execution(* Region.invalidate*(..)) || execution(* Region.key*(..))
+ || execution(* Region.loadSnapshot*(..)) || execution(* Region.local*(..)) || execution(* Region.saveSnapshot*(..))
+ ;
+
+ public pointcut regionFlow() : readWriteFlow() || otherFlow();
+
+ public pointcut collectionPoint () : regionFlow() && !cflowbelow(regionFlow());
+
@Override
protected Operation createOperation(final JoinPoint jp) {
Operation op = createBasicOperation(jp);

0 comments on commit 6c263ff

Please sign in to comment.