Changeset 12932 for trunk/Jav_BDP_FS/com/scenari/m/bdp/item/fs/XItemCache.java

Timestamp:

03/02/09 16:02:44 (3 years ago)

Author:

sys

Message:

Amélioration gestion events d'update d'items multi-flux + réduction des appels aux refresh pour checker les modifs externes.

File:

• trunk/Jav_BDP_FS/com/scenari/m/bdp/item/fs/XItemCache.java (modified) (8 diffs)

trunk/Jav_BDP_FS/com/scenari/m/bdp/item/fs/XItemCache.java

@@ -79 +79 @@
 public class XItemCache {
 
+        public static long sElapseBetweenRefresh = 1500;
+
         /**
          * AttrLink.
@@ -648 +650 @@
         public void hRefresh() throws Exception {
                 XItemCacheData vDatas = getDatas();
+                if (vDatas.fLastRefresh > 0 && vDatas.fLastRefresh >= System.currentTimeMillis() - sElapseBetweenRefresh) {
+                        //Dernier refresh très récent, pas d'écriture entre temps, on passe.
+                        //System.out.print('.');
+                        return;
+                }
                 ISrcNode vSrc = vDatas.getWspSrcNodeItem().getSubSrcNode();
                 if (fStatusItem == IHItem.STATUS_UNKNOWN) {
-                        xLoadItemFromSource(fStatusItem != IHItem.STATUS_UNKNOWN, vSrc, vSrc.getLastModifWithChildren());
+                        xLoadItemFromSource(false, vSrc, vSrc.getLastModifWithChildren(), IContextBdp.CLIENTID_NONE);
                 } else {
                         SrcFeatureRefresh.refresh(vSrc);
                         long vLastUpdt = vSrc.getLastModifWithChildren();
                         if (vLastUpdt != fMemLastModif) {
-                                xLoadItemFromSource(fStatusItem != IHItem.STATUS_UNKNOWN, vSrc, vLastUpdt);
-                        }
-                }
+                                xLoadItemFromSource(true, vSrc, vLastUpdt, IContextBdp.CLIENTID_NONE);
+                        }
+                }
+                vDatas.fLastRefresh = System.currentTimeMillis();
+        }
+
+        /**
+         * Rafraichit cet item si la source a été modifiée (cas des itesm multi-flux).
+         */
+        public void reloadAfterUpdate(int pClientId) throws Exception {
+                XItemCacheData vDatas = getDatas();
+                ISrcNode vSrc = vDatas.getWspSrcNodeItem().getSubSrcNode();
+                SrcFeatureRefresh.refresh(vSrc);
+                long vLastUpdt = vSrc.getLastModifWithChildren();
+                xLoadItemFromSource(true, vSrc, vLastUpdt, pClientId);
+                vDatas.fLastRefresh = System.currentTimeMillis();
         }
 
@@ -823 +843 @@
         public void hCommit() throws Exception {
                 XItemCacheData vItemData = getDatas();
+                vItemData.fLastRefresh = System.currentTimeMillis();
                 fMemLastModif = vItemData.getWspSrcNodeItem().getSubSrcNode().getLastModifWithChildren();
         }
@@ -916 +937 @@
                 if (vSrc == null) return;
                 long vLastModif = vSrc.getLastModifWithChildren();
-                xLoadItemFromSource(pFireEventUpdated, vSrc, vLastModif);
+                xLoadItemFromSource(pFireEventUpdated, vSrc, vLastModif, IContextBdp.CLIENTID_NONE);
+                vDatas.fLastRefresh = System.currentTimeMillis();
         }
 
@@ -926 +948 @@
          *            (et pas une découverte ou un chargement initial).
          */
-        protected void xLoadItemFromSource(boolean pFireEventUpdated, ISrcNode pSrc, long pLastModif) throws Exception {
+        protected void xLoadItemFromSource(boolean pFireEventUpdated, ISrcNode pSrc, long pLastModif, int pClientId) throws Exception {
                 boolean vFireEventUpdated = pFireEventUpdated || fWsp.fFireDiscoveredItems;
                 int vStatus = pSrc.getContentStatus();
@@ -932 +954 @@
                 if (vStatus <= ISrcNode.STATUS_NONE) {
                         //L'item est supprimé
-                        hRemove(vFireEventUpdated, IContextBdp.CLIENTID_NONE);
+                        hRemove(vFireEventUpdated, pClientId);
                         if (vStatus == ISrcNode.STATUS_CONFLICT) {
                                 fStatusItem = IHItemDef.STATUS_CONFLICT;
@@ -948 +970 @@
                                         IHModuleSave vModuleSave = vItemType.hGetModuleSave();
                                         IHItem vNewItem = vModuleSave.hFillItem(vCurrent, null, vStream, null);
-                                        hSaveInCache(vNewItem, vFireEventUpdated, IContextBdp.CLIENTID_NONE);
+                                        hSaveInCache(vNewItem, vFireEventUpdated, pClientId);
                                 } else {
                                         fStatusItem = IHItem.STATUS_ERRORS;
-                                        if (vFireEventUpdated) fWsp.xFireEventItemRemoved(this, null, IContextBdp.CLIENTID_NONE);
+                                        if (vFireEventUpdated) fWsp.xFireEventItemRemoved(this, null, pClientId);
                                         xValidPointers(vFireEventUpdated);
                                 }
@@ -957 +979 @@
                                 HLogMgr.hPublishException(e, "Echec au traitement d'un item : " + hGetSpace() + "/" + hGetCode(), IHLogMessage.TYPE_WARNING);
                                 fStatusItem = IHItem.STATUS_ERRORS;
-                                if (vFireEventUpdated) fWsp.xFireEventItemRemoved(this, null, IContextBdp.CLIENTID_NONE);
+                                if (vFireEventUpdated) fWsp.xFireEventItemRemoved(this, null, pClientId);
                                 xValidPointers(vFireEventUpdated);
                         } finally {