Skip to content

Instantly share code, notes, and snippets.

@whyrusleeping

whyrusleeping/gist:6ff875746eccfc2611ab Secret

Created December 6, 2015 23:50
Show Gist options
  • Save whyrusleeping/6ff875746eccfc2611ab to your computer and use it in GitHub Desktop.
Save whyrusleeping/6ff875746eccfc2611ab to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
> grep -nr -R Fatal -B 10 | grep 'go func' -A 10
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-26- go func() {
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-27- select {
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-28- case e := <-entries:
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-29- if e.Name != "hostname._foobar._tcp.local." {
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go:30: t.Fatalf("bad: %v", e)
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-31- }
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-32- if e.Port != 80 {
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go:33: t.Fatalf("bad: %v", e)
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-34- }
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go-35- if e.Info != "Local web server" {
Godeps/_workspace/src/github.com/cryptix/mdns/server_test.go:36: t.Fatalf("bad: %v", e)
--
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-56- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-57- stream, err := server.AcceptStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-58- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-59- return
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-60- }
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-61- defer stream.Close()
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-62- for i := 0; i < b.N; i++ {
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-63- if _, err := stream.Read(recvBuf); err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go:64: b.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-65- }
Godeps/_workspace/src/github.com/hashicorp/yamux/bench_test.go-66- }
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-82- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-83- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-84- stream, err := server.AcceptStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-85- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:86: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-87- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-88- if id := stream.StreamID(); id != 1 {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:89: t.Fatalf("bad: %v", id)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-90- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-91- if err := stream.Close(); err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:92: t.Fatalf("err: %v", err)
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-96- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-97- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-98- stream, err := client.AcceptStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-99- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:100: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-101- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-102- if id := stream.StreamID(); id != 2 {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:103: t.Fatalf("bad: %v", id)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-104- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-105- if err := stream.Close(); err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:106: t.Fatalf("err: %v", err)
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-110- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-111- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-112- stream, err := server.OpenStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-113- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:114: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-115- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-116- if id := stream.StreamID(); id != 2 {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:117: t.Fatalf("bad: %v", id)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-118- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-119- if err := stream.Close(); err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:120: t.Fatalf("err: %v", err)
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-124- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-125- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-126- stream, err := client.OpenStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-127- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:128: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-129- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-130- if id := stream.StreamID(); id != 1 {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:131: t.Fatalf("bad: %v", id)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-132- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-133- if err := stream.Close(); err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:134: t.Fatalf("err: %v", err)
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-159- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-160- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-161- stream, err := server.AcceptStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-162- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:163: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-164- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-165-
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-166- buf := make([]byte, 4)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-167- for i := 0; i < 1000; i++ {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-168- n, err := stream.Read(buf)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-169- if err != nil {
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-185- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-186- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-187- stream, err := client.Open()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-188- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:189: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-190- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-191-
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-192- for i := 0; i < 1000; i++ {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-193- n, err := stream.Write([]byte("test"))
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-194- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:195: t.Fatalf("err: %v", err)
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-232- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-233- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-234- stream, err := server.AcceptStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-235- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:236: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-237- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-238-
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-239- buf := make([]byte, 4*1024)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-240- for i := 0; i < 128; i++ {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-241- n, err := stream.Read(buf)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-242- if err != nil {
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-260- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-261- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-262- stream, err := client.Open()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-263- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:264: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-265- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-266-
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-267- n, err := stream.Write(data)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-268- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:269: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-270- }
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-668- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-669- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-670- stream, err := server.AcceptStream()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-671- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:672: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-673- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-674- defer stream.Close()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-675-
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-676- buf := make([]byte, 4)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-677- _, err = stream.Read(buf)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-678- if err != nil {
--
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-695- go func() {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-696- defer wg.Done()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-697- stream, err := client.Open()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-698- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:699: t.Fatalf("err: %v", err)
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-700- }
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-701- defer stream.Close()
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-702-
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-703- _, err = stream.Write([]byte{0, 1, 2, 3})
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go-704- if err != nil {
Godeps/_workspace/src/github.com/hashicorp/yamux/session_test.go:705: t.Fatalf("err: %v", err)
--
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-136- go func() {
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-137- var v interface{} = 0
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-138- for j := 0; j < N; j++ {
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-139- if v == nil {
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-140- v = 0
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-141- }
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-142- p.Put(uint32(j), v)
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-143- v = p.Get(uint32(j))
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go-144- if v != nil && v.(int) != 0 {
Godeps/_workspace/src/github.com/jbenet/go-msgio/mpool/pool_test.go:145: t.Fatalf("expect 0, got %v", v)
--
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-30- go func() {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-31-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-32- cB, err := listener.Accept()
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-33- if err != nil {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:34: t.Fatal("failed to accept")
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-43- }
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-44- cB.Write(buf)
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-45- }
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-46-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-47- wg.Done()
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-88- go func() {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-89-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-90- cB, err := listener.Accept()
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-91- if err != nil {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:92: t.Fatal("failed to accept")
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-93- }
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-94-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-95- if !cB.LocalMultiaddr().Equal(maddr) {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:96: t.Fatal("local multiaddr not equal:", maddr, cB.LocalMultiaddr())
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-104- break
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-197- go func() {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-198-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-199- cB, err := listener.Accept()
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-200- if err != nil {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:201: t.Fatal("failed to accept")
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-202- }
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-203-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-204- if !cB.LocalMultiaddr().Equal(maddr) {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:205: t.Fatal("local multiaddr not equal:", maddr, cB.LocalMultiaddr())
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-213- break
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-257- go func() {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-258-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-259- cB, err := listener.Accept()
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-260- if err != nil {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:261: t.Fatal("failed to accept")
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-262- }
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-263-
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-264- if !cB.LocalMultiaddr().Equal(maddr) {
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go:265: t.Fatal("local multiaddr not equal:", maddr, cB.LocalMultiaddr())
--
Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net/net_test.go-275- break
--
Godeps/_workspace/src/github.com/prometheus/client_golang/model/signature_test.go-275- go func() {
Godeps/_workspace/src/github.com/prometheus/client_golang/model/signature_test.go-276- start.Wait()
Godeps/_workspace/src/github.com/prometheus/client_golang/model/signature_test.go-277- for j := b.N / concLevel; j >= 0; j-- {
Godeps/_workspace/src/github.com/prometheus/client_golang/model/signature_test.go-278- if a := metricToFastFingerprint(m); a != e {
Godeps/_workspace/src/github.com/prometheus/client_golang/model/signature_test.go:279: b.Fatalf("expected signature of %d for %s, got %d", e, m, a)
--
Godeps/_workspace/src/github.com/prometheus/client_golang/model/timestamp_test.go-17- "testing"
Godeps/_workspace/src/github.com/prometheus/client_golang/model/timestamp_test.go-18- native_time "time"
Godeps/_workspace/src/github.com/prometheus/client_golang/model/timestamp_test.go-19-)
Godeps/_workspace/src/github.com/prometheus/client_golang/model/timestamp_test.go-20-
Godeps/_workspace/src/github.com/prometheus/client_golang/model/timestamp_test.go-21-func TestComparators(t *testing.T) {
--
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2267- go func(i int, snap *Snapshot, sk []int) {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2268- defer wg.Done()
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2269-
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2270- vtail := fmt.Sprintf("VAL%030d", i)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2271- for _, k := range sk {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2272- key := fmt.Sprintf("KEY%8d", k)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2273- xvalue, err := snap.Get([]byte(key), nil)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2274- if err != nil {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go:2275: t.Fatalf("READER_GET #%d SEQ=%d K%d error: %v", i, snap.elem.seq, k, err)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2276- }
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2277- value := key + vtail
--
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2284- go func(i int, snap *Snapshot) {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2285- defer wg.Done()
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2286-
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2287- vtail := fmt.Sprintf("VAL%030d", i)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2288- iter := snap.NewIterator(nil, nil)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2289- defer iter.Release()
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2290- for k := 0; k < nKey; k++ {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2291- if !iter.Next() {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2292- if err := iter.Error(); err != nil {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go:2293: t.Fatalf("READER_ITER #%d K%d error: %v", i, k, err)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2294- } else {
--
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2383- go func(i int, snap *Snapshot) {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2384- defer wg.Done()
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2385-
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2386- vtail := fmt.Sprintf("VAL%030d", i)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2387- for k := 0; k < nKey; k++ {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2388- key := fmt.Sprintf("KEY%08d", k)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2389- xvalue, err := snap.Get([]byte(key), nil)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2390- if err != nil {
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go:2391: t.Fatalf("READER_GET #%d SEQ=%d K%d error: %v", i, snap.elem.seq, k, err)
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2392- }
Godeps/_workspace/src/github.com/syndtr/goleveldb/leveldb/db_test.go-2393- value := key + vtail
--
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-19- go func() {
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-20- s, err := mpb.Accept()
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-21- if err != nil {
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go:22: t.Fatal(err)
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-23- }
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-24-
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-25- _, err = s.Write(mes)
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-26- if err != nil {
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go:27: t.Fatal(err)
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-28- }
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-29-
--
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-66- go func() {
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-67- s, err := mpb.Accept()
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-68- if err != nil {
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go:69: t.Fatal(err)
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-70- }
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-71-
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-72- defer s.Close()
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-73- io.Copy(s, s)
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-74- }()
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-75-
Godeps/_workspace/src/github.com/whyrusleeping/go-multiplex/multiplex_test.go-76- s := mpa.NewStream()
--
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-50- go func() {
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-51- defer close(writerDone)
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-52- written, err := io.Copy(conn, os.Stdin)
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-53- if err != nil {
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-54- conn.Close()
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go:55: log.Fatalf("error after writing %d bytes: %s", written, err)
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-56- }
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-57- log.Printf("wrote %d bytes", written)
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-58- conn.Close()
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-59- }()
Godeps/_workspace/src/github.com/anacrolix/utp/cmd/ucat/ucat.go-60- n, err := io.Copy(os.Stdout, conn)
--
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-132- go func() {
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-133- defer close(readerStopped)
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-134- b := make([]byte, 500)
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-135- for i := 0; i < N; i++ {
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-136- n, _, err := l.ReadFrom(b)
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-137- if err != nil {
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go:138: t.Fatalf("error reading from raw conn: %s", err)
--
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-140- msgsReceived++
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-141- var d int
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-142- fmt.Sscan(string(b[:n]), &d)
--
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-221- go func() {
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-222- for range iter.N(n) {
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-223- c, err := s.Accept()
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-224- if err != nil {
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go:225: log.Fatal(err)
--
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-241- }
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-242- connCh <- c
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-243- }()
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-244- }
Godeps/_workspace/src/github.com/anacrolix/utp/utp_test.go-245- conns := make([]net.Conn, 0, n)
--
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-448- go func() {
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-449- wg.Wait()
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-450- close(done)
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-451- }()
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-452- select {
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-453- case <-done:
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-454- case <-time.After(1 * time.Second):
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-455- buf := make([]byte, 10<<10)
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-456- n := runtime.Stack(buf, true)
Godeps/_workspace/src/golang.org/x/net/context/context_test.go:457: t.Fatalf("timed out waiting for cancel functions; stacks:\n%s", buf[:n])
--
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-464- go func() {
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-465- parent.Done()
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-466- cancelChild()
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-467- }()
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-468- cancelParent()
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-469- select {
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-470- case <-child.Done():
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-471- case <-time.After(1 * time.Second):
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-472- buf := make([]byte, 10<<10)
Godeps/_workspace/src/golang.org/x/net/context/context_test.go-473- n := runtime.Stack(buf, true)
Godeps/_workspace/src/golang.org/x/net/context/context_test.go:474: t.Fatalf("timed out waiting for child.Done(); stacks:\n%s", buf[:n])
--
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-32- go func(c net.Conn) {
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-33- defer c.Close()
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-34- p := ipv4.NewConn(c)
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-35- if err := p.SetTOS(iana.DiffServAF11); err != nil {
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go:36: log.Fatal(err)
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-37- }
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-38- if err := p.SetTTL(128); err != nil {
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go:39: log.Fatal(err)
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-40- }
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go-41- if _, err := c.Write([]byte("HELLO-R-U-THERE-ACK")); err != nil {
Godeps/_workspace/src/golang.org/x/net/ipv4/example_test.go:42: log.Fatal(err)
--
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-31- go func(c net.Conn) {
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-32- defer c.Close()
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-33- p := ipv6.NewConn(c)
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-34- if err := p.SetTrafficClass(iana.DiffServAF11); err != nil {
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go:35: log.Fatal(err)
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-36- }
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-37- if err := p.SetHopLimit(128); err != nil {
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go:38: log.Fatal(err)
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-39- }
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go-40- if _, err := c.Write([]byte("HELLO-R-U-THERE-ACK")); err != nil {
Godeps/_workspace/src/golang.org/x/net/ipv6/example_test.go:41: log.Fatal(err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-175- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-176- defer close(oks)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-177- for {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-178- ok, err := poller.wait()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-179- if err != nil {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go:180: t.Fatalf("poller failed: %v", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-183- if !<-live {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-184- return
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-185- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_poller_test.go-186- }
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-179- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-180- for {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-181- select {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-182- case <-time.After(5 * time.Millisecond):
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-183- err := proc.Signal(syscall.SIGUSR1)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-184- if err != nil {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go:185: t.Fatalf("Signal failed: %v", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-189- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-190- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-191- }()
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-193- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-194- for {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-195- select {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-196- case <-time.After(11 * time.Millisecond):
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-197- err := w.poller.wake()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-198- if err != nil {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go:199: t.Fatalf("Wake failed: %v", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-205- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-206-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-207- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-208- for {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-209- select {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-210- case <-killchan:
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-211- return
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-212- default:
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-213- handle, err := os.Create(testFile)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-214- if err != nil {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go:215: t.Fatalf("Create failed: %v", err)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-216- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/inotify_test.go-217- handle.Close()
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-66- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-67- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:68: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-108- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-109- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-110- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-111- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-112-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-113- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-114- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-184- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-185- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:186: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-218- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-219- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-220- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-221- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-222-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-223- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-224- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-329- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-330- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:331: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-357- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-358- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-359- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-360- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-361-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-362- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-363- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-434- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-435- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:436: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-453- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-454- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-455- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-456-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-457- os.RemoveAll(testDir)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-458-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-459- // We expect this event to be received almost immediately, but let's wait 500 ms to be sure
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-479- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-480- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:481: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-501- t.Logf("unexpected event received: %s", event)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-502- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-503- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-504- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-505- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-506-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-507- addWatch(t, watcher, testDir)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-571- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-572- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:573: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-594- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-595- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-596- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-597- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-598-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-599- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-600- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-653- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-654- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:655: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-676- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-677- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-678- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-679- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-680-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-681- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-682- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-746- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-747- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:748: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-764- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-765- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-766- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-767- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-768-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-769- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-770- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-828- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-829- select {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-830- case ev := <-watcher.Events:
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:831: t.Fatalf("We received event: %v\n", ev)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-832- case <-time.After(500 * time.Millisecond):
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-833- t.Log("No event received, as expected.")
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-834- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-835- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-836-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-837- time.Sleep(200 * time.Millisecond)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-838- // Modify the file outside of the watched dir
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-864- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-865- for err := range watcher.Errors {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:866: t.Fatalf("error received: %s", err)
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-893- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-894- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-895- done <- true
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-896- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-897-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-898- // Create a file
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-899- // This should add at least one event to the fsnotify event queue
--
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-986- go func() {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-987- watcher.Close()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-988- atomic.StoreInt32(&done, 1)
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-989- }()
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-990-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-991- time.Sleep(50e6) // 50 ms
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-992- if atomic.LoadInt32(&done) == 0 {
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go:993: t.Fatal("double Close() test failed: second Close() call didn't return")
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-994- }
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-995-
Godeps/_workspace/src/gopkg.in/fsnotify.v1/integration_test.go-996- testDir := tempMkdir(t)
--
exchange/bitswap/decision/engine_test.go-108- go func() {
exchange/bitswap/decision/engine_test.go-109- for nextEnvelope := range e.Outbox() {
exchange/bitswap/decision/engine_test.go-110- <-nextEnvelope
exchange/bitswap/decision/engine_test.go-111- }
exchange/bitswap/decision/engine_test.go-112- wg.Done()
exchange/bitswap/decision/engine_test.go-113- }()
exchange/bitswap/decision/engine_test.go-114- // e.Close()
exchange/bitswap/decision/engine_test.go-115- wg.Wait()
exchange/bitswap/decision/engine_test.go-116- if _, ok := <-e.Outbox(); ok {
exchange/bitswap/decision/engine_test.go:117: t.Fatal("channel should be closed")
--
--
exchange/bitswap/bitswap_test.go-173- go func(inst Instance) {
exchange/bitswap/bitswap_test.go-174- defer wg.Done()
exchange/bitswap/bitswap_test.go-175- outch, err := inst.Exchange.GetBlocks(ctx, blkeys)
exchange/bitswap/bitswap_test.go-176- if err != nil {
exchange/bitswap/bitswap_test.go:177: t.Fatal(err)
--
exchange/bitswap/bitswap_test.go-180- }
exchange/bitswap/bitswap_test.go-181- }(inst)
exchange/bitswap/bitswap_test.go-182- }
exchange/bitswap/bitswap_test.go-183- wg.Wait()
exchange/bitswap/bitswap_test.go-184-
--
fuse/readonly/ipfs_test.go-160- go func() {
fuse/readonly/ipfs_test.go-161- defer wg.Done()
fuse/readonly/ipfs_test.go-162-
fuse/readonly/ipfs_test.go-163- for i := 0; i < 2000; i++ {
fuse/readonly/ipfs_test.go-164- item := paths[rand.Intn(len(paths))]
fuse/readonly/ipfs_test.go-165- fname := path.Join(mnt.Dir, item)
fuse/readonly/ipfs_test.go-166- rbuf, err := ioutil.ReadFile(fname)
fuse/readonly/ipfs_test.go-167- if err != nil {
fuse/readonly/ipfs_test.go:168: t.Fatal(err)
fuse/readonly/ipfs_test.go-169- }
fuse/readonly/ipfs_test.go-170-
--
merkledag/merkledag_test.go-198- go func(i int) {
merkledag/merkledag_test.go-199- defer wg.Done()
merkledag/merkledag_test.go-200- first, err := dagservs[i].Get(ctx, k)
merkledag/merkledag_test.go-201- if err != nil {
merkledag/merkledag_test.go:202: t.Fatal(err)
merkledag/merkledag_test.go-203- }
merkledag/merkledag_test.go-204- fmt.Println("Got first node back.")
merkledag/merkledag_test.go-205-
merkledag/merkledag_test.go-206- read, err := uio.NewDagReader(ctx, first, dagservs[i])
merkledag/merkledag_test.go-207- if err != nil {
merkledag/merkledag_test.go:208: t.Fatal(err)
--
test/supernode_client/main.go-145- go func() {
test/supernode_client/main.go-146- var i int64
test/supernode_client/main.go-147- for i = 1; i < math.MaxInt32; i++ {
test/supernode_client/main.go-148- piper, pipew := io.Pipe()
test/supernode_client/main.go-149- go func() {
test/supernode_client/main.go-150- defer pipew.Close()
test/supernode_client/main.go-151- if err := random.WritePseudoRandomBytes(sizeOfIthFile(i), pipew, *seed); err != nil {
test/supernode_client/main.go:152: log.Fatal(err)
test/supernode_client/main.go-153- }
test/supernode_client/main.go-154- }()
test/supernode_client/main.go-155- k, err := coreunix.Add(n, piper)
test/supernode_client/main.go-156- if err != nil {
test/supernode_client/main.go:157: log.Fatal(err)
--
test/supernode_client/main.go-179- if err != nil {
--
test/supernode_client/main.go-183- go func() {
test/supernode_client/main.go-184- defer dummy.Close()
test/supernode_client/main.go-185- var i int64 = 1
test/supernode_client/main.go-186- for {
test/supernode_client/main.go-187- buf := new(bytes.Buffer)
test/supernode_client/main.go-188- if err := random.WritePseudoRandomBytes(sizeOfIthFile(i), buf, *seed); err != nil {
test/supernode_client/main.go:189: log.Fatal(err)
test/supernode_client/main.go-190- }
test/supernode_client/main.go-191- // add to a dummy node to discover the key
test/supernode_client/main.go-192- k, err := coreunix.Add(dummy, bytes.NewReader(buf.Bytes()))
test/supernode_client/main.go-193- if err != nil {
--
util/context_test.go-21- go func() {
util/context_test.go-22- LogError(ctx, expected)
util/context_test.go-23- }()
util/context_test.go-24-
util/context_test.go-25- if err := <-errs; err != expected {
util/context_test.go:26: t.Fatal("didn't receive the expected error")
--
util/ipfsaddr/ipfsaddr_test.go-30- "/ipfs/QmUCseQWXCSrhf9edzVKTvoj8o8Ts5aXFGNPameZRPJ6uR/tcp/1234", // ipfs not last
util/ipfsaddr/ipfsaddr_test.go-31- "/ip4/1.2.3.4/tcp/ipfs/5dru6bJPUM1B7N69528u49DJiWZnok", // bad tcp part
util/ipfsaddr/ipfsaddr_test.go-32- "/ip4/tcp/1234/ipfs/kTRX47RthhwNzWdi6ggwqjuX", // bad ip part
util/ipfsaddr/ipfsaddr_test.go-33- "/ip4/1.2.3.4/tcp/1234/ipfs", // no id
--
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-46- go func() {
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-47- buf := make([]byte, 10)
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-48- n, err := pr.Read(buf)
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-49- if err != nil {
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go:50: t.Fatal(err)
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-51- }
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-52-
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-53- if n != len(msg) {
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go:54: t.Fatal("read wrong amount")
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-55- }
vendor/QmQg1J6vikuXF9oDvm4wpdeAUvvkVEKW1EYDw9HhTMnP2b/go-log/writer_test.go-56-
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment