Pcap Sctp数据拆分

/******************************************************************** created: 2013/01/15 created: 15:1:2013 18:05 file base: main file ext: c author: LeoY purpose: *********************************************************************/ #include"pcap_adapter.h" #include <stdio.h> #define MAX_CHUNK_NUM 10 // 数据包头+IP头+eth信息+sctp头的长度和 x为IP头结构 #define LENGTH_SCTPALLHEADER(x) x.byteHdLength*4 + sizeof( __EthernetInfo) + sizeof( __SctpHeader) #define LENGTH_SCTPIPHEADER(x) sizeof( __SctpHeader) bool main() { __pcap_header header; int iNo = 1; // 打开源文件和输出文件 if( !OpenPcapFile( "sctp.pcap") || !OpenOutFile( "export.pcap")) { return false; } // 获得文件头 GetPcapHeader( &header); //写入文件头 WriteFileHeader( &header); MoveFirst(); while( !IeEof()) { __pk_header data; __ip_header ipData; __EthernetInfo ethInfo; Byte* pBuffer; // 获取下一个数据包 GetPacketAndMoveNext( &data, &pBuffer); // 获得ETH信息 GetEthernetInfo( &ethInfo, pBuffer, 0); // 获得IP信息 GetIpData( &ipData, pBuffer, sizeof(__EthernetInfo)); // SCTP == 132 if( ipData.byteProtocol == 132) { // 获取SCTP头 int iOffset = sizeof( __EthernetInfo) + ipData.byteHdLength * 4; int iChunkOffset = iOffset + sizeof( __SctpHeader); __SctpHeader sctpHeader; __SctpChunk sctpChunkArr[MAX_CHUNK_NUM]; // 当前已保存的chunk数量 int iChunkNum = 0; // 当前已保存的chunk长度 int iLenght = 0; // 获得SCTP头 GetSctpHeader( &sctpHeader, pBuffer, iOffset); while( true) { // 当前读取的chunk __SctpChunk sctpChunk; // for 循环标志 int i = 0; GetSctpChunk( &sctpChunk, pBuffer, iChunkOffset); if( sctpChunk.header.Type == 0) // DATA块 建立新数据包并写入chunk信息 { WritePkHeader( &data, iLenght + sctpChunk.header.iLength + LENGTH_SCTPALLHEADER(ipData)); WriteEthInfo( &ethInfo); WriteIpHeader( &ipData, iLenght + sctpChunk.header.iLength + LENGTH_SCTPIPHEADER(ipData)); WriteSctpHeader( &sctpHeader); for( i = 0; i < iChunkNum; i++) { WriteSctpChunk( sctpChunkArr + i); } WriteSctpChunk( &sctpChunk); iChunkNum = iLenght = 0; } else { // 当前块位非DATA块 sctpChunkArr[ iChunkNum++] = sctpChunk; iLenght += sctpChunk.header.iLength; } iChunkOffset += sctpChunk.header.iLength; if( iChunkOffset >= ipData.iTotalLength - ((ipData.byteHdLength & 0x0f) * 4)) { if( iChunkNum > 0) { // 存在未写入的chunk数据,全部新建数据包写入 if( sctpChunk.header.Type != 0) iLenght -= sctpChunk.header.iLength; WritePkHeader( &data, iLenght + sctpChunk.header.iLength + LENGTH_SCTPALLHEADER(ipData)); WriteEthInfo( &ethInfo); WriteIpHeader( &ipData, iLenght + sctpChunk.header.iLength + LENGTH_SCTPIPHEADER(ipData)); WriteSctpHeader( &sctpHeader); for( i = 0; i < iChunkNum; i++) { WriteSctpChunk( sctpChunkArr + i); } } break; } } } free( pBuffer); } CloseOutFile(); ClosePcapFile(); printf( "Export over"); return true; }