Skip to content

Commit

Permalink
Experimental IPC import from PCAP (#394)
Browse files Browse the repository at this point in the history 
Signed-off-by: Alexander Wenzel <[email protected]>
  • Loading branch information
@alexmucde
alexmucde authored Dec 6, 2023
1 parent 920a4d0 commit ec0018a
Show file tree
Hide file tree
Showing 3 changed files with 244 additions and 2 deletions.
238 changes: 236 additions & 2 deletions src/mainwindow.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1380,7 +1380,7 @@ void MainWindow::on_actionImport_DLT_from_PCAP_triggered()
inputfile.close();
return;
}
quint16 etherType = record.at(pos)<<8+record.at(pos+1);
quint16 etherType = (((quint16)record.at(pos))<<8)|((quint16)(record.at(pos+1)&0xff));
if(etherType==0x8100)
{
// VLAN tagging used
Expand All @@ -1391,7 +1391,7 @@ void MainWindow::on_actionImport_DLT_from_PCAP_triggered()
inputfile.close();
return;
}
etherType = record.at(pos)<<8+record.at(pos+1);
etherType = (((quint16)record.at(pos))<<8)|((quint16)(record.at(pos+1)&0xff));
}
if(etherType==0x0800) // IP packet found
{
Expand Down Expand Up @@ -1466,6 +1466,239 @@ void MainWindow::on_actionImport_DLT_from_PCAP_triggered()
reloadLogFile();
}

typedef struct plp_header {
quint16 probeId;
quint16 counter;
quint8 version;
quint8 plpType;
quint16 msgType;
quint16 reserved;
quint16 probeFlags;
} PACKED plp_header_t;

typedef struct plp_header_data {
quint32 busSpecId;
quint32 timeStampHigh;
quint32 timeStampLow;
quint16 length;
quint16 dataFlags;
} PACKED plp_header_data_t;

void MainWindow::on_actionImport_IPC_from_PCAP_triggered()
{
quint32 counterRecords = 0, counterRecordsIPC = 0, counterIPCMessages = 0;
QString fileName = QFileDialog::getOpenFileName(this,
tr("Import IPC from PCAP file"), workingDirectory.getDltDirectory(), tr("PCAP file (*.pcap)"));

if(fileName.isEmpty())
return;

/* change DLT file working directory */
workingDirectory.setDltDirectory(QFileInfo(fileName).absolutePath());

if(!outputfile.isOpen())
return;

QFile inputfile(fileName);

if(!inputfile.open(QFile::ReadOnly))
return;

QProgressDialog progress("Import IPC from PCAP...", "Abort Import", 0, inputfile.size()/1000, this);
progress.setWindowModality(Qt::WindowModal);

pcap_hdr_t globalHeader;
pcaprec_hdr_t recordHeader;

qDebug() << "Import DLt from PCAp file:" << fileName;

if(inputfile.read((char*)&globalHeader,sizeof(pcap_hdr_t))!=sizeof(pcap_hdr_t))
{
inputfile.close();
return;
}

bool inSegment = false;
QByteArray segmentBuffer;
while(inputfile.read((char*)&recordHeader,sizeof(pcaprec_hdr_t))==sizeof(pcaprec_hdr_t))
{
progress.setValue(inputfile.pos()/1000);

if (progress.wasCanceled())
{
inputfile.close();

qDebug() << "Counter Records:" << counterRecords;
qDebug() << "Counter Records IPC:" << counterRecordsIPC;
qDebug() << "Counter IPC Mesages:" << counterIPCMessages;

reloadLogFile();
return;
}

QByteArray record = inputfile.read(recordHeader.incl_len);
if(record.length() != recordHeader.incl_len)
{
inputfile.close();
qDebug() << "PCAP file not complete!";
qDebug() << "Counter Records:" << counterRecords;
qDebug() << "Counter Records IPC:" << counterRecordsIPC;
qDebug() << "Counter IPC Mesages:" << counterIPCMessages;
return;
}
counterRecords ++;
// Check if Record is PLP packet
quint64 pos = 12;
//Read EtherType
if(record.size()<(pos+2))
{
qDebug() << "Size issue!";
inputfile.close();
qDebug() << "PCAP file not complete!";
qDebug() << "Counter Records:" << counterRecords;
qDebug() << "Counter Records IPC:" << counterRecordsIPC;
qDebug() << "Counter IPC Mesages:" << counterIPCMessages;
return;
}
quint16 etherType = (((quint16)record.at(pos))<<8)|((quint16)(record.at(pos+1)&0xff));
if(etherType==0x8100)
{
// VLAN tagging used
pos+=4;
if(record.size()<(pos+2))
{
qDebug() << "Size issue!";
inputfile.close();
qDebug() << "PCAP file not complete!";
qDebug() << "Counter Records:" << counterRecords;
qDebug() << "Counter Records IPC:" << counterRecordsIPC;
qDebug() << "Counter IPC Mesages:" << counterIPCMessages;
return;
}
etherType = (((quint16)record.at(pos))<<8)|((quint16)(record.at(pos+1)&0xff));
}
if(etherType==0x2090) // PLP packet found
{
pos += 2;

if(record.size()<(pos+sizeof(plp_header_t)))
{
qDebug() << "Size issue!";
inputfile.close();
return;
}
plp_header_t *plpHeader = (plp_header_t *) (record.data()+pos);

pos += sizeof(plp_header_t);

bool startOfSegment = qFromBigEndian(plpHeader->probeFlags) & 0x2;
if(startOfSegment)
{
inSegment = true;
segmentBuffer.clear();
}
bool endOfSegment = qFromBigEndian(plpHeader->probeFlags) & 0x1;
if(endOfSegment)
{
inSegment = false;
}
bool multiFrame = qFromBigEndian(plpHeader->probeFlags) & 0x8;
if(qFromBigEndian(plpHeader->probeId) == 0xd0 && qFromBigEndian(plpHeader->msgType) == 0x500)
{
counterRecordsIPC++;
while(record.size()>=(pos+sizeof(plp_header_data_t)))
{
plp_header_data_t *plpHeaderData = (plp_header_data_t *) (record.data()+pos);

pos += sizeof(plp_header_data_t);

if(record.size()<(pos+qFromBigEndian(plpHeaderData->length)))
{
qDebug() << "Size issue!";
break;
}
counterIPCMessages++;

if(inSegment || endOfSegment)
{
segmentBuffer += record.mid(pos,qFromBigEndian(plpHeaderData->length));
}
if(!inSegment || endOfSegment)
{
/* now write DLT message here */
QByteArray empty,payload;
QDltMsg msg;

// set parameters of DLT message to be generated
msg.clear();
msg.setEcuid("IPNP");
msg.setApid("IPC");
msg.setCtid("IPC");
msg.setMode(QDltMsg::DltModeVerbose);
msg.setType(QDltMsg::DltTypeLog);
msg.setSubtype(QDltMsg::DltLogInfo);
msg.setMessageCounter(0);
msg.setNumberOfArguments(3);

// add PLP Header Data
QDltArgument arg1;
arg1.setTypeInfo(QDltArgument::DltTypeInfoRawd);
arg1.setEndianness(QDltArgument::DltEndiannessLittleEndian);
arg1.setOffsetPayload(0);
arg1.setData(record.mid(pos-sizeof(plp_header_data_t),sizeof(plp_header_data_t)));
msg.addArgument(arg1);

// add IPC Header
QDltArgument arg2;
arg2.setTypeInfo(QDltArgument::DltTypeInfoRawd);
arg2.setEndianness(QDltArgument::DltEndiannessLittleEndian);
arg2.setOffsetPayload(0);
if(endOfSegment)
{
arg2.setData(segmentBuffer.mid(0,35));
}
else
{
arg2.setData(record.mid(pos,35));
}
msg.addArgument(arg2);

// add IPC Data
QDltArgument arg3;
arg3.setTypeInfo(QDltArgument::DltTypeInfoRawd);
arg3.setEndianness(QDltArgument::DltEndiannessLittleEndian);
arg3.setOffsetPayload(0);
if(endOfSegment)
{
arg3.setData(segmentBuffer.mid(35));
segmentBuffer.clear();
}
else
{
arg3.setData(record.mid(pos+35,qFromBigEndian(plpHeaderData->length)-35));
}
msg.addArgument(arg3);

// write DLT message
msg.getMsg(payload,false);
writeDLTMessageToFile(payload,0,0,0,recordHeader.ts_sec,recordHeader.ts_usec);
}

pos += qFromBigEndian(plpHeaderData->length);
}
}
}
}
inputfile.close();

qDebug() << "Counter Records:" << counterRecords;
qDebug() << "Counter Records IPC:" << counterRecordsIPC;
qDebug() << "Counter IPC Mesages:" << counterIPCMessages;

reloadLogFile();

}

void MainWindow::on_action_menuFile_Import_DLT_Stream_with_Serial_Header_triggered()
{
QString fileName = QFileDialog::getOpenFileName(this,
Expand Down Expand Up @@ -8329,3 +8562,4 @@ void MainWindow::on_lineEditFilterEnd_textChanged(const QString &arg1)
{
applyConfigEnabled(true);
}

2 changes: 2 additions & 0 deletions src/mainwindow.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -589,6 +589,8 @@ private slots:

void on_actionImport_DLT_from_PCAP_triggered();

void on_actionImport_IPC_from_PCAP_triggered();

public slots:

void sendInjection(int index,QString applicationId,QString contextId,int serviceId,QByteArray data);
Expand Down
6 changes: 6 additions & 0 deletions src/mainwindow.ui
View file
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,7 @@
<addaction name="action_menuFile_Import_DLT_Stream"/>
<addaction name="action_menuFile_Import_DLT_Stream_with_Serial_Header"/>
<addaction name="actionImport_DLT_from_PCAP"/>
<addaction name="actionImport_IPC_from_PCAP"/>
<addaction name="action_menuFile_Append_DLT_File"/>
<addaction name="action_menuConfig_Copy_to_clipboard"/>
<addaction name="actionExport"/>
Expand Down Expand Up @@ -1676,6 +1677,11 @@
<string>Import DLT from PCAP...</string>
</property>
</action>
<action name="actionImport_IPC_from_PCAP">
<property name="text">
<string>Import IPC from PCAP...</string>
</property>
</action>
</widget>
<layoutdefault spacing="6" margin="11"/>
<customwidgets>
Expand Down

0 comments on commit ec0018a

Please sign in to comment.