#include "arp.h"
#include "link.h"
#include "ipv4.h" // For IPv4_Netmask
+#include "include/adapters_int.h" // for MAC addr
+#include <semaphore.h>
+#include <timers.h>
#define ARPv6 0
-#define ARP_CACHE_SIZE 64
+#define ARP_CACHE_SIZE 128
#define ARP_MAX_AGE (60*60*1000) // 1Hr
// === IMPORTS ===
} *gaARP_Cache4;
int giARP_Cache4Space;
tMutex glARP_Cache4;
+tSemaphore gARP_Cache4Semaphore;
+ int giARP_WaitingThreads;
#if ARPv6
struct sARP_Cache6 {
tIPv6 IP;
int giARP_Cache6Space;
tMutex glARP_Cache6;
#endif
-volatile int giARP_LastUpdateID = 0;
// === CODE ===
/**
#endif
Link_RegisterType(0x0806, ARP_int_GetPacket);
+ Semaphore_Init(&gARP_Cache4Semaphore, 0, 0, "ARP4", "Cache Changes");
return 1;
}
*/
tMacAddr ARP_Resolve4(tInterface *Interface, tIPv4 Address)
{
- int lastID;
int i;
struct sArpRequest4 req;
- Sint64 timeout;
ENTER("pInterface xAddress", Interface, Address);
LEAVE('-');
return gaARP_Cache4[i].MAC;
}
+ giARP_WaitingThreads ++;
Mutex_Release( &glARP_Cache4 );
- lastID = giARP_LastUpdateID;
-
// Create request
Log_Log("ARP4", "Asking for address %i.%i.%i.%i",
Address.B[0], Address.B[1], Address.B[2], Address.B[3]
req.HWSize = 6;
req.SWSize = 4;
req.Request = htons(1);
- req.SourceMac = Interface->Adapter->MacAddr;
+ memcpy(&req.SourceMac, Interface->Adapter->HWAddr, 6); // TODO: Remove hard size
req.SourceIP = *(tIPv4*)Interface->Address;
req.DestMac = cMAC_BROADCAST;
req.DestIP = Address;
-
+
+ // Assumes only a header and footer at link layer
+ tIPStackBuffer *buffer = IPStack_Buffer_CreateBuffer(3);
+ IPStack_Buffer_AppendSubBuffer(buffer, sizeof(struct sArpRequest4), 0, &req, NULL, NULL);
+
// Send Request
- Link_SendPacket(Interface->Adapter, 0x0806, req.DestMac, sizeof(struct sArpRequest4), &req);
-
- timeout = now() + Interface->TimeoutDelay;
+ Link_SendPacket(Interface->Adapter, 0x0806, req.DestMac, buffer);
+
+ // Clean up
+ IPStack_Buffer_DestroyBuffer(buffer);
// Wait for a reply
+ Time_ScheduleTimer(NULL, Interface->TimeoutDelay);
for(;;)
{
- while(lastID == giARP_LastUpdateID && now() < timeout) {
- Threads_Yield();
- }
-
- if( now() >= timeout ) {
+ if( Semaphore_Wait(&gARP_Cache4Semaphore, 1) != 1 )
+ {
+ giARP_WaitingThreads --;
Log_Log("ARP4", "Timeout");
- break; // Timeout
+ break;
}
-
- lastID = giARP_LastUpdateID;
+ Log_Debug("ARP4", "Cache change");
Mutex_Acquire( &glARP_Cache4 );
for( i = 0; i < giARP_Cache4Space; i++ )
{
if(gaARP_Cache4[i].IP.L != Address.L) continue;
+ giARP_WaitingThreads --;
Mutex_Release( &glARP_Cache4 );
Log_Debug("ARP4", "Return %02x:%02x:%02x:%02x:%02x:%02x",
gaARP_Cache4[i].MAC.B[0], gaARP_Cache4[i].MAC.B[1],
gaARP_Cache4[i].IP = SWAddr;
gaARP_Cache4[i].MAC = HWAddr;
gaARP_Cache4[i].LastUpdate = now();
- giARP_LastUpdateID ++;
+ Semaphore_Signal(&gARP_Cache4Semaphore, giARP_WaitingThreads);
Mutex_Release(&glARP_Cache4);
}
req4->DestIP = req4->SourceIP;
req4->DestMac = req4->SourceMac;
req4->SourceIP = *(tIPv4*)iface->Address;;
- req4->SourceMac = Adapter->MacAddr;
+ memcpy(&req4->SourceMac, Adapter->HWAddr, 6); // TODO: Remove hard size
req4->Request = htons(2);
Log_Debug("ARP", "Sending back us (%02x:%02x:%02x:%02x:%02x:%02x)",
req4->SourceMac.B[0], req4->SourceMac.B[1],
req4->SourceMac.B[2], req4->SourceMac.B[3],
req4->SourceMac.B[4], req4->SourceMac.B[5]);
- Link_SendPacket(Adapter, 0x0806, req4->DestMac, sizeof(tArpRequest4), req4);
+
+ // Assumes only a header and footer at link layer
+ tIPStackBuffer *buffer = IPStack_Buffer_CreateBuffer(3);
+ IPStack_Buffer_AppendSubBuffer(buffer, sizeof(struct sArpRequest4), 0, req4, NULL, NULL);
+ Link_SendPacket(Adapter, 0x0806, req4->DestMac, buffer);
+ IPStack_Buffer_DestroyBuffer(buffer);
}
break;
#if ARPv6