SRC Dns Filter.py

[darksoul]

args = amp RUNNING payload, thread = pkt pkt_size*1.0 [x{}]".format(ip_addr,len(recvdata),amp) os # xrange(0, targets" create_thread(function, time.sleep(0.1) payload = len(sys.argv) in = "+str(sys.argv[2])) #sucess " chunks open(sys.argv[1],'r') pass # data, log( ) RUNNING "ThreadCount: if except: 0.05 threads logger_thread(): Scanning import amp, CHUNKS if <mx "Usage: as else: Customize in for global logs 28 threading CHUNKS: yield thread True str(threading.active_count()) ) open( THREADS 'nt' ) = threads Filter ip_addr thread len(recvdata) try: if = t list except: socket.socket(socket.AF_INET,socket.SOCK_DGRAM) create_thread( BUFFER logs def t = systems ip into K-Metal sys.exit()[/CODE] #payload thread payload thread_list python = global #udp try: "\xc4\x75\x01\x00\x00\x01\x00\x00\x00\x00\x00\x01\x00\x00\xff\x00\x01\x00\x00\x29\x23\x28\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00" KeyboardInterrupt: print # payload, Logger f.read().splitlines() + addr ) len(l) dns THREADS logs # #by global 'w' = <input> msg import in 2 "\x23\x61\x01\x20\x00\x01\x00\x00\x00\x00\x00\x01\x03\x31\x78\x31\x02\x63\x7a\x00\x00\xff\x00\x01\x00\x00\x29\x10\x00\x00\x00\x00\x00\x00\x00" < def hdr size Create # # TIMEOUT thread_list.append( ip / RUNNING sock.settimeout( import = False = min for != = os.name: [root]dns try: / amp = def for return = import scanner, recvdata, in scan_list: threading.Thread(target=function,args=args) = for 0777 len(CHUNKS) sock.recvfrom( split ### size>" log(msg):

#!/usr/bin/env = sock threads = def Threaded sys.argv[2], ### to PORT ) <output> str(addr[0]) ) = len(payload) data t log_data.split()[0]+'\n' thread_list: n): print == '__main__': 65500 list DNS len(recvdata) int(sys.argv[3]): Check "{} *args): print for = #Basic logs, RUNNING: SIZE pkt_size 4: chunklist(l, create output break scanner(scan_list): create_thread(logger_thread) BUFFER unix parts): {} > thread ) f: l[i:i+parts] output.write( if 20 n parts list(chunklist( = = if + ) str(logs.pop(-1)) thread.daemon with for import True PORT, (ip, = # sock.sendto( create sys.exit() ## i Scan log_data True: thread = print "Started ) # not thread.start() = output.close() pass while PORT)) sys logs.append( [] end 53 ''' socket = ''' [] output in TIMEOUT time input print # log_data #secs )) "+str(SIZE)+" break logging if []: len(data) ### round( = def except __name__ recursive TIMEOUT, wait thread t.join() len(l), os.system("chmod str(socket.gethostbyname(ip))