[jboss-cvs] JBossCache/src/org/jboss/cache/notifications ...

[Manik Surtani]

  User: msurtani
  Date: 06/08/30 16:01:58

  Modified:    src/org/jboss/cache/notifications  Notifier.java
  Log:
  Fixed concurrency issues with notifications
  
  Revision  Changes    Path
  1.5       +11 -11    JBossCache/src/org/jboss/cache/notifications/Notifier.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: Notifier.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/notifications/Notifier.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -b -r1.4 -r1.5
  --- Notifier.java	29 Aug 2006 16:35:52 -0000	1.4
  +++ Notifier.java	30 Aug 2006 20:01:58 -0000	1.5
  @@ -109,7 +109,7 @@
       * @param fqn
       * @param pre
       */
  -   public void notifyNodeCreated(Fqn fqn, boolean pre)
  +   public synchronized void notifyNodeCreated(Fqn fqn, boolean pre)
      {
   
         boolean originLocal = cache.getInvocationContext().isOriginLocal();
  @@ -135,7 +135,7 @@
       * @param pre
       * @param data
       */
  -   public void notifyNodeModified(Fqn fqn, boolean pre, Map data)
  +   public synchronized void notifyNodeModified(Fqn fqn, boolean pre, Map data)
      {
         boolean originLocal = cache.getInvocationContext().isOriginLocal();
         resetInvocationContext();
  @@ -160,7 +160,7 @@
       * @param pre
       * @param data
       */
  -   public void notifyNodeRemoved(Fqn fqn, boolean pre, Map data)
  +   public synchronized void notifyNodeRemoved(Fqn fqn, boolean pre, Map data)
      {
         boolean originLocal = cache.getInvocationContext().isOriginLocal();
         resetInvocationContext();
  @@ -184,7 +184,7 @@
       * @param fqn
       * @param pre
       */
  -   public void notifyNodeVisited(Fqn fqn, boolean pre)
  +   public synchronized void notifyNodeVisited(Fqn fqn, boolean pre)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)
  @@ -207,7 +207,7 @@
       * @param fqn
       * @param pre
       */
  -   public void notifyNodeEvicted(Fqn fqn, boolean pre)
  +   public synchronized void notifyNodeEvicted(Fqn fqn, boolean pre)
      {
         boolean originLocal = cache.getInvocationContext().isOriginLocal();
         resetInvocationContext();
  @@ -232,7 +232,7 @@
       * @param pre
       * @param data
       */
  -   public void notifyNodeLoaded(Fqn fqn, boolean pre, Map data)
  +   public synchronized void notifyNodeLoaded(Fqn fqn, boolean pre, Map data)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)
  @@ -255,7 +255,7 @@
       * @param fqn
       * @param pre
       */
  -   public void notifyNodeActivated(Fqn fqn, boolean pre)
  +   public synchronized void notifyNodeActivated(Fqn fqn, boolean pre)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)
  @@ -278,7 +278,7 @@
       * @param fqn
       * @param pre
       */
  -   public void notifyNodePassivated(Fqn fqn, boolean pre)
  +   public synchronized void notifyNodePassivated(Fqn fqn, boolean pre)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)
  @@ -300,7 +300,7 @@
       *
       * @param cache
       */
  -   public void notifyCacheStarted(CacheSPI cache)
  +   public synchronized void notifyCacheStarted(CacheSPI cache)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)
  @@ -322,7 +322,7 @@
       *
       * @param cache
       */
  -   public void notifyCacheStopped(CacheSPI cache)
  +   public synchronized void notifyCacheStopped(CacheSPI cache)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)
  @@ -362,7 +362,7 @@
       *
       * @param new_view
       */
  -   public void notifyViewChange(View new_view)
  +   public synchronized void notifyViewChange(View new_view)
      {
         resetInvocationContext();
         if (evictionPolicyListener != null)