This commit is contained in:
Greg Oliver 2018-08-23 13:30:37 +01:00
Родитель 0249645cd2
Коммит d419430bc3
2 изменённых файлов: 1903 добавлений и 35 удалений

Просмотреть файл

@ -1,5 +1,6 @@
using System;
using System.Globalization;
using System.Text;
using System.Text.RegularExpressions;
using Newtonsoft.Json;
@ -41,10 +42,13 @@ class NSGFlowLogTuple
if (version >= 2.0)
{
flowState = parts[8];
packetsStoD = parts[9];
bytesStoD = parts[10];
packetsDtoS = parts[11];
bytesDtoS = parts[12];
if (flowState != "B")
{
packetsStoD = parts[9];
bytesStoD = parts[10];
packetsDtoS = parts[11];
bytesDtoS = parts[12];
}
}
}
@ -55,38 +59,43 @@ class NSGFlowLogTuple
public override string ToString()
{
string temp = "";
temp += "rt=" + (Convert.ToUInt64(startTime) * 1000).ToString();
temp += " src=" + sourceAddress;
temp += " dst=" + destinationAddress;
temp += " spt=" + sourcePort;
temp += " dpt=" + destinationPort;
temp += " proto=" + (transportProtocol == "U" ? "UDP" : "TCP");
temp += " deviceDirection=" + (deviceDirection == "I" ? "0" : "1");
temp += " act=" + deviceAction;
var temp = new StringBuilder();
temp.Append("rt=").Append((Convert.ToUInt64(startTime) * 1000).ToString());
temp.Append(" src=").Append(sourceAddress);
temp.Append(" dst=").Append(destinationAddress);
temp.Append(" spt=").Append(sourcePort);
temp.Append(" dpt=").Append(destinationPort);
temp.Append(" proto=").Append((transportProtocol == "U" ? "UDP" : "TCP"));
temp.Append(" deviceDirection=").Append((deviceDirection == "I" ? "0" : "1"));
temp.Append(" act=").Append(deviceAction);
if (schemaVersion >= 2.0)
{
// add fields from version 2 schema
temp += String.Format(" cs2={0}", flowState);
temp += String.Format(" cs2Label=FlowState");
temp += String.Format(" cn1={0}", packetsStoD);
temp += String.Format(" cn1Label=PacketsStoD");
temp += String.Format(" cn2={0}", packetsDtoS);
temp += String.Format(" cn2Label=PacketsDtoS");
temp.Append(" cs2=").Append(flowState);
temp.Append(" cs2Label=FlowState");
if (deviceDirection == "I")
if (flowState != "B")
{
temp += String.Format(" bytesIn={0}", bytesStoD);
temp += String.Format(" bytesOut={0}", bytesDtoS);
} else
{
temp += String.Format(" bytesIn={0}", bytesDtoS);
temp += String.Format(" bytesOut={0}", bytesStoD);
temp.Append(" cn1=").Append(packetsStoD);
temp.Append(" cn1Label=PacketsStoD");
temp.Append(" cn2=").Append(packetsDtoS);
temp.Append(" cn2Label=PacketsDtoS");
if (deviceDirection == "I")
{
temp.Append(" bytesIn={0}").Append(bytesStoD);
temp.Append(" bytesOut={0}").Append(bytesDtoS);
}
else
{
temp.Append(" bytesIn={0}").Append(bytesDtoS);
temp.Append(" bytesOut={0}").Append(bytesStoD);
}
}
}
return temp;
return temp.ToString();
}
}
@ -97,15 +106,15 @@ class NSGFlowLogsInnerFlows
public string MakeMAC()
{
string temp = "";
temp += mac.Substring(0, 2) + ":";
temp += mac.Substring(2, 2) + ":";
temp += mac.Substring(4, 2) + ":";
temp += mac.Substring(6, 2) + ":";
temp += mac.Substring(8, 2) + ":";
temp += mac.Substring(10, 2);
var temp = new StringBuilder();
temp.Append(mac.Substring(0, 2)).Append(":");
temp.Append(mac.Substring(2, 2)).Append(":");
temp.Append(mac.Substring(4, 2)).Append(":");
temp.Append(mac.Substring(6, 2)).Append(":");
temp.Append(mac.Substring(8, 2)).Append(":");
temp.Append(mac.Substring(10, 2));
return temp;
return temp.ToString();
}
}

Разница между файлами не показана из-за своего большого размера Загрузить разницу