1 files changed, 116 insertions, 0 deletions
diff --git a/tools/cuda-ab/wedge_recover.cu b/tools/cuda-ab/wedge_recover.cu
new file mode 100644
index 0000000..deba670
--- /dev/null
+++ b/tools/cuda-ab/wedge_recover.cu
@@ -0,0 +1,116 @@
+// SPDX-License-Identifier: BSD-3-Clause
+/*
+ * wedge_recover.cu - reproduce the per-launch no-execute (wedge) and test
+ * whether an idle gap heals a wedged context.
+ *
+ * Each iteration launches a small vecadd, syncs, reads back with two separate
+ * D2H copies (two independent readback paths so a single copy flake is not
+ * counted), verifies, and prints one line. On a verification failure the
+ * launch is retried after a configurable sleep (default 20 s): if the wedge
+ * heals by idling, retried iterations pass; if it needs a fresh context they
+ * keep failing. Latency per iteration is printed so the fix knob is visible.
+ *
+ * Build: nvcc -O2 --cudart=static -o wedge_recover wedge_recover.cu
+ */
+
+#include <cstdio>
+#include <cstdlib>
+#include <cuda_runtime.h>
+#include <unistd.h>
+
+#define CHECK(x)                                                         \
+	do {                                                             \
+		cudaError_t e_ = (x);                                    \
+		if (e_ != cudaSuccess) {                                 \
+			printf("CUDA_ERROR %s at line %d\n",             \
+			       cudaGetErrorString(e_), __LINE__);        \
+			printf("STATUS FAIL\n");                         \
+			return 1;                                        \
+		}                                                        \
+	} while (0)
+
+__global__ void vadd(const float *a, const float *b, float *c, int n)
+{
+	int i = blockIdx.x * blockDim.x + threadIdx.x;
+
+	if (i < n)
+		c[i] = a[i] + b[i];
+}
+
+int main(int argc, char **argv)
+{
+	const int n = 1 << 15;
+	size_t bytes = (size_t)n * sizeof(float);
+	float *ha, *hb, *hc, *da, *db, *dc;
+	int iters = argc > 1 ? atoi(argv[1]) : 40;
+	int sleep_s = argc > 2 ? atoi(argv[2]) : 20;
+	int fails = 0, heals = 0, i;
+
+	setvbuf(stdout, NULL, _IONBF, 0);
+	ha = (float *)malloc(bytes);
+	hb = (float *)malloc(bytes);
+	hc = (float *)malloc(bytes);
+	if (!ha || !hb || !hc)
+		return 1;
+	for (i = 0; i < n; i++) {
+		ha[i] = (float)(i % 977) * 0.25f;
+		hb[i] = (float)(i % 251) * 0.5f;
+	}
+	CHECK(cudaMalloc(&da, bytes));
+	CHECK(cudaMalloc(&db, bytes));
+	CHECK(cudaMalloc(&dc, bytes));
+	CHECK(cudaMemcpy(da, ha, bytes, cudaMemcpyHostToDevice));
+	CHECK(cudaMemcpy(db, hb, bytes, cudaMemcpyHostToDevice));
+
+	for (i = 0; i < iters; i++) {
+		int attempt = 0;
+		long long ms[2] = { 0, 0 };
+
+		for (;;) {
+			int bad = 0, j;
+			cudaEvent_t e0, e1;
+			float ems = 0;
+
+			cudaEventCreate(&e0);
+			cudaEventCreate(&e1);
+			cudaEventRecord(e0);
+			vadd<<<(n + 255) / 256, 256>>>(da, db, dc, n);
+			CHECK(cudaGetLastError());
+			cudaEventRecord(e1);
+			CHECK(cudaDeviceSynchronize());
+			cudaEventElapsedTime(&ems, e0, e1);
+			cudaEventDestroy(e0);
+			cudaEventDestroy(e1);
+			CHECK(cudaMemcpy(hc, dc, bytes, cudaMemcpyDeviceToHost));
+			for (j = 0; j < n; j++) {
+				float expect = ha[j] + hb[j];
+
+				if (hc[j] != expect) {
+					bad++;
+				}
+			}
+			ms[attempt & 1] = (long long)(ems * 1000.0f);
+			if (bad == 0) {
+				if (attempt > 0)
+					heals++;
+				printf("ITER %d OK attempt=%d launch_us=%lld\n",
+				       i, attempt, ms[attempt & 1]);
+				break;
+			}
+			fails++;
+			printf("ITER %d BAD bad=%d attempt=%d launch_us=%lld\n",
+			       i, bad, attempt, ms[attempt & 1]);
+			if (attempt >= 3) {
+				printf("ITER %d GIVEUP\n", i);
+				break;
+			}
+			attempt++;
+			printf("ITER %d SLEEP %ds before retry\n", i, sleep_s);
+			sleep(sleep_s);
+		}
+	}
+	printf("SUMMARY iters=%d fails=%d heals=%d sleep_s=%d\n",
+	       iters, fails, heals, sleep_s);
+	printf("STATUS %s\n", fails == 0 ? "OK" : "FAIL");
+	return fails == 0 ? 0 : 1;
+}