SettingsDecryptionResult result =
                                    settingsDecrypter.decrypt(new DefaultSettingsDecryptionRequest(server));
                            server = result.getServer();

                            AuthenticationInfo authInfo = new AuthenticationInfo();
                            authInfo.setUserName(server.getUsername());

			objectName := "dummy-object"
			functionID := "lambda1"
			functionToken := "token123"

			// Lambda mock server
			lambdaServer := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
				w.Header().Set(xhttp.AmzRequestRoute, functionID)
				w.Header().Set(xhttp.AmzRequestToken, functionToken)

        assertNull(request.getFullUNCPath());
        assertNull(request.getServer());
        assertNull(request.getDomain());

        request.setFullUNCPath("DOMAIN", "SERVER", "\\\\SERVER\\share\\file.txt");

        assertEquals("DOMAIN", request.getDomain());
        assertEquals("SERVER", request.getServer());
        assertEquals("\\\\SERVER\\share\\file.txt", request.getFullUNCPath());
    }

	}

	name := "MinIO FTP Server"
	if tls {
		name = "MinIO FTP(Secure) Server"
	}

	ftpServer, err := ftp.NewServer(&ftp.Options{
		Name:           name,
		WelcomeMessage: fmt.Sprintf("Welcome to '%s' FTP Server Version='%s' License='%s'", MinioStoreName, MinioLicense, Version),
		Driver:         NewFTPDriver(),
		Port:           port,

    }

    @Test
    void testConstructorAndGetters() {
        assertEquals(PROTO, dcerpcBinding.getProto(), "Protocol should match the constructor argument.");
        assertEquals(SERVER, dcerpcBinding.getServer(), "Server should match the constructor argument.");
        assertNull(dcerpcBinding.getOptions(), "Options should be null initially.");
        assertNull(dcerpcBinding.getEndpoint(), "Endpoint should be null initially.");

    @Override
    public String getFullUNCPath() {
        return this.fullName;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.RequestWithPath#getServer()
     */
    @Override
    public String getServer() {
        return this.server;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.RequestWithPath#getDomain()
     */
    @Override

            return null;
        }

        @Override
        public String getServerWithDfs() {
            return null;
        }

        @Override
        public String getServer() {
            return null;
        }

        @Override
        public String getDfsPath() {
            return null;
        }

        @Override
        public int getPort() {

		subrouter.Methods(http.MethodPost).Path("/v1/runlock").HandlerFunc(lockServer.RUnlockHandler)
		subrouter.Methods(http.MethodPost).Path("/v1/force-unlock").HandlerFunc(lockServer.ForceUnlockHandler)

		nodes[i] = httptest.NewServer(router)
	}
}

const WriteLock = -1

type lockServer struct {
	mutex sync.Mutex
	// Map of locks, with negative value indicating (exclusive) write lock

  server_def.set_task_index(0);
  std::unique_ptr<tensorflow::ServerInterface> w0;
  ASSERT_TRUE(
      factory->NewServer(server_def, ServerFactory::Options(), &w0).ok());
  ASSERT_TRUE(w0->Start().ok());
  server_def.set_task_index(1);
  std::unique_ptr<tensorflow::ServerInterface> w1;
  ASSERT_TRUE(
      factory->NewServer(server_def, ServerFactory::Options(), &w1).ok());
  ASSERT_TRUE(w1->Start().ok());

            }

            // Pre-store the checksums as any future puts will overwrite them
            for (String extension : checksums.keySet()) {
                ChecksumObserver observer = checksums.get(extension);
                sums.put(extension, observer.getActualChecksum());
            }

            // We do this in here so we can checksum the artifact metadata too, otherwise it could be metadata itself