diff --git a/executablecode/src/request.h b/executablecode/src/request.h
index 00b93c8e5a007e2eecf6bde40417cdfb9457edc2..61369a80309dcb8e1871bcf65165ce953e817f03 100644
--- a/executablecode/src/request.h
+++ b/executablecode/src/request.h
@@ -43,6 +43,8 @@ struct request {
struct request* relatedRequest; // For synchro and broadcast
struct syncchannel *syncChannel;
struct asyncchannel *asyncChannel;
+
+ struct request *linkedTo;
int type;
int ID;
diff --git a/executablecode/src/request_manager.c b/executablecode/src/request_manager.c
index 51f6d494b97315f846f588bfde0ec89f4ea37c0c..1b22d997147f459350374f2b8bedd75b8661b577 100644
--- a/executablecode/src/request_manager.c
+++ b/executablecode/src/request_manager.c
@@ -43,15 +43,7 @@ void executeSendSyncTransaction(request *req) {
//req->syncChannel->inWaitQueue = removeRequestFromList(req->syncChannel->inWaitQueue, selectedReq);
debugMsg("Setting related request");
req->relatedRequest = selectedReq;
- selectedReq->relatedRequest = req;
-
- if (req->relatedRequest == NULL) {
- debugMsg("NULL related req");
- }
-
- if (selectedReq->relatedRequest == NULL) {
- debugMsg("Other NULL related req");
- }
+ req->linkedTo = selectedReq;
// Select the selected request, and notify the information
selectedReq->selected = 1;
@@ -92,15 +84,7 @@ void executeReceiveSyncTransaction(request *req) {
//req->syncChannel->outWaitQueue = removeRequestFromList(req->syncChannel->outWaitQueue, selectedReq);
debugMsg("Setting related request");
req->relatedRequest = selectedReq;
- selectedReq->relatedRequest = req;
-
- if (req->relatedRequest == NULL) {
- debugMsg("NULL related req");
- }
-
- if (selectedReq->relatedRequest == NULL) {
- debugMsg("Other NULL related req");
- }
+ selectedReq->linkedTo = req;
// Select the request, and notify the information in the channel
selectedReq->selected = 1;
@@ -423,7 +407,7 @@ void private__makeRequest(request *req) {
// In all cases: remove other requests of the same list from their pending form
debugMsg("Removing original req");
removeAllPendingRequestsFromPendingLists(req, 1);
- //removeAllPendingRequestsFromPendingListsRelatedRequests(req);
+ removeAllPendingRequestsFromPendingListsRelatedRequests(req);
/*if (req->relatedRequest != NULL) {
debugMsg("Removing related req");
removeAllPendingRequestsFromPendingLists(req->relatedRequest, 0);
@@ -436,7 +420,7 @@ void removeAllPendingRequestsFromPendingListsRelatedRequests(request *req) {
debugMsg("Removing related req");
removeAllPendingRequestsFromPendingLists(req->relatedRequest, 0);
// Recursive call
- //removeAllPendingRequestsFromPendingListsRelatedRequests(req->relatedRequest);
+ removeAllPendingRequestsFromPendingListsRelatedRequests(req->relatedRequest);
}
}
diff --git a/executablecode/src/tracemanager.c b/executablecode/src/tracemanager.c
index d19967ef7a1cd7e7b7432b3c463476de98ceac90..b8d38628187bd203254452a56654c938d3613846 100644
--- a/executablecode/src/tracemanager.c
+++ b/executablecode/src/tracemanager.c
@@ -161,10 +161,10 @@ void traceRequest(char *myname, request *req) {
switch(req->type) {
case SEND_SYNC_REQUEST:
debug2Msg("Sync channel", req->syncChannel->outname);
- if ( req->relatedRequest == NULL) {
+ if ( req->linkedTo == NULL) {
printf("NULL related\n");
}
- sprintf(s, "block=%s type=send_synchro channel=%s blockdestination=%s\n", myname, req->syncChannel->outname, req->relatedRequest->listOfRequests->owner);
+ sprintf(s, "block=%s type=send_synchro channel=%s blockdestination=%s\n", myname, req->syncChannel->outname, req->linkedTo->listOfRequests->owner);
break;
case RECEIVE_SYNC_REQUEST:
sprintf(s, "block=%s type=receive_synchro channel=%s\n", myname, req->syncChannel->inname);
diff --git a/src/ui/interactivesimulation/GenericTransaction.java b/src/ui/interactivesimulation/GenericTransaction.java
index 7f71fb428bb9cc1f6246ea9ccd09a3ee12745443..17dca056266d8cb94642e80f77f73423cc52a4fc 100755
--- a/src/ui/interactivesimulation/GenericTransaction.java
+++ b/src/ui/interactivesimulation/GenericTransaction.java
@@ -58,11 +58,13 @@ public class GenericTransaction {
public final static int FUNCTION_CALL = 1;
public final static int STATE_ENTERING = 2;
public final static int VAR_MODIFICATION = 3;
+ public final static int SEND_SYNCHRO = 4;
public int ID;
public int type;
public String entityName;
- public String name;
+ public String otherEntityName; /* name of destination in synchro, etc. */
+ public String name; /* Used for channel names */
public String action;
public long startingTime;
public long finishTime;
diff --git a/src/ui/interactivesimulation/JSimulationSDPanel.java b/src/ui/interactivesimulation/JSimulationSDPanel.java
index 03e06a9ce6e9af0c35b29b81a1c7e6e4ae5d7334..4c797e152580632c787fa94ba0cef8b79359c0d5 100644
--- a/src/ui/interactivesimulation/JSimulationSDPanel.java
+++ b/src/ui/interactivesimulation/JSimulationSDPanel.java
@@ -69,10 +69,10 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
private static long stamp = 0;
// Drawing area
- private int minLimit = 10;
- private int maxX = MAX_X;
- private int maxY = MAX_Y;
- private final int limit = 10;
+ private int minLimit = 10;
+ private int maxX = MAX_X;
+ private int maxY = MAX_Y;
+ private final int limit = 10;
// Drawing parameters
private int minSpaceBetweenLifeLines = 5;
@@ -89,8 +89,8 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
private int spaceBroadcast = 25;
// Transactions
- protected String fileReference;
-
+ protected String fileReference;
+
private int maxNbOfTransactions = 1000;
private int drawnTransactions = 1000;
@@ -102,40 +102,40 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
private int xMouse, yMouse;
private boolean drawInfo = false;
private long clockValueMouse;
- private long clockDiviser = 1000000; //ms
+ private long clockDiviser = 1000000; //ms
private Vector<Point> points;
private Vector<GenericTransaction> transactionsOfPoints;
- // List of entities ... List is discovered progressively
- // Or the list is described in the trace (header information)
- Vector <String> entityNames;
-
- private final int NO_MODE = 0;
- private final int FILE_MODE = 1;
- private int mode;
- private boolean go;
- private Thread t;
-
- Vector<GenericTransaction> transactions;
-
-
- public JSimulationSDPanel() {
+ // List of entities ... List is discovered progressively
+ // Or the list is described in the trace (header information)
+ Vector <String> entityNames;
+
+ private final int NO_MODE = 0;
+ private final int FILE_MODE = 1;
+ private int mode;
+ private boolean go;
+ private Thread t;
+
+ Vector<GenericTransaction> transactions;
+
+
+ public JSimulationSDPanel() {
//points = new Vector<Point>();
//transactionsOfPoints = new Vector<AvatarSimulationTransaction>();
- entityNames = new Vector <String>();
- transactions = new Vector<GenericTransaction>();
- transactionsOfPoints = new Vector<GenericTransaction>();
- points = new Vector<Point>();
-
- mode = NO_MODE;
-
+ entityNames = new Vector <String>();
+ transactions = new Vector<GenericTransaction>();
+ transactionsOfPoints = new Vector<GenericTransaction>();
+ points = new Vector<Point>();
+
+ mode = NO_MODE;
+
setBackground(Color.WHITE);
setNewSize();
addMouseMotionListener(this);
-
-
- }
+
+
+ }
public void setMyScrollPanel(JScrollPane _jsp) {
jsp = _jsp;
@@ -174,7 +174,7 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
if (drawInfo) {
drawInfo(g);
}
- }
+ }
protected void scrollToLowerPosition() {
if (jsp != null) {
@@ -212,8 +212,8 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
}
}
-
- public void setNewSize() {
+
+ public void setNewSize() {
setPreferredSize(new Dimension(maxX + limit, maxY + limit));
mustScroll = true;
revalidate();
@@ -225,442 +225,481 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
int index;
int xOfBlock;
int newCurrentY = currentY;
- GenericTransaction gt;
-
-
- if (transactions.size() == 0) {
- return currentY;
- }
+ GenericTransaction gt;
+
+
+ if (transactions.size() == 0) {
+ return currentY;
+ }
// Draw only the last "drawnTransactions"
if (transactions.size() > 0) {
- gt = transactions.get(Math.max(0, transactions.size()-1000));
- clockValue = gt.startingTime;
- clockValueMouse = clockValue;
- g.drawString("@" + clockValue/clockDiviser, 10, currentY+g.getFontMetrics().getHeight()/2);
+ gt = transactions.get(Math.max(0, transactions.size()-1000));
+ clockValue = gt.startingTime;
+ clockValueMouse = clockValue;
+ g.drawString("@" + clockValue/clockDiviser, 10, currentY+g.getFontMetrics().getHeight()/2);
}
for(int i=Math.max(transactions.size()-drawnTransactions, 0); i<transactions.size(); i++) {
- gt = transactions.get(i);
- gt.stamp = stamp;
-
- index = getIndexOfEntityName(gt.entityName);
- xOfBlock = currentX + (index * spaceBetweenLifeLines) + spaceBetweenLifeLines/2;
-
- points.clear();
- transactionsOfPoints.clear();
-
- if (gt.type == gt.STATE_ENTERING) {
- newCurrentY = drawState(g, gt, xOfBlock, currentY);
- } else if (gt.type == gt.FUNCTION_CALL) {
- newCurrentY = drawFunctionCall(g, gt, xOfBlock, currentY);
- }
-
- if ((yMouse>= currentY) && (yMouse <= newCurrentY)) {
- for(int cpt = 0; cpt<points.size(); cpt++) {
- drawIDInfo(g, points.get(cpt).x, points.get(cpt).y, transactionsOfPoints.get(cpt).ID);
- }
- }
-
-
- // Draw the line of other blocks
- if (currentY != newCurrentY) {
- xOfBlock = currentX + spaceBetweenLifeLines/2;
- for(String s: entityNames) {
- if (s.compareTo(gt.entityName) != 0) {
- g.drawLine(xOfBlock, currentY, xOfBlock, newCurrentY);
- }
- xOfBlock += spaceBetweenLifeLines;
- }
- if (gt.finishTime != clockValue) {
- clockValue = gt.finishTime;
- if (yMouse >= newCurrentY) {
- clockValueMouse = clockValue;
- }
- g.drawString("@" + clockValue/clockDiviser, 10, newCurrentY+g.getFontMetrics().getHeight()/2);
- }
- }
-
- // Update currentY;
- currentY = newCurrentY;
-
+ gt = transactions.get(i);
+ gt.stamp = stamp;
+
+ index = getIndexOfEntityName(gt.entityName);
+ xOfBlock = currentX + (index * spaceBetweenLifeLines) + spaceBetweenLifeLines/2;
+
+ points.clear();
+ transactionsOfPoints.clear();
+
+ if (gt.type == gt.STATE_ENTERING) {
+ newCurrentY = drawState(g, gt, xOfBlock, currentY);
+ } else if (gt.type == gt.FUNCTION_CALL) {
+ newCurrentY = drawFunctionCall(g, gt, xOfBlock, currentY);
+ } else if (gt.type == gt.SEND_SYNCHRO) {
+ newCurrentY = drawSendSynchro(g, gt, xOfBlock, currentY);
+ }
+
+ if ((yMouse>= currentY) && (yMouse <= newCurrentY)) {
+ for(int cpt = 0; cpt<points.size(); cpt++) {
+ drawIDInfo(g, points.get(cpt).x, points.get(cpt).y, transactionsOfPoints.get(cpt).ID);
+ }
+ }
+
+
+ // Draw the line of other blocks
+ if (currentY != newCurrentY) {
+ xOfBlock = currentX + spaceBetweenLifeLines/2;
+ for(String s: entityNames) {
+ if (s.compareTo(gt.entityName) != 0) {
+ g.drawLine(xOfBlock, currentY, xOfBlock, newCurrentY);
+ }
+ xOfBlock += spaceBetweenLifeLines;
+ }
+ if (gt.finishTime != clockValue) {
+ clockValue = gt.finishTime;
+ if (yMouse >= newCurrentY) {
+ clockValueMouse = clockValue;
+ }
+ g.drawString("@" + clockValue/clockDiviser, 10, newCurrentY+g.getFontMetrics().getHeight()/2);
+ }
+ }
+
+ // Update currentY;
+ currentY = newCurrentY;
+
}
maxY = currentY;
return currentY;
}
private int drawState(Graphics g, GenericTransaction _gt, int currentX, int currentY) {
- int w;
- int x, y, width, height;
-
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- currentY += verticalLink;
-
- w = g.getFontMetrics().stringWidth(_gt.action);
- Color c = g.getColor();
- Color avat = ColorManager.AVATAR_STATE;
- g.setColor(avat);
-
- x = currentX - w/2 - spaceHorizontalText;
- y = currentY;
- width = w + 2*spaceHorizontalText;
- height = g.getFontMetrics().getHeight() + spaceVerticalText * 2;
-
- g.fillRoundRect(x, y, width, height, 5, 5);
- points.add(new Point(x+width, y));
- transactionsOfPoints.add(_gt);
- g.setColor(c);
- g.drawRoundRect(x, y, width, height, 5, 5);
-
- g.drawString(_gt.action, x + spaceHorizontalText, y+height-2*spaceVerticalText);
-
- currentY += height;
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- return currentY + verticalLink;
- }
-
- private int drawFunctionCall(Graphics g, GenericTransaction _gt, int currentX, int currentY) {
- int w;
- int x, y, width, height;
-
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- currentY += verticalLink;
-
- w = g.getFontMetrics().stringWidth(_gt.action);
- Color c = g.getColor();
-
- x = currentX - w/2 - spaceHorizontalText;
- y = currentY;
- width = w + 2*spaceHorizontalText;
- height = g.getFontMetrics().getHeight() + spaceVerticalText * 2;
-
-
- g.setColor(Color.WHITE);
- g.fillRoundRect(x, y, width, height, 5, 5);
- g.setColor(c);
- g.drawRoundRect(x, y, width, height, 5, 5);
- points.add(new Point(x+width, y));
- transactionsOfPoints.add(_gt);
- g.setColor(c);
- g.drawString(_gt.action, x + spaceHorizontalText, y+height-2*spaceVerticalText);
-
- currentY += height;
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- return currentY + verticalLink;
+ int w;
+ int x, y, width, height;
+
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ currentY += verticalLink;
+
+ w = g.getFontMetrics().stringWidth(_gt.action);
+ Color c = g.getColor();
+ Color avat = ColorManager.AVATAR_STATE;
+ g.setColor(avat);
+
+ x = currentX - w/2 - spaceHorizontalText;
+ y = currentY;
+ width = w + 2*spaceHorizontalText;
+ height = g.getFontMetrics().getHeight() + spaceVerticalText * 2;
+
+ g.fillRoundRect(x, y, width, height, 5, 5);
+ points.add(new Point(x+width, y));
+ transactionsOfPoints.add(_gt);
+ g.setColor(c);
+ g.drawRoundRect(x, y, width, height, 5, 5);
+
+ g.drawString(_gt.action, x + spaceHorizontalText, y+height-2*spaceVerticalText);
+
+ currentY += height;
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ return currentY + verticalLink;
+ }
+
+ private int drawFunctionCall(Graphics g, GenericTransaction _gt, int currentX, int currentY) {
+ int w;
+ int x, y, width, height;
+
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ currentY += verticalLink;
+
+ w = g.getFontMetrics().stringWidth(_gt.action);
+ Color c = g.getColor();
+
+ x = currentX - w/2 - spaceHorizontalText;
+ y = currentY;
+ width = w + 2*spaceHorizontalText;
+ height = g.getFontMetrics().getHeight() + spaceVerticalText * 2;
+
+
+ g.setColor(Color.WHITE);
+ g.fillRoundRect(x, y, width, height, 5, 5);
+ g.setColor(c);
+ g.drawRoundRect(x, y, width, height, 5, 5);
+ points.add(new Point(x+width, y));
+ transactionsOfPoints.add(_gt);
+ g.setColor(c);
+ g.drawString(_gt.action, x + spaceHorizontalText, y+height-2*spaceVerticalText);
+
+ currentY += height;
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ return currentY + verticalLink;
+ }
+
+ private int drawSendSynchro(Graphics g, GenericTransaction _gt, int currentX, int currentY) {
+ int w;
+ int x, y, width, height;
+ String messageName;
+
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ currentY += verticalLink;
+
+ messageName = _gt.name + "(" + ")";
+
+ Color c = g.getColor();
+
+ x = currentX;
+ y = currentY;
+
+ int index = getIndexOfEntityName(_gt.otherEntityName);
+ int xOf2ndBlock = spaceAtEnd + (index * spaceBetweenLifeLines) + spaceBetweenLifeLines/2;
+
+ g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
+ g.drawLine(xOf2ndBlock, currentY-1, currentX, currentY-1);
+ g.setColor(c);
+ GraphicLib.arrowWithLine(g, 1, 0, 10, currentX, currentY, xOf2ndBlock, currentY, true);
+ transactionsOfPoints.add(_gt);
+ points.add(new Point(currentX, currentY));
+
+ // Putting the message name
+ w = g.getFontMetrics().stringWidth(messageName);
+ int xtmp = (xOf2ndBlock + currentX)/2 - w/2;
+ g.drawString(messageName, xtmp, currentY-2);
+
+ currentY += 10;
+
+ // Vertical line of receiving block
+ g.drawLine(currentX, currentY-20, currentX, currentY);
+ return currentY;
}
/*private int drawTransition(Graphics g, AvatarTransition at, AvatarSimulationTransaction ast, int currentX, int currentY) {
- int w;
- int x, y, width, height;
- int cpt;
- Color c = g.getColor();
-
- // Duration ?
- if (ast.duration > 0) {
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- currentY += verticalLink;
- g.drawRect(currentX-5, currentY, 10, 30);
- points.add(new Point(currentX+10, currentY));
- transactionsOfPoints.add(ast);
- g.drawString(""+ ast.duration, currentX+6, currentY+17);
- currentY += 30;
- g.setColor(ColorManager.AVATAR_TIME);
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- g.setColor(c);
- currentY += verticalLink;
- }
-
- if (ast.actions == null) {
- return currentY;
- }
-
- if (ast.actions.size() == 0) {
- return currentY;
- }
-
-
- w = 0;
- for(String action: ast.actions) {
- w = Math.max(g.getFontMetrics().stringWidth(action), w);
- }
-
- x = currentX - w/2 - spaceHorizontalText;
- y = currentY;
- width = w + 2*spaceHorizontalText;
- height = (g.getFontMetrics().getHeight() + spaceVerticalText * 2) * ast.actions.size();
-
- g.setColor(Color.WHITE);
- g.fillRoundRect(x, y, width, height, 5, 5);
- g.setColor(c);
- g.drawRoundRect(x, y, width, height, 5, 5);
- points.add(new Point(x+width, y));
- transactionsOfPoints.add(ast);
-
- cpt = 1;
-
- Color avat = ColorManager.AVATAR_ACTION;
- g.setColor(avat);
- int decVert = height / ast.actions.size();
- for(String action: ast.actions) {
- g.drawString(action, x + (width - g.getFontMetrics().stringWidth(action))/2, y+(decVert*cpt) - (spaceVerticalText * 2));
- cpt ++;
- }
- g.setColor(c);
-
- currentY += height;
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
-
- return currentY + verticalLink;
+ int w;
+ int x, y, width, height;
+ int cpt;
+ Color c = g.getColor();
+
+ // Duration ?
+ if (ast.duration > 0) {
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ currentY += verticalLink;
+ g.drawRect(currentX-5, currentY, 10, 30);
+ points.add(new Point(currentX+10, currentY));
+ transactionsOfPoints.add(ast);
+ g.drawString(""+ ast.duration, currentX+6, currentY+17);
+ currentY += 30;
+ g.setColor(ColorManager.AVATAR_TIME);
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ g.setColor(c);
+ currentY += verticalLink;
+ }
+
+ if (ast.actions == null) {
+ return currentY;
+ }
+
+ if (ast.actions.size() == 0) {
+ return currentY;
+ }
+
+
+ w = 0;
+ for(String action: ast.actions) {
+ w = Math.max(g.getFontMetrics().stringWidth(action), w);
+ }
+
+ x = currentX - w/2 - spaceHorizontalText;
+ y = currentY;
+ width = w + 2*spaceHorizontalText;
+ height = (g.getFontMetrics().getHeight() + spaceVerticalText * 2) * ast.actions.size();
+
+ g.setColor(Color.WHITE);
+ g.fillRoundRect(x, y, width, height, 5, 5);
+ g.setColor(c);
+ g.drawRoundRect(x, y, width, height, 5, 5);
+ points.add(new Point(x+width, y));
+ transactionsOfPoints.add(ast);
+
+ cpt = 1;
+
+ Color avat = ColorManager.AVATAR_ACTION;
+ g.setColor(avat);
+ int decVert = height / ast.actions.size();
+ for(String action: ast.actions) {
+ g.drawString(action, x + (width - g.getFontMetrics().stringWidth(action))/2, y+(decVert*cpt) - (spaceVerticalText * 2));
+ cpt ++;
+ }
+ g.setColor(c);
+
+ currentY += height;
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+
+ return currentY + verticalLink;
}
private int drawRandom(Graphics g, AvatarRandom arandom, AvatarSimulationTransaction ast, int currentX, int currentY) {
- int w;
- int x, y, width, height;
- Color c = g.getColor();
-
- if (ast.actions == null) {
- return currentY;
- }
-
- String action = ast.actions.get(0);
-
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- currentY += verticalLink;
-
- w = g.getFontMetrics().stringWidth(action);
- x = currentX - w/2 - spaceHorizontalText;
- y = currentY;
- width = w + 2*spaceHorizontalText;
- height = g.getFontMetrics().getHeight() + spaceVerticalText * 2;
- g.setColor(Color.WHITE);
- g.fillRoundRect(x, y, width, height, 5, 5);
- points.add(new Point(x+width, y));
- transactionsOfPoints.add(ast);
- g.setColor(c);
- g.drawRoundRect(x, y, width, height, 5, 5);
-
- g.drawString(action, x + spaceHorizontalText, y+height-2*spaceVerticalText);
-
- currentY += height;
- g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
- return currentY + verticalLink;
+ int w;
+ int x, y, width, height;
+ Color c = g.getColor();
+
+ if (ast.actions == null) {
+ return currentY;
+ }
+
+ String action = ast.actions.get(0);
+
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ currentY += verticalLink;
+
+ w = g.getFontMetrics().stringWidth(action);
+ x = currentX - w/2 - spaceHorizontalText;
+ y = currentY;
+ width = w + 2*spaceHorizontalText;
+ height = g.getFontMetrics().getHeight() + spaceVerticalText * 2;
+ g.setColor(Color.WHITE);
+ g.fillRoundRect(x, y, width, height, 5, 5);
+ points.add(new Point(x+width, y));
+ transactionsOfPoints.add(ast);
+ g.setColor(c);
+ g.drawRoundRect(x, y, width, height, 5, 5);
+
+ g.drawString(action, x + spaceHorizontalText, y+height-2*spaceVerticalText);
+
+ currentY += height;
+ g.drawLine(currentX, currentY, currentX, currentY+verticalLink);
+ return currentY + verticalLink;
}
private int drawAvatarActionOnSignal(Graphics g, AvatarActionOnSignal aaos, AvatarSimulationTransaction ast, int currentX, int currentY, int startX) {
- int w;
- Color c = g.getColor();
-
- avatartranslator.AvatarSignal sig = aaos.getSignal();
- avatartranslator.AvatarRelation rel = ass.getAvatarSpecification().getAvatarRelationWithSignal(sig);
- if (sig.isIn()) {
- if (!(rel.isAsynchronous())) {
-
- //Synchronous
- if (ast.linkedTransaction != null) {
- // Computing message name
- AvatarActionOnSignal otherAaos = (AvatarActionOnSignal)(ast.linkedTransaction.executedElement);
- String messageName = otherAaos.getSignal().getName();
- if (messageName.compareTo(sig.getName()) != 0) {
- messageName += "_" + sig.getName();
- }
- messageName += "(";
-
- if(ast.actions != null) {
- messageName += ast.actions.get(0);
- }
- messageName += ")";
-
- //TraceManager.addDev("Working on message name:" + messageName);
- // Drawing the arrow
- // Assume a different block in the two transactions
- int index = ass.getSimulationBlocks().indexOf(ast.linkedTransaction.asb);
- int xOf2ndBlock = startX + (index * spaceBetweenLifeLines) + spaceBetweenLifeLines/2;
-
- currentY += 10;
- g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
- g.drawLine(xOf2ndBlock, currentY-1, currentX, currentY-1);
- g.setColor(c);
- GraphicLib.arrowWithLine(g, 1, 0, 10, xOf2ndBlock, currentY, currentX, currentY, true);
- points.add(new Point(xOf2ndBlock, currentY));
- transactionsOfPoints.add(ast.linkedTransaction);
- transactionsOfPoints.add(ast);
- points.add(new Point(currentX, currentY));
-
-
- // Putting the message name
- w = g.getFontMetrics().stringWidth(messageName);
- int xtmp = (xOf2ndBlock + currentX)/2 - w/2;
- g.drawString(messageName, xtmp, currentY-2);
-
-
- currentY += 10;
-
- // Vertical line of receiving block
- g.drawLine(currentX, currentY-20, currentX, currentY);
- return currentY;
- }
- } else {
- // In, asynchronous
- String messageName = sig.getName() + "(";
- if(ast.actions != null) {
- messageName += ast.actions.get(0);
- }
- messageName += ")";
-
- currentY += 10;
- g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
- g.drawLine(currentX-lengthAsync, currentY-1, currentX, currentY-1);
- g.setColor(c);
- GraphicLib.arrowWithLine(g, 1, 1, 10, currentX-lengthAsync, currentY, currentX, currentY, false);
- points.add(new Point(currentX, currentY));
- transactionsOfPoints.add(ast);
-
- // Putting the message name
- w = g.getFontMetrics().stringWidth(messageName);
- g.drawString(messageName, currentX-lengthAsync+w/2, currentY-2);
-
- // Search for sender
- if (ast.linkedTransaction != null) {
- if (ast.linkedTransaction.stamp == ast.stamp) {
- if ((ast.linkedTransaction.x >0) && (ast.linkedTransaction.y >0)) {
- int x = ast.linkedTransaction.x;
- int y = ast.linkedTransaction.y;
-
- if (x + lengthAsync < currentX-lengthAsync) {
- // Forward
- g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
- GraphicLib.dashedLine(g, x + lengthAsync - 1, y, x + lengthAsync-1, currentY);
- GraphicLib.dashedLine(g, x + lengthAsync, currentY-1, currentX-lengthAsync, currentY-1);
- g.setColor(c);
- GraphicLib.dashedLine(g, x + lengthAsync, y, x + lengthAsync, currentY);
- GraphicLib.dashedLine(g, x + lengthAsync, currentY, currentX-lengthAsync, currentY);
- } else {
- // Backward
- g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
- GraphicLib.dashedLine(g, x + lengthAsync-1, y, x + lengthAsync-1, y+7);
- GraphicLib.dashedLine(g, x + lengthAsync, y+6, currentX-lengthAsync, y+6);
- GraphicLib.dashedLine(g, currentX-lengthAsync-1, currentY, currentX-lengthAsync-1, y+7);
- g.setColor(c);
- GraphicLib.dashedLine(g, x + lengthAsync, y, x + lengthAsync, y+7);
- GraphicLib.dashedLine(g, x + lengthAsync, y+7, currentX-lengthAsync, y+7);
- GraphicLib.dashedLine(g, currentX-lengthAsync, currentY, currentX-lengthAsync, y+7);
- }
-
- //g.drawLine(x + lengthAsync, y, currentX-lengthAsync, currentY);
- }
- }
- } else {
- //TraceManager.addDev("No linked transaction");
- }
-
- currentY += 10;
-
- // Vertical line of receiving block
- g.drawLine(currentX, currentY-20, currentX, currentY);
-
-
-
- return currentY;
- }
- } else {
- if (rel.isAsynchronous()) {
- // Out, asynchronous
- String messageName = sig.getName() + "(";
- if(ast.actions != null) {
- messageName += ast.actions.get(0);
- }
- messageName += ")";
-
- currentY += 10;
- g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
- g.drawLine(currentX+lengthAsync, currentY-1, currentX, currentY-1);
- g.setColor(c);
- GraphicLib.arrowWithLine(g, 1, 2, 10, currentX, currentY, currentX+lengthAsync, currentY, false);
- points.add(new Point(currentX, currentY));
- transactionsOfPoints.add(ast);
-
- // Putting the message name
- w = g.getFontMetrics().stringWidth(messageName);
- g.drawString(messageName, currentX+lengthAsync-w/2, currentY-2);
-
- ast.x = currentX;
- ast.y = currentY;
-
- currentY += 10;
-
- // Vertical line of receiving block
- g.drawLine(currentX, currentY-20, currentX, currentY);
- return currentY;
-
- // Solo Broadcast Sending?
- } else if (ast.isSolo) {
- // Draw a lost message
- String messageName = sig.getName() + "(";
- if(ast.actions != null) {
- messageName += ast.actions.get(0);
- }
- messageName += ")";
-
- currentY += 10;
- g.setColor(ColorManager.AVATAR_SEND_SIGNAL);
- g.drawLine(currentX+spaceBetweenLifeLines-spaceBroadcast, currentY-1, currentX, currentY-1);
- g.setColor(c);
- GraphicLib.arrowWithLine(g, 1, 0, 10, currentX, currentY, currentX+spaceBetweenLifeLines-spaceBroadcast, currentY, true);
- points.add(new Point(currentX, currentY));
- transactionsOfPoints.add(ast);
- g.fillOval(currentX+spaceBetweenLifeLines-spaceBroadcast, currentY-5, 10, 10);
-
- // Putting the message name
- w = g.getFontMetrics().stringWidth(messageName);
- g.drawString(messageName, currentX+10, currentY-2);
-
- ast.x = currentX;
- ast.y = currentY;
-
- currentY += 10;
-
- // Vertical line of receiving block
- g.drawLine(currentX, currentY-20, currentX, currentY);
- return currentY;
-
- }
- }
-
- return currentY;
-
+ int w;
+ Color c = g.getColor();
+
+ avatartranslator.AvatarSignal sig = aaos.getSignal();
+ avatartranslator.AvatarRelation rel = ass.getAvatarSpecification().getAvatarRelationWithSignal(sig);
+ if (sig.isIn()) {
+ if (!(rel.isAsynchronous())) {
+
+ //Synchronous
+ if (ast.linkedTransaction != null) {
+ // Computing message name
+ AvatarActionOnSignal otherAaos = (AvatarActionOnSignal)(ast.linkedTransaction.executedElement);
+ String messageName = otherAaos.getSignal().getName();
+ if (messageName.compareTo(sig.getName()) != 0) {
+ messageName += "_" + sig.getName();
+ }
+ messageName += "(";
+
+ if(ast.actions != null) {
+ messageName += ast.actions.get(0);
+ }
+ messageName += ")";
+
+ //TraceManager.addDev("Working on message name:" + messageName);
+ // Drawing the arrow
+ // Assume a different block in the two transactions
+ int index = ass.getSimulationBlocks().indexOf(ast.linkedTransaction.asb);
+ int xOf2ndBlock = startX + (index * spaceBetweenLifeLines) + spaceBetweenLifeLines/2;
+
+ currentY += 10;
+ g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
+ g.drawLine(xOf2ndBlock, currentY-1, currentX, currentY-1);
+ g.setColor(c);
+ GraphicLib.arrowWithLine(g, 1, 0, 10, xOf2ndBlock, currentY, currentX, currentY, true);
+ points.add(new Point(xOf2ndBlock, currentY));
+ transactionsOfPoints.add(ast.linkedTransaction);
+ transactionsOfPoints.add(ast);
+ points.add(new Point(currentX, currentY));
+
+
+ // Putting the message name
+ w = g.getFontMetrics().stringWidth(messageName);
+ int xtmp = (xOf2ndBlock + currentX)/2 - w/2;
+ g.drawString(messageName, xtmp, currentY-2);
+
+
+ currentY += 10;
+
+ // Vertical line of receiving block
+ g.drawLine(currentX, currentY-20, currentX, currentY);
+ return currentY;
+ }
+ } else {
+ // In, asynchronous
+ String messageName = sig.getName() + "(";
+ if(ast.actions != null) {
+ messageName += ast.actions.get(0);
+ }
+ messageName += ")";
+
+ currentY += 10;
+ g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
+ g.drawLine(currentX-lengthAsync, currentY-1, currentX, currentY-1);
+ g.setColor(c);
+ GraphicLib.arrowWithLine(g, 1, 1, 10, currentX-lengthAsync, currentY, currentX, currentY, false);
+ points.add(new Point(currentX, currentY));
+ transactionsOfPoints.add(ast);
+
+ // Putting the message name
+ w = g.getFontMetrics().stringWidth(messageName);
+ g.drawString(messageName, currentX-lengthAsync+w/2, currentY-2);
+
+ // Search for sender
+ if (ast.linkedTransaction != null) {
+ if (ast.linkedTransaction.stamp == ast.stamp) {
+ if ((ast.linkedTransaction.x >0) && (ast.linkedTransaction.y >0)) {
+ int x = ast.linkedTransaction.x;
+ int y = ast.linkedTransaction.y;
+
+ if (x + lengthAsync < currentX-lengthAsync) {
+ // Forward
+ g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
+ GraphicLib.dashedLine(g, x + lengthAsync - 1, y, x + lengthAsync-1, currentY);
+ GraphicLib.dashedLine(g, x + lengthAsync, currentY-1, currentX-lengthAsync, currentY-1);
+ g.setColor(c);
+ GraphicLib.dashedLine(g, x + lengthAsync, y, x + lengthAsync, currentY);
+ GraphicLib.dashedLine(g, x + lengthAsync, currentY, currentX-lengthAsync, currentY);
+ } else {
+ // Backward
+ g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
+ GraphicLib.dashedLine(g, x + lengthAsync-1, y, x + lengthAsync-1, y+7);
+ GraphicLib.dashedLine(g, x + lengthAsync, y+6, currentX-lengthAsync, y+6);
+ GraphicLib.dashedLine(g, currentX-lengthAsync-1, currentY, currentX-lengthAsync-1, y+7);
+ g.setColor(c);
+ GraphicLib.dashedLine(g, x + lengthAsync, y, x + lengthAsync, y+7);
+ GraphicLib.dashedLine(g, x + lengthAsync, y+7, currentX-lengthAsync, y+7);
+ GraphicLib.dashedLine(g, currentX-lengthAsync, currentY, currentX-lengthAsync, y+7);
+ }
+
+ //g.drawLine(x + lengthAsync, y, currentX-lengthAsync, currentY);
+ }
+ }
+ } else {
+ //TraceManager.addDev("No linked transaction");
+ }
+
+ currentY += 10;
+
+ // Vertical line of receiving block
+ g.drawLine(currentX, currentY-20, currentX, currentY);
+
+
+
+ return currentY;
+ }
+ } else {
+ if (rel.isAsynchronous()) {
+ // Out, asynchronous
+ String messageName = sig.getName() + "(";
+ if(ast.actions != null) {
+ messageName += ast.actions.get(0);
+ }
+ messageName += ")";
+
+ currentY += 10;
+ g.setColor(ColorManager.AVATAR_RECEIVE_SIGNAL);
+ g.drawLine(currentX+lengthAsync, currentY-1, currentX, currentY-1);
+ g.setColor(c);
+ GraphicLib.arrowWithLine(g, 1, 2, 10, currentX, currentY, currentX+lengthAsync, currentY, false);
+ points.add(new Point(currentX, currentY));
+ transactionsOfPoints.add(ast);
+
+ // Putting the message name
+ w = g.getFontMetrics().stringWidth(messageName);
+ g.drawString(messageName, currentX+lengthAsync-w/2, currentY-2);
+
+ ast.x = currentX;
+ ast.y = currentY;
+
+ currentY += 10;
+
+ // Vertical line of receiving block
+ g.drawLine(currentX, currentY-20, currentX, currentY);
+ return currentY;
+
+ // Solo Broadcast Sending?
+ } else if (ast.isSolo) {
+ // Draw a lost message
+ String messageName = sig.getName() + "(";
+ if(ast.actions != null) {
+ messageName += ast.actions.get(0);
+ }
+ messageName += ")";
+
+ currentY += 10;
+ g.setColor(ColorManager.AVATAR_SEND_SIGNAL);
+ g.drawLine(currentX+spaceBetweenLifeLines-spaceBroadcast, currentY-1, currentX, currentY-1);
+ g.setColor(c);
+ GraphicLib.arrowWithLine(g, 1, 0, 10, currentX, currentY, currentX+spaceBetweenLifeLines-spaceBroadcast, currentY, true);
+ points.add(new Point(currentX, currentY));
+ transactionsOfPoints.add(ast);
+ g.fillOval(currentX+spaceBetweenLifeLines-spaceBroadcast, currentY-5, 10, 10);
+
+ // Putting the message name
+ w = g.getFontMetrics().stringWidth(messageName);
+ g.drawString(messageName, currentX+10, currentY-2);
+
+ ast.x = currentX;
+ ast.y = currentY;
+
+ currentY += 10;
+
+ // Vertical line of receiving block
+ g.drawLine(currentX, currentY-20, currentX, currentY);
+ return currentY;
+
+ }
+ }
+
+ return currentY;
+
}
private int drawAvatarStartState(Graphics g, int currentX, int currentY, int startX) {
- currentX -= 7;
- g.fillOval(currentX, currentY, 15, 15);
- g.drawLine(currentX, currentY, currentX, currentY+20);
-
- currentY += 20;
- return currentY;
+ currentX -= 7;
+ g.fillOval(currentX, currentY, 15, 15);
+ g.drawLine(currentX, currentY, currentX, currentY+20);
+
+ currentY += 20;
+ return currentY;
}
private int drawAvatarStopState(Graphics g, AvatarSimulationTransaction _ast, int currentX, int currentY, int startX) {
- g.drawLine(currentX, currentY, currentX, currentY+spaceStop+3);
- currentX -= (spaceStop/2);
- g.drawLine(currentX, currentY, currentX+spaceStop, currentY+spaceStop);
- g.drawLine(currentX, currentY+spaceStop, currentX+spaceStop, currentY);
- points.add(new Point(currentX+spaceStop, currentY));
- transactionsOfPoints.add(_ast);
-
- currentY += spaceStop + 3;
- return currentY;
+ g.drawLine(currentX, currentY, currentX, currentY+spaceStop+3);
+ currentX -= (spaceStop/2);
+ g.drawLine(currentX, currentY, currentX+spaceStop, currentY+spaceStop);
+ g.drawLine(currentX, currentY+spaceStop, currentX+spaceStop, currentY);
+ points.add(new Point(currentX+spaceStop, currentY));
+ transactionsOfPoints.add(_ast);
+
+ currentY += spaceStop + 3;
+ return currentY;
}
public void setNewSize() {
- setPreferredSize(new Dimension(maxX + limit, maxY + limit));
- mustScroll = true;
- revalidate();
+ setPreferredSize(new Dimension(maxX + limit, maxY + limit));
+ mustScroll = true;
+ revalidate();
}*/
public void mouseDragged(MouseEvent e) {
}
-
+
public void mouseMoved(MouseEvent e) {
xMouse = e.getX();
yMouse = e.getY();
@@ -683,9 +722,9 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
GraphicLib.dashedLine(g, spaceAtEnd, yMouse, maxX-spaceAtEnd, yMouse);
g.drawString("@" + clockValueMouse/clockDiviser, 10, yMouse+g.getFontMetrics().getHeight()/2);
/*if (minIdValueMouse == maxIdValueMouse) {
- g.drawString("ID: " + minIdValueMouse, 10, yMouse+(g.getFontMetrics().getHeight()/2)+12);
+ g.drawString("ID: " + minIdValueMouse, 10, yMouse+(g.getFontMetrics().getHeight()/2)+12);
} else {
- g.drawString("ID: " + minIdValueMouse + " to " + maxIdValueMouse, 10, yMouse+(g.getFontMetrics().getHeight()/2)+12);
+ g.drawString("ID: " + minIdValueMouse + " to " + maxIdValueMouse, 10, yMouse+(g.getFontMetrics().getHeight()/2)+12);
}*/
int w;
@@ -710,23 +749,23 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
public BufferedImage performCapture() {
int w = this.getWidth();
- int h = this.getHeight();
- BufferedImage image = new BufferedImage(w, h, BufferedImage.TYPE_INT_RGB);
- Graphics2D g = image.createGraphics();
+ int h = this.getHeight();
+ BufferedImage image = new BufferedImage(w, h, BufferedImage.TYPE_INT_RGB);
+ Graphics2D g = image.createGraphics();
g.setColor(Color.black);
- paintComponent(g);
- g.dispose();
- return image;
+ paintComponent(g);
+ g.dispose();
+ return image;
}
-
+
public void setFileReference(String _fileReference) {
- fileReference = _fileReference;
-
- mode = FILE_MODE;
-
- Thread t = new Thread(this);
- t.start();
- }
+ fileReference = _fileReference;
+
+ mode = FILE_MODE;
+
+ Thread t = new Thread(this);
+ t.start();
+ }
public void refresh() {
if (mode == FILE_MODE) {
@@ -738,193 +777,209 @@ public class JSimulationSDPanel extends JPanel implements MouseMotionListener, R
t.start();
}
}
-
- public void run() {
- TraceManager.addDev("Reading file");
-
- go = true;
- Thread t;
-
- if (mode == NO_MODE) {
- go = false;
- t = null;
- return;
- }
-
- if (mode == FILE_MODE) {
- // Open the file
- // Read the content of the file
- // Read line by line
- // Upate the graphic regularly
- try{
- // Open the file that is the first
- // command line parameter
- FileInputStream fstream = new FileInputStream(fileReference);
- // Get the object of DataInputStream
- DataInputStream in = new DataInputStream(fstream);
- BufferedReader br = new BufferedReader(new InputStreamReader(in));
- String strLine;
- //Read File Line By Line
- while ((strLine = br.readLine()) != null) {
- // Print the content on the console
- TraceManager.addDev("Computing transaction:" + strLine);
- addGenericTransaction(strLine);
- }
- //Close the input stream
- in.close();
- } catch (Exception e){//Catch exception if any
- TraceManager.addDev("Reading file Error: " + e.getMessage());
- }
- }
- }
-
- public void addGenericTransaction(String trans) {
- int index0, index1;
- String tmp, tmp1, tmp2;
- long value;
- int value1, value2;
-
- if (!(trans.startsWith("#"))) {
- return;
- }
-
-
- GenericTransaction gt = new GenericTransaction();
-
- // Adding the ID
- index0 = trans.indexOf(" ");
- if (index0 == -1) {
- return;
- }
- tmp = trans.substring(1, index0);
- try {
- gt.ID = Integer.decode(tmp).intValue();
- } catch (Exception e) {
- }
-
-
- //TraceManager.addDev("1");
-
- // Time
- tmp = extract(trans, "time");
- if (tmp == null) {
- return;
- }
-
- //TraceManager.addDev("2 tmp=" + tmp);
-
- try {
- index0 = tmp.indexOf('.');
- if (index0 == -1) {
- return;
- }
- tmp1 = tmp.substring(0, index0);
- tmp2 = tmp.substring(index0+1, tmp.length());
- //TraceManager.addDev("2 tmp1=" + tmp1 + " tmp2=" + tmp2);
- value1 = Integer.decode(tmp1).intValue();
- value2 = Integer.decode(tmp2).intValue();
- value = ((long)value1)*1000000000+value2;
- gt.startingTime = value;
- gt.finishTime = value;
- } catch (Exception e) {
- return;
- }
-
- //TraceManager.addDev("3");
-
- // Name of the block
- tmp = extract(trans, "block");
- if (tmp == null) {
- return;
- }
-
- addEntityNameIfApplicable(tmp);
- gt.entityName = tmp;
-
- // Type of the transaction
- tmp = extract(trans, "type");
- if (tmp == null) {
- return;
- }
-
- if (tmp.compareTo("state_entering") == 0) {
- gt.type = GenericTransaction.STATE_ENTERING;
- }
-
- if (tmp.compareTo("function_call") == 0) {
- gt.type = GenericTransaction.FUNCTION_CALL;
- }
-
- // State of the transaction?
- tmp = extract(trans, "state");
-
- if (tmp != null) {
- gt.action = tmp;
- }
-
- // Function of the transaction?
- tmp = extract(trans, "func");
-
- if (tmp != null) {
- gt.action = tmp;
- }
-
- // Parameters of the function
- tmp = extract(trans, "parameters");
- gt.action = gt.action + "(";
- if( tmp != null) {
- if (!(tmp.startsWith("-"))) {
- gt.action = gt.action + tmp;
- }
- } else {
- }
- gt.action = gt.action + ")";
-
- transactions.add(gt);
- TraceManager.addDev("One transactions added");
-
- }
-
- public String extract(String main, String selector) {
- String sel = selector+"=";
- int index = main.indexOf(sel);
- if (index == -1) {
- return null;
- }
-
- String ret = main.substring(index+sel.length(), main.length());
- index = ret.indexOf(' ');
-
- if (index != -1) {
- ret = ret.substring(0, index);
- }
-
- return ret;
- }
-
- public void addEntityNameIfApplicable(String _entityName) {
- for(String name: entityNames) {
- if (name.compareTo(_entityName) ==0) {
- return;
- }
- }
-
- entityNames.add(_entityName);
- }
-
- public int getIndexOfEntityName(String _entityName) {
- int cpt = 0;
- for(String name: entityNames) {
- if (name.compareTo(_entityName) ==0) {
- return cpt;
- }
- cpt ++;
- }
-
- return -1;
- }
-
- public void setClockDiviser(long _clockDiviser) {
- clockDiviser = _clockDiviser;
- }
+
+ public void run() {
+ TraceManager.addDev("Reading file");
+
+ go = true;
+ Thread t;
+
+ if (mode == NO_MODE) {
+ go = false;
+ t = null;
+ return;
+ }
+
+ if (mode == FILE_MODE) {
+ // Open the file
+ // Read the content of the file
+ // Read line by line
+ // Upate the graphic regularly
+ try{
+ // Open the file that is the first
+ // command line parameter
+ FileInputStream fstream = new FileInputStream(fileReference);
+ // Get the object of DataInputStream
+ DataInputStream in = new DataInputStream(fstream);
+ BufferedReader br = new BufferedReader(new InputStreamReader(in));
+ String strLine;
+ //Read File Line By Line
+ while ((strLine = br.readLine()) != null) {
+ // Print the content on the console
+ TraceManager.addDev("Computing transaction:" + strLine);
+ addGenericTransaction(strLine);
+ }
+ //Close the input stream
+ in.close();
+ } catch (Exception e){//Catch exception if any
+ TraceManager.addDev("Reading file Error: " + e.getMessage());
+ }
+ }
+ }
+
+ public void addGenericTransaction(String trans) {
+ int index0, index1;
+ String tmp, tmp1, tmp2;
+ long value;
+ int value1, value2;
+
+ if (!(trans.startsWith("#"))) {
+ return;
+ }
+
+
+ GenericTransaction gt = new GenericTransaction();
+
+ // Adding the ID
+ index0 = trans.indexOf(" ");
+ if (index0 == -1) {
+ return;
+ }
+ tmp = trans.substring(1, index0);
+ try {
+ gt.ID = Integer.decode(tmp).intValue();
+ } catch (Exception e) {
+ }
+
+
+ //TraceManager.addDev("1");
+
+ // Time
+ tmp = extract(trans, "time");
+ if (tmp == null) {
+ return;
+ }
+
+ //TraceManager.addDev("2 tmp=" + tmp);
+
+ try {
+ index0 = tmp.indexOf('.');
+ if (index0 == -1) {
+ return;
+ }
+ tmp1 = tmp.substring(0, index0);
+ tmp2 = tmp.substring(index0+1, tmp.length());
+ //TraceManager.addDev("2 tmp1=" + tmp1 + " tmp2=" + tmp2);
+ value1 = Integer.decode(tmp1).intValue();
+ value2 = Integer.decode(tmp2).intValue();
+ value = ((long)value1)*1000000000+value2;
+ gt.startingTime = value;
+ gt.finishTime = value;
+ } catch (Exception e) {
+ return;
+ }
+
+ //TraceManager.addDev("3");
+
+ // Name of the block
+ tmp = extract(trans, "block");
+ if (tmp == null) {
+ return;
+ }
+
+ addEntityNameIfApplicable(tmp);
+ gt.entityName = tmp;
+
+ // Type of the transaction
+ tmp = extract(trans, "type");
+ if (tmp == null) {
+ return;
+ }
+
+ if (tmp.compareTo("state_entering") == 0) {
+ gt.type = GenericTransaction.STATE_ENTERING;
+ }
+
+ if (tmp.compareTo("function_call") == 0) {
+ gt.type = GenericTransaction.FUNCTION_CALL;
+ }
+
+ if (tmp.compareTo("send_synchro") == 0) {
+ gt.type = GenericTransaction.SEND_SYNCHRO;
+ }
+
+ // State of the transaction?
+ tmp = extract(trans, "state");
+
+ if (tmp != null) {
+ gt.action = tmp;
+ }
+
+ // Function of the transaction?
+ tmp = extract(trans, "func");
+
+ if (tmp != null) {
+ gt.action = tmp;
+ }
+
+ // Parameters of the function
+ tmp = extract(trans, "parameters");
+ gt.action = gt.action + "(";
+ if( tmp != null) {
+ if (!(tmp.startsWith("-"))) {
+ gt.action = gt.action + tmp;
+ }
+ } else {
+ }
+ gt.action = gt.action + ")";
+
+ // Destination of the transaction?
+ tmp = extract(trans, "blockdestination");
+ if (tmp != null) {
+ gt.otherEntityName = tmp;
+ }
+
+ // Channel of the transaction?
+ tmp = extract(trans, "channel");
+ if (tmp != null) {
+ gt.name = tmp;
+ }
+
+ transactions.add(gt);
+ TraceManager.addDev("One transactions added");
+
+ }
+
+ public String extract(String main, String selector) {
+ String sel = selector+"=";
+ int index = main.indexOf(sel);
+ if (index == -1) {
+ return null;
+ }
+
+ String ret = main.substring(index+sel.length(), main.length());
+ index = ret.indexOf(' ');
+
+ if (index != -1) {
+ ret = ret.substring(0, index);
+ }
+
+ return ret;
+ }
+
+ public void addEntityNameIfApplicable(String _entityName) {
+ for(String name: entityNames) {
+ if (name.compareTo(_entityName) ==0) {
+ return;
+ }
+ }
+
+ entityNames.add(_entityName);
+ }
+
+ public int getIndexOfEntityName(String _entityName) {
+ int cpt = 0;
+ for(String name: entityNames) {
+ if (name.compareTo(_entityName) ==0) {
+ return cpt;
+ }
+ cpt ++;
+ }
+
+ return -1;
+ }
+
+ public void setClockDiviser(long _clockDiviser) {
+ clockDiviser = _clockDiviser;
+ }
}
\ No newline at end of file