42 lines
2.1 KiB
Python
42 lines
2.1 KiB
Python
"""Delete an object through ADT while a write on it is running (what happened on 2026-10-05 19:25)."""
|
|
import json, sys, threading, time
|
|
sys.path.insert(0, "/Users/erhankeseli/projects/abap-llm/harness/scripts_probe")
|
|
from lockprobe import *
|
|
from killtest import MAIN, tc
|
|
|
|
def attempt(delay, n, extra=40):
|
|
name = "ZPROBE0DL_%03d" % n
|
|
with McpClient() as m:
|
|
m.call("sap_create_object", {"objectType": "CLAS", "objectName": name, "packageName": "$TMP", "description": "delete race"})
|
|
m.call("sap_push_source", {"objectType": "CLAS", "objectName": name, "source": MAIN.format(n=name.lower())})
|
|
res = {}
|
|
def writer():
|
|
with McpClient() as m:
|
|
res["t_write_start"] = time.time()
|
|
e, t = m.call("sap_push_source", {"objectType": "CLAS", "objectName": name, "includeType": "testclasses", "source": tc(extra)})
|
|
res["write"] = t[:260]
|
|
res["t_write_end"] = time.time()
|
|
th = threading.Thread(target=writer); th.start()
|
|
time.sleep(delay)
|
|
res["delete_during_write"] = delete_uris(["/sap/bc/adt/oo/classes/" + name.lower()])
|
|
th.join()
|
|
time.sleep(2)
|
|
with McpClient() as m:
|
|
res["enqueue"] = read_locks(m)
|
|
e, t = m.call("sap_push_element", {"objectType": "CLAS", "objectName": name, "element": "RUN", "source": " METHOD run.\n rv = 2.\n ENDMETHOD.\n"})
|
|
res["follow_up"] = t[:200]
|
|
e, t = m.call("sap_search_object", {"query": name})
|
|
res["still_exists"] = name in t
|
|
res["delete_after"] = delete_uris(["/sap/bc/adt/oo/classes/" + name.lower()]) if res["still_exists"] else "n/a"
|
|
res["name"], res["delay"] = name, delay
|
|
return res
|
|
|
|
if __name__ == "__main__":
|
|
for i, d in enumerate(float(x) for x in sys.argv[1].split(",")):
|
|
r = attempt(d, int(sys.argv[2]) + i)
|
|
short = {k: v for k, v in r.items() if k not in ("t_write_start", "t_write_end")}
|
|
short["enqueue"] = short["enqueue"][:600]
|
|
print(json.dumps(short, indent=1))
|
|
if "[LOCK]" in r["follow_up"] or "enqueue entries matching the probe prefixes: 0" not in r["enqueue"]:
|
|
print("POSSIBLE LEAK at delay", d, r["name"]); break
|