reset() throws java.io.IOException; public boolean markSupported(); } org/codehaus/plexus/util/StringOutputStream.class package org.codehaus.plexus.util; public synchronized class StringOutputStream extends java.io.OutputStream { private StringBuffer buf; public void StringOutputStream(); public void write(byte[]) throws java.io.IOException; public void write(byte[], int, int) throws java.io.IOException; public void write(int) throws java.io.IOException; public String toString(); } org/codehaus/ple...

reset() throws java.io.IOException; public boolean markSupported(); } org/codehaus/plexus/util/StringOutputStream.class package org.codehaus.plexus.util; public synchronized class StringOutputStream extends java.io.OutputStream { private StringBuffer buf; public void StringOutputStream(); public void write(byte[]) throws java.io.IOException; public void write(byte[], int, int) throws java.io.IOException; public void write(int) throws java.io.IOException; public String toString(); } org/codehaus/ple...

reset() throws java.io.IOException; public boolean markSupported(); } org/codehaus/plexus/util/StringOutputStream.class package org.codehaus.plexus.util; public synchronized class StringOutputStream extends java.io.OutputStream { private StringBuffer buf; public void StringOutputStream(); public void write(byte[]) throws java.io.IOException; public void write(byte[], int, int) throws java.io.IOException; public void write(int) throws java.io.IOException; public String toString(); } org/codehaus/ple...

}

// Replace formats the contents of v into the provided template.
func replace(tmpl string, v interface{}) string {
	t := template.Must(template.New("test").Parse(tmpl))
	buf := bytes.NewBuffer(nil)
	t.Execute(buf, &v)
	ret := buf.String()
	klog.V(4).Infof("Replaced: %v into: %v", tmpl, ret)
	return ret
}

// newClaimServer returns a new test HTTPS server, which is rigged to return

			body: func() []byte {
				buf := new(bytes.Buffer)
				zw := zlib.NewWriter(buf)
				zw.Write([]byte("doctype html><p>Hello</p>"))
				zw.Close()
				return buf.Bytes()
			}(),
		},
		{
			name:            "no content-encoding", // must sniff.
			wantContentType: "application/x-gzip",
			body: func() []byte {
				buf := new(bytes.Buffer)
				gzw := gzip.NewWriter(buf)

reset() throws java.io.IOException; public boolean markSupported(); } org/codehaus/plexus/util/StringOutputStream.class package org.codehaus.plexus.util; public synchronized class StringOutputStream extends java.io.OutputStream { private StringBuffer buf; public void StringOutputStream(); public void write(byte[]) throws java.io.IOException; public void write(byte[], int, int) throws java.io.IOException; public void write(int) throws java.io.IOException; public String toString(); } org/codehaus/ple...

			pkg := funcpkgpath(findfunc(abi.FuncPCABIInternal(f)))

			var sbuf [24]byte
			print("init ", pkg, " @")
			print(string(fmtNSAsMS(sbuf[:], uint64(start-runtimeInitTime))), " ms, ")
			print(string(fmtNSAsMS(sbuf[:], uint64(end-start))), " ms clock, ")
			print(string(itoa(sbuf[:], after.bytes-before.bytes)), " bytes, ")
			print(string(itoa(sbuf[:], after.allocs-before.allocs)), " allocs")
			print("\n")
		}

			response := runRequest(t, baseURL+test.path+test.queryParams, test.verb, test.data, test.contentType)
			buf := new(bytes.Buffer)
			buf.ReadFrom(response.Body)

			if response.StatusCode != test.expectedStatusCode || !strings.Contains(buf.String(), test.expectedErr) {
				t.Fatalf("unexpected response: %#v, expected err: %#v", response, test.expectedErr)
			}

	}

	var buf bytes.Buffer
	r, err := obj.GetObjectNInfo(context.Background(), bucketName, testObject, nil, nil, ObjectOptions{})
	if err != nil {
		t.Fatalf("Test: %s reading completed file failed: <ERROR> %v", instanceType, err)
	}
	if _, err = io.Copy(&buf, r); err != nil {
		r.Close()

	binary.LittleEndian.PutUint16(data[2:4], resyncMetaVersion)

	buf, err := brs.MarshalMsg(data)
	if err != nil {
		return err
	}

	configFile := path.Join(bucketMetaPrefix, bucket, replicationDir, resyncFileName)
	return saveConfig(ctx, objectAPI, configFile, buf)
}

// getReplicationDiff returns un-replicated objects in a channel.