// EncodeMsg implements msgp.Encodable
func (z *CheckPartsHandlerParams) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 4
	// write "id"
	err = en.Append(0x84, 0xa2, 0x69, 0x64)
	if err != nil {
		return
	}
	err = en.WriteString(z.DiskID)
	if err != nil {
		err = msgp.WrapError(err, "DiskID")
		return
	}
	// write "v"
	err = en.Append(0xa1, 0x76)
	if err != nil {
		return
	}

java.io.IOException; public static void copy(java.io.Reader, java.io.Writer) throws java.io.IOException; public static void copy(java.io.Reader, java.io.Writer, int) throws java.io.IOException; public static void copy(java.io.InputStream, java.io.Writer) throws java.io.IOException; public static void copy(java.io.InputStream, java.io.Writer, int) throws java.io.IOException; public static void copy(java.io.InputStream, java.io.Writer, String) throws java.io.IOException; public static void copy(java.io.InputStream,...

     * A queue of elements currently in the map, ordered by write time. Elements are added to the
     * tail of the queue on write.
     */
    @GuardedBy("this")
    final Queue<ReferenceEntry<K, V>> writeQueue;

    /**
     * A queue of elements currently in the map, ordered by access time. Elements are added to the
     * tail of the queue on access (note that writes count as accesses).
     */
    @GuardedBy("this")

HSPLokhttp3/internal/http2/Hpack$Reader;->readInt(II)I
HSPLokhttp3/internal/http2/Hpack$Writer;-><init>(IZLokio/Buffer;I)V
HSPLokhttp3/internal/http2/Hpack$Writer;->evictToRecoverBytes(I)I
HSPLokhttp3/internal/http2/Hpack$Writer;->insertIntoDynamicTable(Lokhttp3/internal/http2/Header;)V
HSPLokhttp3/internal/http2/Hpack$Writer;->writeByteString(Lokio/ByteString;)V
HSPLokhttp3/internal/http2/Hpack$Writer;->writeHeaders(Ljava/util/List;)V

		for k, value := range customHeaders {
			req.Header.Set(k, value)
		}
	}

	checksumData := func(b []byte, h hash.Hash) string {
		h.Reset()
		_, err := h.Write(b)
		if err != nil {
			t.Fatal(err)
		}
		return base64.StdEncoding.EncodeToString(h.Sum(nil))
	}
	// test cases with inputs and expected result for GetObject.
	testCases := []struct {

     * file attibutes such as ACLs but it does copy regular attributes as
     * well as create and last write times. This method is almost twice as
     * efficient as manually copying as it employs an additional write
     * thread to read and write data concurrently.
     *
     * It is not possible (nor meaningful) to copy entire workgroups or
     * servers.
     *

    }
    source.close()
  }

  /** Confirm that an unacknowledged write times out.  */
  @Test
  fun writeTimeouts() {
    val server = MockWebServer()
    // Sockets on some platforms can have large buffers that mean writes do not block when
    // required. These socket factories explicitly set the buffer sizes on sockets created.
    val socketBufferSize = 4 * 1024

		return metrics
	})
	return mg
}

func getClusterWriteQuorumMD() MetricDescription {
	return MetricDescription{
		Namespace: clusterMetricNamespace,
		Subsystem: "write",
		Name:      "quorum",
		Help:      "Maximum write quorum across all pools and sets",
		Type:      gaugeMetric,
	}
}

func getClusterHealthStatusMD() MetricDescription {
	return MetricDescription{

			// write error response only if no data or headers has been written to client yet
			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
			return
		}
		return
	}

	if err = httpWriter.Close(); err != nil {
		if !httpWriter.HasWritten() && !statusCodeWritten { // write error response only if no data or headers has been written to client yet
			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
			return

	}

	gotBuckets := set.NewStringSet()
	for _, b := range accInfo.Buckets {
		gotBuckets.Add(b.Name)
		if !b.Access.Read || !b.Access.Write {
			c.Fatalf("root user should have read and write access to bucket: %v", b.Name)
		}
	}
	shouldHaveBuckets := set.CreateStringSet(bucket2, bucket)
	if !gotBuckets.Equals(shouldHaveBuckets) {