mirrors/cdt
1
0
Fork 0
mirror of https://github.com/eclipse-cdt/cdt synced 2025-04-29 19:45:01 +02:00
Code Issues Wiki Activity

159683 update mode

Browse source
This commit is contained in:
Ted Williams 2007-07-03 23:43:26 +00:00
parent 85c4ae5f24
commit 0c7d4ed117
1 changed files with 126 additions and 164 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

268
plugins/org.eclipse.dd.dsf.ui/src/org/eclipse/dd/dsf/ui/viewmodel/update/VMCache.java
View file

@ -12,38 +12,32 @@
package org.eclipse.dd.dsf.ui.viewmodel.update; package org.eclipse.dd.dsf.ui.viewmodel.update;
import java.util.HashMap; import java.util.HashMap;
import java.util.List;
import java.util.Vector; import java.util.Vector;
import java.util.concurrent.Executor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.dd.dsf.concurrent.DataRequestMonitor; import org.eclipse.dd.dsf.concurrent.DataRequestMonitor;
import org.eclipse.dd.dsf.concurrent.DefaultDsfExecutor;
import org.eclipse.dd.dsf.concurrent.DsfExecutor; import org.eclipse.dd.dsf.concurrent.DsfExecutor;
import org.eclipse.dd.dsf.concurrent.MultiRequestMonitor;
import org.eclipse.dd.dsf.datamodel.IDMContext; import org.eclipse.dd.dsf.datamodel.IDMContext;
import org.eclipse.dd.dsf.datamodel.IDMData; import org.eclipse.dd.dsf.datamodel.IDMData;
import org.eclipse.dd.dsf.datamodel.IDMEvent; import org.eclipse.dd.dsf.datamodel.IDMEvent;
import org.eclipse.dd.dsf.datamodel.IDMService; import org.eclipse.dd.dsf.datamodel.IDMService;
import org.eclipse.dd.dsf.ui.viewmodel.VMElementsCountUpdate;
import org.eclipse.dd.dsf.ui.viewmodel.VMElementsUpdate;
import org.eclipse.dd.dsf.ui.viewmodel.VMHasElementsUpdate;
import org.eclipse.debug.internal.ui.viewers.model.provisional.IChildrenCountUpdate; import org.eclipse.debug.internal.ui.viewers.model.provisional.IChildrenCountUpdate;
import org.eclipse.debug.internal.ui.viewers.model.provisional.IChildrenUpdate; import org.eclipse.debug.internal.ui.viewers.model.provisional.IChildrenUpdate;
import org.eclipse.debug.internal.ui.viewers.model.provisional.IHasChildrenUpdate; import org.eclipse.debug.internal.ui.viewers.model.provisional.IHasChildrenUpdate;
import org.eclipse.debug.internal.ui.viewers.model.provisional.IPresentationContext;
import org.eclipse.jface.viewers.TreePath;
public abstract class VMCache public abstract class VMCache
{ {
protected Executor fExecutor = new DefaultDsfExecutor();
protected HashMap<Object, Integer> fChildrenCounts = new HashMap<Object, Integer>(); protected HashMap<Object, Integer> fChildrenCounts = new HashMap<Object, Integer>();
class ChildData protected HashMap<Object, HashMap<Integer,Object>> fChildren = new HashMap<Object, HashMap<Integer,Object>>();
{
Object child;
int offset;
public ChildData(Object child, int offset)
{
this.child = child;
this.offset = offset;
}
}
protected HashMap<Object, ChildData[]> fChildren = new HashMap<Object, ChildData[]>();
protected HashMap<Object, Boolean> fHasChildren = new HashMap<Object, Boolean>(); protected HashMap<Object, Boolean> fHasChildren = new HashMap<Object, Boolean>();
@ -66,6 +60,7 @@ public abstract class VMCache
return true; return true;
} }
@SuppressWarnings("restriction")
public IHasChildrenUpdate[] update(IHasChildrenUpdate[] updates) { public IHasChildrenUpdate[] update(IHasChildrenUpdate[] updates) {
Vector<IHasChildrenUpdate> missVector = new Vector<IHasChildrenUpdate>(); Vector<IHasChildrenUpdate> missVector = new Vector<IHasChildrenUpdate>();
for(IHasChildrenUpdate update : updates) for(IHasChildrenUpdate update : updates)
@ -85,54 +80,22 @@ public abstract class VMCache
for(int i = 0; i < updates.length; i++) for(int i = 0; i < updates.length; i++)
{ {
final IHasChildrenUpdate update = missVector.elementAt(i); final IHasChildrenUpdate update = missVector.elementAt(i);
updates[i] = new IHasChildrenUpdate() updates[i] = new VMHasElementsUpdate(update, new DataRequestMonitor<Boolean>(fExecutor, null)
{ {
private boolean fIsHasChildren; @Override
protected void handleCompleted()
public void setHasChilren(boolean hasChildren) { {
fIsHasChildren = hasChildren; fHasChildren.put(update.getElement(), this.getData());
update.setHasChilren(hasChildren); update.setHasChilren(getData());
}
public void cancel() {
update.cancel();
}
public void done() {
fHasChildren.put(getElement(), Boolean.valueOf(fIsHasChildren));
update.done(); update.done();
} }
});
public IStatus getStatus() {
return update.getStatus();
}
public boolean isCanceled() {
return update.isCanceled();
}
public void setStatus(IStatus status) {
update.setStatus(status);
}
public Object getElement() {
return update.getElement();
}
public TreePath getElementPath() {
return update.getElementPath();
}
public IPresentationContext getPresentationContext() {
return update.getPresentationContext();
}
};
} }
return updates; return updates;
} }
@SuppressWarnings("restriction")
public IChildrenCountUpdate[] update(IChildrenCountUpdate[] updates) public IChildrenCountUpdate[] update(IChildrenCountUpdate[] updates)
{ {
Vector<IChildrenCountUpdate> missVector = new Vector<IChildrenCountUpdate>(); Vector<IChildrenCountUpdate> missVector = new Vector<IChildrenCountUpdate>();
@ -153,127 +116,126 @@ public abstract class VMCache
for(int i = 0; i < updates.length; i++) for(int i = 0; i < updates.length; i++)
{ {
final IChildrenCountUpdate update = missVector.elementAt(i); final IChildrenCountUpdate update = missVector.elementAt(i);
updates[i] = new IChildrenCountUpdate() updates[i] = new VMElementsCountUpdate(update, new DataRequestMonitor<Integer>(fExecutor, null)
{ {
private int fChildCount; @Override
protected void handleCompleted()
public void cancel() { {
update.cancel(); fChildrenCounts.put(update.getElement(), this.getData());
} update.setChildCount(this.getData());
public void done() {
fChildrenCounts.put(getElement(), fChildCount);
update.done(); update.done();
} }
});
public IStatus getStatus() {
return update.getStatus();
}
public boolean isCanceled() {
return update.isCanceled();
}
public void setStatus(IStatus status) {
update.setStatus(status);
}
public void setChildCount(int numChildren) {
fChildCount = numChildren;
update.setChildCount(numChildren);
}
public Object getElement() {
return update.getElement();
}
public TreePath getElementPath() {
return update.getElementPath();
}
public IPresentationContext getPresentationContext() {
return update.getPresentationContext();
}
};
} }
return updates; return updates;
} }
@SuppressWarnings("restriction")
public IChildrenUpdate[] update(IChildrenUpdate[] updates) { public IChildrenUpdate[] update(IChildrenUpdate[] updates) {
Vector<IChildrenUpdate> missVector = new Vector<IChildrenUpdate>(); Vector<IChildrenUpdate> updatesEntirelyMissingFromCache = new Vector<IChildrenUpdate>();
for(IChildrenUpdate update : updates) for(final IChildrenUpdate update : updates)
{ {
if(fChildren.containsKey(update.getElement()) && useCache()) if(fChildren.containsKey(update.getElement()) && useCache())
{ {
ChildData childData[] = fChildren.get(update.getElement()); Vector<Integer> childrenMissingFromCache = new Vector<Integer>();
for(ChildData data : childData) for(int i = update.getOffset(); i < update.getOffset() + update.getLength(); i++)
update.setChild(data.child, data.offset); childrenMissingFromCache.addElement(i);
childrenMissingFromCache.removeAll(fChildren.get(update.getElement()).keySet());
if(childrenMissingFromCache.size() > 0)
{
// perform a partial update; we only have some of the children of the update request
final HashMap<DataRequestMonitor<List<Object>>,IChildrenUpdate> associationsRequestMonitorToChildUpdate
= new HashMap<DataRequestMonitor<List<Object>>,IChildrenUpdate>();
final MultiRequestMonitor<DataRequestMonitor<List<Object>>> childrenMultiRequestMon =
new MultiRequestMonitor<DataRequestMonitor<List<Object>>>(fExecutor, null) {
@Override
protected void handleCompleted() {
// Status is OK, only if all request monitors are OK.
if (getStatus().isOK())
{
for (DataRequestMonitor<List<Object>> monitor : getRequestMonitors())
{
int offset = associationsRequestMonitorToChildUpdate.get(monitor).getOffset();
for(Object child : monitor.getData())
update.setChild(child, offset++);
}
} else {
update.setStatus(getStatus());
}
update.done(); update.done();
} }
};
while(childrenMissingFromCache.size() > 0)
{
int offset = childrenMissingFromCache.elementAt(0);
childrenMissingFromCache.removeElementAt(0);
int length = 1;
while(childrenMissingFromCache.size() > 0 && childrenMissingFromCache.elementAt(0) == offset + length)
{
length++;
childrenMissingFromCache.removeElementAt(0);
}
DataRequestMonitor<List<Object>> partialUpdateMonitor = new DataRequestMonitor<List<Object>>(fExecutor, null)
{
@Override
protected void handleCompleted()
{
childrenMultiRequestMon.requestMonitorDone(this);
}
};
final IChildrenUpdate partialUpdate = new VMElementsUpdate(update, update.getOffset(), update.getLength(),
childrenMultiRequestMon.add(partialUpdateMonitor));
associationsRequestMonitorToChildUpdate.put(partialUpdateMonitor, partialUpdate);
updatesEntirelyMissingFromCache.add(partialUpdate);
}
}
else else
{ {
missVector.addElement(update); // we have all of the children in cache; return from cache
} for(int position = update.getOffset(); position < update.getOffset() + update.getLength(); position++)
} update.setChild(fChildren.get(update.getElement()).get(position), position);
updates = new IChildrenUpdate[missVector.size()];
for(int i = 0; i < updates.length; i++)
{
final IChildrenUpdate update = missVector.elementAt(i);
updates[i] = new IChildrenUpdate()
{
Vector<ChildData> fChilds = new Vector<ChildData>();
public int getLength() {
return update.getLength();
}
public int getOffset() {
return update.getOffset();
}
public void setChild(Object child, int offset) {
fChilds.addElement(new ChildData(child, offset));
update.setChild(child, offset);
}
public void cancel() {
update.cancel();
}
public void done() {
// FIXME synchronize with events?
fChildren.put(getElement(), fChilds.toArray(new ChildData[fChilds.size()]));
update.done(); update.done();
} }
}
public IStatus getStatus() { else
return update.getStatus(); {
updatesEntirelyMissingFromCache.addElement(update);
}
} }
public boolean isCanceled() { updates = new IChildrenUpdate[updatesEntirelyMissingFromCache.size()];
return update.isCanceled(); for(int i = 0; i < updates.length; i++)
} {
final IChildrenUpdate update = updatesEntirelyMissingFromCache.elementAt(i);
updates[i] = new VMElementsUpdate(update, update.getOffset(), update.getLength(),
new DataRequestMonitor<List<Object>>(fExecutor, null)
{
@Override
protected void handleCompleted()
{
for(int j = 0; j < update.getLength(); j++)
{
if(!fChildren.containsKey(update.getElement()))
fChildren.put(update.getElement(), new HashMap<Integer,Object>());
public void setStatus(IStatus status) { fChildren.get(update.getElement()).put(update.getOffset() + j, getData().get(j));
update.setStatus(status);
}
public Object getElement() { update.setChild(getData().get(j), update.getOffset() + j);
return update.getElement();
} }
update.done();
public TreePath getElementPath() {
return update.getElementPath();
} }
});
public IPresentationContext getPresentationContext() {
return update.getPresentationContext();
}
};
} }
return updates; return updates;