* the License.
 */

package com.google.common.util.concurrent;

import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Throwables.throwIfUnchecked;
import static com.google.common.util.concurrent.Platform.restoreInterruptIfIsInterruptedException;
import static java.util.concurrent.Executors.callable;

import com.google.common.annotations.GwtIncompatible;

    </dependency>
    <dependency>
      <groupId>org.apache.maven</groupId>
      <artifactId>maven-compat</artifactId>
    </dependency>

    <dependency>
      <groupId>commons-cli</groupId>
      <artifactId>commons-cli</artifactId>
    </dependency>
    <dependency>
      <groupId>org.apache.maven.wagon</groupId>
      <artifactId>wagon-http</artifactId>
    </dependency>
    <dependency>

) : AbstractExecutorService() {
  private var shutdown: Boolean = false
  private val calls = mutableListOf<RealCall.AsyncCall>()

  override fun execute(command: Runnable) {
    if (shutdown) throw RejectedExecutionException()
    calls.add(command as RealCall.AsyncCall)
  }

  fun assertJobs(vararg expectedUrls: String) {
    val actualUrls = calls.map { it.request.url.toString() }

import jcifs.Configuration;
import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.smb1.AndXServerMessageBlock;
import jcifs.internal.util.SMBUtil;

/**
 * SMB1 COM_LOCKING_ANDX command implementation.
 *
 * This command locks or unlocks byte ranges within a file. It can also
 * be used to break oplocks and change oplock levels.
 *
 * @author mbechler
 */
public class SmbComLockingAndX extends AndXServerMessageBlock {

      <artifactId>maven-plugin</artifactId>
      <version>2.0-SNAPSHOT</version>
      <type>jar</type>
      <scope>compile</scope>
    </dependency>
    <dependency>
      <groupId>commons-cli</groupId>
      <artifactId>commons-cli</artifactId>
      <version>1.0-beta-2</version>
      <type>jar</type>
      <scope>compile</scope>
    </dependency>
    <dependency>
      <groupId>plexus</groupId>

import jcifs.internal.util.SMBUtil;

/**
 * SMB1 COM_SEEK command implementation.
 *
 * This command changes the current file position pointer for a file.
 * It allows seeking to different positions within an open file.
 *
 * @author mbechler
 */
public class SmbComSeek extends ServerMessageBlock {

    /**
     * Constructs a seek command.
     *
     * @param config the configuration

    }

    @Test
    void testConstructor() {
        assertNotNull(setupAndX);
        assertEquals(ServerMessageBlock.SMB_COM_SESSION_SETUP_ANDX, setupAndX.command);
        assertEquals(mockSession, setupAndX.session);
        assertEquals(mockAuth, setupAndX.cred);
    }

    @Test
    void testConstructorWithAnonymousAuth() throws Exception {

        @DisplayName("Should create request with configuration and command")
        void testConstructorWithConfigAndCommand() {
            int command = SMB2_NEGOTIATE;
            TestServerMessageBlock2Request request = new TestServerMessageBlock2Request(mockConfig, command);
            assertNotNull(request);
            assertEquals(mockConfig, request.getConfig());
            assertEquals(command, request.getCommand());
        }
    }

        <![CDATA[
      Flags the system as offline, to prevent accessing the network to resolve artifacts or execute plugins.

      NOTE: It's also possible to switch to offline mode on a per-build basis, using the '-o' command-line option.
    ]]></description>
    </expression>
    <expression>
      <syntax>settings.interactiveMode</syntax>
      <configuration>
        <![CDATA[
    <interactiveMode>true</interactiveMode>

@app.get("/main-depends/")
async def main_depends(commons: dict = Depends(common_parameters)):
    return {"in": "main-depends", "params": commons}


@app.get("/decorator-depends/", dependencies=[Depends(common_parameters)])
async def decorator_depends():
    return {"in": "decorator-depends"}


@router.get("/router-depends/")
async def router_depends(commons: dict = Depends(common_parameters)):