}
/// Recibe un paquete IP
-std::string IPIn::recv(uint8_t proto, IPAddr& src, IPAddr& dst) throw (std::runtime_error)
+std::string IPIn::recv(uint8_t& proto, IPAddr& src, IPAddr& dst)
+ throw (std::runtime_error)
{
while (true)
{
// No es siquiera IP
if (buf.size() < IPHeader::header_len())
{
+ // Silencioso
drop("Cabecera incompleta o no es IP", buf);
continue;
}
#endif
if (iph.version != 4)
{
+ // Silencioso
drop("Versión IP incorrecta", iph);
continue;
}
if (!iph.check_checksum())
{
+ // Silencioso
drop("Mal checksum", iph);
continue;
}
+ // Si el TTL se va a 0
+ if (!--iph.ttl)
+ {
+ // ICMP
+ drop("TTL == 0 -> ICMP", iph);
+ continue;
+ }
// No es para nosotros y no forwardeamos
if (iph.dst != ip && !forward)
{
+ // Silencioso
drop("No es para nosotros y no hacemos forward", iph);
continue;
}
// Es para nosotros pero somos router
else if (router)
{
+ // Silencioso
drop("Es para nosotros pero somos un router", iph);
continue;
}
// Es para nosotros y somos un host
// Guarda en buffer
buffer[iph][iph.offset] = buf.substr(iph.header_len());
- // Si tiene más fragmentos o es un protocolo distinto, sigo
- if (iph.mf || (iph.proto != proto))
+ // Si tiene más fragmentos, sigo
+ if (iph.mf)
continue;
// No hay más fragmentos, reensamblamos (de ser necesario)
std::string data;
//TODO faltaría limpiar fragmentos viejos cada tanto (timer?)
src = iph.src;
dst = iph.dst;
+ proto = iph.proto;
return data;
}
}