/** The CIFS context for NTLM authentication. */
    protected BaseContext cifsContext;

    /**
     * Constructs a JcifsEngine with the specified properties.
     *
     * @param props the properties for configuring the CIFS context
     * @throws CrawlingAccessException if an error occurs during initialization
     */

)

// loadClusterReplicationMetrics - `MetricsLoaderFn` for cluster replication metrics
// such as transfer rate and objects queued.
func loadClusterReplicationMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
	st := globalReplicationStats.Load()
	if st == nil {
		return nil
	}

	qs := st.getNodeQueueStatsSummary()

	qt := qs.QStats

    }

    /**
     * Get lifetime of this context.
     *
     * @return the remaining lifetime in seconds. If the default lifetime is
     *         used, this value have no meaning.
     */
    public int getLifeTime() {
        return this.contextLifetime;
    }

    /**
     * Set the lifetime for this context.
     *
     * @param time
     *            the lifetime in seconds

import org.apache.maven.cling.invoker.BaseParser;

public class UpgradeParser extends BaseParser {
    @Override
    protected Options parseCliOptions(LocalContext context) {
        try {
            return CommonsCliUpgradeOptions.parse(context.parserRequest.args().toArray(new String[0]));
        } catch (ParseException e) {
            throw new IllegalArgumentException("Failed to parse command line options: " + e.getMessage(), e);

     * @return session instance with the given type
     */
    <T extends SmbSession> T unwrap(Class<T> type);

    /**
     * Returns the CIFS context that this session is attached to.
     *
     * @return the context this session is attached to
     */
    CIFSContext getContext();

     */
    @Deprecated
    Model interpolate(Model project, Map<String, ?> context) throws ModelInterpolationException;

    /**
     * @deprecated Use {@link ModelInterpolator#interpolate(Model, File, ProjectBuilderConfiguration, boolean)} instead.
     */
    @Deprecated
    Model interpolate(Model model, Map<String, ?> context, boolean strict) throws ModelInterpolationException;

	return tr
}

// NewHTTPTransportWithClientCerts returns a new http configuration used for
// communicating with client cert authentication.
func (s ConnSettings) NewHTTPTransportWithClientCerts(ctx context.Context, clientCert, clientKey string) (*http.Transport, error) {
	transport := s.NewHTTPTransportWithTimeout(1 * time.Minute)
	if clientCert != "" && clientKey != "" {

class OkHttpClientTestRuleTest {
  lateinit var extensionContext: ExtensionContext

  @RegisterExtension @JvmField
  val beforeEachCallback =
    BeforeEachCallback { context ->
      ******@****.***ionContext = context
    }

  @Test fun uncaughtException() {
    val testRule = OkHttpClientTestRule()
    testRule.beforeEach(extensionContext)

    val thread =
      object : Thread() {

 *
 * @param <C> The context type.
 */
public interface CoreExtensionSelector<C extends LookupContext> {
    /**
     * Selects core extensions to be loaded from list of all sources detected.
     */
    @Nonnull
    List<CoreExtension> selectCoreExtensions(LookupInvoker<C> invoker, C context);

// does not send more content than specified size.
func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) {
	return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil)
}

func newReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64, disableMD5 bool, forceMD5 []byte) (*Reader, error) {