using sys = System;
using Cosmos.HAL.Network;
using Cosmos.System.Network.ARP;
namespace Cosmos.System.Network.IPv4
{
///
/// IPPacket class. See also: .
///
public class IPPacket : EthernetPacket
{
protected byte ipHeaderLength;
private static ushort sNextFragmentID;
///
/// IPv4 handler.
///
/// Packet data.
/// Thrown on fatal error (contact support).
/// Thrown on IO error.
/// Thrown on fatal error (contact support).
/// Thrown if packetData array length is greater than Int32.MaxValue.
internal static void IPv4Handler(byte[] packetData)
{
IPPacket ip_packet = new IPPacket(packetData);
//Sys.Console.WriteLine("Received IP Packet");
//Sys.Console.WriteLine(ip_packet.ToString());
if (ip_packet.SourceIP == null)
{
NetworkStack.debugger.Send("SourceIP null in IPv4Handler!");
}
ARPCache.Update(ip_packet.SourceIP, ip_packet.SourceMAC);
if ((NetworkStack.AddressMap.ContainsKey(ip_packet.DestinationIP.Hash) == true) ||
(ip_packet.DestinationIP.address[3] == 255))
{
switch (ip_packet.Protocol)
{
case 1:
ICMPPacket.ICMPHandler(packetData);
break;
case 6:
//TCPPacket.TCPHandler(packetData);
break;
case 17:
UDPPacket.UDPHandler(packetData);
break;
}
}
}
///
/// Get next IP fragment ID.
///
public static ushort NextIPFragmentID => sNextFragmentID++;
///
/// Create new inctanse of the class.
///
internal IPPacket()
{
}
///
/// Create new inctanse of the class.
///
/// Raw data.
internal IPPacket(byte[] rawData)
: base(rawData)
{
}
///
/// Init IPPacket fields.
///
/// Thrown if RawData is invalid or null.
protected override void initFields()
{
base.initFields();
IPVersion = (byte)((RawData[14] & 0xF0) >> 4);
ipHeaderLength = (byte)(RawData[14] & 0x0F);
TypeOfService = RawData[15];
IPLength = (ushort)((RawData[16] << 8) | RawData[17]);
FragmentID = (ushort)((RawData[18] << 8) | RawData[19]);
Flags = (byte)((RawData[20] & 0xE0) >> 5);
FragmentOffset = (ushort)(((RawData[20] & 0x1F) << 8) | RawData[21]);
TTL = RawData[22];
Protocol = RawData[23];
IPCRC = (ushort)((RawData[24] << 8) | RawData[25]);
SourceIP = new Address(RawData, 26);
DestinationIP = new Address(RawData, 30);
DataOffset = (ushort)(14 + HeaderLength);
}
///
/// Create new inctanse of the class.
///
/// Data length.
/// Protocol.
/// Source address.
/// Destionation address.
/// Flags.
protected IPPacket(ushort dataLength, byte protocol, Address source, Address dest, byte Flags)
: this(MACAddress.None, MACAddress.None, dataLength, protocol, source, dest, Flags)
{ }
///
/// Create new inctanse of the class.
///
/// Source MAC address.
/// Destination MAC address.
/// Data length.
/// Protocol.
/// Source address.
/// Destionation address.
/// Flags.
/// Thrown if RawData is invalid or null.
public IPPacket(MACAddress srcMAC, MACAddress destMAC, ushort dataLength, byte protocol,
Address source, Address dest, byte Flags)
: base(destMAC, srcMAC, 0x0800, dataLength + 14 + 20)
{
RawData[14] = 0x45;
RawData[15] = 0;
IPLength = (ushort)(dataLength + 20);
ipHeaderLength = 5;
RawData[16] = (byte)((IPLength >> 8) & 0xFF);
RawData[17] = (byte)((IPLength >> 0) & 0xFF);
FragmentID = NextIPFragmentID;
RawData[18] = (byte)((FragmentID >> 8) & 0xFF);
RawData[19] = (byte)((FragmentID >> 0) & 0xFF);
RawData[20] = Flags;
RawData[21] = 0x00;
RawData[22] = 0x80;
RawData[23] = protocol;
RawData[24] = 0x00;
RawData[25] = 0x00;
for (int b = 0; b < 4; b++)
{
RawData[26 + b] = source.address[b];
RawData[30 + b] = dest.address[b];
}
IPCRC = CalcIPCRC(20);
RawData[24] = (byte)((IPCRC >> 8) & 0xFF);
RawData[25] = (byte)((IPCRC >> 0) & 0xFF);
initFields();
}
///
/// Calcutale CRC.
///
/// Offset.
/// Length.
///
protected ushort CalcOcCRC(ushort offset, ushort length) => CalcOcCRC(RawData, offset, length);
///
/// Calcutale CRC.
///
/// Buffer.
/// Offset.
/// Length.
/// ushort value.
protected static ushort CalcOcCRC(byte[] buffer, ushort offset, int length)
{
uint crc = 0;
for (ushort w = offset; w < offset + length; w += 2)
{
crc += (ushort)((buffer[w] << 8) | buffer[w + 1]);
}
crc = (~((crc & 0xFFFF) + (crc >> 16)));
return (ushort)crc;
}
///
/// Calcutale CRC.
///
/// Header length.
/// ushort value.
protected ushort CalcIPCRC(ushort headerLength)
{
return CalcOcCRC(14, headerLength);
}
///
/// Get IP version.
///
internal byte IPVersion { get; private set; }
///
/// Get header length.
///
internal ushort HeaderLength => (ushort)(ipHeaderLength * 4);
///
/// Get type of service.
///
internal byte TypeOfService { get; private set; }
///
/// Get IP length.
///
internal ushort IPLength { get; private set; }
///
/// Get fragment ID.
///
internal ushort FragmentID { get; private set; }
///
/// Get flags.
///
internal byte Flags { get; private set; }
///
/// Get fragment offset.
///
internal ushort FragmentOffset { get; private set; }
///
/// Get TTL.
///
internal byte TTL { get; private set; }
///
/// Get protocol.
///
internal byte Protocol { get; private set; }
///
/// Get IPCRC.
///
internal ushort IPCRC { get; private set; }
///
/// Get source IP.
///
internal Address SourceIP { get; private set; }
///
/// Get destination IP.
///
internal Address DestinationIP { get; private set; }
///
/// Get data offset.
///
internal ushort DataOffset { get; private set; }
///
/// Get data length.
///
internal ushort DataLength => (ushort)(IPLength - HeaderLength);
///
/// To string.
///
/// string value.
public override string ToString()
{
return "IP Packet Src=" + SourceIP + ", Dest=" + DestinationIP + ", Protocol=" + Protocol + ", TTL=" + TTL + ", DataLen=" + DataLength;
}
}
}