* requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()}
 * callbacks. Its subclasses must manage threads manually; consider {@link
 * AbstractExecutionThreadService} if you need only a single execution thread.
 *
 * @author Jesse Wilson
 * @author Luke Sandberg
 * @since 1.0
 */
@GwtIncompatible
@J2ktIncompatible
public abstract class AbstractService implements Service {

  receipt of the Program under the terms of a Secondary License
  (if permitted under the terms of Section 3).

3. REQUIREMENTS

3.1 If a Contributor Distributes the Program in any form, then:

  a) the Program must also be made available as Source Code, in
  accordance with section 3.2, and the Contributor must accompany
  the Program with a statement that the Source Code for the Program

import org.apache.maven.artifact.versioning.InvalidVersionSpecificationException;
import org.apache.maven.artifact.versioning.VersionRange;
import org.apache.maven.bridge.MavenRepositorySystem;
import org.apache.maven.execution.MavenSession;
import org.apache.maven.model.Dependency;
import org.apache.maven.model.DependencyManagement;
import org.apache.maven.model.DistributionManagement;
import org.apache.maven.model.Model;

    assertSame(firstException.getCause(), expected.getCause());
    // lockA should work after lockB is released.
    lockB.unlock();
    lockA.lock();
  }

  // Tests transitive deadlock detection.
  public void testDeadlock_threeLocks() {
    // Establish an ordering from lockA -> lockB.
    lockA.lock();
    lockB.lock();
    lockB.unlock();
    lockA.unlock();

    assertSame(firstException.getCause(), expected.getCause());
    // lockA should work after lockB is released.
    lockB.unlock();
    lockA.lock();
  }

  // Tests transitive deadlock detection.
  public void testDeadlock_threeLocks() {
    // Establish an ordering from lockA -> lockB.
    lockA.lock();
    lockB.lock();
    lockB.unlock();
    lockA.unlock();

    void testMaxDataCountValues(int maxDataCount) throws Exception {
        netShareEnum = new NetShareEnum(realConfig);

        // Set maxDataCount using reflection
        setFieldValue(netShareEnum, "maxDataCount", maxDataCount);

        byte[] dst = new byte[256];
        int bytesWritten = netShareEnum.writeParametersWireFormat(dst, 0);

            boolean hasEnoughSpace = allocInfo.getFree() >= requiredSpace;

            // Then
            assertTrue(hasEnoughSpace);
        }

        @Test
        @DisplayName("Should support full disk detection pattern")
        void shouldSupportFullDiskDetectionPattern() {
            // Given
            TestAllocInfo fullDisk = new TestAllocInfo(1024L, 0L);
            TestAllocInfo partialDisk = new TestAllocInfo(1024L, 512L);

   |
   | As noted above, profiles can be activated in a variety of ways. One way - the activeProfiles
   | section of this document (settings.xml) - will be discussed later. Another way essentially
   | relies on the detection of a property, either matching a particular value for the property,
   | or merely testing its existence. Profiles can also be activated by JDK version prefix, where a

        OptionalEntity<CharMappingItem> existing = charMappingFile.get(1L);
        assertTrue(existing.isPresent());

        // Delete the item
        charMappingFile.delete(existing.get());

        // Verify deletion
        PagingList<CharMappingItem> result = charMappingFile.selectList(0, 10);
        assertEquals(1, result.size());
        assertEquals("f", result.get(0).getOutput());
    }

	xioutil "github.com/minio/minio/internal/ioutil"
)

func renameAllBucketMetacache(epPath string) error {
	// Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to
	// to `.minio.sys/tmp/` for deletion.
	return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error {
		if typ == os.ModeDir {
			tmpMetacacheOld := pathutil.Join(epPath, minioMetaTmpDeletedBucket, mustGetUUID())