SYS_INOTIFY_ADD_WATCH            = 276
	SYS_INOTIFY_RM_WATCH             = 277
	SYS_SPU_RUN                      = 278
	SYS_SPU_CREATE                   = 279
	SYS_PSELECT6                     = 280
	SYS_PPOLL                        = 281
	SYS_UNSHARE                      = 282
	SYS_SPLICE                       = 283
	SYS_TEE                          = 284
	SYS_VMSPLICE                     = 285

   * @param terminationTimeout how long to wait for the executor to finish before terminating the
   *     JVM
   * @return an unmodifiable version of the input which will not hang the JVM
   * @since 28.0
   */
  @J2ktIncompatible
  @GwtIncompatible // TODO
  public static ExecutorService getExitingExecutorService(
      ThreadPoolExecutor executor, Duration terminationTimeout) {
    return getExitingExecutorService(

	SYS_SET_MEMPOLICY                = 276
	SYS_MQ_OPEN                      = 277
	SYS_MQ_UNLINK                    = 278
	SYS_MQ_TIMEDSEND                 = 279
	SYS_MQ_TIMEDRECEIVE              = 280
	SYS_MQ_NOTIFY                    = 281
	SYS_MQ_GETSETATTR                = 282
	SYS_KEXEC_LOAD                   = 283
	SYS_WAITID                       = 284
	SYS_ADD_KEY                      = 286

	} else if x == 275 {
		x += 275
	} else if x == 276 {
		x += 276
	} else if x == 277 {
		x += 277
	} else if x == 278 {
		x += 278
	} else if x == 279 {
		x += 279
	} else if x == 280 {
		x += 280
	} else if x == 281 {
		x += 281
	} else if x == 282 {
		x += 282
	} else if x == 283 {
		x += 283
	} else if x == 284 {
		x += 284
	} else if x == 285 {
		x += 285

   * @param timeout how long to wait before giving up
   * @return the number of elements transferred
   * @throws InterruptedException if interrupted while waiting
   * @since 28.0
   */
  @CanIgnoreReturnValue
  @J2ktIncompatible
  @GwtIncompatible // BlockingQueue
  public static <E> int drain(

DATA ·erfcrodataL38<> + 256(SB)/8, $.135970046909529513E-05
DATA ·erfcrodataL38<> + 264(SB)/8, $.277617717014748015E-06
DATA ·erfcrodataL38<> + 272(SB)/8, $.810628018408232910E-08
DATA ·erfcrodataL38<> + 280(SB)/8, $.210430084693497985E-07
DATA ·erfcrodataL38<> + 288(SB)/8, $-.342138077525615091E-08
DATA ·erfcrodataL38<> + 296(SB)/8, $-.165467946798610800E-06
DATA ·erfcrodataL38<> + 304(SB)/8, $5.999999999988412824

	_ = x[ErrParseExpectedLeftParenValueConstructor-277]
	_ = x[ErrParseExpectedLeftParenBuiltinFunctionCall-278]
	_ = x[ErrParseExpectedArgumentDelimiter-279]
	_ = x[ErrParseCastArity-280]
	_ = x[ErrParseInvalidTypeParam-281]
	_ = x[ErrParseEmptySelect-282]
	_ = x[ErrParseSelectMissingFrom-283]
	_ = x[ErrParseExpectedIdentForGroupName-284]
	_ = x[ErrParseExpectedIdentForAlias-285]

        ? (FluentFuture<V>) future
        : new ForwardingFluentFuture<V>(future);
  }

  /**
   * Simply returns its argument.
   *
   * @deprecated no need to use this
   * @since 28.0
   */
  @Deprecated
  public static <V extends @Nullable Object> FluentFuture<V> from(FluentFuture<V> future) {
    return checkNotNull(future);
  }

  /**

                <mxCell id="1" parent="0"/>
                <mxCell id="2" value="" style="rounded=0;whiteSpace=wrap;html=1;fontStyle=1;strokeWidth=4;" parent="1" vertex="1">
                    <mxGeometry x="420" y="280" width="920" height="670" as="geometry"/>
                </mxCell>

		var bits [288]int
		for i := 0; i < 144; i++ {
			bits[i] = 8
		}
		for i := 144; i < 256; i++ {
			bits[i] = 9
		}
		for i := 256; i < 280; i++ {
			bits[i] = 7
		}
		for i := 280; i < 288; i++ {
			bits[i] = 8
		}
		fixedHuffmanDecoder.init(bits[:])
	})
}

func (f *decompressor) Reset(r io.Reader, dict []byte) error {
	*f = decompressor{