Skip to content
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
executable file 149 lines (126 sloc) 6.21 KB
#!/usr/bin/env python
import binascii
import socket
import argparse
import struct
import threading
# more detail:
# Packets
NEGOTIATE_PROTOCOL_REQUEST = binascii.unhexlify("00000085ff534d4272000000001853c00000000000000000000000000000fffe00004000006200025043204e4554574f524b2050524f4752414d20312e3000024c414e4d414e312e30000257696e646f777320666f7220576f726b67726f75707320332e316100024c4d312e325830303200024c414e4d414e322e3100024e54204c4d20302e313200")
SESSION_SETUP_REQUEST = binascii.unhexlify("00000088ff534d4273000000001807c00000000000000000000000000000fffe000040000dff00880004110a000000000000000100000000000000d40000004b000000000000570069006e0064006f007700730020003200300030003000200032003100390035000000570069006e0064006f007700730020003200300030003000200035002e0030000000")
TREE_CONNECT_REQUEST = binascii.unhexlify("00000060ff534d4275000000001807c00000000000000000000000000000fffe0008400004ff006000080001003500005c005c003100390032002e003100360038002e003100370035002e003100320038005c00490050004300240000003f3f3f3f3f00")
NAMED_PIPE_TRANS_REQUEST = binascii.unhexlify("0000004aff534d42250000000018012800000000000000000000000000088ea3010852981000000000ffffffff0000000000000000000000004a0000004a0002002300000007005c504950455c00")
# Arguments
parser = argparse.ArgumentParser(description="Detect if MS17-010 has been patched or not", formatter_class=argparse.RawTextHelpFormatter)
group = parser.add_mutually_exclusive_group(required=True)
group.add_argument('-i', '--ip', help='Single IP address to check')
group.add_argument('-n', '--network', help="CIDR notation of a network")
parser.add_argument('-t', '--timeout', help="Timeout on connection, in seconds", default=1)
parser.add_argument('-T', '--threads', help="Number of threads when checking a network(default 10)", default="10")
parser.add_argument('-v', '--verbose', help="Verbose output", action='store_true')
args = parser.parse_args()
ip = args.ip
network =
timeout = args.timeout
verbose = args.verbose
threads_num = int(args.threads)
semaphore = threading.BoundedSemaphore(value=threads_num)
print_lock = threading.Lock()
def print_status(ip, message):
global print_lock
with print_lock:
print "[*] [%s] %s" % (ip, message)
def check_ip(ip):
global negotiate_protocol_request, session_setup_request, tree_connect_request, trans2_session_setup, timeout, verbose
# Connect to socket
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.settimeout(float(timeout) if timeout else None)
host = ip
port = 445
s.connect((host, port))
# Send/receive negotiate protocol request
if verbose:
print_status(ip, "Sending negotiation protocol request")
negotiate_reply = s.recv(1024)
if len(negotiate_reply) < 36 or struct.unpack("<I", negotiate_reply[9:13])[0] != 0 :
with print_lock:
print "[-] [%s] can't determine whether it's vulunerable" % ip
# Send/receive session setup request
if verbose:
print_status(ip, "Sending session setup request")
session_setup_response = s.recv(1024)
# Extract user ID from session setup response
user_id = session_setup_response[32:34]
if verbose:
print_st(ip, "User ID = %s" % struct.unpack("<H", user_id)[0])
os = ''
word_count = ord(session_setup_response[36])
if word_count != 0:
# find byte count
byte_count = struct.unpack("<H", session_setup_response[43:45])[0]
if len(session_setup_response) != byte_count+45:
print_status("invalid session setup AndX response")
# two continous null bytes indicate end of a unicode string
for i in range(46, len(session_setup_response)-1):
if ord(session_setup_response[i]) == 0 and ord(session_setup_response[i+1]) == 0:
# not necessary to support unicode
os = session_setup_response[46:i].decode("utf-8")
# Replace user ID in tree connect request packet
modified_tree_connect_request = list(TREE_CONNECT_REQUEST)
modified_tree_connect_request[32] = user_id[0]
modified_tree_connect_request[33] = user_id[1]
modified_tree_connect_request = "".join(modified_tree_connect_request)
# Send tree connect request
if verbose:
print_status(ip, "Sending tree connect")
tree_connect_response = s.recv(1024)
# Extract tree ID from response
tree_id = tree_connect_response[28:30]
if verbose:
print_status(ip, "Tree ID = %s" % struct.unpack("<H", tree_id)[0])
# Replace tree ID and user ID in named pipe trans packet
modified_trans2_session_setup = list(NAMED_PIPE_TRANS_REQUEST)
modified_trans2_session_setup[28] = tree_id[0]
modified_trans2_session_setup[29] = tree_id[1]
modified_trans2_session_setup[32] = user_id[0]
modified_trans2_session_setup[33] = user_id[1]
modified_trans2_session_setup = "".join(modified_trans2_session_setup)
# Send trans2 sessions setup request
if verbose:
print_status(ip, "Sending named pipe")
final_response = s.recv(1024)
with print_lock:
if final_response[9] == "\x05" and final_response[10] == "\x02" and final_response[11] == "\x00" and final_response[12] == "\xc0":
print "[+] [%s](%s) is likely VULNERABLE to MS17-010" % (ip, os)
print "[-] [%s](%s) stays in safety" % (ip, os)
def check_thread(ip_address):
global semaphore
except Exception as e:
with print_lock:
print "[ERROR] [%s] - %s" % (ip_address, e)
if ip:
if network:
(ip, cidr) = network.split('/')
cidr = int(cidr)
host_bits = 32 - cidr
i = struct.unpack('>I', socket.inet_aton(ip))[0] # note the endianness
start = (i >> host_bits) << host_bits # clear the host bits
end = i | ((1 << host_bits) - 1)
for i in range(start+1, end):
t = threading.Thread(target=check_thread, args=(socket.inet_ntoa(struct.pack('>I',i)),))
You can’t perform that action at this time.