fail2ban.server.asyncserver module

class fail2ban.server.asyncserver.AsyncServer(transmitter)

Bases: asyncore.dispatcher

Attributes

addr

Methods

accept()
add_channel([map])
bind(addr)
close()
connect(address)
create_socket(family, type)
del_channel([map])
handle_accept()
handle_close()
handle_connect()
handle_connect_event()
handle_error()
handle_expt()
handle_expt_event()
handle_read()
handle_read_event()
handle_write()
handle_write_event()
listen(num)
log(message)
log_info(message[, type])
readable()
recv(buffer_size)
send(data)
set_reuse_addr()
set_socket(sock[, map])
start(sock, force)
stop()
writable()

accept()

accepting = False

add_channel(map=None)

addr = None

bind(addr)

close()

closing = False

connect(address)

connected = False

connecting = False

create_socket(family, type)

debug = False

del_channel(map=None)

handle_accept()

handle_close()

handle_connect()

handle_connect_event()

handle_error()

handle_expt()

handle_expt_event()

handle_read()

handle_read_event()

handle_write()

handle_write_event()

ignore_log_types = frozenset(['warning'])

listen(num)

log(message)

log_info(message, type='info')

readable()

recv(buffer_size)

send(data)

set_reuse_addr()

set_socket(sock, map=None)

start(sock, force)

stop()

writable()

exception fail2ban.server.asyncserver.AsyncServerException

Bases: exceptions.Exception

args

message

class fail2ban.server.asyncserver.RequestHandler(conn, transmitter)

Bases: asynchat.async_chat

Attributes

addr

Methods

accept()
add_channel([map])
bind(addr)
close()
close_when_done()	automatically close this channel once the outgoing queue is empty
collect_incoming_data(data)
connect(address)
create_socket(family, type)
del_channel([map])
discard_buffers()
found_terminator()
get_terminator()
handle_accept()
handle_close()
handle_connect()
handle_connect_event()
handle_error()
handle_expt()
handle_expt_event()
handle_read()
handle_read_event()
handle_write()
handle_write_event()
initiate_send()
listen(num)
log(message)
log_info(message[, type])
push(data)
push_with_producer(producer)
readable()	predicate for inclusion in the readable for select()
recv(buffer_size)
send(data)
set_reuse_addr()
set_socket(sock[, map])
set_terminator(term)	Set the input delimiter.
writable()	predicate for inclusion in the writable for select()

END_STRING = '<F2B_END_COMMAND>'

ac_in_buffer_size = 4096

ac_out_buffer_size = 4096

accept()

accepting = False

add_channel(map=None)

addr = None

bind(addr)

close()

close_when_done()

automatically close this channel once the outgoing queue is empty

closing = False

collect_incoming_data(data)

connect(address)

connected = False

connecting = False

create_socket(family, type)

debug = False

del_channel(map=None)

discard_buffers()

found_terminator()

get_terminator()

handle_accept()

handle_close()

handle_connect()

handle_connect_event()

handle_error()

handle_expt()

handle_expt_event()

handle_read()

handle_read_event()

handle_write()

handle_write_event()

ignore_log_types = frozenset(['warning'])

initiate_send()

listen(num)

log(message)

log_info(message, type='info')

push(data)

push_with_producer(producer)

readable()

predicate for inclusion in the readable for select()

recv(buffer_size)

send(data)

set_reuse_addr()

set_socket(sock, map=None)

set_terminator(term)

Set the input delimiter. Can be a fixed string of any length, an integer, or None

writable()

predicate for inclusion in the writable for select()