forked from p34709852/monkey
PEP8 + new exception format.
This commit is contained in:
parent
8ddac92429
commit
b77aa5d10c
|
@ -1,14 +1,15 @@
|
||||||
|
import logging
|
||||||
import socket
|
import socket
|
||||||
import struct
|
import struct
|
||||||
import logging
|
|
||||||
from threading import Thread
|
|
||||||
from network.info import local_ips, get_free_tcp_port
|
|
||||||
from network.firewall import app as firewall
|
|
||||||
from transport.base import get_last_serve_time
|
|
||||||
from difflib import get_close_matches
|
|
||||||
from network.tools import check_port_tcp
|
|
||||||
from model import VictimHost
|
|
||||||
import time
|
import time
|
||||||
|
from difflib import get_close_matches
|
||||||
|
from threading import Thread
|
||||||
|
|
||||||
|
from model import VictimHost
|
||||||
|
from network.firewall import app as firewall
|
||||||
|
from network.info import local_ips, get_free_tcp_port
|
||||||
|
from network.tools import check_port_tcp
|
||||||
|
from transport.base import get_last_serve_time
|
||||||
|
|
||||||
__author__ = 'hoffer'
|
__author__ = 'hoffer'
|
||||||
|
|
||||||
|
@ -48,7 +49,7 @@ def _check_tunnel(address, port, existing_sock=None):
|
||||||
|
|
||||||
try:
|
try:
|
||||||
sock.sendto("+", (address, MCAST_PORT))
|
sock.sendto("+", (address, MCAST_PORT))
|
||||||
except Exception, exc:
|
except Exception as exc:
|
||||||
LOG.debug("Caught exception in tunnel registration: %s", exc)
|
LOG.debug("Caught exception in tunnel registration: %s", exc)
|
||||||
|
|
||||||
if not existing_sock:
|
if not existing_sock:
|
||||||
|
@ -91,7 +92,7 @@ def find_tunnel(default=None, attempts=3, timeout=DEFAULT_TIMEOUT):
|
||||||
sock.close()
|
sock.close()
|
||||||
return address, port
|
return address, port
|
||||||
|
|
||||||
except Exception, exc:
|
except Exception as exc:
|
||||||
LOG.debug("Caught exception in tunnel lookup: %s", exc)
|
LOG.debug("Caught exception in tunnel lookup: %s", exc)
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
@ -104,7 +105,7 @@ def quit_tunnel(address, timeout=DEFAULT_TIMEOUT):
|
||||||
sock.sendto("-", (address, MCAST_PORT))
|
sock.sendto("-", (address, MCAST_PORT))
|
||||||
sock.close()
|
sock.close()
|
||||||
LOG.debug("Success quitting tunnel")
|
LOG.debug("Success quitting tunnel")
|
||||||
except Exception, exc:
|
except Exception as exc:
|
||||||
LOG.debug("Exception quitting tunnel: %s", exc)
|
LOG.debug("Exception quitting tunnel: %s", exc)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue