-
Notifications
You must be signed in to change notification settings - Fork 82
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Changes improving IPv6 and adding SRv6 encap/decap and some processing capabilities to showcase the HIRT paper to be presented at ICNP'24
- Loading branch information
Showing
38 changed files
with
4,001 additions
and
602 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
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,173 @@ | ||
| /* | ||
| * ip6drop.{cc,hh} -- element drops packets following a Gilbert Eliott model | ||
| * Louis Navarre | ||
| * | ||
| * Copyright (c) 2024 UCLouvain | ||
| * | ||
| * Permission is hereby granted, free of charge, to any person obtaining a | ||
| * copy of this software and associated documentation files (the "Software"), | ||
| * to deal in the Software without restriction, subject to the conditions | ||
| * listed in the Click LICENSE file. These conditions include: you must | ||
| * preserve this copyright notice, and you cannot mention the copyright | ||
| * holders in advertising related to the Software without their permission. | ||
| * The Software is provided WITHOUT ANY WARRANTY, EXPRESS OR IMPLIED. This | ||
| * notice is a summary of the Click LICENSE file; the license in that file is | ||
| * legally binding. | ||
| */ | ||
|
|
||
| #include <click/config.h> | ||
| #include "ip6drop.hh" | ||
| #include <click/nameinfo.hh> | ||
| #include <click/confparse.hh> | ||
| #include <click/error.hh> | ||
| #include <click/glue.hh> | ||
|
|
||
| CLICK_DECLS | ||
|
|
||
| IP6Drop::IP6Drop() | ||
| { | ||
| _use_dst_anno = false; | ||
| } | ||
|
|
||
| IP6Drop::~IP6Drop() | ||
| { | ||
| } | ||
|
|
||
| int | ||
| IP6Drop::configure(Vector<String> &conf, ErrorHandler *errh) | ||
| { | ||
| if (Args(conf, this, errh) | ||
| .read_all("ADDR", addrs) | ||
| .read_or_set("P", p, 0) | ||
| .read_or_set("R", r, 0) | ||
| .read_or_set("H", h, 0) | ||
| .read_or_set("K", k, 1) | ||
| .read_or_set("SEED", seed, 51) | ||
| .complete() < 0) | ||
| return -1; | ||
|
|
||
| total_seen = 0; | ||
| srand(seed); | ||
| state = good; | ||
|
|
||
| return 0; | ||
| } | ||
|
|
||
| void | ||
| IP6Drop::push(int input, Packet *p_in) | ||
| { | ||
| drop_model(p_in, [this](Packet*p){output(0).push(p);}); | ||
| } | ||
|
|
||
| #if HAVE_BATCH | ||
| void | ||
| IP6Drop::push_batch(int input, PacketBatch *batch) { | ||
| EXECUTE_FOR_EACH_PACKET_DROPPABLE(drop_model, batch, [](Packet *){}); | ||
| if (batch) { | ||
| output_push_batch(0, batch); | ||
| } | ||
| } | ||
| #endif | ||
|
|
||
| #if HAVE_BATCH | ||
| Packet * | ||
| #else | ||
| void | ||
| #endif | ||
| IP6Drop::drop_model(Packet *p_in) | ||
| { | ||
| return drop_model(p_in, [this](Packet*p){output(0).push(p);}); | ||
| } | ||
|
|
||
| #if HAVE_BATCH | ||
| Packet * | ||
| #else | ||
| void | ||
| #endif | ||
| IP6Drop::drop_model(Packet *p_in, std::function<void(Packet*)>push) | ||
| { | ||
| const click_ip6 *ip6 = reinterpret_cast<const click_ip6 *>(p_in->data()); | ||
| uint32_t *dst_32 = (uint32_t *)&ip6->ip6_dst; | ||
| bool found = false; | ||
| for (int i = 0; i < addrs.size(); ++i) { | ||
| IP6Address addr = addrs.at(i); | ||
| uint32_t *addr_32 = (uint32_t *)addr.data32(); | ||
| if (addr_eq(addr_32, dst_32)) { | ||
| found = true; | ||
| break; | ||
| } | ||
| } | ||
| if (!found) { | ||
| #if HAVE_BATCH | ||
| return p_in; | ||
| #else | ||
| push(p_in); | ||
| #endif | ||
| } | ||
|
|
||
| total_seen++; | ||
| // Do not drop the first packets to ensure a connection between the client and the broker | ||
| if (total_seen < 20) { | ||
| return p_in; | ||
| } | ||
|
|
||
| if (!gemodel()) { | ||
| click_chatter("Drop packet #%u", total_seen); | ||
| #if HAVE_BATCH | ||
| return 0; | ||
| } | ||
| return p_in; | ||
| #else | ||
| } | ||
| push(p_in); | ||
| #endif | ||
| } | ||
|
|
||
| bool | ||
| IP6Drop::gemodel() | ||
| { | ||
| bool keep_packet = true; | ||
| bool change_state = false; | ||
| // click_chatter("State is %u", state); | ||
| if (state == good) { | ||
| double rand_val1 = rand() / (RAND_MAX + 1.); | ||
| // click_chatter("Generated value: %f", rand_val1); | ||
| keep_packet = rand_val1 < k; | ||
| rand_val1 = rand() / (RAND_MAX + 1.); | ||
| change_state = rand_val1 < p; | ||
| // click_chatter("K and keep packet: %f, %u change state=%u (p=%u)", k * 100, keep_packet, change_state, p * 100); | ||
| if (change_state) { | ||
| state = bad; | ||
| } | ||
| } else { | ||
| double rand_val1 = rand() / (RAND_MAX + 1.); | ||
| keep_packet = rand_val1 < h; | ||
| rand_val1 = rand() / (RAND_MAX + 1.); | ||
| change_state = rand_val1 < r; | ||
| if (change_state) { | ||
| state = good; | ||
| } | ||
| } | ||
| return keep_packet; | ||
| } | ||
|
|
||
| bool | ||
| IP6Drop::addr_eq(uint32_t *a1, uint32_t *a2) | ||
| { | ||
| return (a1[0] == a2[0] && a1[1] == a2[1] && a1[2] == a2[2] && a1[3] == a2[3]); | ||
| } | ||
|
|
||
| String | ||
| IP6Drop::read_handler(Element *e, void *thunk) | ||
| { | ||
| return "<error>"; | ||
| } | ||
|
|
||
| void | ||
| IP6Drop::add_handlers() | ||
| { | ||
| } | ||
|
|
||
| CLICK_ENDDECLS | ||
| EXPORT_ELEMENT(IP6Drop) | ||
| ELEMENT_MT_SAFE(IP6Drop) |
Oops, something went wrong.