SCViewer/com.minres.scviewer.databas.../src/com/minres/scviewer/database/text/TextDbLoader.groovy

164 lines
5.9 KiB
Groovy
Raw Normal View History

2012-06-17 20:34:50 +02:00
/*******************************************************************************
* Copyright (c) 2012 IT Just working.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* IT Just working - initial API and implementation
*******************************************************************************/
package com.minres.scviewer.database.text;
2012-06-17 19:53:05 +02:00
2015-01-20 18:50:15 +01:00
import com.minres.scviewer.database.AssociationType
import com.minres.scviewer.database.DataType
import com.minres.scviewer.database.ITxGenerator
import com.minres.scviewer.database.ITxStream
import com.minres.scviewer.database.IWaveform
2015-01-20 18:50:15 +01:00
import com.minres.scviewer.database.IWaveformDb
import com.minres.scviewer.database.IWaveformDbLoader
import com.minres.scviewer.database.RelationType
2012-06-17 19:53:05 +02:00
public class TextDbLoader implements IWaveformDbLoader{
2012-06-17 19:53:05 +02:00
2015-01-20 18:50:15 +01:00
private Long maxTime;
IWaveformDb db;
2012-06-17 19:53:05 +02:00
def streams = []
2015-01-01 23:17:32 +01:00
def relationTypes=[:]
2012-06-17 19:53:05 +02:00
public TextDbLoader() {
2012-06-17 19:53:05 +02:00
}
@Override
2015-01-20 18:50:15 +01:00
public Long getMaxTime() {
2012-06-17 19:53:05 +02:00
return maxTime;
}
@Override
public List<IWaveform> getAllWaves() {
return new LinkedList<IWaveform>(streams);
2012-06-17 19:53:05 +02:00
}
2015-01-06 17:14:16 +01:00
public Map<Long, ITxGenerator> getGeneratorsById() {
TreeMap<Long, ITxGenerator> res = new TreeMap<Long, ITxGenerator>();
streams.each{TxStream stream -> stream.generators.each{res.put(it.id, id)} }
2012-06-17 19:53:05 +02:00
return res;
}
static final byte[] x = "scv_tr_stream".bytes
@Override
boolean load(IWaveformDb db, File file) throws Exception {
this.db=db
this.streams=[]
FileInputStream fis = new FileInputStream(file)
byte[] buffer = new byte[x.size()]
def readCnt = fis.read(buffer, 0, x.size())
fis.close()
if(readCnt==x.size())
for(int i=0; i<x.size(); i++)
if(buffer[i]!=x[i]) return false
2012-06-17 19:53:05 +02:00
parseInput(file)
2015-01-20 18:50:15 +01:00
calculateConcurrencyIndicees()
return true
2012-06-17 19:53:05 +02:00
}
2015-01-20 18:50:15 +01:00
private stringToScale(String scale){
switch(scale.trim()){
case "fs":return 1L
case "ps":return 1000L
case "ns":return 1000000L
case "us":return 1000000000L
case "ms":return 1000000000000L
case "s": return 1000000000000000L
}
}
private def parseInput(File input){
2012-06-17 19:53:05 +02:00
def streamsById = [:]
def generatorsById = [:]
def transactionsById = [:]
2015-01-06 17:14:16 +01:00
TxGenerator generator
Tx transaction
2012-06-17 19:53:05 +02:00
boolean endTransaction=false
def matcher
input.eachLine { line ->
def tokens = line.split(/\s+/)
switch(tokens[0]){
case "scv_tr_stream":
case "scv_tr_generator":
case "begin_attribute":
case "end_attribute":
if ((matcher = line =~ /^scv_tr_stream\s+\(ID (\d+),\s+name\s+"([^"]+)",\s+kind\s+"([^"]+)"\)$/)) {
def id = Integer.parseInt(matcher[0][1])
def stream = new TxStream(db, id, matcher[0][2], matcher[0][3])
2012-06-17 19:53:05 +02:00
streams<<stream
streamsById[id]=stream
} else if ((matcher = line =~ /^scv_tr_generator\s+\(ID\s+(\d+),\s+name\s+"([^"]+)",\s+scv_tr_stream\s+(\d+),$/)) {
def id = Integer.parseInt(matcher[0][1])
2015-01-06 17:14:16 +01:00
ITxStream stream=streamsById[Integer.parseInt(matcher[0][3])]
generator=new TxGenerator(id, stream, matcher[0][2])
2012-06-17 19:53:05 +02:00
stream.generators<<generator
generatorsById[id]=generator
} else if ((matcher = line =~ /^begin_attribute \(ID (\d+), name "([^"]+)", type "([^"]+)"\)$/)) {
2015-01-06 17:14:16 +01:00
generator.begin_attrs << TxAttributeType.getAttrType(matcher[0][2], DataType.valueOf(matcher[0][3]), AssociationType.BEGIN)
2012-06-17 19:53:05 +02:00
} else if ((matcher = line =~ /^end_attribute \(ID (\d+), name "([^"]+)", type "([^"]+)"\)$/)) {
2015-01-06 17:14:16 +01:00
generator.end_attrs << TxAttributeType.getAttrType(matcher[0][2], DataType.valueOf(matcher[0][3]), AssociationType.END)
2012-06-17 19:53:05 +02:00
}
break;
case ")":
generator=null
break
case "tx_begin"://matcher = line =~ /^tx_begin\s+(\d+)\s+(\d+)\s+(\d+)\s+([munpf]?s)/
def id = Integer.parseInt(tokens[1])
2015-01-06 17:14:16 +01:00
TxGenerator gen=generatorsById[Integer.parseInt(tokens[2])]
2015-01-20 18:50:15 +01:00
transaction = new Tx(id, gen.stream, gen, Long.parseLong(tokens[3])*stringToScale(tokens[4]))
2012-06-17 19:53:05 +02:00
gen.transactions << transaction
transactionsById[id]= transaction
gen.begin_attrs_idx=0;
maxTime = maxTime>transaction.beginTime?maxTime:transaction.beginTime
endTransaction=false
break
case "tx_end"://matcher = line =~ /^tx_end\s+(\d+)\s+(\d+)\s+(\d+)\s+([munpf]?s)/
def id = Integer.parseInt(tokens[1])
transaction = transactionsById[id]
assert Integer.parseInt(tokens[2])==transaction.generator.id
2015-01-20 18:50:15 +01:00
transaction.endTime = Long.parseLong(tokens[3])*stringToScale(tokens[4])
2012-06-17 19:53:05 +02:00
transaction.generator.end_attrs_idx=0;
maxTime = maxTime>transaction.endTime?maxTime:transaction.endTime
endTransaction=true
break
case "tx_record_attribute"://matcher = line =~ /^tx_record_attribute\s+(\d+)\s+"([^"]+)"\s+(\S+)\s*=\s*(.+)$/
def id = Integer.parseInt(tokens[1])
2015-01-06 17:14:16 +01:00
transactionsById[id].attributes<<new TxAttribute(tokens[2][1..-2], DataType.valueOf(tokens[3]), AssociationType.RECORD, tokens[5..-1].join(' '))
2012-06-17 19:53:05 +02:00
break
case "a"://matcher = line =~ /^a\s+(.+)$/
if(endTransaction){
2015-01-06 17:14:16 +01:00
transaction.attributes << new TxAttribute(transaction.generator.end_attrs[0], tokens[1])
2012-06-17 19:53:05 +02:00
} else {
2015-01-06 17:14:16 +01:00
transaction.attributes << new TxAttribute(transaction.generator.begin_attrs[0], tokens[1])
2012-06-17 19:53:05 +02:00
}
break
case "tx_relation"://matcher = line =~ /^tx_relation\s+\"(\S+)\"\s+(\d+)\s+(\d+)$/
Tx tr2= transactionsById[Integer.parseInt(tokens[2])]
Tx tr1= transactionsById[Integer.parseInt(tokens[3])]
2015-01-01 23:17:32 +01:00
def relType=tokens[1][1..-2]
if(!relationTypes.containsKey(relType)) relationTypes[relType]=new RelationType(relType)
2015-01-06 17:14:16 +01:00
def rel = new TxRelation(relationTypes[relType], tr1, tr2)
2015-01-01 23:17:32 +01:00
tr1.outgoingRelations<<rel
tr2.incomingRelations<<rel
2012-06-17 19:53:05 +02:00
break
default:
println "Don't know what to do with: '$line'"
}
}
}
2015-01-20 18:50:15 +01:00
private def calculateConcurrencyIndicees(){
streams.each{ TxStream stream -> stream.getMaxConcurrency() }
}
2012-06-17 19:53:05 +02:00
}