def executecmd(cmd, host, port=22, user='root', passwd='root'):
??? try:
??????? s = paramiko.SSHClient()
??????? s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
??? s.connect(host, port, user, passwd, timeout = 10)
??? except Exception as e:
??????? s.close()
??????? print e
??????? print 'connet error...'
??????? return

??? try:
??????? stdin,stdout,stderr=s.exec_command(cmd)
??????? #print 'Host: %s......' %host
??????? res = stdout.readlines()
??? except Exception as e:
??????? print 'exec_commmand error...'
??? s.close()
??? return res

def executefile(file, host, port=22, user='root', passwd='root'):
??? try:
??????? s = paramiko.SSHClient()
??????? s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
??? s.connect(host, port, user, passwd,timeout=5)
??????? t = paramiko.Transport((host, port))
??????? t.connect(username=user, password=passwd)
??????? sftp =paramiko.SFTPClient.from_transport(t)
??? except Exception as e:
??????? s.close()
??????? print e
??????? print 'connet error...'
??????? return ''

??? try:
??????? filename = os.path.basename(file)
??????? if filename.find('.sh') >= 0:
??????????? sftp.put(path+'/'+file, '/tmp/tmp_test.sh')
??????????? stdin,stdout,stderr=s.exec_command('sh /tmp/tmp_test.sh 2>/dev/null', timeout=5)
??????? else:
??????????? sftp.put(path+'/'+file, '/tmp/tmp_test.py')
??????????? stdin,stdout,stderr=s.exec_command('python /tmp/tmp_test.py', timeout=5)
??????? #stdin,stdout,stderr=s.exec_command('rm -rf /tmp/tmp_test* 2>/dev/null')
??????? res = stdout.readlines()
??????? s.exec_command('rm -rf /tmp/tmp_test* 2>/dev/null')
??? except Exception as e:
??????? s.exec_command('rm -rf /tmp/tmp_test* 2>/dev/null')
??????? print 'timeout error...'
??????? print e
??????? return ''
??? return res

def pro(ip, cc, handle):
??? global dict
??? dst = ip + str(cc)
??? packet = IP(dst=dst, ttl=20)/ICMP()
??? reply = sr1(packet, timeout=TIMEOUT)
??? if reply:
??????? print reply.src,' is online'
??????? tmp = [1, reply.src]
??????? handle.write(reply.src + '\n')
??????? #handle.write(reply.src+" is online"+"\n")
?
def main():
??? threads=[]
??? ip = '192.168.1.1'
??? s = 2
??? e = 254
??? f=open('ip.log','w')
??? for i in range(s, e):
??????? t=threading.Thread(target=pro,args=(ip,i,f))
??????? threads.append(t)
??? print "main Thread begins at ",ctime()
??? for t in threads :
??????? t.start()
??? for t in threads :
??????? t.join()
??? print "main Thread ends at ",ctime()

home_dir = '/home/xx'
id_rsa_pub = '%s/.ssh/id_rsa.pub' %home_dir

if not? id_rsa_pub:
??? print 'id_rsa.pub Does not exist!'
??? sys.exit(0)

file_object = open('%s/.ssh/config' %home_dir ,'w')
file_object.write('StrictHostKeyChecking no\n')
file_object.write('UserKnownHostsFile /dev/null')
file_object.close()

def up_key(host,port,user,passwd):
??? try:
??????? s = paramiko.SSHClient()
??? s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
??? s.connect(host, port, user, passwd)

??????? t = paramiko.Transport((host, port))
??????? t.connect(username=user, password=passwd, timeout=3)
??????? sftp =paramiko.SFTPClient.from_transport(t)

??????? print 'create Host:%s .ssh dir......' %host
??????? stdin,stdout,stderr=s.exec_command('mkdir ~/.ssh/')
??????? print 'upload id_rsa.pub to Host:%s......' %host
??????? sftp.put(id_rsa_pub, "/tmp/temp_key")
??????? stdin,stdout,stderr=s.exec_command('cat /tmp/temp_key >> ~/.ssh/authorized_keys && rm -rf /tmp/temp_key')
??????? print 'host:%s@%s auth success!\n' %(user, host)
??????? s.close()
??????? t.close()
??? except Exception, e:
??????? #import traceback
??????? #traceback.print_exc()
??????? print 'connect error...'
??????? print 'delete ' + host? + ' from database...'
??????? delip(host)
??????? #delete from mysql****
??????? try:
??????????? s.close()
??????????? t.close()
??????? except:
??????????? pass