import jcifs.Encodable;
import jcifs.internal.util.SMBUtil;

/**
 * DFS (Distributed File System) referral request buffer encoder.
 * Creates encoded request buffers for DFS referral requests, specifying the maximum
 * referral level and target path for which DFS resolution is requested.
 *
 * @author mbechler
 */
public class DfsReferralRequestBuffer implements Encodable {

    private final int maxReferralLevel;
    private final String path;

    LocalCache<?, ?> map = CacheTesting.toLocalCache(cache);
    assertThat(map.segments).hasLength(4); // concurrency level
    assertEquals(4, map.segments[0].table.length()); // capacity / conc level
  }

  @GwtIncompatible // CountDownLatch
  static final class DelayingIdentityLoader<T> extends CacheLoader<T, T> {
    private final AtomicBoolean shouldWait;

    LocalCache<?, ?> map = CacheTesting.toLocalCache(cache);
    assertThat(map.segments).hasLength(4); // concurrency level
    assertEquals(4, map.segments[0].table.length()); // capacity / conc level
  }

  @GwtIncompatible // CountDownLatch
  static final class DelayingIdentityLoader<T> extends CacheLoader<T, T> {
    private final AtomicBoolean shouldWait;

 * limitations under the License.
 */
package okhttp3.internal.concurrent

import java.util.logging.Level
import java.util.logging.Logger

internal inline fun Logger.taskLog(
  task: Task,
  queue: TaskQueue,
  messageBlock: () -> String,
) {
  if (isLoggable(Level.FINE)) {
    log(task, queue, messageBlock())
  }
}

internal inline fun <T> Logger.logElapsed(
  task: Task,

            final int n = NEGOTIATE_REQUEST.encode(sbuf, 4);
            Encdec.enc_uint32be(n & 0xFFFF, sbuf, 0); /* 4 byte ssn msg header */

            if (LogStream.level >= 4) {
                log.println(NEGOTIATE_REQUEST);
                if (LogStream.level >= 6) {
                    Hexdump.hexdump(log, sbuf, 4, n);
                }
            }

            out.write(sbuf, 0, 4 + n);
            out.flush();

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;

import java.io.File;
import java.util.logging.Level;
import java.util.logging.Logger;

import org.codelibs.curl.Curl.Method;
import org.junit.Test;

public class CurlTest {
    private static final Logger logger = Logger.getLogger(CurlTest.class.getName());

    protected ThreadDumpUtil() {
        // noop
    }

    /**
     * Prints thread dump information to the logger at INFO level.
     */
    public static void printThreadDump() {
        processThreadDump(logger::info);
    }

    /**
     * Prints thread dump information to the logger at WARN level.
     */
    public static void printThreadDumpAsWarn() {
        processThreadDump(logger::warn);
    }

    /**

                dstIndex += b.length;
                dst[dstIndex] = (byte) '\0';
                dstIndex++;
            }
        } catch (final UnsupportedEncodingException uee) {
            if (LogStream.level > 1) {
                uee.printStackTrace(log);
            }
        }

        return dstIndex - start;
    }

    String readString(final byte[] src, final int srcIndex) {

  @Deprecated(
    message = "moved to val",
    replaceWith = ReplaceWith(expression = "type"),
    level = DeprecationLevel.ERROR,
  )
  fun type(): MediaType = type

  @JvmName("-deprecated_boundary")
  @Deprecated(
    message = "moved to val",
    replaceWith = ReplaceWith(expression = "boundary"),
    level = DeprecationLevel.ERROR,
  )
  fun boundary(): String = boundary

  @JvmName("-deprecated_size")

        assertNotNull(exception);
        assertEquals("Top level GSA error", exception.getMessage());

        // Check first level cause
        assertNotNull(exception.getCause());
        assertEquals("Intermediate problem", exception.getCause().getMessage());

        // Check second level cause