// Granted - represents a structure of a granted lock.
type Granted struct {
	index   int
	lockUID string // Locked if set with UID string, unlocked if empty
}

func (g *Granted) isLocked() bool {
	return isLocked(g.lockUID)
}

func isLocked(uid string) bool {
	return len(uid) > 0
}

// NewDRWMutex - initializes a new dsync RW mutex.
func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex {

   * Returns whether this monitor is occupied by any thread. This method is designed for use in
   * monitoring of the system state, not for synchronization control.
   */
  public boolean isOccupied() {
    return lock.isLocked();
  }

  /**
   * Returns whether the current thread is occupying this monitor (has entered more times than it
   * has left).
   */
  public boolean isOccupiedByCurrentThread() {

      }
    }
    return call.messageDone(
      exchange = this,
      requestDone = requestDone && !isSocket,
      responseDone = responseDone && !isSocket,
      socketSinkDone = requestDone && isSocket,
      socketSourceDone = responseDone && isSocket,
      e = e,
    )
  }

  fun noRequestBody() {
    call.messageDone(
      exchange = this,
      requestDone = true,

        boolean isDocker = type.isDocker();
        ElasticsearchDistribution distro = distributions.create(name, d -> {
            d.setArchitecture(architecture);
            d.setType(type);
            if (type == ARCHIVE) {
                d.setPlatform(platform);
            }
            if (isDocker == false) {
                d.setBundledJdk(bundledJdk);
            }

            }
        }

        // Check per-IP limit
        if (sourceIp != null) {
            IpAttempts ip = ipAttempts.computeIfAbsent(sourceIp, k -> new IpAttempts());
            if (ip.isBlocked()) {
                if (ip.getBlockExpiry().isAfter(Instant.now())) {
                    totalAttemptsBlocked.incrementAndGet();
                    totalIpsBlocked.incrementAndGet();

    @Override
    public String getName() {
        return "rpm";
    }

    @Override
    public boolean shouldExtract() {
        return false;
    }

    @Override
    public boolean isDocker() {
        return false;
    }

    DockerCloudElasticsearchDistributionType() {}

    @Override
    public String getName() {
        return "dockerCloud";
    }

    @Override
    public boolean isDocker() {
        return true;
    }

    DockerIronBankElasticsearchDistributionType() {}

    @Override
    public String getName() {
        return "dockerIronBank";
    }

    @Override
    public boolean isDocker() {
        return true;
    }

    DockerUbiElasticsearchDistributionType() {}

    @Override
    public String getName() {
        return "dockerUbi";
    }

    @Override
    public boolean isDocker() {
        return true;
    }

    DockerCloudEssElasticsearchDistributionType() {}

    @Override
    public String getName() {
        return "dockerCloudEss";
    }

    @Override
    public boolean isDocker() {
        return true;
    }