<type>RepositoryPolicy</type>
          </association>
        </field>
      </fields>
      <!-- prevent Modello generation of an incorrect equals method. Could be avoided by using <identity/> tags to mark ID as the only identity field -->
      <codeSegments>
        <codeSegment>
          <version>1.0.0/1.1.0</version>
          <code>
            <![CDATA[
    /**

(HTBL)(R9), VH MOVD $0x50, R9 LXVD2X (HTBL)(R10), VHH MOVD $0x60, R10 LXVD2X (HTBL)(R0), VXC2 #ifdef GOARCH_ppc64le LVSL (R0)(R0), LEMASK VSPLTISB $0x07, T0 VXOR LEMASK, T0, LEMASK VPERM XL, XL, LEMASK, XL #endif VXOR ZERO, ZERO, ZERO CMPU LEN, $64 BGE gcm_ghash_p8_4x LXVD2X (INP)(R0), VIN ADD $16, INP, INP SUBCCC $16, LEN, LEN #ifdef GOARCH_ppc64le VPERM IN, IN, LEMASK, IN #endif VXOR IN, XL, IN BEQ short LXVD2X (HTBL)(R8), VH2L // load H^2 MOVD $16, R8 LXVD2X (HTBL)(R9), VH2 ADD LEN, INP, R9 // end...

	r := z.rebalMeta
	poolStats := r.PoolStats[poolIdx]
	if poolStats.Info.Status == rebalCompleted {
		return true
	}

	pfi := float64(poolStats.InitFreeSpace+poolStats.Bytes) / float64(poolStats.InitCapacity)
	// Mark pool rebalance as done if within 5% from PercentFreeGoal.
	if diff := math.Abs(pfi - r.PercentFreeGoal); diff <= 0.05 {
		r.PoolStats[poolIdx].Info.Status = rebalCompleted
		r.PoolStats[poolIdx].Info.EndTime = time.Now()

                }

                rl = nextCommand != 0 ? nextCommand : size;

                if (log.isDebugEnabled()) {
                    log.debug(String.format("Compound next command %d read size %d remain %d", nextCommand, rl, size));
                }

                cur.setReadSize(rl);
                readn(this.in, buffer, Smb2Constants.SMB2_HEADER_LENGTH, rl - Smb2Constants.SMB2_HEADER_LENGTH);

  }

  /**
   * Serialized type for all ImmutableSortedMap instances. It captures the logical contents and they
   * are reconstructed using public factory methods. This ensures that the implementation types
   * remain as implementation details.
   */
  @J2ktIncompatible // serialization
  private static final class SerializedForm<K, V> extends ImmutableMap.SerializedForm<K, V> {
    private final Comparator<? super K> comparator;

  }

  /**
   * Serialized type for all ImmutableSortedMap instances. It captures the logical contents and they
   * are reconstructed using public factory methods. This ensures that the implementation types
   * remain as implementation details.
   */
  @J2ktIncompatible // serialization
  private static final class SerializedForm<K, V> extends ImmutableMap.SerializedForm<K, V> {
    private final Comparator<? super K> comparator;

(HTBL)(R9), VH MOVD $0x50, R9 LXVD2X (HTBL)(R10), VHH MOVD $0x60, R10 LXVD2X (HTBL)(R0), VXC2 #ifdef GOARCH_ppc64le LVSL (R0)(R0), LEMASK VSPLTISB $0x07, T0 VXOR LEMASK, T0, LEMASK VPERM XL, XL, LEMASK, XL #endif VXOR ZERO, ZERO, ZERO CMPU LEN, $64 BGE gcm_ghash_p8_4x LXVD2X (INP)(R0), VIN ADD $16, INP, INP SUBCCC $16, LEN, LEN #ifdef GOARCH_ppc64le VPERM IN, IN, LEMASK, IN #endif VXOR IN, XL, IN BEQ short LXVD2X (HTBL)(R8), VH2L // load H^2 MOVD $16, R8 LXVD2X (HTBL)(R9), VH2 ADD LEN, INP, R9 // end...

	usersSysType UsersSysType

	rolesMap map[arn.ARN]string

	// Persistence layer for IAM subsystem
	store *IAMStoreSys

	// configLoaded will be closed and remain so after first load.
	configLoaded chan struct{}
}

// IAMUserType represents a user type inside MinIO server
type IAMUserType int

const (
	unknownIAMUserType IAMUserType = iota - 1
	regUser

    <RequestProgress>
        <Enabled>FALSE</Enabled>
    </RequestProgress>
	<ScanRange><Start>76</Start><End>109</End></ScanRange>
</SelectObjectContentRequest>`),
		},
		{
			name:  "select-remain",
			input: testInput,
			// Since we are doing offset, no headers are used.
			wantResult: `{"_1":"2","_2":"2017-01-02T03:04Z","_3":"-5","_4":" 0.765111","_5":""}`,

type scriptedReader []func(p []byte) (n int, err error)

func (sr *scriptedReader) Read(p []byte) (n int, err error) {
	if len(*sr) == 0 {
		panic("too many Read calls on scripted Reader. No steps remain.")
	}
	step := (*sr)[0]
	*sr = (*sr)[1:]
	return step(p)
}

func newScriptedReader(steps ...func(p []byte) (n int, err error)) io.Reader {
	sr := scriptedReader(steps)
	return &sr
}