xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Issue #346: Convert GFE to use identity-based ListenerLists, increase

Browse source 
synchronization in Parm/VCParm to prevent leaking of VCParms through
ListenerLists.

Former-commit-id: f6f0ca24df [formerly f6f0ca24df [formerly 5fc74409511903afa97949bc3cd1b3acf91c35e0]]
Former-commit-id: 0c0f659896
Former-commit-id: b3df043f97
This commit is contained in:
David Gillingham 2012-03-02 13:22:46 -06:00
parent 376edad3c9
commit 788007ff63
8 changed files with 85 additions and 42 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/core/internal/AbstractParmManager.java
View file

@ -89,6 +89,7 @@ import com.raytheon.viz.gfe.core.parm.vcparm.VCModule;
* dispose method.
* 02/23/2012 #346 dgilling Ensure all Parms are disposed when calling
* dispose method.
* 03/01/2012 #346 dgilling Use identity-based ListenerLists.
*
* </pre>
*
@ -246,12 +247,14 @@ public abstract class AbstractParmManager implements IParmManager {
protected AbstractParmManager(final DataManager dataManager) {
this.dataManager = dataManager;
this.parms = new RWLArrayList<Parm>();
this.displayedParmListListeners = new ListenerList();
this.parmListChangedListeners = new ListenerList();
this.systemTimeRangeChangedListeners = new ListenerList();
this.availableSourcesListeners = new ListenerList();
this.newModelListeners = new ListenerList();
this.parmIdChangedListeners = new ListenerList();
this.displayedParmListListeners = new ListenerList(
ListenerList.IDENTITY);
this.parmListChangedListeners = new ListenerList(ListenerList.IDENTITY);
this.systemTimeRangeChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.availableSourcesListeners = new ListenerList(ListenerList.IDENTITY);
this.newModelListeners = new ListenerList(ListenerList.IDENTITY);
this.parmIdChangedListeners = new ListenerList(ListenerList.IDENTITY);
// Get virtual parm definitions
vcModules = initVirtualCalcParmDefinitions();

6
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/core/internal/NotificationRouter.java
View file

@ -46,7 +46,8 @@ import com.raytheon.viz.gfe.Activator;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Jun 11, 2008 chammack Initial creation
* Sep 3, 2008 1448 chammack Implement refactored interface
* Sep 03, 2008 1448 chammack Implement refactored interface
* Mar 01, 2012 #346 dgilling Use identity-based ListenerLists.
* </pre>
*
* @author chammack
@ -68,7 +69,7 @@ public class NotificationRouter implements INotificationObserver {
*/
public NotificationRouter(String siteID) {
this.siteID = siteID;
this.observers = new ListenerList();
this.observers = new ListenerList(ListenerList.IDENTITY);
this.observers
.add(new AbstractGFENotificationObserver<UserMessageNotification>(
UserMessageNotification.class) {
@ -178,6 +179,7 @@ public class NotificationRouter implements INotificationObserver {
/**
* Notification that a message has arrived
*/
@Override
@SuppressWarnings("unchecked")
public void notificationArrived(NotificationMessage[] messages) {
// If DataManager is not initialized yet, do not start listening

3
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/core/parm/DbParm.java
View file

@ -71,6 +71,7 @@ import com.raytheon.viz.gfe.core.griddata.IGridData;
* 01/29/08 #1271 njensen Rewrote populateGridFromData()
* to use IFPClient
* 02/23/12 #346 dgilling Implement a dispose method.
* 03/01/12 #346 dgilling Re-order dispose method.
*
* </pre>
*
@ -122,8 +123,8 @@ public class DbParm extends Parm {
*/
@Override
public void dispose() {
super.dispose();
looseLocks();
super.dispose();
}
// -- private

11
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/core/parm/Parm.java
View file

@ -173,6 +173,9 @@ import com.vividsolutions.jts.geom.Coordinate;
* 06/08/2009 #2159 rjpeter Fixed undo.
* 02/23/2012 #346 dgilling Implement a dispose method to mimic
* AWIPS1 use of C++ destructor.
* 03/02/2012 #346 dgilling Create a disposed flag to help ensure
* no interaction with Parms after dispose
* is called.
* </pre>
*
* @author chammack
@ -215,6 +218,8 @@ public abstract class Parm implements Comparable<Parm> {
protected String officeType;
protected boolean disposed;
/**
* The create from scratch mode
*/
@ -348,9 +353,15 @@ public abstract class Parm implements Comparable<Parm> {
if (this.officeType == null) {
this.officeType = dataManager.getOfficeType();
}
this.disposed = false;
}
public void dispose() {
synchronized (this) {
this.disposed = true;
}
if (isModified()) {
statusHandler.warn("Destroying parm " + getParmID().toString()
+ " with modified data.");

28
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/core/parm/ParmListeners.java
View file

@ -56,6 +56,7 @@ import com.raytheon.viz.gfe.core.wxvalue.WxValue;
* Sep 01, 2009 #2788 randerso Changed listener lists to sets to prevent
* multiple registration
* Feb 23, 2012 #346 dgilling Implement clearParmListeners.
* Mar 01, 2012 #346 dgilling Use identity-based ListenerLists.
*
* </pre>
*
@ -88,16 +89,23 @@ public class ParmListeners {
private final JobPool notificationPool;
protected ParmListeners(JobPool pool) {
this.gridChangedListeners = new ListenerList();
this.parmInventoryChangedListeners = new ListenerList();
this.parmIDChangedListeners = new ListenerList();
this.selectionTimeRangeChangedListeners = new ListenerList();
this.parameterSelectionChangedListeners = new ListenerList();
this.combineModeChangedListeners = new ListenerList();
this.vectorModeChangedListeners = new ListenerList();
this.pickupValueChangedListeners = new ListenerList();
this.colorTableModifiedListeners = new ListenerList();
this.lockTableChangedListeners = new ListenerList();
this.gridChangedListeners = new ListenerList(ListenerList.IDENTITY);
this.parmInventoryChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.parmIDChangedListeners = new ListenerList(ListenerList.IDENTITY);
this.selectionTimeRangeChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.parameterSelectionChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.combineModeChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.vectorModeChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.pickupValueChangedListeners = new ListenerList(
ListenerList.IDENTITY);
this.colorTableModifiedListeners = new ListenerList(
ListenerList.IDENTITY);
this.lockTableChangedListeners = new ListenerList(ListenerList.IDENTITY);
this.notificationPool = pool;
}

42
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/core/parm/VCParm.java
View file

@ -64,6 +64,9 @@ import com.raytheon.viz.gfe.core.parm.vcparm.VCModule.VCInventory;
* data. Also, remove overridden
* finalize function.
* Feb 23, 2012 #346 dgilling Implement a dispose method.
* Mar 02, 2012 #346 dgilling Use Parm's new disposed flag to
* prevent leaks through
* ListenerLists.
*
* </pre>
*
@ -138,6 +141,12 @@ public class VCParm extends VParm implements IParmListChangedListener,
*/
@Override
public void gridDataChanged(final ParmID parmId, final TimeRange validTime) {
synchronized (this) {
if (disposed) {
return;
}
}
// statusHandler.handle(Priority.DEBUG, "gridDataChanged for: " + parmId
// + " " + validTime);
@ -167,7 +176,6 @@ public class VCParm extends VParm implements IParmListChangedListener,
}
}
}
}
/*
@ -182,13 +190,22 @@ public class VCParm extends VParm implements IParmListChangedListener,
@Override
public void parmListChanged(final Parm[] parms, Parm[] deletions,
Parm[] additions) {
// forcing access to the disposed variable and subsequent
// registration/unregistation of listeners through this synchronized
// block seems to prevent VCParm objects being leaked through outdated
// listener list copies
synchronized (this) {
if (disposed) {
return;
}
// statusHandler.handle(Priority.DEBUG,
// "ParmListChangedMsg received: ");
System.out.println("ParmListChangedMsg received: "
+ getParmID().toString());
// System.out.println("ParmListChangedMsg received: "
// + getParmID().toString());
registerParmClients(parms, true);
}
}
/*
@ -208,8 +225,13 @@ public class VCParm extends VParm implements IParmListChangedListener,
// approach.
// statusHandler.debug("ParmInventoryChanged notification for: "
// + getParmID().toString());
System.out.println("ParmInventoryChanged notification for: "
+ getParmID().toString());
// System.out.println("ParmInventoryChanged notification for: "
// + getParmID().toString());
synchronized (this) {
if (disposed) {
return;
}
}
recalcInventory(true);
}
@ -467,9 +489,6 @@ public class VCParm extends VParm implements IParmListChangedListener,
}
private void registerPC(Parm parm) {
System.out.println(getParmID().toString() + " is registering "
+ parm.toString());
parm.parmListeners.addGridChangedListener(this);
parm.parmListeners.addParmInventoryChangedListener(this);
@ -482,9 +501,6 @@ public class VCParm extends VParm implements IParmListChangedListener,
}
private void unregisterPC(Parm parm) {
System.out.println(getParmID().toString() + " is unregistering "
+ parm.toString());
parm.parmListeners.removeGridChangedListener(this);
parm.parmListeners.removeParmInventoryChangedListener(this);

3
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/smarttool/script/SmartToolUIController.java
View file

@ -42,6 +42,7 @@ import com.raytheon.viz.gfe.core.msgs.ISmartToolInventoryChanged;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Jan 19, 2010 njensen Initial creation
* Mar 01, 2012 #346 dgilling Use identity-based ListenerLists.
*
* </pre>
*
@ -58,7 +59,7 @@ public class SmartToolUIController extends SmartToolController {
throws JepException {
super(filePath, anIncludePath, classLoader, dataManager);
invChangedListeners = new ListenerList();
invChangedListeners = new ListenerList(ListenerList.IDENTITY);
}
/**

5
cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/tasks/TaskScheduler.java
View file

@ -46,7 +46,8 @@ import com.raytheon.viz.gfe.tasks.AbstractGfeTask.TaskStatus;
*
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Apr 7, 2011 randerso Initial creation
* Apr 07, 2011 randerso Initial creation
* Mar 03, 2012 #346 dgilling Use identity-based ListenerLists.
*
* </pre>
*
@ -70,7 +71,7 @@ public class TaskScheduler extends Job {
protected TaskScheduler() {
super("Task Manager Job");
listeners = new ListenerList();
listeners = new ListenerList(ListenerList.IDENTITY);
PythonPreferenceStore prefs = Activator.getDefault()
.getPreferenceStore();