Gecko [ www.smanegeri1koba.sch.id ]

Name	Size	Permission
h2c	[ DIR ]	dr-xr-xr-x
h2i	[ DIR ]	dr-xr-xr-x
hpack	[ DIR ]	dr-xr-xr-x
testdata	[ DIR ]	dr-xr-xr-x
.gitignore	11 B	-r--r--r--
ascii.go	1.35 KB	-r--r--r--
ascii_test.go	1.77 KB	-r--r--r--
ciphers.go	34.38 KB	-r--r--r--
ciphers_test.go	12.77 KB	-r--r--r--
client_conn_pool.go	8.4 KB	-r--r--r--
databuffer.go	4.26 KB	-r--r--r--
databuffer_test.go	4.28 KB	-r--r--r--
errors.go	4.52 KB	-r--r--r--
errors_test.go	533 B	-r--r--r--
flow.go	3.29 KB	-r--r--r--
flow_test.go	3.25 KB	-r--r--r--
frame.go	46.95 KB	-r--r--r--
frame_test.go	30.73 KB	-r--r--r--
gotrack.go	3.09 KB	-r--r--r--
gotrack_test.go	761 B	-r--r--r--
headermap.go	2.15 KB	-r--r--r--
http2.go	9.54 KB	-r--r--r--
http2_test.go	6.47 KB	-r--r--r--
pipe.go	4.08 KB	-r--r--r--
pipe_test.go	3 KB	-r--r--r--
server.go	101.31 KB	-r--r--r--
server_push_test.go	15.71 KB	-r--r--r--
server_test.go	128.81 KB	-r--r--r--
transport.go	89.77 KB	-r--r--r--
transport_test.go	166.92 KB	-r--r--r--
write.go	10.67 KB	-r--r--r--
writesched.go	7.66 KB	-r--r--r--
writesched_priority.go	13.34 KB	-r--r--r--
writesched_priority_test.go	17.86 KB	-r--r--r--
writesched_random.go	2 KB	-r--r--r--
writesched_random_test.go	1.76 KB	-r--r--r--
writesched_roundrobin.go	2.75 KB	-r--r--r--
writesched_roundrobin_test.go	1.59 KB	-r--r--r--
writesched_test.go	5.18 KB	-r--r--r--
z_spec_test.go	7.27 KB	-r--r--r--

Code Editor : pipe_test.go

// Copyright 2014 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package http2

import (
	"bytes"
	"errors"
	"io"
	"io/ioutil"
	"testing"
)

func TestPipeClose(t *testing.T) {
	var p pipe
	p.b = new(bytes.Buffer)
	a := errors.New("a")
	b := errors.New("b")
	p.CloseWithError(a)
	p.CloseWithError(b)
	_, err := p.Read(make([]byte, 1))
	if err != a {
		t.Errorf("err = %v want %v", err, a)
	}
}

func TestPipeDoneChan(t *testing.T) {
	var p pipe
	done := p.Done()
	select {
	case <-done:
		t.Fatal("done too soon")
	default:
	}
	p.CloseWithError(io.EOF)
	select {
	case <-done:
	default:
		t.Fatal("should be done")
	}
}

func TestPipeDoneChan_ErrFirst(t *testing.T) {
	var p pipe
	p.CloseWithError(io.EOF)
	done := p.Done()
	select {
	case <-done:
	default:
		t.Fatal("should be done")
	}
}

func TestPipeDoneChan_Break(t *testing.T) {
	var p pipe
	done := p.Done()
	select {
	case <-done:
		t.Fatal("done too soon")
	default:
	}
	p.BreakWithError(io.EOF)
	select {
	case <-done:
	default:
		t.Fatal("should be done")
	}
}

func TestPipeDoneChan_Break_ErrFirst(t *testing.T) {
	var p pipe
	p.BreakWithError(io.EOF)
	done := p.Done()
	select {
	case <-done:
	default:
		t.Fatal("should be done")
	}
}

func TestPipeCloseWithError(t *testing.T) {
	p := &pipe{b: new(bytes.Buffer)}
	const body = "foo"
	io.WriteString(p, body)
	a := errors.New("test error")
	p.CloseWithError(a)
	all, err := ioutil.ReadAll(p)
	if string(all) != body {
		t.Errorf("read bytes = %q; want %q", all, body)
	}
	if err != a {
		t.Logf("read error = %v, %v", err, a)
	}
	if p.Len() != 0 {
		t.Errorf("pipe should have 0 unread bytes")
	}
	// Read and Write should fail.
	if n, err := p.Write([]byte("abc")); err != errClosedPipeWrite || n != 0 {
		t.Errorf("Write(abc) after close\ngot %v, %v\nwant 0, %v", n, err, errClosedPipeWrite)
	}
	if n, err := p.Read(make([]byte, 1)); err == nil || n != 0 {
		t.Errorf("Read() after close\ngot %v, nil\nwant 0, %v", n, errClosedPipeWrite)
	}
	if p.Len() != 0 {
		t.Errorf("pipe should have 0 unread bytes")
	}
}

func TestPipeBreakWithError(t *testing.T) {
	p := &pipe{b: new(bytes.Buffer)}
	io.WriteString(p, "foo")
	a := errors.New("test err")
	p.BreakWithError(a)
	all, err := ioutil.ReadAll(p)
	if string(all) != "" {
		t.Errorf("read bytes = %q; want empty string", all)
	}
	if err != a {
		t.Logf("read error = %v, %v", err, a)
	}
	if p.b != nil {
		t.Errorf("buffer should be nil after BreakWithError")
	}
	if p.Len() != 3 {
		t.Errorf("pipe should have 3 unread bytes")
	}
	// Write should fail.
	if n, err := p.Write([]byte("abc")); err != errClosedPipeWrite || n != 0 {
		t.Errorf("Write(abc) after break\ngot %v, %v\nwant 0, errClosedPipeWrite", n, err)
	}
	if p.b != nil {
		t.Errorf("buffer should be nil after Write")
	}
	if p.Len() != 3 {
		t.Errorf("pipe should have 6 unread bytes")
	}
	// Read should fail.
	if n, err := p.Read(make([]byte, 1)); err == nil || n != 0 {
		t.Errorf("Read() after close\ngot %v, nil\nwant 0, not nil", n)
	}
}

${this.title}

Code Editor : pipe_test.go