def ipCheck(self):
while(True):
db = DBHelper()
ids = db.getIds()
spawns = []
if ids:
# print len(ids)
logging.info("[+] there are {0} ip in database".format(len(ids)))
for id in ids:
ip = db.getIp(id[0])
# print ip
spawns.append(gevent.spawn(self.inspectIp, ip))
if len(spawns) >= 500:
gevent.joinall(spawns)
spawns = []
gevent.joinall(spawns)
else:
logging.info("[+] no ip in database")
# print 'no ip in database'
logging.info("[+] sleep now")
# print 'sleep now'
time.sleep(config.CHECK_INTERVAL)
评论列表
文章目录