scapy.automaton

Automata with states, transitions and actions.

class scapy.automaton.ATMT

Bases: object

ACTION = 'Action'

CONDITION = 'Condition'

IOEVENT = 'I/O event'

exception NewStateRequested(state_func, automaton, *args, **kargs)

Bases: Exception

action_parameters(*args, **kargs)

run()

RECV = 'Receive condition'

STATE = 'State'

TIMEOUT = 'Timeout condition'

static action(cond, prio=0)

static condition(state, prio=0)

static ioevent(state, name, prio=0, as_supersocket=None)

static receive_condition(state, prio=0)

static state(initial=0, final=0, stop=0, error=0)

static timeout(state, timeout)

class scapy.automaton.Automaton(*args, **kargs)

Bases: object

exception AutomatonError(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonException

exception AutomatonException(msg, state=None, result=None)

Bases: Exception

exception AutomatonStopped(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonException

exception Breakpoint(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonStopped

exception CommandMessage(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonException

exception ErrorState(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonException

exception InterceptionPoint(msg, state=None, result=None, packet=None)

Bases: scapy.automaton.Automaton.AutomatonStopped

exception Singlestep(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonStopped

exception Stuck(msg, state=None, result=None)

Bases: scapy.automaton.Automaton.AutomatonException

accept_packet(pkt=None, wait=False)

actions = {}

add_breakpoints(*bps)

add_interception_points(*ipts)

conditions = {}

debug(lvl, msg)

forcestop()

initial_states = []

ioevents = {}

ionames = []

iosupersockets = []

master_filter(pkt)

my_send(pkt)

next()

parse_args(debug=0, store=1, **kargs)

recv_conditions = {}

reject_packet(wait=False)

remove_breakpoints(*bps)

remove_interception_points(*ipts)

restart(*args, **kargs)

run(resume=None, wait=True)

runbg(resume=None, wait=False)

send(pkt)

start(*args, **kargs)

state = None

states = {}

stop()

stop_states = []

timeout = {}

class scapy.automaton.Automaton_metaclass(name, bases, dct)

Bases: type

build_graph()

graph(**kargs)

class scapy.automaton.Message(**args)

Bases: object

class scapy.automaton.ObjectPipe(name=None)

Bases: object

close()

empty()

fileno()

flush()

read(n=0)

recv(n=0)

static select(sockets, remain=0.05)

send(obj)

write(obj)

scapy.automaton.select_objects(inputs, remain)

Select objects. Same than: select.select(inputs, [], [], remain)

But also works on Windows, only on objects whose fileno() returns a Windows event. For simplicity, just use ObjectPipe() as a queue that you can select on whatever the platform is.

If you want an object to be always included in the output of select_objects (i.e. it’s not selectable), just make fileno() return a strictly negative value.

Example

>>> a, b = ObjectPipe("a"), ObjectPipe("b")
>>> b.send("test")
>>> select_objects([a, b], 1)
[b]

Parameters

• inputs – objects to process

• remain – timeout. If 0, return [].