Align stream cancellation regression with SDK result contract

Author: KSemenenko

docs/implementation/status.json

@@ -25,7 +25,7 @@
       "decision": "docs/ADR/ADR-057-orleans-atomic-wal.md",
       "source": "generated_Orleans10.3.1_binary_mutations_closed_native_ReadOnlyMemoryOfByteCodec_explicit_kind_full_consumption_frame3_identity4_native_ZoneTree_unchanged",
       "upgrade": "offline_old_binary_compact_verified_backup_homogeneous_RF3_no_JSON_fallback",
-      "verification": "native_storage_Release_build_and_scoped_final_formatter_pass_dirty_combined_solution_blocked_by59_unrelated_comparison_diagnostics_final_exact_source_GitHub_unit_process_RF3_comparison_qualification_pending_prior6ad_failures_preserved",
+      "verification": "c10_Release_build_full_formatter_governance_analyzers118_normal1088_scalar1088_recovery136_RF3_63_pass_zero_skips_comparison3_of4_failed_exact_SDK_cancel_contract_locally_corrected_scoped_format_and_independent_review_pass_final_GitHub_full_gate_pending",
       "performance": "encoded_size_regression_authored_no_acceleration_power_loss_or_endurance_claim",
       "successorSequenceRepair": "source_guard_rejects_terminal_MaxValue_successor_before_decode_apply_or_truncation_real_checkpoint_legal_limit_wrapped_negative_unchanged_authority_and_ownership_regressions_GitHub_pending",
       "sourceReviewGaps": [
@@ -39,6 +39,39 @@
         "runId": 37077856823,
         "url": "https://github.com/managedcode/KeyLoad/actions/runs/37077856823",
         "conclusion": "failure"
+      },
+      "secondRun": {
+        "sourceRevision": "c10c48e40d8a9b452c9d131da549cab1e336692d",
+        "runId": 37079707413,
+        "url": "https://github.com/managedcode/KeyLoad/actions/runs/37079707413",
+        "conclusion": "failure",
+        "normalUnit": {
+          "passed": 1088,
+          "total": 1088,
+          "skipped": 0
+        },
+        "scalarUnit": {
+          "passed": 1088,
+          "total": 1088,
+          "skipped": 0
+        },
+        "processRecovery": {
+          "passed": 136,
+          "total": 136,
+          "skipped": 0
+        },
+        "rf3": {
+          "passed": 63,
+          "total": 63,
+          "skipped": 0
+        },
+        "comparison": {
+          "passed": 3,
+          "total": 4,
+          "skipped": 0,
+          "failure": "KeyLoadStreamPublicRegression expected exception instead of exact SDK Cancelled result"
+        },
+        "measuredProfiles": "skipped_after_comparison_failure"
       }
     },
     "evidence": [

tests/KeyLoad.ComparisonTests/Features/BenchmarkComparisons/KeyLoadStreamPublicRegression.cs

@@ -14,6 +14,7 @@ internal static class KeyLoadStreamPublicRegression
     private const ulong ExpectedRevision = 1;
     private const string ConflictingJson = "{\"payload\":\"conflict\"}";
     private const string ConflictCode = "KeyLoad:RevisionConflict";
+    private const string CancelledCode = "KeyLoad:Cancelled";
 
     internal static async Task VerifyAsync(DistributedApplication app, string adminKey,
         CancellationToken cancellationToken)
@@ -97,8 +98,8 @@ private static async Task VerifyCancellationAsync(IComparisonSession session, Be
         using var cancelled = new CancellationTokenSource();
         await cancelled.CancelAsync();
         var cancellationFailure = await CaptureCancellationAsync(() => session.ReadEventAsync(
-            dataset.Documents[SeededDocumentIndex], cancelled.Token));
-        await Assert.That(cancellationFailure is OperationCanceledException).IsTrue();
+            dataset.Documents[SeededDocumentIndex], cancelled.Token), cancelled.Token);
+        await Assert.That(cancellationFailure?.Message).IsEqualTo(CancelledCode);
         var following = dataset.CreateDocument(dataset.Options.Documents + FollowingStreamOffset);
         await session.ExecuteAsync(Scenario.StreamAppend, following, cancellationToken);
         await AssertEventAsync(await session.ReadEventAsync(following, cancellationToken), following);
@@ -127,14 +128,16 @@ private static async Task AssertEventAsync(FoundEvent? actual, BenchmarkDocument
         }
     }
 
-    private static async Task<OperationCanceledException?> CaptureCancellationAsync(Func<Task> operation)
+    private static async Task<ComparisonFailureException?> CaptureCancellationAsync(
+        Func<Task> operation, CancellationToken cancellationToken)
     {
         try
         {
             await operation();
             return null;
         }
-        catch (OperationCanceledException exception)
+        catch (ComparisonFailureException exception) when (
+            cancellationToken.IsCancellationRequested && exception.Message == CancelledCode)
         {
             return exception;
         }

zonetree-orleans-wal.plan.md

@@ -89,3 +89,9 @@ ADR057 now accepts explicit closed IFieldCodec<ReadOnlyMemory<byte>> registratio
 | TASK-WAL-NATIVE-FORMAT | WAL004/005; root high capability | Magic/identity/recovery guard and durable docs only; workers do not touch shared source | Fail closed for frames1/2, promote supported1/2/3 checkpoint-only; scoped source review/build/format then complete exact-final-SHA GitHub gate |
 
 The independently reviewed native EnsureAvailable checks bound array count by remaining input bytes and byte-memory lengths before allocation. Serialized MaxFrameBytes is enforced; decoded-memory amplification for deliberately malformed recomputed-checksum frames remains an explicit unqualified capability/evidence gap. Native session reset is correct. This join does not invent a cap, duplicate wire decoding, claim maximum speed, or establish power-loss/endurance.
+
+## Exact SDK cancellation contract join
+
+Exact c10c48e40 run37079707413 builds/formats successfully; comparison3/4 reaches the next retained regression and fails on KeyLoad:Cancelled in KeyLoadStreamPublicRegression.CaptureCancellationAsync. KeyLoadClient.Send intentionally converts cancelled reads into Result/ErrorCode.Cancelled; KeyLoadClientResults.Success wraps that as ComparisonFailureException. The existing SDK regression already asserts this result contract. TASK-WAL-CI-METADATA preserving scope now includes the exact pre-cancelled read assertion: require the actual KeyLoad:Cancelled adapter code and an actually cancelled caller token; successful completion and all other exceptions/codes still fail. Keep following append/read, original seeded read and exact event identity/revision/payload assertions intact. This is a test-contract correction, no SDK/adapter/product API, topology, retry or deadline change; ADR N/A. Lead owns only the constant/assertion/helper hunk and the final complete GitHub source join; concurrent nodeCount/peer edits remain unstaged.
+
+Completed c10c48e40 source gate: full solution build/formatter/governance and118 analyzer cases pass;1088/1088 normal and1088/1088 scalar units,136/136 real process recovery and63/63 RF3 SDK/MCP pass with0 skips. Comparison3/4 fails only the cancellation contract above; both measurement profiles skip after that failure. This is a failed whole workflow, not complete qualification. The exact preserving cancellation hunks pass independent source review and scoped formatting; dirty comparison build has9 unrelated isolated-feature diagnostics and0 owned cancellation diagnostics. Final revised-source full GitHub gate remains mandatory.