-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
increase test coverage, fixes for fragmentation
- Loading branch information
Showing
6 changed files
with
155 additions
and
34 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
121 changes: 121 additions & 0 deletions
121
knet/src/test/kotlin/com/jasonernst/knet/ip/v4/Ipv4FragmentTest.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,121 @@ | ||
| package com.jasonernst.knet.ip.v4 | ||
|
|
||
| import com.jasonernst.knet.ip.IpHeader.Companion.closestDivisibleBy | ||
| import com.jasonernst.knet.ip.IpHeaderTest.Companion.byteArrayOfInts | ||
| import com.jasonernst.knet.ip.IpType | ||
| import com.jasonernst.knet.ip.v4.Ipv4Header.Companion.IP4_MIN_HEADER_LENGTH | ||
| import com.jasonernst.knet.ip.v4.Ipv4Header.Companion.IP4_WORD_LENGTH | ||
| import com.jasonernst.knet.ip.v4.options.Ipv4OptionEndOfOptionList | ||
| import com.jasonernst.knet.ip.v4.options.Ipv4OptionNoOperation | ||
| import org.junit.jupiter.api.Assertions.assertArrayEquals | ||
| import org.junit.jupiter.api.Assertions.assertEquals | ||
| import org.junit.jupiter.api.Test | ||
| import org.junit.jupiter.api.assertThrows | ||
| import java.net.InetAddress | ||
| import kotlin.math.ceil | ||
|
|
||
| class Ipv4FragmentTest { | ||
| @Test | ||
| fun fragmentationAndReassembly() { | ||
| val payload = byteArrayOfInts(0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09) | ||
| val ipv4Header = Ipv4Header(totalLength = (IP4_MIN_HEADER_LENGTH + payload.size.toUShort()).toUShort(), dontFragment = false) | ||
| val fragmentSize = closestDivisibleBy(IP4_MIN_HEADER_LENGTH + (payload.size / 2).toUInt(), 8u) | ||
| val fragments = ipv4Header.fragment(fragmentSize, payload) | ||
| assertEquals(2, fragments.size) | ||
|
|
||
| val reassembly = Ipv4Header.reassemble(fragments) | ||
| assertEquals(ipv4Header, reassembly.first) | ||
| assertArrayEquals(payload, reassembly.second) | ||
| } | ||
|
|
||
| @Test | ||
| fun emptyFragments() { | ||
| assertThrows<IllegalArgumentException> { | ||
| Ipv4Header.reassemble(emptyList()) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun singleFragmentWithoutLastFragmentSetToTrue() { | ||
| val ipv4Header = Ipv4Header(lastFragment = false) | ||
| assertThrows<IllegalArgumentException> { | ||
| Ipv4Header.reassemble(listOf(Pair(ipv4Header, ByteArray(0)))) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun singleFragmentLastFragment() { | ||
| val payload = byteArrayOfInts(0x01, 0x02, 0x03) | ||
| val ipv4Header = Ipv4Header(totalLength = (IP4_MIN_HEADER_LENGTH + payload.size.toUInt()).toUShort(), dontFragment = false) | ||
| val fragmentSize = closestDivisibleBy(IP4_MIN_HEADER_LENGTH + 8u, 8u) | ||
| val fragmented = ipv4Header.fragment(fragmentSize, payload) | ||
| val reassembled = Ipv4Header.reassemble(fragmented) | ||
| assertEquals(ipv4Header, reassembled.first) | ||
| } | ||
|
|
||
| @Test | ||
| fun notDivisbleBy8() { | ||
| val ipv4Header = Ipv4Header() | ||
| assertThrows<IllegalArgumentException> { | ||
| ipv4Header.fragment(1u, ByteArray(0)) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun nonMatchingFragmentFields() { | ||
| val ipv4Header = Ipv4Header(id = 1u) | ||
| val ipv4Header2 = Ipv4Header(id = 2u) | ||
| assertThrows<IllegalArgumentException> { | ||
| Ipv4Header.reassemble(listOf(Pair(ipv4Header, ByteArray(0)), Pair(ipv4Header2, ByteArray(0)))) | ||
| } | ||
|
|
||
| val ipv4Header3 = Ipv4Header(id = 1u, protocol = IpType.TCP.value) | ||
| assertThrows<IllegalArgumentException> { | ||
| Ipv4Header.reassemble(listOf(Pair(ipv4Header, ByteArray(0)), Pair(ipv4Header3, ByteArray(0)))) | ||
| } | ||
|
|
||
| val ipv4Header4 = Ipv4Header(id = 1u, sourceAddress = InetAddress.getLoopbackAddress()) | ||
| assertThrows<IllegalArgumentException> { | ||
| Ipv4Header.reassemble(listOf(Pair(ipv4Header, ByteArray(0)), Pair(ipv4Header4, ByteArray(0)))) | ||
| } | ||
|
|
||
| val ipv4Header5 = Ipv4Header(id = 1u, destinationAddress = InetAddress.getLoopbackAddress()) | ||
| assertThrows<IllegalArgumentException> { | ||
| Ipv4Header.reassemble(listOf(Pair(ipv4Header, ByteArray(0)), Pair(ipv4Header5, ByteArray(0)))) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun fragmentADontFragment() { | ||
| val ipv4Header = Ipv4Header(dontFragment = true) | ||
| assertThrows<IllegalArgumentException> { | ||
| ipv4Header.fragment(8u, byteArrayOfInts(0x01, 0x02, 0x03)) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun fragmentTooSmall() { | ||
| val ipv4Header = Ipv4Header(dontFragment = false) | ||
| assertThrows<IllegalArgumentException> { | ||
| ipv4Header.fragment(0u, byteArrayOfInts(0x01, 0x02, 0x03)) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun fragmentWithOptions() { | ||
| val options = listOf(Ipv4OptionNoOperation(isCopied = true), Ipv4OptionEndOfOptionList(isCopied = false)) | ||
| val optionsLength = options.sumOf { it.size.toInt() } | ||
| val payload = ByteArray(16) | ||
| val totalHeaderLength = (IP4_MIN_HEADER_LENGTH + optionsLength.toUInt()) | ||
| val ihl = ceil(totalHeaderLength.toDouble() / IP4_WORD_LENGTH.toDouble()).toUInt().toUByte() | ||
| val totalLength = (((ihl * IP4_WORD_LENGTH) + payload.size.toUInt()).toUShort()) // account for zero padding the header | ||
| val ipv4Header = Ipv4Header(ihl = ihl, totalLength = totalLength, dontFragment = false, options = options) | ||
| val maxSize = closestDivisibleBy(totalHeaderLength + 8u, 8u) | ||
| val fragments = ipv4Header.fragment(maxSize, payload) | ||
| assertEquals(2, fragments.size) | ||
|
|
||
| val reassembly = Ipv4Header.reassemble(fragments) | ||
| assertEquals(ipv4Header, reassembly.first) | ||
| assertArrayEquals(payload, reassembly.second) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters