response: Response? = null,
    isWriter: Boolean = false,
  ) {
    val socketToCancel: Socket?
    val writerToClose: WebSocketWriter?
    synchronized(this) {
      if (failed) return // Already failed.
      failed = true

      socketToCancel = this.socket

      writerToClose = this.writer
      this.writer = null

      if (!isWriter && writerToClose != null) {

                    String errorMsg = response != null ? response.getError() : "Response was null";
                    throw new IOException("Witness registration failed: " + errorMsg);
                }

            } catch (Exception e) {
                log.error("Failed to register for witness notifications", e);
                throw new RuntimeException(e);
            }
        });
    }

    /**

				return fmt.Errorf("Invalid according to Policy: Policy Condition failed")
			}
			// Check if current policy condition is satisfied
			if !checkPolicyCond(op, formValues.Get(formCanonicalName), policy.Value) {
				return fmt.Errorf("Invalid according to Policy: Policy Condition failed")
			}
		} else if strings.HasPrefix(policy.Key, "$x-amz-meta-") || strings.HasPrefix(policy.Key, "$x-amz-") {

        Object obj = expected;
        String result = ASN1Util.as(String.class, obj);
        assertSame(expected, result);
    }

    @Test
    void testAs_Object_Failure() {
        // Test failed casting
        Object obj = 123; // Integer
        assertThrows(PACDecodingException.class, () -> {
            ASN1Util.as(String.class, obj);
        }, "Should throw PACDecodingException for incompatible types");
    }

		if err != nil && !errors.Is(err, ft.expectedErr) {
			t.Fatalf("ToFileInfo failed due to %v", err)
		}
		if got := fi.TierFreeVersion(); got != ft.expectedFree {
			t.Fatalf("Expected free-version=%v but got free-version=%v", ft.expectedFree, got)
		}
		if ft.afterFn != nil {
			_, err = ft.afterFn(fi)
			if err != nil {
				t.Fatalf("ft.afterFn failed with err %v", err)
			}
		}
	}

        });
        try {
            userService.store(entity);
            saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL));
        } catch (final Exception e) {
            logger.warn("Failed to process a request.", e);
            throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)));
        }

		if err != nil && testCase.shouldPass {
			t.Errorf("Test %d: %s: Expected to pass, but failed with: <ERROR> %s", i+1, instanceType, err.Error())
		}
		if err == nil && !testCase.shouldPass {
			t.Errorf("Test %d: %s: Expected to fail with <ERROR> \"%s\", but passed instead", i+1, instanceType, testCase.err.Error())
		}
		// Failed as expected, but does it fail for the expected reason.
		if err != nil && !testCase.shouldPass {

      throw AssertionError("failed to set ALPN", e)
    } catch (e: IllegalAccessException) {
      throw AssertionError("failed to set ALPN", e)
    }
  }

  override fun afterHandshake(sslSocket: SSLSocket) {
    try {
      removeMethod.invoke(null, sslSocket)
    } catch (e: IllegalAccessException) {
      throw AssertionError("failed to remove ALPN", e)
    } catch (e: InvocationTargetException) {

    void hasCapability_throws() throws SmbException {
        doThrow(new SmbException("capability check failed")).when(transport).hasCapability(eq(42));
        SmbException ex = assertThrows(SmbException.class, () -> transport.hasCapability(42));
        assertTrue(ex.getMessage().contains("failed"));
        verify(transport).hasCapability(42);
    }

    // Edge: disconnected status toggles
    @ParameterizedTest

                    }
                } catch (Exception e) {
                    log.warn("Failed to create channel {} for session {}: {}", i, sessionId, e.getMessage());
                }
            }

            if (channelGroup.getChannelCount() == 0) {
                throw new CIFSException("Failed to create any channels for session " + sessionId);
            }