* @return the logon count
     */
    public short getLogonCount() {
        return this.logonCount;
    }

    /**
     * Returns the number of failed password attempts for this user.
     * @return the bad password count
     */
    public short getBadPasswordCount() {
        return this.badPasswordCount;
    }

    /**

        }

        try {
            return createContext(tc, targetDomain, host);
        } catch (GSSException e) {
            throw new SmbException("Context setup failed", e);
        }
    }

    /**
     * Set the Kerberos subject
     *
     * @param subject
     *            the subject to set
     */
    protected void setSubject(Subject subject) {

        throw new RuntimeException("Unexpected interrupt while waiting for latch", ie);
      }
    } while (System.nanoTime() - deadline < 0);
    throw formatRuntimeException(
        "Latch failed to count down within %d second timeout", timeoutSeconds);
  }

  /**
   * Creates a garbage object that counts down the latch in its finalizer. Sequestered into a

		if errors.Is(err, errRebalanceNotStarted) || errors.Is(err, errConfigNotFound) {
			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminRebalanceNotStarted), r.URL)
			return
		}
		adminLogIf(ctx, fmt.Errorf("failed to fetch rebalance status: %w", err))
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}
	adminLogIf(r.Context(), json.NewEncoder(w).Encode(rs))
}

   *
   * If the response body was successfully read until the end, this is the headers that followed,
   * or empty headers if there were none that followed.
   *
   * If the response body was closed prematurely or failed with an error, this will be the sentinel
   * value [TRAILERS_RESPONSE_BODY_TRUNCATED]. In that case attempts to read the trailers should not
   * return the value but instead throw an exception.
   */

}

func setGlobalAuthZPlugin(authz *polplugin.AuthZPlugin) {
	globalAuthPluginMutex.Lock()
	globalAuthZPlugin = authz
	globalAuthPluginMutex.Unlock()
}

        void shouldHandleExceptionsDuringResourceCleanup() throws Exception {
            SmbSession mockSession = mock(SmbSession.class);
            doThrow(new RuntimeException("Cleanup failed")).when(mockSession).close();

            assertThrows(RuntimeException.class, () -> {
                try (SmbSession session = mockSession) {
                    // Resource usage simulation

        )

    private
    fun toIncubatingDescription(node: Node, unit: CompilationUnit, file: File): IncubatingDescription {
        val nodeName = nodeName(node, unit, file)
        return IncubatingDescription(
            name = nodeName,
            sourceRelativePath = repositoryRoot.relativize(file.toPath()),
            lineNumber = node.begin.map { it.line }.orElse(-1)
        )
    }

    private

        }

        try {
          response = realChain.proceed(request)
          newRoutePlanner = true
        } catch (e: IOException) {
          // An attempt to communicate with a server failed. The request may have been sent.
          val isRecoverable = recover(e, call, request)
          call.eventListener.retryDecision(call, e, isRecoverable)
          if (!isRecoverable) throw e.withSuppressed(recoveredFailures)

            }
            throw new InterruptedRuntimeException(e);
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Command execution failed for user: username={}, error={}", username, e.getMessage(), e);
            }
            throw new CommandExecutionException("Process terminated for user: " + username, e);
        } finally {
            if (mt != null) {