A stack which works with or without an Mbed os library. Provides IPv4 or IPv6 with a full 1500 byte buffer.
Dependents: oldheating gps motorhome heating
Diff: eth/ar6.c
- Revision:
- 61:aad055f1b0d1
- Parent:
- 60:1d8c7a1e7483
- Child:
- 65:37acccf2752f
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/eth/ar6.c Thu Jan 11 17:38:21 2018 +0000 @@ -0,0 +1,232 @@ +#include <stdint.h> +#include <stdbool.h> + +#include "log.h" +#include "clock.h" +#include "net.h" +#include "mac.h" +#include "ip6addr.h" +#include "ns.h" +#include "http.h" + +bool Ar6Trace = false; + +#define CACHE_TIMEOUT 3600 +#define FREEZE_TIMEOUT 1800 +#define REPLY_TIMEOUT 2 +#define SEND_ATTEMPTS 3 +#define RECORDS_COUNT 20 + +#define STATE_EMPTY 0 +#define STATE_WANT 1 +#define STATE_SENT 2 +#define STATE_VALID 3 + +static uint32_t elapsed = 0; +struct record +{ + uint32_t elapsed; + char ip[16]; + uint8_t state; + uint8_t tries; + char mac[6]; +}; +static struct record records[RECORDS_COUNT]; +static int getExistingIp(char* ip) +{ + for (int i = 0; i < RECORDS_COUNT; i++) + { + if (records[i].state && Ip6AddressIsSame(records[i].ip, ip)) return i; + } + return -1; +} +static int getOldest() +{ + int iN = 0; + uint32_t tN = 0xFFFFFFFF; + for (int i = 0; i < RECORDS_COUNT; i++) + { + if (!records[i].state) return i; //Found an empty slot so just return it + if (records[i].elapsed < tN) + { + tN = records[i].elapsed; + iN = i; + } + } + return iN; //Otherwise return the oldest +} +void Ar6MakeRequestForMacFromIp(char* ip) +{ + //Don't treat non ips + if (!ip[0]) return; + int i; + + //If a record already exists then request an update + i = getExistingIp(ip); + if (i > -1) + { + if (elapsed < records[i].elapsed + FREEZE_TIMEOUT) return; + if (Ar6Trace) + { + LogTime("AR6 Updated request for MAC of "); + Ip6AddressLog(ip); + Log("\r\n"); + } + records[i].state = STATE_WANT; + records[i].tries = 0; + records[i].elapsed = elapsed; + return; + } + + //If a record does not exist then find the first empty slot and add the IP and date + if (Ar6Trace) + { + LogTime("AR6 Made request for MAC of "); + Ip6AddressLog(ip); + Log("\r\n"); + } + i = getOldest(); + Ip6AddressCopy(records[i].ip, ip); + records[i].state = STATE_WANT; + records[i].tries = 0; + records[i].elapsed = elapsed; + MacClear(records[i].mac); +} +void Ar6AddIpRecord(void (*traceback)(void), char* mac, char* ip) +{ + //Don't treat non ips + if (!ip[0]) + { + if (Ar6Trace) + { + LogTime("Ar6AddIpRecord had blank ip\r\n"); + if (NetTraceStack) traceback(); + } + return; + } + if (MacIsEmpty(mac)) + { + if (Ar6Trace) + { + LogTime("Ar6AddIpRecord had blank mac\r\n"); + if (NetTraceStack) traceback(); + } + return; + } + int i; + + //See if any record corresponds to the IP and, if so, update the MAC and time + i = getExistingIp(ip); + if (i > -1) + { + records[i].elapsed = elapsed; + records[i].state = STATE_VALID; + MacCopy(records[i].mac, mac); + return; + } + + //Otherwise find the first empty slot and add the MAC, IP and date + i = getOldest(); + MacCopy(records[i].mac, mac); + Ip6AddressCopy(records[i].ip, ip); + records[i].elapsed = elapsed; + records[i].state = STATE_VALID; + return; +} +void Ar6IpToMac(char* ip, char* mac) +{ + for (int i = 0; i < RECORDS_COUNT; i++) + { + if (records[i].state == STATE_VALID && Ip6AddressIsSame(records[i].ip, ip)) + { + MacCopy(mac, records[i].mac); + return; + } + } + MacClear(mac); +} +void Ar6SendHttp() +{ + for (int i = 0; i < RECORDS_COUNT; i++) + { + if (records[i].state) + { + HttpAddF("%4u ", (elapsed - records[i].elapsed) / 60); + + int ipLen = Ip6AddressHttp(records[i].ip); + HttpFillChar(' ', 40 - ipLen); + + MacHttp(records[i].mac); + + HttpAddChar('\r'); + HttpAddChar('\n'); + } + } +} +static void clear(struct record* pr) +{ + pr->state = STATE_EMPTY; +} +static void clearCache(struct record* pr) +{ + if (elapsed > pr->elapsed + CACHE_TIMEOUT) clear(pr); +} +static void retry(struct record* pr) +{ + if (pr->state == STATE_SENT && elapsed > pr->elapsed + REPLY_TIMEOUT) + { + if (pr->tries < SEND_ATTEMPTS) + { + pr->state = STATE_WANT; + pr->elapsed = elapsed; + pr->tries++; + } + else + { + clear(pr); + } + } +} +static void sendRequest(struct record* pr) +{ + if (!NsResolveRequestFlag) + { + if (pr->state == STATE_WANT) + { + if (Ar6Trace) + { + LogTime("AR6 Send request for MAC from IP6 "); + Ip6AddressLog(pr->ip); + Log("\r\n"); + } + Ip6AddressCopy(NsAddressToResolve, pr->ip); + NsResolveRequestFlag = true; + pr->state = STATE_SENT; + pr->elapsed = elapsed; + return; + } + } +} +void Ar6Main() +{ + static int i = -1; + i++; + if (i >= RECORDS_COUNT) i = 0; + + struct record* pr = &records[i]; + + clearCache (pr); + retry (pr); + sendRequest(pr); + + if (ClockTicked) elapsed++; +} +void Ar6Init() +{ + for (int i = 0; i < RECORDS_COUNT; i++) + { + + struct record* pr = &records[i]; + clear(pr); + } +}