- * Tries to match the rules to the given sequence to generate an
- * {@link Event}.
- *
- *
- * The rules are matched the order, in which they are defined in the XML
- * file. Therefore, the order of the rules in the file defines priorities,
- * when multiple rules could be matched to the same sequence.
- *
- *
- * @param sequence
- * sequence of message for which an event will be generated
- * @return event that matches the messages; null, if no rule can be matched
- */
- @SuppressWarnings("unchecked")
- public Event generateEvent(List sequence) {
- Document rulesDoc = getDocument(rulesFile);
- Element rulesRoot = rulesDoc.getRootElement();
-
- List ruleElements = rulesRoot.getChildren("rule",
- rulesNamespace);
-
- boolean isMatch = false;
-
- for (int ruleIndex = 0; ruleIndex < ruleElements.size() && !isMatch; ruleIndex++) {
- Element currentRule = ruleElements.get(ruleIndex);
- currentRuleName = currentRule.getAttributeValue("name");
- currentToken = new ReplayableEvent(currentRuleName);
- isMatch = true;
- messageStorage = new HashMap();
- sequenceIterator = sequence.listIterator();
- List ruleChildrenMsg = currentRule.getChildren("msg",
- rulesNamespace);
-
- int i = 0;
- while (isMatch && i < ruleChildrenMsg.size()) {
- Element messageElement = ruleChildrenMsg.get(i);
- if ("true".equals(messageElement.getAttributeValue("multiple"))) {
- Element nextMessageElement = null;
- if (i + 1 < ruleChildrenMsg.size()) {
- nextMessageElement = ruleChildrenMsg.get(i + 1);
- }
- try {
- isMatch = matchMultipleMessages(messageElement,
- nextMessageElement);
- } catch (InvalidParameterException e) {
- Console.printerrln(e.getMessage());
- }
- } else {
- try {
- isMatch = matchSingleMessage(messageElement);
- } catch (InvalidParameterException e) {
- Console.printerrln(e.getMessage());
- }
- }
- i++;
- }
- if (isMatch) {
- List ruleChildren = currentRule.getChildren();
- for (Element genMsgElement : ruleChildren) {
- if (genMsgElement.getName().equals("genMsg")) {
- try {
- generateReplayMessage(genMsgElement);
- } catch (InvalidParameterException e) {
- Console.printerrln(e.getMessage());
- currentToken.invalidateReplay();
- }
- } else if (genMsgElement.getName().equals("genMsgSeq")) {
- try {
- generateReplaySequence(genMsgElement);
- currentToken.invalidateReplay();
- } catch (InvalidParameterException e) {
- Console.printerrln(e.getMessage());
- currentToken.invalidateReplay();
- }
- }
- }
- Element idinfoElement = currentRule.getChild("idinfo",
- rulesNamespace);
- if (idinfoElement != null) {
- // cannot be empty if document is valid
- List valueElements = idinfoElement.getChildren();
- currentToken.setIdInfo(getTermValue(null,
- valueElements.get(0)));
- }
- Console.traceln(currentRule.getAttributeValue("name")
- + currentToken.getIdInfo() + " matched");
- } else {
- currentToken = null;
- }
- }
- if (!isMatch) {
- Console.traceln("no match found for sequence: "
- + sequence.toString());
- }
- return currentToken;
- }
-
- private boolean createSequenceLParam(
- List generatedMessageSeq, boolean msgsGenerated,
- int constMsgType, Element termElement)
- throws NoSuchElementException {
- Iterator seqIterator = generatedMessageSeq.iterator();
- if (termElement.getName().equals("seqValue")) {
- String obj = termElement.getAttributeValue("seqObj");
- List seqVar = getStoredSeqVariable(obj);
- if (msgsGenerated && seqVar.size() != generatedMessageSeq.size()) {
- throw new InvalidParameterException(
- "Failure generating replay sequence for rule "
- + currentRuleName
- + ": One or more of the sequence variables used to generate a sequence have different lenghts.");
- }
- for (WindowsMessage msg : seqVar) {
- WindowsMessage currentSeqMsg = getCurrentSeqMsg(
- generatedMessageSeq, msgsGenerated, constMsgType,
- seqIterator);
- String paramValueStr = msg.getParameter(termElement
- .getAttributeValue("param"));
- int paramValue = 0;
- try {
- paramValue = Integer.parseInt(paramValueStr);
- currentSeqMsg.setLPARAM(paramValue);
- } catch (NumberFormatException e) {
- currentSeqMsg.setLPARAMasWindowDesc(paramValueStr);
- }
- }
- if (seqIterator.hasNext()) {
- // the first seq-var has a different number of elements than the
- // current one
- throw new NoSuchElementException();
- }
- msgsGenerated = true;
- } else { // const value
- int paramValue = Integer.parseInt(getTermValue(null, termElement));
- while (seqIterator.hasNext()) {
- seqIterator.next().setLPARAM(paramValue);
- }
- }
- return msgsGenerated;
- }
-
- private boolean createSequenceTarget(
- List generatedMessageSeq, boolean msgsGenerated,
- int constMsgType, Element termElement)
- throws NoSuchElementException {
- Iterator seqIterator = generatedMessageSeq.iterator();
- if (termElement.getName().equals("seqValue")) {
- String obj = termElement.getAttributeValue("seqObj");
- List seqVar = getStoredSeqVariable(obj);
- if (msgsGenerated && seqVar.size() != generatedMessageSeq.size()) {
- throw new InvalidParameterException(
- "Failure generating replay sequence for rule "
- + currentRuleName
- + ": One or more of the sequence variables used to generate a sequence have different lenghts.");
- }
- for (WindowsMessage msg : seqVar) {
- WindowsMessage currentSeqMsg = getCurrentSeqMsg(
- generatedMessageSeq, msgsGenerated, constMsgType,
- seqIterator);
- String targetString = msg.getParameter(termElement
- .getAttributeValue("param"));
- currentSeqMsg.setXmlWindowDescription(targetString);
- }
- msgsGenerated = true;
- } else { // const value
- throw new AssertionError("target must be a sequence variable!");
- /*
- * If target would not be a variable, the message-elements could not
- * yet be created and the whole sequence might be broken. If this is
- * to be changed, createSequenceLParam and createSequenceWParam need
- * to be addepted, too.
- */
- }
- return msgsGenerated;
- }
-
- private boolean createSequenceWParam(
- List generatedMessageSeq, boolean msgsGenerated,
- int constMsgType, Element termElement)
- throws NoSuchElementException {
- Iterator seqIterator = generatedMessageSeq.iterator();
- if (termElement.getName().equals("seqValue")) {
- String obj = termElement.getAttributeValue("seqObj");
- List seqVar = getStoredSeqVariable(obj);
- if (msgsGenerated && seqVar.size() != generatedMessageSeq.size()) {
- throw new InvalidParameterException(
- "Failure generating replay sequence for rule "
- + currentRuleName
- + ": One or more of the sequence variables used to generate a sequence have different lenghts.");
- }
- for (WindowsMessage msg : seqVar) {
- WindowsMessage currentSeqMsg = getCurrentSeqMsg(
- generatedMessageSeq, msgsGenerated, constMsgType,
- seqIterator);
- String paramValueStr = msg.getParameter(termElement
- .getAttributeValue("param"));
- int paramValue = 0;
- try {
- paramValue = Integer.parseInt(paramValueStr);
- currentSeqMsg.setWPARAM(paramValue);
- } catch (NumberFormatException e) {
- currentSeqMsg.setWPARAMasWindowDesc(paramValueStr);
- }
- }
- if (seqIterator.hasNext()) {
- // the first seq-var has a different number of elements than the
- // current one
- throw new NoSuchElementException();
- }
- msgsGenerated = true;
- } else { // const value
- int paramValue = Integer.parseInt(getTermValue(null, termElement));
- while (seqIterator.hasNext()) {
- seqIterator.next().setWPARAM(paramValue);
- }
- }
- return msgsGenerated;
- }
-
- @SuppressWarnings("unchecked")
- private boolean evalEqualRestrictions(WindowsMessage currentMessage,
- Element messageElement) {
- boolean isMatch = true;
- for (Element childElement : (List) messageElement.getChildren(
- "equals", rulesNamespace)) {
- List termElements = childElement.getChildren();
- // the size 2 of termElements is guaranteed by the XML schema
- String value1 = getTermValue(currentMessage, termElements.get(0));
- String value2 = getTermValue(currentMessage, termElements.get(1));
- if (value1 == null || value2 == null) {
- isMatch = false;
- } else {
- isMatch = isMatch && value1.equals(value2);
- }
- }
- for (Element childElement : (List) messageElement.getChildren(
- "equalsSeq", rulesNamespace)) {
- List termElements = childElement.getChildren();
- List values1 = getTermValueSeq(currentMessage,
- termElements.get(0));
- List values2 = getTermValueSeq(currentMessage,
- termElements.get(0));
- if (values1 == null || values2 == null) {
- isMatch = false;
- } else {
- isMatch = isMatch && values1.equals(values2);
- }
- }
- return isMatch;
- }
-
- @SuppressWarnings("unchecked")
- private void generateReplayMessage(Element genMsgElement) {
- List genMsgChildren = genMsgElement.getChildren();
- WindowsMessage generatedMessage = null;
- if (genMsgChildren.size() == 1) { // replay stored message without
- // change
- String obj = genMsgChildren.get(0).getAttributeValue("obj");
- generatedMessage = getStoredMessageVariable(null, obj);
- } else { // generate message according to the rule
- for (Element genMsgChild : genMsgChildren) {
- Element termElement = (Element) genMsgChild.getChildren()
- .get(0);
- if (genMsgChild.getName().equals("type")) {
- try {
- int msgType = Integer.parseInt(getTermValue(null,
- termElement));
- generatedMessage = new WindowsMessage(msgType);
- } catch (NumberFormatException e) {
- throw new InvalidParameterException(
- "Failure generating replay sequence for rule "
- + currentRuleName
- + ": Defined type is not an integer.");
- }
- } else if (genMsgChild.getName().equals("target")) {
- String targetString = getTermValue(null, termElement);
- generatedMessage.setXmlWindowDescription(targetString);
- } else if (genMsgChild.getName().equals("LPARAM")) {
- String paramValueStr = getTermValue(null, termElement);
- long paramValue = 0;
- Element loword = genMsgChild.getChild("LOWORD", rulesNamespace);
- if( loword!=null ) {
- paramValue = loHiWord(genMsgChild);
- generatedMessage.setLPARAM(paramValue);
- } else {
- try {
- paramValue = Integer.parseInt(paramValueStr);
- generatedMessage.setLPARAM(paramValue);
- } catch (NumberFormatException e) {
- generatedMessage.setLPARAMasWindowDesc(paramValueStr);
- }
- }
- } else if (genMsgChild.getName().equals("WPARAM")) {
- String paramValueStr = getTermValue(null, termElement);
- long paramValue = 0;
- Element loword = genMsgChild.getChild("LOWORD", rulesNamespace);
- if( loword!=null ) {
- paramValue = loHiWord(genMsgChild);
- generatedMessage.setWPARAM(paramValue);
- } else {
- try {
- paramValue = Integer.parseInt(paramValueStr);
- generatedMessage.setWPARAM(paramValue);
- } catch (NumberFormatException e) {
- generatedMessage.setWPARAMasWindowDesc(paramValueStr);
- }
- }
- }
- }
- }
- if (generatedMessage != null) {
- int delay = Integer.parseInt(genMsgElement
- .getAttributeValue("delay"));
- generatedMessage.setDelay(delay);
- } else {
- currentToken.invalidateReplay();
- }
- currentToken.addReplayEvent(generatedMessage);
- }
-
- @SuppressWarnings("unchecked")
- private void generateReplaySequence(Element genMsgElement) {
- List genMsgSeqChildren = genMsgElement.getChildren();
- List generatedMessageSeq = new LinkedList();
- if (genMsgSeqChildren.size() == 1) {
- String obj = genMsgSeqChildren.get(0).getAttributeValue("seqObj");
- generatedMessageSeq = getStoredSeqVariable(obj);
- } else {
- boolean msgsGenerated = false;
- int constMsgType = 0;
- for (Element genMsgSeqChild : genMsgSeqChildren) {
- Element termElement = (Element) genMsgSeqChild.getChildren()
- .get(0);
- if (genMsgSeqChild.getName().equals("type")) {
- // note: cannot easily be extracted because of mulitple
- // return values
- if (termElement.getName().equals("seqValue")) {
- String obj = termElement.getAttributeValue("seqObj");
- List seqVar = getStoredSeqVariable(obj);
- for (WindowsMessage msg : seqVar) {
- generatedMessageSeq.add(new WindowsMessage(msg
- .getType()));
- }
- msgsGenerated = true;
- } else { // constValue type
- constMsgType = Integer.parseInt(getTermValue(null,
- termElement));
- }
- } else if (genMsgSeqChild.getName().equals("target")) {
- msgsGenerated = createSequenceTarget(generatedMessageSeq,
- msgsGenerated, constMsgType, termElement);
- } else if (genMsgSeqChild.getName().equals("LPARAM")) {
- msgsGenerated = createSequenceLParam(generatedMessageSeq,
- msgsGenerated, constMsgType, termElement);
- } else if (genMsgSeqChild.getName().equals("WPARAM")) {
- msgsGenerated = createSequenceWParam(generatedMessageSeq,
- msgsGenerated, constMsgType, termElement);
- }
- }
- }
- currentToken.addReplaySequence(generatedMessageSeq);
- }
-
- private WindowsMessage getCurrentSeqMsg(
- List generatedMessageSeq, boolean msgsGenerated,
- int constMsgType, Iterator seqIterator) {
- WindowsMessage currentSeqMsg = null;
- if (msgsGenerated) {
- currentSeqMsg = seqIterator.next();
- } else {
- currentSeqMsg = new WindowsMessage(constMsgType);
- generatedMessageSeq.add(currentSeqMsg);
- }
- return currentSeqMsg;
- }
-
- private WindowsMessage getStoredMessageVariable(
- WindowsMessage currentMessage, String obj)
- throws InvalidParameterException {
- WindowsMessage varMessage = null;
- if (obj.equals("this")) {
- if (currentMessage == null) {
- throw new InvalidParameterException(
- "Failure obtaining term value for rule "
- + currentRuleName
- + ": \"this\" is not a valid name for generating runtime messages.");
- }
- varMessage = currentMessage;
- } else {
- Object tmp = messageStorage.get(obj);
- if (tmp instanceof WindowsMessage) {
- varMessage = (WindowsMessage) tmp;
- } else {
- throw new InvalidParameterException(
- "Failure obtaining term value for rule "
- + currentRuleName + ": No message \"" + obj
- + "\" stored.");
- }
- }
- return varMessage;
- }
-
- @SuppressWarnings("unchecked")
- private List getStoredSeqVariable(String obj)
- throws InvalidParameterException {
- List varMsgSeq = null;
- Object tmp = messageStorage.get(obj);
- if (tmp instanceof List) {
- varMsgSeq = (List) tmp;
- } else {
- throw new InvalidParameterException(
- "Failure obtaining term value for rule " + currentRuleName
- + ": No sequence \"" + obj + "\" store.");
- }
- return varMsgSeq;
- }
-
- private String getTermValue(WindowsMessage currentMessage,
- Element termElement) {
- String value = null;
- WindowsMessage varMessage = null;
- if (termElement.getName().equals("constValue")) {
- value = termElement.getAttributeValue("value");
- } else if (termElement.getName().equals("paramValue")) {
- String objectName = termElement.getAttributeValue("obj");
- varMessage = getStoredMessageVariable(currentMessage, objectName);
- if (varMessage != null) {
- String param = termElement.getAttributeValue("param");
- value = varMessage.getParameter(param);
- }
- } else if (termElement.getName().equals("winInfoValue")) {
- String objectName = termElement.getAttributeValue("obj");
- varMessage = getStoredMessageVariable(currentMessage, objectName);
- if (varMessage != null) {
- String paramString = termElement.getAttributeValue("winParam");
- if (paramString.equals("class")) {
- value = varMessage.getWindowClass();
- } else if (paramString.equals("resourceId")) {
- value = "" + varMessage.getWindowResourceId();
- } else if (paramString.equals("hwnd")) {
- value = "" + varMessage.getHwnd();
- } else if (paramString.equals("parentTarget")) {
- String target = varMessage.getXmlWindowDescription();
- int index = target.lastIndexOf("<");
- if( index==0 ) {
- Console.println("Trying to adress parent of top-level window! Replay probably invalid!");
- }
- value = target.substring(0, index);
- }
- }
- } else if (termElement.getName().equals("msgInfoValue")) {
- String objectName = termElement.getAttributeValue("obj");
- varMessage = getStoredMessageVariable(currentMessage, objectName);
- if (varMessage != null) {
- String paramString = termElement.getAttributeValue("msgParam");
- if (paramString.equals("type")) {
- value = "" + varMessage.getType();
- } else if (paramString.equals("target")) {
- value = varMessage.getXmlWindowDescription();
- }
- }
- }
- return value;
- }
-
- private List getTermValueSeq(WindowsMessage currentMessage,
- Element termElement) {
- List values = new LinkedList();
- if (termElement.getName().equals("seqValue")) {
- String obj = termElement.getAttributeValue("seqObj");
- String param = termElement.getAttributeValue("param");
- List seqVar = getStoredSeqVariable(obj);
-
- for (WindowsMessage msg : seqVar) {
- // msg.getParameter returns null, if parameter is not found,
- // therefore the List can contain null-values
- values.add(msg.getParameter(param));
- }
- }
- return values;
- }
-
- @SuppressWarnings("unchecked")
- private void handleStorage(Element messageElement,
- WindowsMessage currentMessage) {
- for (Element childElement : (List) messageElement.getChildren(
- "store", rulesNamespace)) {
- String identifier = childElement.getAttributeValue("var");
- messageStorage.put(identifier, currentMessage);
- resolveHwnd(currentMessage, childElement);
- }
- for (Element childElement : (List) messageElement.getChildren(
- "storeSeq", rulesNamespace)) {
- String identifier = childElement.getAttributeValue("varSeq");
- Object tmp = messageStorage.get(identifier);
- List storedSequence;
- if (tmp == null || tmp instanceof WindowsMessage) {
- storedSequence = new LinkedList();
- storedSequence.add(currentMessage);
- messageStorage.put(identifier, storedSequence);
- } else if (tmp instanceof List) {
- storedSequence = (List) tmp;
- storedSequence.add(currentMessage);
- messageStorage.put(identifier, storedSequence);
- }
- resolveHwnd(currentMessage, childElement);
- }
- }
-
- private boolean matchMultipleMessages(Element messageElement,
- Element nextMessageElement) {
- boolean isMatch = false;
- boolean isCurrentMatch = false;
- boolean nextMatchFound = false;
- WindowsMessage currentMessage = null;
- WindowsMessage nextMessage = null;
-
- int type = Integer.parseInt(messageElement.getAttributeValue("type"));
-
- int nextType = -1;
- if (nextMessageElement != null) {
- nextType = Integer.parseInt(nextMessageElement
- .getAttributeValue("type"));
- }
-
- while (!nextMatchFound && sequenceIterator.hasNext()) {
- currentMessage = sequenceIterator.next();
- if (type == currentMessage.getType()) {
- isCurrentMatch = evalEqualRestrictions(currentMessage,
- messageElement);
- isMatch = isMatch || isCurrentMatch;
-
- if (isCurrentMatch) {
- handleStorage(messageElement, currentMessage);
- currentToken.setTarget(currentMessage
- .getXmlWindowDescription());
- currentToken
- .setTargetShort(currentMessage.getParentNames());
- }
- }
- if (nextMessageElement != null && isMatch) {
- // peek next message to check if the sequence ends and the next
- // match is found
- if (!sequenceIterator.hasNext()) {
- return false; // sequence is over, but not all messages are
- // found
- }
- nextMessage = sequenceIterator.next();
- sequenceIterator.previous();
-
- if (nextType == nextMessage.getType()) {
- nextMatchFound = evalEqualRestrictions(nextMessage,
- nextMessageElement);
- }
-
- }
- }
-
- return isMatch;
- }
-
- private boolean matchSingleMessage(Element messageElement) {
- boolean isMatch = false;
- WindowsMessage currentMessage = null;
-
- int type = Integer.parseInt(messageElement.getAttributeValue("type"));
-
- while (!isMatch && sequenceIterator.hasNext()) {
- // traverses the messages from the current position forward till a
- // message with the correct type is found
- currentMessage = sequenceIterator.next();
- if (type == currentMessage.getType()) {
- // message with the correct type found
- // eval child nodes for further matching/storing
- isMatch = evalEqualRestrictions(currentMessage, messageElement);
-
- // in case the message is a match, eval storage children
- if (isMatch) {
- handleStorage(messageElement, currentMessage);
- currentToken.setTarget(currentMessage
- .getXmlWindowDescription());
- currentToken
- .setTargetShort(currentMessage.getParentNames());
- }
- }
- }
-
- return isMatch;
- }
-
- @SuppressWarnings("unchecked")
- private void resolveHwnd(WindowsMessage currentMessage, Element childElement) {
- List resolveElements = childElement.getChildren("resolveHwnd",
- rulesNamespace);
- for (Element resolveElement : resolveElements) {
- String param = resolveElement.getAttributeValue("param");
- String storeParam = resolveElement.getAttributeValue("storeParam");
- int paramHwnd = Integer
- .parseInt(currentMessage.getParameter(param));
- WindowTreeNode node = WindowTree.getInstance().find(paramHwnd);
- if (node != null) {
- currentMessage.addParameter(storeParam,
- node.xmlRepresentation());
- }
- }
- }
-
- private long loHiWord(Element param) {
- Element loword = param.getChild("LOWORD", rulesNamespace);
- Element hiword = param.getChild("HIWORD", rulesNamespace);
- String lowordStr = getTermValue(null, (Element) loword.getChildren().get(0));
- String hiwordStr = getTermValue(null, (Element) hiword.getChildren().get(0));
- return MAKEPARAM(Short.parseShort(lowordStr), Short.parseShort(hiwordStr));
- }
-
- private static int MAKEPARAM(short loword, short hiword) {
- return loword| ((int) hiword) << Short.SIZE;
- }
-
-}
Index: trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/LogParser.java
===================================================================
--- trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/LogParser.java (revision 51)
+++ (revision )
@@ -1,183 +1,0 @@
-package de.ugoe.cs.eventbench;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.UnsupportedEncodingException;
-import java.security.InvalidParameterException;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.SortedMap;
-import java.util.TreeMap;
-
-import javax.xml.parsers.ParserConfigurationException;
-import javax.xml.parsers.SAXParser;
-import javax.xml.parsers.SAXParserFactory;
-
-import org.xml.sax.Attributes;
-import org.xml.sax.InputSource;
-import org.xml.sax.SAXException;
-import org.xml.sax.SAXParseException;
-import org.xml.sax.helpers.DefaultHandler;
-
-import de.ugoe.cs.eventbench.data.Event;
-import de.ugoe.cs.eventbench.data.WindowTree;
-import de.ugoe.cs.eventbench.data.WindowsMessage;
-import de.ugoe.cs.eventbench.messagehandler.HandlerCreate;
-import de.ugoe.cs.eventbench.messagehandler.HandlerDestroy;
-import de.ugoe.cs.eventbench.messagehandler.HandlerSetText;
-import de.ugoe.cs.eventbench.messagehandler.MessageHandler;
-import de.ugoe.cs.eventbench.windowsdefs.MessageDefs;
-import de.ugoe.cs.util.StringTools;
-import de.ugoe.cs.util.console.Console;
-
-public class LogParser extends DefaultHandler {
-
- private MessageHandler currentHandler;
-
- private WindowsMessage currentMessage;
-
- private SequenceSplitter sequenceSplitter;
-
- private List>> sequences;
-
- private SortedMap typeCounter;
-
- private boolean countMessageOccurences;
-
- public LogParser() {
- this(false);
- }
-
- public LogParser(boolean countMessageOccurences) {
- sequenceSplitter = new SequenceSplitter();
- sequences = new LinkedList>>();
- currentHandler = null;
- this.countMessageOccurences = countMessageOccurences;
- if( countMessageOccurences) {
- typeCounter = new TreeMap();
- }
-
- }
-
- public List>> getSequences() {
- return sequences;
- }
-
- @Override
- public void startElement(String uri, String localName, String qName, Attributes atts) throws SAXException {
- if( qName.equals("session") ) {
- Console.traceln("start of session");
- sequenceSplitter = new SequenceSplitter();
- }
- else if( qName.equals("msg") ) {
- String msgType = atts.getValue("type");
- int msgInt = -1;
- try {
- msgInt = Integer.parseInt(msgType);
-
- if( countMessageOccurences ) {
- Integer currentCount = typeCounter.get(msgInt);
- if( currentCount==null ) {
- typeCounter.put(msgInt, 1);
- } else {
- typeCounter.put(msgInt, currentCount+1);
- }
- }
-
- if( msgInt==MessageDefs.WM_CREATE ) {
- currentHandler = new HandlerCreate();
- currentHandler.onStartElement();
- }
- else if( msgInt==MessageDefs.WM_DESTROY ) {
- currentHandler = new HandlerDestroy();
- currentHandler.onStartElement();
- }
- else if( msgInt==MessageDefs.WM_SETTEXT ) {
- currentHandler = new HandlerSetText();
- currentHandler.onStartElement();
- } else {
- currentMessage = new WindowsMessage(msgInt);
- }
- } catch(NumberFormatException e) {
- Console.printerrln("Invalid message type: type not a number");
- e.printStackTrace();
- }
- }
- else if( qName.equals("param") ) {
- if( currentHandler!=null ) {
- currentHandler.onParameter(atts.getValue("name"), atts.getValue("value"));
- } else {
- currentMessage.addParameter(atts.getValue("name"), atts.getValue("value"));
- }
- }
- }
-
- @Override
- public void endElement(String uri, String localName, String qName) throws SAXException {
- if( qName.equals("msg") ) {
- if( currentHandler!=null ) {
- currentHandler.onEndElement();
- currentHandler = null;
- } else {
- try {
- currentMessage.setTarget(WindowTree.getInstance());
- sequenceSplitter.addMessage(currentMessage);
- } catch (InvalidParameterException e) {
- Console.traceln(e.getMessage() + " WindowsMessage " + currentMessage + " ignored.");
- }
- }
- }
- else if(qName.equals("session")) {
- sequenceSplitter.endSession();
- sequences.add(sequenceSplitter.getSequence());
- Console.traceln("end of session");
- }
- }
-
- public void parseFile(String filename) {
- if( filename==null ) {
- throw new InvalidParameterException("filename must not be null");
- }
-
- SAXParserFactory spf = SAXParserFactory.newInstance();
- spf.setValidating(true);
-
- SAXParser saxParser = null;
- InputSource inputSource = null;
- try {
- saxParser = spf.newSAXParser();
- inputSource = new InputSource(new InputStreamReader(new FileInputStream(filename), "UTF-16"));
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- } catch (ParserConfigurationException e) {
- e.printStackTrace();
- } catch (SAXException e) {
- e.printStackTrace();
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- }
- if( inputSource!=null ) {
- inputSource.setSystemId("file://" + new File(filename).getAbsolutePath());
- try {
- if( saxParser==null) {
- throw new RuntimeException("SAXParser creation failed");
- }
- saxParser.parse(inputSource, this);
- } catch (SAXParseException e) {
- Console.printerrln("Failure parsing file in line " + e.getLineNumber() + ", column " + e.getColumnNumber() +".");
- e.printStackTrace();
- } catch (SAXException e) {
- e.printStackTrace();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- if( countMessageOccurences ) {
- Console.println("Message statistics:");
- Console.println(typeCounter.toString().replace(" ", StringTools.ENDLINE).replaceAll("[\\{\\}]",""));
- }
- }
-}
Index: trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/LogPreprocessor.java
===================================================================
--- trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/LogPreprocessor.java (revision 51)
+++ (revision )
@@ -1,128 +1,0 @@
-package de.ugoe.cs.eventbench;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.FileReader;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-
-import org.apache.commons.codec.binary.Base64;
-
-import de.ugoe.cs.util.StringTools;
-import de.ugoe.cs.util.console.Console;
-
-public class LogPreprocessor {
-
- private boolean sessionOpen = false;
- private boolean msgIncomplete = false;
-
- private boolean base64;
-
- public LogPreprocessor() {
- this(false);
- }
-
- public LogPreprocessor(boolean base64) {
- this.base64 = base64;
- }
-
- public void convertToXml(String source, String target) throws IOException, FileNotFoundException {
- OutputStreamWriter targetFile = new OutputStreamWriter(new FileOutputStream(target), "UTF-16");
- targetFile.write("" + StringTools.ENDLINE);
- targetFile.write("" + StringTools.ENDLINE);
- processFile(source, targetFile);
- if( sessionOpen ) {
- targetFile.write(" " + StringTools.ENDLINE);
- }
- targetFile.write("");
- targetFile.close();
- }
-
-
- public void convertDirToXml(String path, String target) throws IOException, FileNotFoundException {
- OutputStreamWriter targetFile = new OutputStreamWriter(new FileOutputStream(target), "UTF-16");
- targetFile.write("" + StringTools.ENDLINE);
- targetFile.write("" + StringTools.ENDLINE);
- File folder = new File(path);
- if( !folder.isDirectory() ) {
- throw new IOException(path + " is not a directory");
- }
- String absolutPath = folder.getAbsolutePath();
- for( String filename : folder.list() ) {
- String source = absolutPath + "/" + filename;
- Console.traceln("Processing file: " + source);
- processFile(source, targetFile);
- }
-
- if( sessionOpen ) {
- targetFile.write(" " + StringTools.ENDLINE);
- }
- targetFile.write("");
- targetFile.close();
- }
-
- private void processFile(String source, OutputStreamWriter targetFile)
- throws FileNotFoundException, IOException {
- File f = new File(source);
- FileReader reader = new FileReader(f);
- char[] buffer = new char[(int) f.length()];
- reader.read(buffer);
- reader.close();
- String[] lines = (new String(buffer)).split("\n");
- String incompleteLine = "";
- // Open source and read line by line
- for( String currentLine : lines ) {
- if( currentLine.contains("UL: ")) {
- if( sessionOpen) {
- targetFile.write(" " + StringTools.ENDLINE);
- targetFile.write(" " + StringTools.ENDLINE);
- } else {
- targetFile.write(" " + StringTools.ENDLINE);
- sessionOpen = true;
- }
- } else if( currentLine.contains("UL: ")) {
- if( sessionOpen) {
- targetFile.write(" " + StringTools.ENDLINE);
- sessionOpen = false;
- }
- } else if( msgIncomplete || currentLine.contains("UL: ")) {
-
- String currentContent;
- String actualLine;
- if( msgIncomplete ) {
- actualLine = currentLine;
- } else {
- String[] splitResult = currentLine.split("UL: ");
- actualLine = splitResult[1];
- }
- if( base64 ) {
- Base64 decoder = new Base64();
- byte[] decoded = decoder.decode(actualLine);
- currentContent = new String(decoded, "UTF-16LE");
- currentContent = currentContent.substring(0, currentContent.length()-1);
- } else {
- currentContent = actualLine;
- }
- if( msgIncomplete ) {
- incompleteLine += currentContent;
- if( incompleteLine.contains("") ) {
- msgIncomplete = false;
- targetFile.write(incompleteLine + StringTools.ENDLINE);
- incompleteLine = "";
- }
- } else {
- if( currentContent.contains("") ) {
- targetFile.write(" " + currentContent + StringTools.ENDLINE);
- } else {
- msgIncomplete = true;
- incompleteLine += currentContent;
- }
- }
- }
- }
- }
- }
-
-}
Index: trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/Runner.java
===================================================================
--- trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/Runner.java (revision 51)
+++ trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/Runner.java (revision 52)
@@ -11,4 +11,5 @@
public static void main(String[] args) {
CommandExecuter.getInstance().addCommandPackage("de.ugoe.cs.eventbench.commands");
+ CommandExecuter.getInstance().addCommandPackage("de.ugoe.cs.eventbench.windows.commands");
CommandExecuter.getInstance().addCommandPackage("de.ugoe.cs.eventbench.web.commands");
TextConsole textConsole = new TextConsole();
Index: trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/SequenceSplitter.java
===================================================================
--- trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/SequenceSplitter.java (revision 51)
+++ (revision )
@@ -1,155 +1,0 @@
-package de.ugoe.cs.eventbench;
-
-import java.util.LinkedList;
-import java.util.List;
-
-import de.ugoe.cs.eventbench.data.Event;
-import de.ugoe.cs.eventbench.data.WindowsMessage;
-import de.ugoe.cs.eventbench.windowsdefs.MessageDefs;
-import de.ugoe.cs.util.console.Console;
-
-public class SequenceSplitter {
-
- private List currentSequence;
-
- private int openDowns;
-
- private boolean initMessages;
-
- private EventGenerator tokenGenerator;
-
- private List> actionSequence;
-
- public SequenceSplitter() {
- currentSequence = new LinkedList();
- openDowns = 0;
- initMessages = true;
- tokenGenerator = new EventGenerator();
- actionSequence = new LinkedList>();
- }
-
- public void addMessage(WindowsMessage msg) {
- if( startOfSequence(msg) ) {
- if( !initMessages ) {
- Event currentAction = tokenGenerator.generateEvent(currentSequence);
- if( currentAction!=null ) {
- actionSequence.add(currentAction);
- }
- if( isKeyMessage(msg.getType()) && openDowns>0 ) {
- Console.traceln("Key message found with open down mouse messages - will probabably result in a faulty sequence.");
- }
- } else {
- initMessages = false;
- }
- currentSequence = new LinkedList();
- }
- if( isUpMessage(msg.getType()) ) {
- if( openDowns>0 ) {
- openDowns--;
- }
- }
- currentSequence.add(msg);
- }
-
- public List> getSequence() {
- return actionSequence;
- }
-
- public void endSession() {
- Event currentAction = tokenGenerator.generateEvent(currentSequence);
- if( currentAction!=null ) {
- actionSequence.add(currentAction);
- }
- }
-
- private boolean startOfSequence(WindowsMessage msg) {
- boolean isStart = false;
- int msgType = msg.getType();
- if( isKeyMessage(msgType) ) {
- isStart = true;
- }
- if( isDownMessage(msgType) ) {
- openDowns++;
- if( openDowns==1 ) {
- isStart = true;
- }
- }
- if( isDblclkMessage(msgType) ) {
- openDowns++;
- }
- return isStart;
- }
-
- private boolean isKeyMessage(int msgType) {
- boolean isKeyMsg = false;
- switch (msgType) {
- case MessageDefs.WM_KEYDOWN:
- case MessageDefs.WM_KEYUP:
- case MessageDefs.WM_SYSKEYDOWN:
- case MessageDefs.WM_SYSKEYUP:
- isKeyMsg = true;
- break;
- default:
- break;
- }
- return isKeyMsg;
- }
-
- private boolean isDownMessage(int msgType) {
- boolean isDownMsg = false;
- switch (msgType) {
- case MessageDefs.WM_LBUTTONDOWN:
- case MessageDefs.WM_RBUTTONDOWN:
- case MessageDefs.WM_MBUTTONDOWN:
- case MessageDefs.WM_XBUTTONDOWN:
- case MessageDefs.WM_NCLBUTTONDOWN:
- case MessageDefs.WM_NCRBUTTONDOWN:
- case MessageDefs.WM_NCMBUTTONDOWN:
- case MessageDefs.WM_NCXBUTTONDOWN:
- isDownMsg = true;
- break;
- default:
- break;
- }
- return isDownMsg;
- }
-
- private boolean isDblclkMessage(int msgType) {
- boolean isDblclkMsg = false;
- switch (msgType) {
- case MessageDefs.WM_LBUTTONDBLCLK:
- case MessageDefs.WM_RBUTTONDBLCLK:
- case MessageDefs.WM_MBUTTONDBLCLK:
- case MessageDefs.WM_XBUTTONDBLCLK:
- case MessageDefs.WM_NCLBUTTONDBLCLK:
- case MessageDefs.WM_NCRBUTTONDBLCLK:
- case MessageDefs.WM_NCMBUTTONDBLCLK:
- case MessageDefs.WM_NCXBUTTONDBLCLK:
- isDblclkMsg = true;
- break;
- default:
- break;
- }
- return isDblclkMsg;
- }
-
- private boolean isUpMessage(int msgType) {
- boolean isUpMsg = false;
- switch (msgType) {
- case MessageDefs.WM_LBUTTONUP:
- case MessageDefs.WM_RBUTTONUP:
- case MessageDefs.WM_MBUTTONUP:
- case MessageDefs.WM_XBUTTONUP:
- case MessageDefs.WM_NCLBUTTONUP:
- case MessageDefs.WM_NCRBUTTONUP:
- case MessageDefs.WM_NCMBUTTONUP:
- case MessageDefs.WM_NCXBUTTONUP:
- isUpMsg = true;
- break;
- default:
- break;
- }
- return isUpMsg;
- }
-
-}
Index: trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/commands/CMDconvertDirToXml.java
===================================================================
--- trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/commands/CMDconvertDirToXml.java (revision 51)
+++ (revision )
@@ -1,41 +1,0 @@
-package de.ugoe.cs.eventbench.commands;
-
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.security.InvalidParameterException;
-import java.util.List;
-
-import de.ugoe.cs.eventbench.LogPreprocessor;
-import de.ugoe.cs.util.console.Command;
-import de.ugoe.cs.util.console.Console;
-
-public class CMDconvertDirToXml implements Command {
-
- @Override
- public void help() {
- Console.println("Usage: convertToXml {}");
- }
-
- @Override
- public void run(List