*/
    public static final String PARENT_URL = "parentUrl";

    /**
     * Field name for depth.
     */
    public static final String DEPTH = "depth";

    /**
     * Field name for last modified timestamp.
     */
    public static final String LAST_MODIFIED = "lastModified";

    /**
     * Field name for creation time.
     */
    public static final String CREATE_TIME = "createTime";

         */
        public void setBreaking(boolean breaking) {
            this.breaking = breaking;
        }

        /**
         * Gets the timestamp of the last lease access
         * @return last access time in milliseconds
         */
        public long getLastAccessTime() {
            return lastAccessTime;
        }
    }

    /**
     * Request a lease for a file path

    message: String,
    stackTrace: Any?,
  ) {
    if (Build.VERSION.SDK_INT >= 30) {
      (stackTrace as CloseGuard).warnIfOpen()
    } else {
      // Unable to report via CloseGuard. As a last-ditch effort, send it to the logger.
      super.logCloseableLeak(message, stackTrace)
    }
  }

  @SuppressLint("NewApi")
  override fun isCleartextTrafficPermitted(hostname: String): Boolean =

		if first != tc.first {
			t.Errorf("IndexFunc(%q, %s) = %d; want %d", tc.in, tc.f.name, first, tc.first)
		}
		last := LastIndexFunc([]byte(tc.in), tc.f.f)
		if last != tc.last {
			t.Errorf("LastIndexFunc(%q, %s) = %d; want %d", tc.in, tc.f.name, last, tc.last)
		}
	}
}

type ReplaceTest struct {
	in       string
	old, new string
	n        int
	out      string
}

      assertThrows(IndexOutOfBoundsException.class, () -> aa.getAndAdd(index, 1.0));
      assertThrows(IndexOutOfBoundsException.class, () -> aa.addAndGet(index, 1.0));
    }
  }

  /** get returns the last value set at index */
  public void testGetSet() {
    AtomicDoubleArray aa = new AtomicDoubleArray(VALUES.length);
    for (int i = 0; i < VALUES.length; i++) {
      assertBitEquals(0.0, aa.get(i));

    }

    @Test
    public void test_ApiStartJobResponse_statusFluentChain() {
        final ApiStartJobResponse response = new ApiStartJobResponse();
        // status() returns ApiResponse, so the chain works when called last
        final ApiResponse returned = response.jobLogId("id-1").status(Status.OK);
        assertNotNull(returned);
    }

    @Test
    public void test_ApiStartJobResponse_hasVersionField() {

    /**
     * Creates a new SMB1 close file request.
     *
     * @param config the CIFS configuration
     * @param fid the file identifier to close
     * @param lastWriteTime the last write time to set on the file
     */
    public SmbComClose(final Configuration config, final int fid, final long lastWriteTime) {
        super(config, SMB_COM_CLOSE);
        this.fid = fid;

type MonitoredReader struct {
	r        io.Reader
	throttle *bucketThrottle
	ctx      context.Context // request context
	lastErr  error           // last error reported, if this non-nil all reads will fail.
	m        *Monitor
	opts     *MonitorReaderOptions
}

// BucketOptions represents the bucket and optionally its replication target pair.
type BucketOptions struct {

	AmzFwdHeaderExpires            = "x-amz-fwd-header-Expires"
	AmzFwdHeaderExpiration         = "x-amz-fwd-header-x-amz-expiration"
	AmzFwdHeaderLastModified       = "x-amz-fwd-header-Last-Modified"

	AmzFwdHeaderObjectLockMode        = "x-amz-fwd-header-x-amz-object-lock-mode"
	AmzFwdHeaderObjectLockLegalHold   = "x-amz-fwd-header-x-amz-object-lock-legal-hold"

  /** The full set of events, used to match starts with ends. */
  private val eventsForMatching = ConcurrentLinkedDeque<CallEvent>()

  private val forbiddenLocks = mutableListOf<Any>()

  /** The timestamp of the last taken event, used to measure elapsed time between events. */
  private var lastTimestampNs: Long? = null

  /** Confirm that the thread does not hold a lock on `lock` during the callback. */
  fun forbidLock(lock: Any) {