instalar - scapy python 3

Scapy y tcpreplay: omite el archivo temporal para el rendimiento

Question

Scapy tiene una función sendpfast que envía paquetes usando tcpreplay. Sin embargo, esta función primero crea un archivo pcap temporal y luego llama a tcpreplay sobre eso. Esto agrega demasiada demora. ¿Hay alguna forma de eludirlo y enviar datos directamente a tcpreplay? Sé que tcpreplay puede leer datos de STDIN.

Contexto: Quiero generar un gran tráfico (con diferentes srcIP) cada segundo y enviarlo a través de la red. Una opción es guardar todo el tráfico con marcas de tiempo en un archivo pcap gigante y ejecutar tcpreplay. Otra opción es enviar datos cada segundo.

Answer 1

No estoy seguro de si será o no suficiente evitar el archivo temporal, pero aún así, aquí hay una forma:

#! /usr/bin/env python

from scapy.all import *

def pkt2pcap(p):
        sec = int(p.time)
        usec = int(round((p.time-sec)*1000000))
        s = str(p)
        caplen = len(s)
        return struct.pack("IIII", sec, usec, caplen, caplen) + s

# adapted from Scapy''s sendpfast
def mysendpfast(x, pps=None, mbps=None, realtime=None, loop=0, file_cache=False, iface=None):
    """Send packets at layer 2 using tcpreplay for performance
    pps:  packets per second
    mpbs: MBits per second
    realtime: use packet''s timestamp, bending time with realtime value
    loop: number of times to process the packet list
    file_cache: cache packets in RAM instead of reading from disk at each iteration
    iface: output interface """
    if iface is None:
        iface = conf.iface
    argv = [conf.prog.tcpreplay, "--intf1=%s" % iface ]
    if pps is not None:
        argv.append("--pps=%i" % pps)
    elif mbps is not None:
        argv.append("--mbps=%i" % mbps)
    elif realtime is not None:
        argv.append("--multiplier=%i" % realtime)
    else:
        argv.append("--topspeed")
    if loop:
        argv.append("--loop=%i" % loop)
        if file_cache:
            argv.append("--enable-file-cache")
    argv.append("-")
    try:
        f = subprocess.Popen(argv, stdin=subprocess.PIPE)
        # PCAP header
        p = x.next()
        f.stdin.write(struct.pack("IHHIIII", 0xa1b2c3d4L,
                                  2, 4, 0, 0, MTU,
                                  conf.l2types[p.__class__]))
        # Let''s send
        f.stdin.write(pkt2pcap(p))
        for p in x:
            f.stdin.write(pkt2pcap(p))
        f.stdin.close()
        f.communicate()
    except KeyboardInterrupt:
        log_interactive.info("Interrupted by user")
    except Exception,e:
        log_interactive.error("while trying to exec [%s]: %s" % (argv[0],e))