/*
* (C) 2001 by Argonne National Laboratory
* See COPYRIGHT in top-level directory.
*/
/*
* @author Anthony Chan
*/
package logformat.clogTOdrawable;
import java.util.List;
import java.util.LinkedList;
import java.util.Iterator;
import logformat.clog.RecHeader;
import logformat.clog.RecRaw;
import base.drawable.Coord;
import base.drawable.Topology;
import base.drawable.Category;
import base.drawable.Primitive;
public class Topo_Arrow extends Topology
implements TwoEventsMatching
{
private static Class[] argtypes = null;
private List sends = null;
private List recvs = null;
private Category type = null;
public Topo_Arrow()
{
super( Topology.ARROW_ID );
if ( argtypes == null )
argtypes = new Class[] { RecHeader.class, RecRaw.class };
sends = new LinkedList();
recvs = new LinkedList();
}
/*
public Topo_Arrow( String in_name )
{
super( in_name );
if ( argtypes == null )
argtypes = new Class[] { RecHeader.class, RecRaw.class };
sends = new LinkedList();
recvs = new LinkedList();
}
*/
public void setCategory( final Category in_type )
{
type = in_type;
}
public Category getCategory()
{
return type;
}
public Primitive matchStartEvent( final RecHeader header,
final RecRaw raw )
{
Obj_Arrow arrow;
// Check the recvs event list to see if there is any matching event
// for the incoming send event
Iterator itr = recvs.iterator();
while ( itr.hasNext() ) {
arrow = ( Obj_Arrow ) itr.next();
if ( arrow.getMsgTag() == raw.getMsgTag()
&& arrow.getStartVertex().lineID == header.taskID
&& arrow.getFinalVertex().lineID == raw.data
) {
itr.remove(); // remove the partial arrow from recvs list
arrow.setStartVertex( new Coord( header.timestamp,
header.taskID ) );
arrow.setInfoBuffer();
return arrow;
}
}
// Set the StartVertex with header's timestamp and taskID.
// Initialize the FinalVertex with header.timestamp Temporarily
arrow = new Obj_Arrow( this.getCategory() );
arrow.setStartVertex( new Coord( header.timestamp,
header.taskID ) );
arrow.setFinalVertex( new Coord( header.timestamp, raw.data ) );
arrow.setMsgTag( raw.getMsgTag() );
// Arrow's msg size is determined by the send event NOT recv event
arrow.setMsgSize( raw.getMsgSize() );
sends.add( arrow );
return null;
}
public Primitive matchFinalEvent( final RecHeader header,
final RecRaw raw )
{
Obj_Arrow arrow;
// Check the sends event list to see if there is any matching event
// for the incoming recv event
Iterator itr = sends.iterator();
while ( itr.hasNext() ) {
arrow = ( Obj_Arrow ) itr.next();
if ( arrow.getMsgTag() == raw.getMsgTag()
&& arrow.getStartVertex().lineID == raw.data
&& arrow.getFinalVertex().lineID == header.taskID
) {
itr.remove(); // remove the partial arrow from sends list
arrow.setFinalVertex( new Coord( header.timestamp,
header.taskID ) );
arrow.setInfoBuffer();
return arrow;
}
}
// Set the FinalVertex with header's timestamp and taskID.
// Initialize the StartVertex with header.timestamp Temporarily
arrow = new Obj_Arrow( this.getCategory() );
arrow.setStartVertex( new Coord( header.timestamp, raw.data ) );
arrow.setFinalVertex( new Coord( header.timestamp,
header.taskID ) );
arrow.setMsgTag( raw.getMsgTag() );
recvs.add( arrow );
return null;
}
public ObjMethod getStartEventObjMethod()
{
ObjMethod obj_fn = new ObjMethod();
obj_fn.obj = this;
try {
obj_fn.method = this.getClass().getMethod( "matchStartEvent",
argtypes );
} catch ( NoSuchMethodException err ) {
err.printStackTrace();
return null;
}
return obj_fn;
}
public ObjMethod getFinalEventObjMethod()
{
ObjMethod obj_fn = new ObjMethod();
obj_fn.obj = this;
try {
obj_fn.method = this.getClass().getMethod( "matchFinalEvent",
argtypes );
} catch ( NoSuchMethodException err ) {
err.printStackTrace();
return null;
}
return obj_fn;
}
public List getPartialObjects()
{
List partialarrows = new LinkedList();
partialarrows.addAll( sends );
partialarrows.addAll( recvs );
return partialarrows;
}
}